Hex Artifact Content

Artifact 263f67c7ab1e57c115565c7fe5b93d3717b73f40:


0000: 23 69 6e 63 6c 75 64 65 20 3c 73 79 73 2f 73 65  #include <sys/se
0010: 6e 64 66 69 6c 65 2e 68 3e 0a 23 69 6e 63 6c 75  ndfile.h>.#inclu
0020: 64 65 20 3c 73 79 73 2f 73 6f 63 6b 65 74 2e 68  de <sys/socket.h
0030: 3e 0a 23 69 6e 63 6c 75 64 65 20 3c 73 79 73 2f  >.#include <sys/
0040: 74 79 70 65 73 2e 68 3e 0a 23 69 6e 63 6c 75 64  types.h>.#includ
0050: 65 20 3c 61 72 70 61 2f 69 6e 65 74 2e 68 3e 0a  e <arpa/inet.h>.
0060: 23 69 6e 63 6c 75 64 65 20 3c 73 79 73 2f 6d 6d  #include <sys/mm
0070: 61 6e 2e 68 3e 0a 23 69 6e 63 6c 75 64 65 20 3c  an.h>.#include <
0080: 73 79 73 2f 73 74 61 74 2e 68 3e 0a 23 69 6e 63  sys/stat.h>.#inc
0090: 6c 75 64 65 20 3c 70 74 68 72 65 61 64 2e 68 3e  lude <pthread.h>
00a0: 0a 23 69 6e 63 6c 75 64 65 20 3c 73 74 64 6c 69  .#include <stdli
00b0: 62 2e 68 3e 0a 23 69 6e 63 6c 75 64 65 20 3c 75  b.h>.#include <u
00c0: 6e 69 73 74 64 2e 68 3e 0a 23 69 6e 63 6c 75 64  nistd.h>.#includ
00d0: 65 20 3c 66 63 6e 74 6c 2e 68 3e 0a 23 69 6e 63  e <fcntl.h>.#inc
00e0: 6c 75 64 65 20 3c 73 74 64 69 6f 2e 68 3e 0a 0a  lude <stdio.h>..
00f0: 2f 2a 20 44 65 66 61 75 6c 74 20 76 61 6c 75 65  /* Default value
0100: 73 20 2a 2f 0a 23 64 65 66 69 6e 65 20 4d 41 58  s */.#define MAX
0110: 5f 46 41 49 4c 55 52 45 5f 43 4f 55 4e 54 20 33  _FAILURE_COUNT 3
0120: 30 0a 23 64 65 66 69 6e 65 20 50 4f 52 54 20 38  0.#define PORT 8
0130: 30 38 30 0a 23 64 65 66 69 6e 65 20 54 48 52 45  080.#define THRE
0140: 41 44 5f 43 4f 55 4e 54 20 31 30 0a 23 64 65 66  AD_COUNT 10.#def
0150: 69 6e 65 20 42 49 4e 44 5f 41 44 44 52 20 22 3a  ine BIND_ADDR ":
0160: 3a 22 0a 0a 2f 2a 20 41 72 67 75 6d 65 6e 74 73  :"../* Arguments
0170: 20 66 6f 72 20 77 6f 72 6b 65 72 20 74 68 72 65   for worker thre
0180: 61 64 73 20 2a 2f 0a 73 74 72 75 63 74 20 66 69  ads */.struct fi
0190: 6c 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65 61  led_worker_threa
01a0: 64 5f 61 72 67 73 20 7b 0a 09 69 6e 74 20 66 64  d_args {..int fd
01b0: 3b 0a 7d 3b 0a 0a 73 74 61 74 69 63 20 76 6f 69  ;.};..static voi
01c0: 64 20 66 69 6c 65 64 5f 69 6e 69 74 28 76 6f 69  d filed_init(voi
01d0: 64 29 20 7b 0a 09 6d 6c 6f 63 6b 61 6c 6c 28 4d  d) {..mlockall(M
01e0: 43 4c 5f 43 55 52 52 45 4e 54 20 7c 20 4d 43 4c  CL_CURRENT | MCL
01f0: 5f 46 55 54 55 52 45 29 3b 0a 7d 0a 0a 73 74 61  _FUTURE);.}..sta
0200: 74 69 63 20 69 6e 74 20 66 69 6c 65 64 5f 6c 69  tic int filed_li
0210: 73 74 65 6e 28 63 6f 6e 73 74 20 63 68 61 72 20  sten(const char 
0220: 2a 61 64 64 72 65 73 73 2c 20 75 6e 73 69 67 6e  *address, unsign
0230: 65 64 20 69 6e 74 20 70 6f 72 74 29 20 7b 0a 09  ed int port) {..
0240: 73 74 72 75 63 74 20 73 6f 63 6b 61 64 64 72 5f  struct sockaddr_
0250: 69 6e 36 20 61 64 64 72 3b 0a 09 69 6e 74 20 70  in6 addr;..int p
0260: 74 6f 6e 5f 72 65 74 2c 20 62 69 6e 64 5f 72 65  ton_ret, bind_re
0270: 74 2c 20 6c 69 73 74 65 6e 5f 72 65 74 3b 0a 09  t, listen_ret;..
0280: 69 6e 74 20 66 64 3b 0a 0a 09 61 64 64 72 2e 73  int fd;...addr.s
0290: 69 6e 36 5f 66 61 6d 69 6c 79 20 3d 20 41 46 5f  in6_family = AF_
02a0: 49 4e 45 54 36 3b 0a 09 61 64 64 72 2e 73 69 6e  INET6;..addr.sin
02b0: 36 5f 66 6c 6f 77 69 6e 66 6f 20 3d 20 30 3b 0a  6_flowinfo = 0;.
02c0: 09 61 64 64 72 2e 73 69 6e 36 5f 73 63 6f 70 65  .addr.sin6_scope
02d0: 5f 69 64 20 3d 20 30 3b 0a 09 61 64 64 72 2e 73  _id = 0;..addr.s
02e0: 69 6e 36 5f 70 6f 72 74 20 3d 20 68 74 6f 6e 73  in6_port = htons
02f0: 28 70 6f 72 74 29 3b 0a 09 70 74 6f 6e 5f 72 65  (port);..pton_re
0300: 74 20 3d 20 69 6e 65 74 5f 70 74 6f 6e 28 41 46  t = inet_pton(AF
0310: 5f 49 4e 45 54 36 2c 20 61 64 64 72 65 73 73 2c  _INET6, address,
0320: 20 61 64 64 72 2e 73 69 6e 36 5f 61 64 64 72 2e   addr.sin6_addr.
0330: 73 36 5f 61 64 64 72 29 3b 0a 09 69 66 20 28 70  s6_addr);..if (p
0340: 74 6f 6e 5f 72 65 74 20 21 3d 20 31 29 20 7b 0a  ton_ret != 1) {.
0350: 09 09 72 65 74 75 72 6e 28 2d 31 29 3b 0a 09 7d  ..return(-1);..}
0360: 0a 0a 09 66 64 20 3d 20 73 6f 63 6b 65 74 28 41  ...fd = socket(A
0370: 46 5f 49 4e 45 54 36 2c 20 53 4f 43 4b 5f 53 54  F_INET6, SOCK_ST
0380: 52 45 41 4d 2c 20 30 29 3b 0a 09 69 66 20 28 66  REAM, 0);..if (f
0390: 64 20 3c 20 30 29 20 7b 0a 09 09 72 65 74 75 72  d < 0) {...retur
03a0: 6e 28 66 64 29 3b 0a 09 7d 0a 0a 09 62 69 6e 64  n(fd);..}...bind
03b0: 5f 72 65 74 20 3d 20 62 69 6e 64 28 66 64 2c 20  _ret = bind(fd, 
03c0: 28 63 6f 6e 73 74 20 73 74 72 75 63 74 20 73 6f  (const struct so
03d0: 63 6b 61 64 64 72 20 2a 29 20 26 61 64 64 72 2c  ckaddr *) &addr,
03e0: 20 73 69 7a 65 6f 66 28 61 64 64 72 29 29 3b 0a   sizeof(addr));.
03f0: 09 69 66 20 28 62 69 6e 64 5f 72 65 74 20 3c 20  .if (bind_ret < 
0400: 30 29 20 7b 0a 09 09 63 6c 6f 73 65 28 66 64 29  0) {...close(fd)
0410: 3b 0a 0a 09 09 72 65 74 75 72 6e 28 2d 31 29 3b  ;....return(-1);
0420: 0a 09 7d 0a 0a 09 6c 69 73 74 65 6e 5f 72 65 74  ..}...listen_ret
0430: 20 3d 20 6c 69 73 74 65 6e 28 66 64 2c 20 31 32   = listen(fd, 12
0440: 38 29 3b 0a 09 69 66 20 28 6c 69 73 74 65 6e 5f  8);..if (listen_
0450: 72 65 74 20 21 3d 20 30 29 20 7b 0a 09 09 63 6c  ret != 0) {...cl
0460: 6f 73 65 28 66 64 29 3b 0a 0a 09 09 72 65 74 75  ose(fd);....retu
0470: 72 6e 28 2d 31 29 3b 0a 09 7d 0a 0a 09 72 65 74  rn(-1);..}...ret
0480: 75 72 6e 28 66 64 29 3b 0a 7d 0a 0a 73 74 61 74  urn(fd);.}..stat
0490: 69 63 20 69 6e 74 20 66 69 6c 65 64 5f 6c 6f 67  ic int filed_log
04a0: 67 69 6e 67 5f 74 68 72 65 61 64 5f 69 6e 69 74  ging_thread_init
04b0: 28 76 6f 69 64 29 20 7b 0a 09 2f 2a 20 58 58 58  (void) {../* XXX
04c0: 3a 54 4f 44 4f 3a 20 55 6e 69 6d 70 6c 65 6d 65  :TODO: Unimpleme
04d0: 6e 74 65 64 20 2a 2f 0a 09 72 65 74 75 72 6e 28  nted */..return(
04e0: 30 29 3b 0a 7d 0a 0a 73 74 72 75 63 74 20 66 69  0);.}..struct fi
04f0: 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 20 7b 0a 09  led_fileinfo {..
0500: 69 6e 74 20 66 64 3b 0a 09 73 69 7a 65 5f 74 20  int fd;..size_t 
0510: 6c 65 6e 3b 0a 7d 3b 0a 0a 73 74 61 74 69 63 20  len;.};..static 
0520: 73 74 72 75 63 74 20 66 69 6c 65 64 5f 66 69 6c  struct filed_fil
0530: 65 69 6e 66 6f 20 2a 66 69 6c 65 64 5f 6f 70 65  einfo *filed_ope
0540: 6e 5f 66 69 6c 65 28 63 6f 6e 73 74 20 63 68 61  n_file(const cha
0550: 72 20 2a 70 61 74 68 2c 20 73 74 72 75 63 74 20  r *path, struct 
0560: 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 20 2a  filed_fileinfo *
0570: 62 75 66 66 65 72 29 20 7b 0a 09 2f 2a 20 58 58  buffer) {../* XX
0580: 58 3a 54 4f 44 4f 3a 20 43 61 63 68 65 20 66 69  X:TODO: Cache fi
0590: 6c 65 20 64 65 73 63 72 69 70 74 6f 72 73 20 2a  le descriptors *
05a0: 2f 0a 0a 09 6f 66 66 5f 74 20 6c 65 6e 3b 0a 09  /...off_t len;..
05b0: 69 6e 74 20 66 64 3b 0a 0a 09 66 64 20 3d 20 6f  int fd;...fd = o
05c0: 70 65 6e 28 70 61 74 68 2c 20 4f 5f 52 44 4f 4e  pen(path, O_RDON
05d0: 4c 59 29 3b 0a 09 69 66 20 28 66 64 20 3c 20 30  LY);..if (fd < 0
05e0: 29 20 7b 0a 09 09 72 65 74 75 72 6e 28 4e 55 4c  ) {...return(NUL
05f0: 4c 29 3b 0a 09 7d 0a 0a 09 6c 65 6e 20 3d 20 6c  L);..}...len = l
0600: 73 65 65 6b 28 66 64 2c 20 30 2c 20 53 45 45 4b  seek(fd, 0, SEEK
0610: 5f 45 4e 44 29 3b 0a 09 6c 73 65 65 6b 28 66 64  _END);..lseek(fd
0620: 2c 20 30 2c 20 53 45 45 4b 5f 53 45 54 29 3b 0a  , 0, SEEK_SET);.
0630: 0a 09 62 75 66 66 65 72 2d 3e 66 64 20 3d 20 66  ..buffer->fd = f
0640: 64 3b 0a 09 62 75 66 66 65 72 2d 3e 6c 65 6e 20  d;..buffer->len 
0650: 3d 20 6c 65 6e 3b 0a 0a 09 72 65 74 75 72 6e 28  = len;...return(
0660: 62 75 66 66 65 72 29 3b 0a 7d 0a 0a 73 74 61 74  buffer);.}..stat
0670: 69 63 20 63 68 61 72 20 2a 66 69 6c 65 64 5f 67  ic char *filed_g
0680: 65 74 5f 68 74 74 70 5f 72 65 71 75 65 73 74 28  et_http_request(
0690: 46 49 4c 45 20 2a 66 70 2c 20 63 68 61 72 20 2a  FILE *fp, char *
06a0: 62 75 66 66 65 72 2c 20 73 69 7a 65 5f 74 20 62  buffer, size_t b
06b0: 75 66 66 65 72 5f 6c 65 6e 29 20 7b 0a 09 2f 2a  uffer_len) {../*
06c0: 20 58 58 58 3a 54 4f 44 4f 3a 20 55 6e 69 6d 70   XXX:TODO: Unimp
06d0: 6c 65 6d 65 6e 74 65 64 20 2a 2f 0a 09 73 65 74  lemented */..set
06e0: 6c 69 6e 65 62 75 66 28 66 70 29 3b 0a 0a 09 66  linebuf(fp);...f
06f0: 70 20 3d 20 66 70 3b 0a 09 62 75 66 66 65 72 20  p = fp;..buffer 
0700: 3d 20 62 75 66 66 65 72 3b 0a 09 62 75 66 66 65  = buffer;..buffe
0710: 72 5f 6c 65 6e 20 3d 20 62 75 66 66 65 72 5f 6c  r_len = buffer_l
0720: 65 6e 3b 0a 0a 09 66 66 6c 75 73 68 28 66 70 29  en;...fflush(fp)
0730: 3b 0a 0a 09 72 65 74 75 72 6e 28 22 2e 2f 68 65  ;...return("./he
0740: 6c 6c 6f 5f 77 6f 72 6c 64 2e 74 78 74 22 29 3b  llo_world.txt");
0750: 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 64 20  .}..static void 
0760: 66 69 6c 65 64 5f 68 61 6e 64 6c 65 5f 63 6c 69  filed_handle_cli
0770: 65 6e 74 28 69 6e 74 20 66 64 29 20 7b 0a 09 73  ent(int fd) {..s
0780: 74 72 75 63 74 20 66 69 6c 65 64 5f 66 69 6c 65  truct filed_file
0790: 69 6e 66 6f 20 2a 66 69 6c 65 69 6e 66 6f 2c 20  info *fileinfo, 
07a0: 66 69 6c 65 69 6e 66 6f 5f 62 3b 0a 09 63 68 61  fileinfo_b;..cha
07b0: 72 20 2a 70 61 74 68 2c 20 70 61 74 68 5f 62 5b  r *path, path_b[
07c0: 31 30 31 30 5d 3b 0a 09 46 49 4c 45 20 2a 66 70  1010];..FILE *fp
07d0: 3b 0a 0a 09 66 70 20 3d 20 66 64 6f 70 65 6e 28  ;...fp = fdopen(
07e0: 66 64 2c 20 22 77 2b 62 22 29 3b 0a 09 69 66 20  fd, "w+b");..if 
07f0: 28 66 70 20 3d 3d 20 4e 55 4c 4c 29 20 7b 0a 09  (fp == NULL) {..
0800: 09 63 6c 6f 73 65 28 66 64 29 3b 0a 0a 09 09 72  .close(fd);....r
0810: 65 74 75 72 6e 3b 0a 09 7d 0a 0a 09 70 61 74 68  eturn;..}...path
0820: 20 3d 20 66 69 6c 65 64 5f 67 65 74 5f 68 74 74   = filed_get_htt
0830: 70 5f 72 65 71 75 65 73 74 28 66 70 2c 20 70 61  p_request(fp, pa
0840: 74 68 5f 62 2c 20 73 69 7a 65 6f 66 28 70 61 74  th_b, sizeof(pat
0850: 68 5f 62 29 29 3b 0a 09 69 66 20 28 70 61 74 68  h_b));..if (path
0860: 20 3d 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09 66 63   == NULL) {...fc
0870: 6c 6f 73 65 28 66 70 29 3b 0a 0a 09 09 72 65 74  lose(fp);....ret
0880: 75 72 6e 3b 0a 09 7d 0a 0a 09 66 69 6c 65 69 6e  urn;..}...filein
0890: 66 6f 20 3d 20 66 69 6c 65 64 5f 6f 70 65 6e 5f  fo = filed_open_
08a0: 66 69 6c 65 28 70 61 74 68 2c 20 26 66 69 6c 65  file(path, &file
08b0: 69 6e 66 6f 5f 62 29 3b 0a 09 69 66 20 28 66 69  info_b);..if (fi
08c0: 6c 65 69 6e 66 6f 20 3d 3d 20 4e 55 4c 4c 29 20  leinfo == NULL) 
08d0: 7b 0a 09 09 2f 2a 20 58 58 58 3a 20 54 4f 44 4f  {.../* XXX: TODO
08e0: 3a 20 52 65 74 75 72 6e 20 65 72 72 6f 72 20 70  : Return error p
08f0: 61 67 65 20 2a 2f 0a 09 7d 20 65 6c 73 65 20 7b  age */..} else {
0900: 0a 09 09 2f 2a 20 58 58 58 3a 20 54 4f 44 4f 3a  .../* XXX: TODO:
0910: 20 53 65 6e 64 20 48 54 54 50 20 72 65 73 70 6f   Send HTTP respo
0920: 6e 73 65 20 68 65 61 64 65 72 20 2a 2f 0a 09 09  nse header */...
0930: 73 65 6e 64 66 69 6c 65 28 66 64 2c 20 66 69 6c  sendfile(fd, fil
0940: 65 69 6e 66 6f 2d 3e 66 64 2c 20 4e 55 4c 4c 2c  einfo->fd, NULL,
0950: 20 66 69 6c 65 69 6e 66 6f 2d 3e 6c 65 6e 29 3b   fileinfo->len);
0960: 0a 0a 09 09 63 6c 6f 73 65 28 66 69 6c 65 69 6e  ....close(filein
0970: 66 6f 2d 3e 66 64 29 3b 0a 09 7d 0a 0a 09 66 63  fo->fd);..}...fc
0980: 6c 6f 73 65 28 66 70 29 3b 0a 0a 09 72 65 74 75  lose(fp);...retu
0990: 72 6e 3b 0a 7d 0a 0a 73 74 61 74 69 63 20 76 6f  rn;.}..static vo
09a0: 69 64 20 2a 66 69 6c 65 64 5f 77 6f 72 6b 65 72  id *filed_worker
09b0: 5f 74 68 72 65 61 64 28 76 6f 69 64 20 2a 61 72  _thread(void *ar
09c0: 67 5f 76 29 20 7b 0a 09 73 74 72 75 63 74 20 66  g_v) {..struct f
09d0: 69 6c 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65  iled_worker_thre
09e0: 61 64 5f 61 72 67 73 20 2a 61 72 67 3b 0a 09 73  ad_args *arg;..s
09f0: 74 72 75 63 74 20 73 6f 63 6b 61 64 64 72 5f 69  truct sockaddr_i
0a00: 6e 36 20 61 64 64 72 3b 0a 09 73 6f 63 6b 6c 65  n6 addr;..sockle
0a10: 6e 5f 74 20 61 64 64 72 6c 65 6e 3b 0a 09 69 6e  n_t addrlen;..in
0a20: 74 20 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 20  t failure_count 
0a30: 3d 20 30 2c 20 6d 61 78 5f 66 61 69 6c 75 72 65  = 0, max_failure
0a40: 5f 63 6f 75 6e 74 20 3d 20 4d 41 58 5f 46 41 49  _count = MAX_FAI
0a50: 4c 55 52 45 5f 43 4f 55 4e 54 3b 0a 09 69 6e 74  LURE_COUNT;..int
0a60: 20 6d 61 73 74 65 72 5f 66 64 2c 20 66 64 3b 0a   master_fd, fd;.
0a70: 0a 09 2f 2a 20 52 65 61 64 20 61 72 67 75 6d 65  ../* Read argume
0a80: 6e 74 73 20 2a 2f 0a 09 61 72 67 20 3d 20 61 72  nts */..arg = ar
0a90: 67 5f 76 3b 0a 0a 09 6d 61 73 74 65 72 5f 66 64  g_v;...master_fd
0aa0: 20 3d 20 61 72 67 2d 3e 66 64 3b 0a 0a 09 77 68   = arg->fd;...wh
0ab0: 69 6c 65 20 28 31 29 20 7b 0a 09 09 2f 2a 20 46  ile (1) {.../* F
0ac0: 61 69 6c 75 72 65 20 6c 6f 6f 70 20 70 72 65 76  ailure loop prev
0ad0: 65 6e 74 69 6f 6e 20 2a 2f 0a 09 09 69 66 20 28  ention */...if (
0ae0: 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 20 3e 20  failure_count > 
0af0: 6d 61 78 5f 66 61 69 6c 75 72 65 5f 63 6f 75 6e  max_failure_coun
0b00: 74 29 20 7b 0a 09 09 09 62 72 65 61 6b 3b 0a 09  t) {....break;..
0b10: 09 7d 0a 0a 09 09 2f 2a 20 41 63 63 65 70 74 20  .}..../* Accept 
0b20: 61 20 6e 65 77 20 63 6c 69 65 6e 74 20 2a 2f 0a  a new client */.
0b30: 09 09 61 64 64 72 6c 65 6e 20 3d 20 73 69 7a 65  ..addrlen = size
0b40: 6f 66 28 61 64 64 72 29 3b 0a 09 09 66 64 20 3d  of(addr);...fd =
0b50: 20 61 63 63 65 70 74 28 6d 61 73 74 65 72 5f 66   accept(master_f
0b60: 64 2c 20 28 73 74 72 75 63 74 20 73 6f 63 6b 61  d, (struct socka
0b70: 64 64 72 20 2a 29 20 26 61 64 64 72 2c 20 26 61  ddr *) &addr, &a
0b80: 64 64 72 6c 65 6e 29 3b 0a 0a 09 09 2f 2a 0a 09  ddrlen);..../*..
0b90: 09 20 2a 20 49 66 20 77 65 20 66 61 69 6c 2c 20  . * If we fail, 
0ba0: 6d 61 6b 65 20 61 20 6e 6f 74 65 20 6f 66 20 69  make a note of i
0bb0: 74 20 73 6f 20 77 65 20 64 6f 6e 27 74 20 67 6f  t so we don't go
0bc0: 20 69 6e 74 6f 20 61 20 6c 6f 6f 70 20 6f 66 0a   into a loop of.
0bd0: 09 09 20 2a 20 61 63 63 65 70 74 28 29 20 66 61  .. * accept() fa
0be0: 69 6c 69 6e 67 0a 09 09 20 2a 2f 0a 09 09 69 66  iling... */...if
0bf0: 20 28 66 64 20 3c 20 30 29 20 7b 0a 09 09 09 66   (fd < 0) {....f
0c00: 61 69 6c 75 72 65 5f 63 6f 75 6e 74 2b 2b 3b 0a  ailure_count++;.
0c10: 0a 09 09 09 63 6f 6e 74 69 6e 75 65 3b 0a 09 09  ....continue;...
0c20: 7d 0a 0a 09 09 2f 2a 20 52 65 73 65 74 20 66 61  }..../* Reset fa
0c30: 69 6c 75 72 65 20 63 6f 75 6e 74 2a 2f 0a 09 09  ilure count*/...
0c40: 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 20 3d 20  failure_count = 
0c50: 30 3b 0a 0a 09 09 2f 2a 20 48 61 6e 64 6c 65 20  0;..../* Handle 
0c60: 73 6f 63 6b 65 74 20 2a 2f 0a 09 09 66 69 6c 65  socket */...file
0c70: 64 5f 68 61 6e 64 6c 65 5f 63 6c 69 65 6e 74 28  d_handle_client(
0c80: 66 64 29 3b 0a 09 7d 0a 0a 09 2f 2a 20 58 58 58  fd);..}.../* XXX
0c90: 3a 54 4f 44 4f 3a 20 52 65 70 6f 72 74 20 65 72  :TODO: Report er
0ca0: 72 6f 72 20 2a 2f 0a 09 72 65 74 75 72 6e 28 4e  ror */..return(N
0cb0: 55 4c 4c 29 3b 0a 7d 0a 0a 73 74 61 74 69 63 20  ULL);.}..static 
0cc0: 69 6e 74 20 66 69 6c 65 64 5f 77 6f 72 6b 65 72  int filed_worker
0cd0: 5f 74 68 72 65 61 64 73 5f 69 6e 69 74 28 69 6e  _threads_init(in
0ce0: 74 20 66 64 2c 20 69 6e 74 20 74 68 72 65 61 64  t fd, int thread
0cf0: 5f 63 6f 75 6e 74 29 20 7b 0a 09 73 74 72 75 63  _count) {..struc
0d00: 74 20 66 69 6c 65 64 5f 77 6f 72 6b 65 72 5f 74  t filed_worker_t
0d10: 68 72 65 61 64 5f 61 72 67 73 20 2a 61 72 67 3b  hread_args *arg;
0d20: 0a 09 70 74 68 72 65 61 64 5f 74 20 74 68 72 65  ..pthread_t thre
0d30: 61 64 69 64 3b 0a 09 69 6e 74 20 70 74 68 72 65  adid;..int pthre
0d40: 61 64 5f 72 65 74 3b 0a 09 69 6e 74 20 69 3b 0a  ad_ret;..int i;.
0d50: 0a 09 66 6f 72 20 28 69 20 3d 20 30 3b 20 69 20  ..for (i = 0; i 
0d60: 3c 20 74 68 72 65 61 64 5f 63 6f 75 6e 74 3b 20  < thread_count; 
0d70: 69 2b 2b 29 20 7b 0a 09 09 61 72 67 20 3d 20 6d  i++) {...arg = m
0d80: 61 6c 6c 6f 63 28 73 69 7a 65 6f 66 28 2a 61 72  alloc(sizeof(*ar
0d90: 67 29 29 3b 0a 0a 09 09 61 72 67 2d 3e 66 64 20  g));....arg->fd 
0da0: 3d 20 66 64 3b 0a 0a 09 09 70 74 68 72 65 61 64  = fd;....pthread
0db0: 5f 72 65 74 20 3d 20 70 74 68 72 65 61 64 5f 63  _ret = pthread_c
0dc0: 72 65 61 74 65 28 26 74 68 72 65 61 64 69 64 2c  reate(&threadid,
0dd0: 20 4e 55 4c 4c 2c 20 66 69 6c 65 64 5f 77 6f 72   NULL, filed_wor
0de0: 6b 65 72 5f 74 68 72 65 61 64 2c 20 61 72 67 29  ker_thread, arg)
0df0: 3b 0a 09 09 69 66 20 28 70 74 68 72 65 61 64 5f  ;...if (pthread_
0e00: 72 65 74 20 21 3d 20 30 29 20 7b 0a 09 09 09 72  ret != 0) {....r
0e10: 65 74 75 72 6e 28 2d 31 29 3b 0a 09 09 7d 0a 09  eturn(-1);...}..
0e20: 7d 0a 0a 09 72 65 74 75 72 6e 28 30 29 3b 0a 7d  }...return(0);.}
0e30: 0a 0a 69 6e 74 20 6d 61 69 6e 28 69 6e 74 20 61  ..int main(int a
0e40: 72 67 63 2c 20 63 68 61 72 20 2a 2a 61 72 67 76  rgc, char **argv
0e50: 29 20 7b 0a 09 69 6e 74 20 70 6f 72 74 20 3d 20  ) {..int port = 
0e60: 50 4f 52 54 2c 20 74 68 72 65 61 64 5f 63 6f 75  PORT, thread_cou
0e70: 6e 74 20 3d 20 54 48 52 45 41 44 5f 43 4f 55 4e  nt = THREAD_COUN
0e80: 54 3b 0a 09 63 6f 6e 73 74 20 63 68 61 72 20 2a  T;..const char *
0e90: 62 69 6e 64 5f 61 64 64 72 20 3d 20 42 49 4e 44  bind_addr = BIND
0ea0: 5f 41 44 44 52 3b 0a 09 69 6e 74 20 66 64 3b 0a  _ADDR;..int fd;.
0eb0: 0a 09 2f 2a 20 49 67 6e 6f 72 65 20 2a 2f 0a 09  ../* Ignore */..
0ec0: 61 72 67 63 20 3d 20 61 72 67 63 3b 0a 09 61 72  argc = argc;..ar
0ed0: 67 76 20 3d 20 61 72 67 76 3b 0a 0a 09 2f 2a 20  gv = argv;.../* 
0ee0: 43 72 65 61 74 65 20 6c 69 73 74 65 6e 69 6e 67  Create listening
0ef0: 20 73 6f 63 6b 65 74 20 2a 2f 0a 09 66 64 20 3d   socket */..fd =
0f00: 20 66 69 6c 65 64 5f 6c 69 73 74 65 6e 28 62 69   filed_listen(bi
0f10: 6e 64 5f 61 64 64 72 2c 20 70 6f 72 74 29 3b 0a  nd_addr, port);.
0f20: 09 69 66 20 28 66 64 20 3c 20 30 29 20 7b 0a 09  .if (fd < 0) {..
0f30: 09 70 65 72 72 6f 72 28 22 66 69 6c 65 64 5f 6c  .perror("filed_l
0f40: 69 73 74 65 6e 22 29 3b 0a 0a 09 09 72 65 74 75  isten");....retu
0f50: 72 6e 28 31 29 3b 0a 09 7d 0a 0a 09 2f 2a 20 42  rn(1);..}.../* B
0f60: 65 63 6f 6d 65 20 61 20 64 61 65 6d 6f 6e 20 2a  ecome a daemon *
0f70: 2f 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a 20  /../* XXX:TODO: 
0f80: 42 65 63 6f 6d 65 20 61 20 64 61 65 6d 6f 6e 20  Become a daemon 
0f90: 2a 2f 0a 0a 09 2f 2a 20 49 6e 69 74 69 61 6c 69  */.../* Initiali
0fa0: 7a 65 20 2a 2f 0a 09 66 69 6c 65 64 5f 69 6e 69  ze */..filed_ini
0fb0: 74 28 29 3b 0a 0a 09 2f 2a 20 43 72 65 61 74 65  t();.../* Create
0fc0: 20 6c 6f 67 67 69 6e 67 20 74 68 72 65 61 64 20   logging thread 
0fd0: 2a 2f 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a  */../* XXX:TODO:
0fe0: 20 43 68 65 63 6b 20 66 6f 72 20 65 72 72 6f 72   Check for error
0ff0: 73 20 2a 2f 0a 09 66 69 6c 65 64 5f 6c 6f 67 67  s */..filed_logg
1000: 69 6e 67 5f 74 68 72 65 61 64 5f 69 6e 69 74 28  ing_thread_init(
1010: 29 3b 0a 0a 09 2f 2a 20 43 72 65 61 74 65 20 77  );.../* Create w
1020: 6f 72 6b 65 72 20 74 68 72 65 61 64 73 20 2a 2f  orker threads */
1030: 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a 20 43  ../* XXX:TODO: C
1040: 68 65 63 6b 20 66 6f 72 20 65 72 72 6f 72 73 20  heck for errors 
1050: 2a 2f 0a 09 66 69 6c 65 64 5f 77 6f 72 6b 65 72  */..filed_worker
1060: 5f 74 68 72 65 61 64 73 5f 69 6e 69 74 28 66 64  _threads_init(fd
1070: 2c 20 74 68 72 65 61 64 5f 63 6f 75 6e 74 29 3b  , thread_count);
1080: 0a 0a 09 2f 2a 20 57 61 69 74 20 66 6f 72 20 74  .../* Wait for t
1090: 68 72 65 61 64 73 20 74 6f 20 65 78 69 74 20 2a  hreads to exit *
10a0: 2f 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a 20  /../* XXX:TODO: 
10b0: 4d 6f 6e 69 74 6f 72 20 74 68 72 65 61 64 20 75  Monitor thread u
10c0: 73 61 67 65 20 2a 2f 0a 09 77 68 69 6c 65 20 28  sage */..while (
10d0: 31 29 20 7b 0a 09 09 73 6c 65 65 70 28 36 30 29  1) {...sleep(60)
10e0: 3b 0a 09 7d 0a 0a 09 2f 2a 20 52 65 74 75 72 6e  ;..}.../* Return
10f0: 20 69 6e 20 66 61 69 6c 75 72 65 20 2a 2f 0a 09   in failure */..
1100: 72 65 74 75 72 6e 28 32 29 3b 0a 7d 0a           return(2);.}.