Hex Artifact Content

Artifact c73ad10afc9bde3ee6f0477da08243dd2b9a22ac:


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 72 69 6e  .#include <strin
00b0: 67 73 2e 68 3e 0a 23 69 6e 63 6c 75 64 65 20 3c  gs.h>.#include <
00c0: 73 69 67 6e 61 6c 2e 68 3e 0a 23 69 6e 63 6c 75  signal.h>.#inclu
00d0: 64 65 20 3c 73 74 64 6c 69 62 2e 68 3e 0a 23 69  de <stdlib.h>.#i
00e0: 6e 63 6c 75 64 65 20 3c 75 6e 69 73 74 64 2e 68  nclude <unistd.h
00f0: 3e 0a 23 69 6e 63 6c 75 64 65 20 3c 73 74 72 69  >.#include <stri
0100: 6e 67 2e 68 3e 0a 23 69 6e 63 6c 75 64 65 20 3c  ng.h>.#include <
0110: 66 63 6e 74 6c 2e 68 3e 0a 23 69 6e 63 6c 75 64  fcntl.h>.#includ
0120: 65 20 3c 73 74 64 69 6f 2e 68 3e 0a 23 69 6e 63  e <stdio.h>.#inc
0130: 6c 75 64 65 20 3c 65 72 72 6e 6f 2e 68 3e 0a 23  lude <errno.h>.#
0140: 69 6e 63 6c 75 64 65 20 3c 74 69 6d 65 2e 68 3e  include <time.h>
0150: 0a 0a 2f 2a 20 43 6f 6d 70 69 6c 65 20 74 69 6d  ../* Compile tim
0160: 65 20 63 6f 6e 73 74 61 6e 74 73 20 2a 2f 0a 23  e constants */.#
0170: 64 65 66 69 6e 65 20 46 49 4c 45 44 5f 53 45 4e  define FILED_SEN
0180: 44 46 49 4c 45 5f 4d 41 58 20 31 36 37 37 37 32  DFILE_MAX 167772
0190: 31 35 0a 0a 2f 2a 20 44 65 66 61 75 6c 74 20 76  15../* Default v
01a0: 61 6c 75 65 73 20 2a 2f 0a 23 64 65 66 69 6e 65  alues */.#define
01b0: 20 4d 41 58 5f 46 41 49 4c 55 52 45 5f 43 4f 55   MAX_FAILURE_COU
01c0: 4e 54 20 33 30 0a 23 64 65 66 69 6e 65 20 50 4f  NT 30.#define PO
01d0: 52 54 20 38 30 38 30 0a 23 64 65 66 69 6e 65 20  RT 8080.#define 
01e0: 54 48 52 45 41 44 5f 43 4f 55 4e 54 20 31 30 0a  THREAD_COUNT 10.
01f0: 23 64 65 66 69 6e 65 20 42 49 4e 44 5f 41 44 44  #define BIND_ADD
0200: 52 20 22 3a 3a 22 0a 23 64 65 66 69 6e 65 20 43  R "::".#define C
0210: 41 43 48 45 5f 53 49 5a 45 20 38 31 39 32 0a 0a  ACHE_SIZE 8192..
0220: 2f 2a 20 41 72 67 75 6d 65 6e 74 73 20 66 6f 72  /* Arguments for
0230: 20 77 6f 72 6b 65 72 20 74 68 72 65 61 64 73 20   worker threads 
0240: 2a 2f 0a 73 74 72 75 63 74 20 66 69 6c 65 64 5f  */.struct filed_
0250: 77 6f 72 6b 65 72 5f 74 68 72 65 61 64 5f 61 72  worker_thread_ar
0260: 67 73 20 7b 0a 09 69 6e 74 20 66 64 3b 0a 7d 3b  gs {..int fd;.};
0270: 0a 0a 2f 2a 20 46 69 6c 65 20 69 6e 66 6f 72 6d  ../* File inform
0280: 61 74 69 6f 6e 20 2a 2f 0a 73 74 72 75 63 74 20  ation */.struct 
0290: 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 20 7b  filed_fileinfo {
02a0: 0a 09 70 74 68 72 65 61 64 5f 6d 75 74 65 78 5f  ..pthread_mutex_
02b0: 74 20 6d 75 74 65 78 3b 0a 09 63 68 61 72 20 2a  t mutex;..char *
02c0: 70 61 74 68 3b 0a 09 69 6e 74 20 66 64 3b 0a 09  path;..int fd;..
02d0: 73 69 7a 65 5f 74 20 6c 65 6e 3b 0a 09 63 68 61  size_t len;..cha
02e0: 72 20 2a 6c 61 73 74 6d 6f 64 3b 0a 09 63 68 61  r *lastmod;..cha
02f0: 72 20 6c 61 73 74 6d 6f 64 5f 62 5b 36 34 5d 3b  r lastmod_b[64];
0300: 0a 09 63 68 61 72 20 2a 74 79 70 65 3b 0a 7d 3b  ..char *type;.};
0310: 0a 0a 2f 2a 20 52 65 71 75 65 73 74 20 76 61 72  ../* Request var
0320: 69 61 62 6c 65 73 20 2a 2f 0a 73 74 72 75 63 74  iables */.struct
0330: 20 66 69 6c 65 64 5f 68 74 74 70 5f 72 65 71 75   filed_http_requ
0340: 65 73 74 20 7b 0a 09 2f 2a 2a 20 42 75 66 66 65  est {../** Buffe
0350: 72 73 20 2a 2a 2f 0a 09 73 74 72 75 63 74 20 66  rs **/..struct f
0360: 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 20 66 69  iled_fileinfo fi
0370: 6c 65 69 6e 66 6f 3b 0a 09 63 68 61 72 20 70 61  leinfo;..char pa
0380: 74 68 5f 62 5b 31 30 31 30 5d 3b 0a 09 63 68 61  th_b[1010];..cha
0390: 72 20 74 6d 70 62 75 66 5b 31 30 31 30 5d 3b 0a  r tmpbuf[1010];.
03a0: 0a 09 2f 2a 2a 20 48 54 54 50 20 52 65 71 75 65  ../** HTTP Reque
03b0: 73 74 20 69 6e 66 6f 72 6d 61 74 69 6f 6e 20 2a  st information *
03c0: 2a 2f 0a 09 63 68 61 72 20 2a 70 61 74 68 3b 20  */..char *path; 
03d0: 20 20 20 20 2f 2a 2a 2a 20 50 61 74 68 20 62 65      /*** Path be
03e0: 69 6e 67 20 72 65 71 75 65 73 74 65 64 20 2a 2a  ing requested **
03f0: 2a 2f 0a 0a 09 73 74 72 75 63 74 20 7b 0a 09 09  */...struct {...
0400: 73 74 72 75 63 74 20 7b 0a 09 09 09 69 6e 74 20  struct {....int 
0410: 70 72 65 73 65 6e 74 3b 0a 09 09 09 6f 66 66 5f  present;....off_
0420: 74 20 6f 66 66 73 65 74 3b 20 20 20 2f 2a 2a 2a  t offset;   /***
0430: 20 52 61 6e 67 65 20 73 74 61 72 74 20 2a 2a 2a   Range start ***
0440: 2f 0a 09 09 09 73 73 69 7a 65 5f 74 20 6c 65 6e  /....ssize_t len
0450: 67 74 68 3b 20 2f 2a 2a 2a 20 52 61 6e 67 65 20  gth; /*** Range 
0460: 6c 65 6e 67 74 68 20 2a 2a 2a 2f 0a 09 09 7d 20  length ***/...} 
0470: 72 61 6e 67 65 3b 0a 09 7d 20 68 65 61 64 65 72  range;..} header
0480: 73 3b 0a 7d 3b 0a 0a 2f 2a 20 47 6c 6f 62 61 6c  s;.};../* Global
0490: 20 76 61 72 69 61 62 6c 65 73 20 2a 2f 0a 2f 2a   variables */./*
04a0: 2a 20 4f 70 65 6e 20 46 69 6c 65 20 63 61 63 68  * Open File cach
04b0: 65 20 2a 2a 2f 0a 73 74 72 75 63 74 20 66 69 6c  e **/.struct fil
04c0: 65 64 5f 66 69 6c 65 69 6e 66 6f 20 2a 66 69 6c  ed_fileinfo *fil
04d0: 65 64 5f 66 69 6c 65 69 6e 66 6f 5f 66 64 63 61  ed_fileinfo_fdca
04e0: 63 68 65 3b 0a 75 6e 73 69 67 6e 65 64 20 69 6e  che;.unsigned in
04f0: 74 20 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f  t filed_fileinfo
0500: 5f 66 64 63 61 63 68 65 5f 73 69 7a 65 20 3d 20  _fdcache_size = 
0510: 43 41 43 48 45 5f 53 49 5a 45 3b 0a 0a 2f 2a 20  CACHE_SIZE;../* 
0520: 49 6e 69 74 69 61 6c 69 7a 65 20 70 72 6f 63 65  Initialize proce
0530: 73 73 20 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74  ss */.static int
0540: 20 66 69 6c 65 64 5f 69 6e 69 74 28 76 6f 69 64   filed_init(void
0550: 29 20 7b 0a 09 75 6e 73 69 67 6e 65 64 20 69 6e  ) {..unsigned in
0560: 74 20 69 64 78 3b 0a 09 69 6e 74 20 6d 75 74 65  t idx;..int mute
0570: 78 5f 69 6e 69 74 5f 72 65 74 3b 0a 0a 09 6d 6c  x_init_ret;...ml
0580: 6f 63 6b 61 6c 6c 28 4d 43 4c 5f 43 55 52 52 45  ockall(MCL_CURRE
0590: 4e 54 20 7c 20 4d 43 4c 5f 46 55 54 55 52 45 29  NT | MCL_FUTURE)
05a0: 3b 0a 0a 09 66 69 6c 65 64 5f 66 69 6c 65 69 6e  ;...filed_filein
05b0: 66 6f 5f 66 64 63 61 63 68 65 20 3d 20 6d 61 6c  fo_fdcache = mal
05c0: 6c 6f 63 28 73 69 7a 65 6f 66 28 2a 66 69 6c 65  loc(sizeof(*file
05d0: 64 5f 66 69 6c 65 69 6e 66 6f 5f 66 64 63 61 63  d_fileinfo_fdcac
05e0: 68 65 29 20 2a 20 66 69 6c 65 64 5f 66 69 6c 65  he) * filed_file
05f0: 69 6e 66 6f 5f 66 64 63 61 63 68 65 5f 73 69 7a  info_fdcache_siz
0600: 65 29 3b 0a 09 69 66 20 28 66 69 6c 65 64 5f 66  e);..if (filed_f
0610: 69 6c 65 69 6e 66 6f 5f 66 64 63 61 63 68 65 20  ileinfo_fdcache 
0620: 3d 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09 72 65 74  == NULL) {...ret
0630: 75 72 6e 28 31 29 3b 0a 09 7d 0a 0a 09 66 6f 72  urn(1);..}...for
0640: 20 28 69 64 78 20 3d 20 30 3b 20 69 64 78 20 3c   (idx = 0; idx <
0650: 20 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 5f   filed_fileinfo_
0660: 66 64 63 61 63 68 65 5f 73 69 7a 65 3b 20 69 64  fdcache_size; id
0670: 78 2b 2b 29 20 7b 0a 09 09 6d 75 74 65 78 5f 69  x++) {...mutex_i
0680: 6e 69 74 5f 72 65 74 20 3d 20 70 74 68 72 65 61  nit_ret = pthrea
0690: 64 5f 6d 75 74 65 78 5f 69 6e 69 74 28 26 66 69  d_mutex_init(&fi
06a0: 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 5f 66 64 63  led_fileinfo_fdc
06b0: 61 63 68 65 5b 69 64 78 5d 2e 6d 75 74 65 78 2c  ache[idx].mutex,
06c0: 20 4e 55 4c 4c 29 3b 0a 09 09 69 66 20 28 6d 75   NULL);...if (mu
06d0: 74 65 78 5f 69 6e 69 74 5f 72 65 74 20 21 3d 20  tex_init_ret != 
06e0: 30 29 20 7b 0a 09 09 09 72 65 74 75 72 6e 28 31  0) {....return(1
06f0: 29 3b 0a 09 09 7d 0a 0a 09 09 66 69 6c 65 64 5f  );...}....filed_
0700: 66 69 6c 65 69 6e 66 6f 5f 66 64 63 61 63 68 65  fileinfo_fdcache
0710: 5b 69 64 78 5d 2e 70 61 74 68 20 3d 20 73 74 72  [idx].path = str
0720: 64 75 70 28 22 22 29 3b 0a 09 09 66 69 6c 65 64  dup("");...filed
0730: 5f 66 69 6c 65 69 6e 66 6f 5f 66 64 63 61 63 68  _fileinfo_fdcach
0740: 65 5b 69 64 78 5d 2e 66 64 20 3d 20 2d 31 3b 0a  e[idx].fd = -1;.
0750: 09 09 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f  ..filed_fileinfo
0760: 5f 66 64 63 61 63 68 65 5b 69 64 78 5d 2e 6c 61  _fdcache[idx].la
0770: 73 74 6d 6f 64 20 3d 20 22 22 3b 0a 09 09 66 69  stmod = "";...fi
0780: 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 5f 66 64 63  led_fileinfo_fdc
0790: 61 63 68 65 5b 69 64 78 5d 2e 74 79 70 65 20 3d  ache[idx].type =
07a0: 20 22 22 3b 0a 09 7d 0a 0a 09 73 69 67 6e 61 6c   "";..}...signal
07b0: 28 53 49 47 50 49 50 45 2c 20 53 49 47 5f 49 47  (SIGPIPE, SIG_IG
07c0: 4e 29 3b 0a 0a 09 72 65 74 75 72 6e 28 30 29 3b  N);...return(0);
07d0: 0a 7d 0a 0a 2f 2a 20 4c 69 73 74 65 6e 20 6f 6e  .}../* Listen on
07e0: 20 61 20 70 61 72 74 69 63 75 6c 61 72 20 61 64   a particular ad
07f0: 64 72 65 73 73 2f 70 6f 72 74 20 2a 2f 0a 73 74  dress/port */.st
0800: 61 74 69 63 20 69 6e 74 20 66 69 6c 65 64 5f 6c  atic int filed_l
0810: 69 73 74 65 6e 28 63 6f 6e 73 74 20 63 68 61 72  isten(const char
0820: 20 2a 61 64 64 72 65 73 73 2c 20 75 6e 73 69 67   *address, unsig
0830: 6e 65 64 20 69 6e 74 20 70 6f 72 74 29 20 7b 0a  ned int port) {.
0840: 09 73 74 72 75 63 74 20 73 6f 63 6b 61 64 64 72  .struct sockaddr
0850: 5f 69 6e 36 20 61 64 64 72 3b 0a 09 69 6e 74 20  _in6 addr;..int 
0860: 70 74 6f 6e 5f 72 65 74 2c 20 62 69 6e 64 5f 72  pton_ret, bind_r
0870: 65 74 2c 20 6c 69 73 74 65 6e 5f 72 65 74 3b 0a  et, listen_ret;.
0880: 09 69 6e 74 20 66 64 3b 0a 0a 09 61 64 64 72 2e  .int fd;...addr.
0890: 73 69 6e 36 5f 66 61 6d 69 6c 79 20 3d 20 41 46  sin6_family = AF
08a0: 5f 49 4e 45 54 36 3b 0a 09 61 64 64 72 2e 73 69  _INET6;..addr.si
08b0: 6e 36 5f 66 6c 6f 77 69 6e 66 6f 20 3d 20 30 3b  n6_flowinfo = 0;
08c0: 0a 09 61 64 64 72 2e 73 69 6e 36 5f 73 63 6f 70  ..addr.sin6_scop
08d0: 65 5f 69 64 20 3d 20 30 3b 0a 09 61 64 64 72 2e  e_id = 0;..addr.
08e0: 73 69 6e 36 5f 70 6f 72 74 20 3d 20 68 74 6f 6e  sin6_port = hton
08f0: 73 28 70 6f 72 74 29 3b 0a 09 70 74 6f 6e 5f 72  s(port);..pton_r
0900: 65 74 20 3d 20 69 6e 65 74 5f 70 74 6f 6e 28 41  et = inet_pton(A
0910: 46 5f 49 4e 45 54 36 2c 20 61 64 64 72 65 73 73  F_INET6, address
0920: 2c 20 61 64 64 72 2e 73 69 6e 36 5f 61 64 64 72  , addr.sin6_addr
0930: 2e 73 36 5f 61 64 64 72 29 3b 0a 09 69 66 20 28  .s6_addr);..if (
0940: 70 74 6f 6e 5f 72 65 74 20 21 3d 20 31 29 20 7b  pton_ret != 1) {
0950: 0a 09 09 72 65 74 75 72 6e 28 2d 31 29 3b 0a 09  ...return(-1);..
0960: 7d 0a 0a 09 66 64 20 3d 20 73 6f 63 6b 65 74 28  }...fd = socket(
0970: 41 46 5f 49 4e 45 54 36 2c 20 53 4f 43 4b 5f 53  AF_INET6, SOCK_S
0980: 54 52 45 41 4d 2c 20 30 29 3b 0a 09 69 66 20 28  TREAM, 0);..if (
0990: 66 64 20 3c 20 30 29 20 7b 0a 09 09 72 65 74 75  fd < 0) {...retu
09a0: 72 6e 28 66 64 29 3b 0a 09 7d 0a 0a 09 62 69 6e  rn(fd);..}...bin
09b0: 64 5f 72 65 74 20 3d 20 62 69 6e 64 28 66 64 2c  d_ret = bind(fd,
09c0: 20 28 63 6f 6e 73 74 20 73 74 72 75 63 74 20 73   (const struct s
09d0: 6f 63 6b 61 64 64 72 20 2a 29 20 26 61 64 64 72  ockaddr *) &addr
09e0: 2c 20 73 69 7a 65 6f 66 28 61 64 64 72 29 29 3b  , sizeof(addr));
09f0: 0a 09 69 66 20 28 62 69 6e 64 5f 72 65 74 20 3c  ..if (bind_ret <
0a00: 20 30 29 20 7b 0a 09 09 63 6c 6f 73 65 28 66 64   0) {...close(fd
0a10: 29 3b 0a 0a 09 09 72 65 74 75 72 6e 28 2d 31 29  );....return(-1)
0a20: 3b 0a 09 7d 0a 0a 09 6c 69 73 74 65 6e 5f 72 65  ;..}...listen_re
0a30: 74 20 3d 20 6c 69 73 74 65 6e 28 66 64 2c 20 31  t = listen(fd, 1
0a40: 32 38 29 3b 0a 09 69 66 20 28 6c 69 73 74 65 6e  28);..if (listen
0a50: 5f 72 65 74 20 21 3d 20 30 29 20 7b 0a 09 09 63  _ret != 0) {...c
0a60: 6c 6f 73 65 28 66 64 29 3b 0a 0a 09 09 72 65 74  lose(fd);....ret
0a70: 75 72 6e 28 2d 31 29 3b 0a 09 7d 0a 0a 09 72 65  urn(-1);..}...re
0a80: 74 75 72 6e 28 66 64 29 3b 0a 7d 0a 0a 2f 2a 20  turn(fd);.}../* 
0a90: 4c 6f 67 20 61 20 6d 65 73 73 61 67 65 20 2a 2f  Log a message */
0aa0: 0a 2f 2f 23 64 65 66 69 6e 65 20 46 49 4c 45 44  .//#define FILED
0ab0: 5f 44 4f 4e 54 5f 4c 4f 47 0a 23 69 66 64 65 66  _DONT_LOG.#ifdef
0ac0: 20 46 49 4c 45 44 5f 44 4f 4e 54 5f 4c 4f 47 0a   FILED_DONT_LOG.
0ad0: 23 20 20 64 65 66 69 6e 65 20 66 69 6c 65 64 5f  #  define filed_
0ae0: 6c 6f 67 67 69 6e 67 5f 74 68 72 65 61 64 5f 69  logging_thread_i
0af0: 6e 69 74 28 29 20 30 0a 23 20 20 64 65 66 69 6e  nit() 0.#  defin
0b00: 65 20 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 5f  e filed_log_msg_
0b10: 64 65 62 75 67 28 78 2c 20 2e 2e 2e 29 20 2f 2a  debug(x, ...) /*
0b20: 2a 2f 0a 23 20 20 64 65 66 69 6e 65 20 66 69 6c  */.#  define fil
0b30: 65 64 5f 6c 6f 67 5f 6d 73 67 28 78 29 20 2f 2a  ed_log_msg(x) /*
0b40: 2a 2f 0a 23 65 6c 73 65 0a 2f 2a 20 49 6e 69 74  */.#else./* Init
0b50: 69 61 6c 69 7a 65 20 6c 6f 67 67 69 6e 67 20 74  ialize logging t
0b60: 68 72 65 61 64 20 2a 2f 0a 73 74 61 74 69 63 20  hread */.static 
0b70: 69 6e 74 20 66 69 6c 65 64 5f 6c 6f 67 67 69 6e  int filed_loggin
0b80: 67 5f 74 68 72 65 61 64 5f 69 6e 69 74 28 76 6f  g_thread_init(vo
0b90: 69 64 29 20 7b 0a 09 2f 2a 20 58 58 58 3a 54 4f  id) {../* XXX:TO
0ba0: 44 4f 3a 20 55 6e 69 6d 70 6c 65 6d 65 6e 74 65  DO: Unimplemente
0bb0: 64 20 2a 2f 0a 09 72 65 74 75 72 6e 28 30 29 3b  d */..return(0);
0bc0: 0a 7d 0a 0a 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a  .}../* XXX:TODO:
0bd0: 20 55 6e 69 6d 70 6c 65 6d 65 6e 74 65 64 20 2a   Unimplemented *
0be0: 2f 0a 23 64 65 66 69 6e 65 20 66 69 6c 65 64 5f  /.#define filed_
0bf0: 6c 6f 67 5f 6d 73 67 5f 64 65 62 75 67 28 78 2c  log_msg_debug(x,
0c00: 20 2e 2e 2e 29 20 7b 20 66 70 72 69 6e 74 66 28   ...) { fprintf(
0c10: 73 74 64 65 72 72 2c 20 78 2c 20 5f 5f 56 41 5f  stderr, x, __VA_
0c20: 41 52 47 53 5f 5f 29 3b 20 66 70 72 69 6e 74 66  ARGS__); fprintf
0c30: 28 73 74 64 65 72 72 2c 20 22 5c 6e 22 29 3b 20  (stderr, "\n"); 
0c40: 66 66 6c 75 73 68 28 73 74 64 65 72 72 29 3b 20  fflush(stderr); 
0c50: 7d 0a 0a 73 74 61 74 69 63 20 76 6f 69 64 20 66  }..static void f
0c60: 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 63 6f 6e  iled_log_msg(con
0c70: 73 74 20 63 68 61 72 20 2a 62 75 66 66 65 72 29  st char *buffer)
0c80: 20 7b 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f 3a   {../* XXX:TODO:
0c90: 20 55 6e 69 6d 70 6c 65 6d 65 6e 74 65 64 20 2a   Unimplemented *
0ca0: 2f 0a 09 66 70 72 69 6e 74 66 28 73 74 64 65 72  /..fprintf(stder
0cb0: 72 2c 20 22 25 73 5c 6e 22 2c 20 62 75 66 66 65  r, "%s\n", buffe
0cc0: 72 29 3b 0a 0a 09 72 65 74 75 72 6e 3b 0a 7d 0a  r);...return;.}.
0cd0: 0a 23 65 6e 64 69 66 0a 2f 2a 20 46 6f 72 6d 61  .#endif./* Forma
0ce0: 74 20 74 69 6d 65 20 70 65 72 20 52 46 43 32 36  t time per RFC26
0cf0: 31 36 20 2a 2f 0a 73 74 61 74 69 63 20 63 68 61  16 */.static cha
0d00: 72 20 2a 66 69 6c 65 64 5f 66 6f 72 6d 61 74 5f  r *filed_format_
0d10: 74 69 6d 65 28 63 68 61 72 20 2a 62 75 66 66 65  time(char *buffe
0d20: 72 2c 20 73 69 7a 65 5f 74 20 62 75 66 66 65 72  r, size_t buffer
0d30: 5f 6c 65 6e 2c 20 63 6f 6e 73 74 20 74 69 6d 65  _len, const time
0d40: 5f 74 20 74 69 6d 65 69 6e 66 6f 29 20 7b 0a 09  _t timeinfo) {..
0d50: 73 74 72 75 63 74 20 74 6d 20 74 69 6d 65 69 6e  struct tm timein
0d60: 66 6f 5f 74 6d 2c 20 2a 74 69 6d 65 69 6e 66 6f  fo_tm, *timeinfo
0d70: 5f 74 6d 5f 70 3b 0a 0a 09 74 69 6d 65 69 6e 66  _tm_p;...timeinf
0d80: 6f 5f 74 6d 5f 70 20 3d 20 67 6d 74 69 6d 65 5f  o_tm_p = gmtime_
0d90: 72 28 26 74 69 6d 65 69 6e 66 6f 2c 20 26 74 69  r(&timeinfo, &ti
0da0: 6d 65 69 6e 66 6f 5f 74 6d 29 3b 0a 09 69 66 20  meinfo_tm);..if 
0db0: 28 74 69 6d 65 69 6e 66 6f 5f 74 6d 5f 70 20 3d  (timeinfo_tm_p =
0dc0: 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09 72 65 74 75  = NULL) {...retu
0dd0: 72 6e 28 22 75 6e 6b 6e 6f 77 6e 22 29 3b 0a 09  rn("unknown");..
0de0: 7d 0a 0a 09 62 75 66 66 65 72 5b 62 75 66 66 65  }...buffer[buffe
0df0: 72 5f 6c 65 6e 20 2d 20 31 5d 20 3d 20 27 5c 30  r_len - 1] = '\0
0e00: 27 3b 0a 09 62 75 66 66 65 72 5f 6c 65 6e 20 3d  ';..buffer_len =
0e10: 20 73 74 72 66 74 69 6d 65 28 62 75 66 66 65 72   strftime(buffer
0e20: 2c 20 62 75 66 66 65 72 5f 6c 65 6e 20 2d 20 31  , buffer_len - 1
0e30: 2c 20 22 25 61 2c 20 25 64 20 25 62 20 25 59 20  , "%a, %d %b %Y 
0e40: 25 48 3a 25 4d 3a 25 53 20 47 4d 54 22 2c 20 74  %H:%M:%S GMT", t
0e50: 69 6d 65 69 6e 66 6f 5f 74 6d 5f 70 29 3b 0a 0a  imeinfo_tm_p);..
0e60: 09 72 65 74 75 72 6e 28 62 75 66 66 65 72 29 3b  .return(buffer);
0e70: 0a 7d 0a 0a 2f 2a 20 68 61 73 68 20 2a 2f 0a 73  .}../* hash */.s
0e80: 74 61 74 69 63 20 75 6e 73 69 67 6e 65 64 20 69  tatic unsigned i
0e90: 6e 74 20 66 69 6c 65 64 5f 68 61 73 68 28 63 6f  nt filed_hash(co
0ea0: 6e 73 74 20 75 6e 73 69 67 6e 65 64 20 63 68 61  nst unsigned cha
0eb0: 72 20 2a 76 61 6c 75 65 2c 20 75 6e 73 69 67 6e  r *value, unsign
0ec0: 65 64 20 69 6e 74 20 6d 6f 64 75 6c 75 73 29 20  ed int modulus) 
0ed0: 7b 0a 09 75 6e 73 69 67 6e 65 64 20 63 68 61 72  {..unsigned char
0ee0: 20 63 75 72 72 3b 0a 09 75 6e 73 69 67 6e 65 64   curr;..unsigned
0ef0: 20 69 6e 74 20 72 65 74 76 61 6c 3b 0a 0a 09 72   int retval;...r
0f00: 65 74 76 61 6c 20 3d 20 6d 6f 64 75 6c 75 73 20  etval = modulus 
0f10: 2d 20 31 3b 0a 0a 09 77 68 69 6c 65 20 28 28 63  - 1;...while ((c
0f20: 75 72 72 20 3d 20 2a 76 61 6c 75 65 29 29 20 7b  urr = *value)) {
0f30: 0a 09 09 69 66 20 28 63 75 72 72 20 3c 20 33 32  ...if (curr < 32
0f40: 29 20 7b 0a 09 09 09 63 75 72 72 20 3d 20 32 35  ) {....curr = 25
0f50: 35 20 2d 20 63 75 72 72 3b 0a 09 09 7d 20 65 6c  5 - curr;...} el
0f60: 73 65 20 7b 0a 09 09 09 63 75 72 72 20 2d 3d 20  se {....curr -= 
0f70: 33 32 3b 0a 09 09 7d 0a 0a 09 09 72 65 74 76 61  32;...}....retva
0f80: 6c 20 3c 3c 3d 20 35 3b 0a 09 09 72 65 74 76 61  l <<= 5;...retva
0f90: 6c 20 2b 3d 20 63 75 72 72 3b 0a 0a 09 09 76 61  l += curr;....va
0fa0: 6c 75 65 2b 2b 3b 0a 09 7d 0a 0a 09 72 65 74 76  lue++;..}...retv
0fb0: 61 6c 20 3d 20 72 65 74 76 61 6c 20 25 20 6d 6f  al = retval % mo
0fc0: 64 75 6c 75 73 3b 0a 0a 09 72 65 74 75 72 6e 28  dulus;...return(
0fd0: 72 65 74 76 61 6c 29 3b 0a 7d 0a 0a 2f 2a 20 4f  retval);.}../* O
0fe0: 70 65 6e 20 61 20 66 69 6c 65 20 61 6e 64 20 72  pen a file and r
0ff0: 65 74 75 72 6e 20 66 69 6c 65 20 69 6e 66 6f 72  eturn file infor
1000: 6d 61 74 69 6f 6e 20 2a 2f 0a 73 74 61 74 69 63  mation */.static
1010: 20 73 74 72 75 63 74 20 66 69 6c 65 64 5f 66 69   struct filed_fi
1020: 6c 65 69 6e 66 6f 20 2a 66 69 6c 65 64 5f 6f 70  leinfo *filed_op
1030: 65 6e 5f 66 69 6c 65 28 63 6f 6e 73 74 20 63 68  en_file(const ch
1040: 61 72 20 2a 70 61 74 68 2c 20 73 74 72 75 63 74  ar *path, struct
1050: 20 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 20   filed_fileinfo 
1060: 2a 62 75 66 66 65 72 29 20 7b 0a 09 73 74 72 75  *buffer) {..stru
1070: 63 74 20 66 69 6c 65 64 5f 66 69 6c 65 69 6e 66  ct filed_fileinf
1080: 6f 20 2a 63 61 63 68 65 3b 0a 09 75 6e 73 69 67  o *cache;..unsig
1090: 6e 65 64 20 69 6e 74 20 63 61 63 68 65 5f 69 64  ned int cache_id
10a0: 78 3b 0a 09 6f 66 66 5f 74 20 6c 65 6e 3b 0a 09  x;..off_t len;..
10b0: 69 6e 74 20 66 64 3b 0a 0a 09 63 61 63 68 65 5f  int fd;...cache_
10c0: 69 64 78 20 3d 20 66 69 6c 65 64 5f 68 61 73 68  idx = filed_hash
10d0: 28 28 63 6f 6e 73 74 20 75 6e 73 69 67 6e 65 64  ((const unsigned
10e0: 20 63 68 61 72 20 2a 29 20 70 61 74 68 2c 20 66   char *) path, f
10f0: 69 6c 65 64 5f 66 69 6c 65 69 6e 66 6f 5f 66 64  iled_fileinfo_fd
1100: 63 61 63 68 65 5f 73 69 7a 65 29 3b 0a 0a 09 63  cache_size);...c
1110: 61 63 68 65 20 3d 20 26 66 69 6c 65 64 5f 66 69  ache = &filed_fi
1120: 6c 65 69 6e 66 6f 5f 66 64 63 61 63 68 65 5b 63  leinfo_fdcache[c
1130: 61 63 68 65 5f 69 64 78 5d 3b 0a 0a 09 66 69 6c  ache_idx];...fil
1140: 65 64 5f 6c 6f 67 5f 6d 73 67 5f 64 65 62 75 67  ed_log_msg_debug
1150: 28 22 4c 6f 63 6b 69 6e 67 20 6d 75 74 65 78 20  ("Locking mutex 
1160: 66 6f 72 20 69 64 78 3a 20 25 6c 75 22 2c 20 28  for idx: %lu", (
1170: 75 6e 73 69 67 6e 65 64 20 6c 6f 6e 67 29 20 63  unsigned long) c
1180: 61 63 68 65 5f 69 64 78 29 3b 0a 0a 09 70 74 68  ache_idx);...pth
1190: 72 65 61 64 5f 6d 75 74 65 78 5f 6c 6f 63 6b 28  read_mutex_lock(
11a0: 26 63 61 63 68 65 2d 3e 6d 75 74 65 78 29 3b 0a  &cache->mutex);.
11b0: 0a 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 5f  ..filed_log_msg_
11c0: 64 65 62 75 67 28 22 43 6f 6d 70 6c 65 74 65 64  debug("Completed
11d0: 20 6c 6f 63 6b 69 6e 67 20 6d 75 74 65 78 20 66   locking mutex f
11e0: 6f 72 20 69 64 78 3a 20 25 6c 75 22 2c 20 28 75  or idx: %lu", (u
11f0: 6e 73 69 67 6e 65 64 20 6c 6f 6e 67 29 20 63 61  nsigned long) ca
1200: 63 68 65 5f 69 64 78 29 3b 0a 0a 09 69 66 20 28  che_idx);...if (
1210: 73 74 72 63 6d 70 28 70 61 74 68 2c 20 63 61 63  strcmp(path, cac
1220: 68 65 2d 3e 70 61 74 68 29 20 21 3d 20 30 29 20  he->path) != 0) 
1230: 7b 0a 09 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73  {...filed_log_ms
1240: 67 5f 64 65 62 75 67 28 22 43 61 63 68 65 20 6d  g_debug("Cache m
1250: 69 73 73 20 66 6f 72 20 69 64 78 3a 20 25 6c 75  iss for idx: %lu
1260: 3a 20 4f 4c 44 20 5c 22 25 73 5c 22 2c 20 4e 45  : OLD \"%s\", NE
1270: 57 20 5c 22 25 73 5c 22 22 2c 20 28 75 6e 73 69  W \"%s\"", (unsi
1280: 67 6e 65 64 20 6c 6f 6e 67 29 20 63 61 63 68 65  gned long) cache
1290: 5f 69 64 78 2c 20 63 61 63 68 65 2d 3e 70 61 74  _idx, cache->pat
12a0: 68 2c 20 70 61 74 68 29 3b 0a 0a 09 09 66 64 20  h, path);....fd 
12b0: 3d 20 6f 70 65 6e 28 70 61 74 68 2c 20 4f 5f 52  = open(path, O_R
12c0: 44 4f 4e 4c 59 20 7c 20 4f 5f 4c 41 52 47 45 46  DONLY | O_LARGEF
12d0: 49 4c 45 29 3b 0a 09 09 69 66 20 28 66 64 20 3c  ILE);...if (fd <
12e0: 20 30 29 20 7b 0a 09 09 09 70 74 68 72 65 61 64   0) {....pthread
12f0: 5f 6d 75 74 65 78 5f 75 6e 6c 6f 63 6b 28 26 63  _mutex_unlock(&c
1300: 61 63 68 65 2d 3e 6d 75 74 65 78 29 3b 0a 0a 09  ache->mutex);...
1310: 09 09 72 65 74 75 72 6e 28 4e 55 4c 4c 29 3b 0a  ..return(NULL);.
1320: 09 09 7d 0a 0a 09 09 66 72 65 65 28 63 61 63 68  ..}....free(cach
1330: 65 2d 3e 70 61 74 68 29 3b 0a 09 09 69 66 20 28  e->path);...if (
1340: 63 61 63 68 65 2d 3e 66 64 20 3e 3d 20 30 29 20  cache->fd >= 0) 
1350: 7b 0a 09 09 09 63 6c 6f 73 65 28 63 61 63 68 65  {....close(cache
1360: 2d 3e 66 64 29 3b 0a 09 09 7d 0a 0a 09 09 6c 65  ->fd);...}....le
1370: 6e 20 3d 20 6c 73 65 65 6b 28 66 64 2c 20 30 2c  n = lseek(fd, 0,
1380: 20 53 45 45 4b 5f 45 4e 44 29 3b 0a 09 09 6c 73   SEEK_END);...ls
1390: 65 65 6b 28 66 64 2c 20 30 2c 20 53 45 45 4b 5f  eek(fd, 0, SEEK_
13a0: 53 45 54 29 3b 0a 0a 09 09 63 61 63 68 65 2d 3e  SET);....cache->
13b0: 66 64 20 3d 20 66 64 3b 0a 09 09 63 61 63 68 65  fd = fd;...cache
13c0: 2d 3e 6c 65 6e 20 3d 20 6c 65 6e 3b 0a 09 09 63  ->len = len;...c
13d0: 61 63 68 65 2d 3e 70 61 74 68 20 3d 20 73 74 72  ache->path = str
13e0: 64 75 70 28 70 61 74 68 29 3b 0a 0a 09 09 2f 2a  dup(path);..../*
13f0: 20 58 58 58 3a 54 4f 44 4f 3a 20 44 65 74 65 72   XXX:TODO: Deter
1400: 6d 69 6e 65 20 2a 2f 0a 09 09 63 61 63 68 65 2d  mine */...cache-
1410: 3e 74 79 70 65 20 3d 20 22 76 69 64 65 6f 2f 6d  >type = "video/m
1420: 70 34 22 3b 0a 09 09 63 61 63 68 65 2d 3e 6c 61  p4";...cache->la
1430: 73 74 6d 6f 64 20 3d 20 66 69 6c 65 64 5f 66 6f  stmod = filed_fo
1440: 72 6d 61 74 5f 74 69 6d 65 28 63 61 63 68 65 2d  rmat_time(cache-
1450: 3e 6c 61 73 74 6d 6f 64 5f 62 2c 20 73 69 7a 65  >lastmod_b, size
1460: 6f 66 28 63 61 63 68 65 2d 3e 6c 61 73 74 6d 6f  of(cache->lastmo
1470: 64 5f 62 29 2c 20 74 69 6d 65 28 4e 55 4c 4c 29  d_b), time(NULL)
1480: 20 2d 20 33 30 29 3b 0a 09 7d 20 65 6c 73 65 20   - 30);..} else 
1490: 7b 0a 09 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73  {...filed_log_ms
14a0: 67 5f 64 65 62 75 67 28 22 43 61 63 68 65 20 68  g_debug("Cache h
14b0: 69 74 20 66 6f 72 20 69 64 78 3a 20 25 6c 75 3a  it for idx: %lu:
14c0: 20 50 41 54 48 20 5c 22 25 73 5c 22 22 2c 20 28   PATH \"%s\"", (
14d0: 75 6e 73 69 67 6e 65 64 20 6c 6f 6e 67 29 20 63  unsigned long) c
14e0: 61 63 68 65 5f 69 64 78 2c 20 70 61 74 68 29 3b  ache_idx, path);
14f0: 0a 09 7d 0a 0a 09 2f 2a 0a 09 20 2a 20 57 65 20  ..}.../*.. * We 
1500: 68 61 76 65 20 74 6f 20 6d 61 6b 65 20 61 20 64  have to make a d
1510: 75 70 6c 69 63 61 74 65 20 46 44 2c 20 62 65 63  uplicate FD, bec
1520: 61 75 73 65 20 6f 6e 63 65 20 77 65 20 72 65 6c  ause once we rel
1530: 65 61 73 65 20 74 68 65 20 63 61 63 68 65 0a 09  ease the cache..
1540: 20 2a 20 6d 75 74 65 78 2c 20 74 68 65 20 66 69   * mutex, the fi
1550: 6c 65 20 64 65 73 63 72 69 70 74 6f 72 20 6d 61  le descriptor ma
1560: 79 20 62 65 20 63 6c 6f 73 65 64 0a 09 20 2a 2f  y be closed.. */
1570: 0a 09 66 64 20 3d 20 64 75 70 28 63 61 63 68 65  ..fd = dup(cache
1580: 2d 3e 66 64 29 3b 0a 09 69 66 20 28 66 64 20 3c  ->fd);..if (fd <
1590: 20 30 29 20 7b 0a 09 09 70 74 68 72 65 61 64 5f   0) {...pthread_
15a0: 6d 75 74 65 78 5f 75 6e 6c 6f 63 6b 28 26 63 61  mutex_unlock(&ca
15b0: 63 68 65 2d 3e 6d 75 74 65 78 29 3b 0a 0a 09 09  che->mutex);....
15c0: 72 65 74 75 72 6e 28 4e 55 4c 4c 29 3b 0a 09 7d  return(NULL);..}
15d0: 0a 0a 09 62 75 66 66 65 72 2d 3e 66 64 20 3d 20  ...buffer->fd = 
15e0: 66 64 3b 0a 09 62 75 66 66 65 72 2d 3e 6c 65 6e  fd;..buffer->len
15f0: 20 3d 20 63 61 63 68 65 2d 3e 6c 65 6e 3b 0a 09   = cache->len;..
1600: 62 75 66 66 65 72 2d 3e 74 79 70 65 20 3d 20 63  buffer->type = c
1610: 61 63 68 65 2d 3e 74 79 70 65 3b 0a 09 6d 65 6d  ache->type;..mem
1620: 63 70 79 28 62 75 66 66 65 72 2d 3e 6c 61 73 74  cpy(buffer->last
1630: 6d 6f 64 5f 62 2c 20 63 61 63 68 65 2d 3e 6c 61  mod_b, cache->la
1640: 73 74 6d 6f 64 5f 62 2c 20 73 69 7a 65 6f 66 28  stmod_b, sizeof(
1650: 62 75 66 66 65 72 2d 3e 6c 61 73 74 6d 6f 64 5f  buffer->lastmod_
1660: 62 29 29 3b 0a 09 62 75 66 66 65 72 2d 3e 6c 61  b));..buffer->la
1670: 73 74 6d 6f 64 20 3d 20 62 75 66 66 65 72 2d 3e  stmod = buffer->
1680: 6c 61 73 74 6d 6f 64 5f 62 20 2b 20 28 63 61 63  lastmod_b + (cac
1690: 68 65 2d 3e 6c 61 73 74 6d 6f 64 20 2d 20 63 61  he->lastmod - ca
16a0: 63 68 65 2d 3e 6c 61 73 74 6d 6f 64 5f 62 29 3b  che->lastmod_b);
16b0: 0a 0a 09 70 74 68 72 65 61 64 5f 6d 75 74 65 78  ...pthread_mutex
16c0: 5f 75 6e 6c 6f 63 6b 28 26 63 61 63 68 65 2d 3e  _unlock(&cache->
16d0: 6d 75 74 65 78 29 3b 0a 0a 09 72 65 74 75 72 6e  mutex);...return
16e0: 28 62 75 66 66 65 72 29 3b 0a 7d 0a 0a 2f 2a 20  (buffer);.}../* 
16f0: 50 72 6f 63 65 73 73 20 61 6e 20 48 54 54 50 20  Process an HTTP 
1700: 72 65 71 75 65 73 74 20 61 6e 64 20 72 65 74 75  request and retu
1710: 72 6e 20 74 68 65 20 70 61 74 68 20 72 65 71 75  rn the path requ
1720: 65 73 74 65 64 20 2a 2f 0a 73 74 61 74 69 63 20  ested */.static 
1730: 73 74 72 75 63 74 20 66 69 6c 65 64 5f 68 74 74  struct filed_htt
1740: 70 5f 72 65 71 75 65 73 74 20 2a 66 69 6c 65 64  p_request *filed
1750: 5f 67 65 74 5f 68 74 74 70 5f 72 65 71 75 65 73  _get_http_reques
1760: 74 28 46 49 4c 45 20 2a 66 70 2c 20 73 74 72 75  t(FILE *fp, stru
1770: 63 74 20 66 69 6c 65 64 5f 68 74 74 70 5f 72 65  ct filed_http_re
1780: 71 75 65 73 74 20 2a 62 75 66 66 65 72 5f 73 74  quest *buffer_st
1790: 29 20 7b 0a 09 63 68 61 72 20 2a 6d 65 74 68 6f  ) {..char *metho
17a0: 64 2c 20 2a 70 61 74 68 3b 0a 09 63 68 61 72 20  d, *path;..char 
17b0: 2a 62 75 66 66 65 72 2c 20 2a 74 6d 70 62 75 66  *buffer, *tmpbuf
17c0: 66 65 72 2c 20 2a 77 6f 72 6b 62 75 66 66 65 72  fer, *workbuffer
17d0: 2c 20 2a 77 6f 72 6b 62 75 66 66 65 72 5f 6e 65  , *workbuffer_ne
17e0: 78 74 3b 0a 09 73 69 7a 65 5f 74 20 62 75 66 66  xt;..size_t buff
17f0: 65 72 5f 6c 65 6e 2c 20 74 6d 70 62 75 66 66 65  er_len, tmpbuffe
1800: 72 5f 6c 65 6e 3b 0a 09 6f 66 66 5f 74 20 72 61  r_len;..off_t ra
1810: 6e 67 65 5f 73 74 61 72 74 2c 20 72 61 6e 67 65  nge_start, range
1820: 5f 65 6e 64 3b 0a 09 73 73 69 7a 65 5f 74 20 72  _end;..ssize_t r
1830: 61 6e 67 65 5f 6c 65 6e 67 74 68 3b 0a 09 69 6e  ange_length;..in
1840: 74 20 72 61 6e 67 65 5f 72 65 71 75 65 73 74 3b  t range_request;
1850: 0a 09 69 6e 74 20 69 3b 0a 0a 09 72 61 6e 67 65  ..int i;...range
1860: 5f 73 74 61 72 74 20 3d 20 30 3b 0a 09 72 61 6e  _start = 0;..ran
1870: 67 65 5f 65 6e 64 20 20 20 3d 20 30 3b 0a 09 72  ge_end   = 0;..r
1880: 61 6e 67 65 5f 72 65 71 75 65 73 74 20 3d 20 30  ange_request = 0
1890: 3b 0a 09 72 61 6e 67 65 5f 6c 65 6e 67 74 68 20  ;..range_length 
18a0: 3d 20 2d 31 3b 0a 0a 09 62 75 66 66 65 72 20 3d  = -1;...buffer =
18b0: 20 62 75 66 66 65 72 5f 73 74 2d 3e 70 61 74 68   buffer_st->path
18c0: 5f 62 3b 0a 09 62 75 66 66 65 72 5f 6c 65 6e 20  _b;..buffer_len 
18d0: 3d 20 73 69 7a 65 6f 66 28 62 75 66 66 65 72 5f  = sizeof(buffer_
18e0: 73 74 2d 3e 70 61 74 68 5f 62 29 3b 0a 0a 09 74  st->path_b);...t
18f0: 6d 70 62 75 66 66 65 72 20 3d 20 62 75 66 66 65  mpbuffer = buffe
1900: 72 5f 73 74 2d 3e 74 6d 70 62 75 66 3b 0a 09 74  r_st->tmpbuf;..t
1910: 6d 70 62 75 66 66 65 72 5f 6c 65 6e 20 3d 20 73  mpbuffer_len = s
1920: 69 7a 65 6f 66 28 62 75 66 66 65 72 5f 73 74 2d  izeof(buffer_st-
1930: 3e 74 6d 70 62 75 66 29 3b 0a 0a 09 66 69 6c 65  >tmpbuf);...file
1940: 64 5f 6c 6f 67 5f 6d 73 67 28 22 57 41 49 54 5f  d_log_msg("WAIT_
1950: 46 4f 52 5f 52 45 51 55 45 53 54 20 46 44 3d 2e  FOR_REQUEST FD=.
1960: 2e 2e 22 29 3b 0a 0a 09 66 67 65 74 73 28 62 75  ..");...fgets(bu
1970: 66 66 65 72 2c 20 62 75 66 66 65 72 5f 6c 65 6e  ffer, buffer_len
1980: 2c 20 66 70 29 3b 0a 0a 09 6d 65 74 68 6f 64 20  , fp);...method 
1990: 3d 20 62 75 66 66 65 72 3b 0a 0a 09 62 75 66 66  = buffer;...buff
19a0: 65 72 20 3d 20 73 74 72 63 68 72 28 62 75 66 66  er = strchr(buff
19b0: 65 72 2c 20 27 20 27 29 3b 0a 09 69 66 20 28 62  er, ' ');..if (b
19c0: 75 66 66 65 72 20 3d 3d 20 4e 55 4c 4c 29 20 7b  uffer == NULL) {
19d0: 0a 09 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67  ...filed_log_msg
19e0: 28 22 47 4f 54 5f 52 45 51 55 45 53 54 20 46 44  ("GOT_REQUEST FD
19f0: 3d 2e 2e 2e 20 45 52 52 4f 52 3d 66 6f 72 6d 61  =... ERROR=forma
1a00: 74 22 29 3b 0a 0a 09 09 72 65 74 75 72 6e 28 4e  t");....return(N
1a10: 55 4c 4c 29 3b 0a 09 7d 0a 0a 09 2a 62 75 66 66  ULL);..}...*buff
1a20: 65 72 20 3d 20 27 5c 30 27 3b 0a 09 62 75 66 66  er = '\0';..buff
1a30: 65 72 2b 2b 3b 0a 0a 09 70 61 74 68 20 3d 20 62  er++;...path = b
1a40: 75 66 66 65 72 3b 0a 0a 09 62 75 66 66 65 72 20  uffer;...buffer 
1a50: 3d 20 73 74 72 63 68 72 28 62 75 66 66 65 72 2c  = strchr(buffer,
1a60: 20 27 20 27 29 3b 0a 09 69 66 20 28 62 75 66 66   ' ');..if (buff
1a70: 65 72 20 21 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09  er != NULL) {...
1a80: 2a 62 75 66 66 65 72 20 3d 20 27 5c 30 27 3b 0a  *buffer = '\0';.
1a90: 09 09 62 75 66 66 65 72 2b 2b 3b 0a 09 7d 0a 0a  ..buffer++;..}..
1aa0: 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22  .filed_log_msg("
1ab0: 47 4f 54 5f 52 45 51 55 45 53 54 20 46 44 3d 2e  GOT_REQUEST FD=.
1ac0: 2e 2e 20 50 41 54 48 3d 2e 2e 2e 22 29 3b 0a 0a  .. PATH=...");..
1ad0: 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22  .filed_log_msg("
1ae0: 57 41 49 54 5f 46 4f 52 5f 48 45 41 44 45 52 53  WAIT_FOR_HEADERS
1af0: 20 46 44 3d 2e 2e 2e 22 29 3b 0a 0a 09 66 6f 72   FD=...");...for
1b00: 20 28 69 20 3d 20 30 3b 20 69 20 3c 20 31 30 30   (i = 0; i < 100
1b10: 3b 20 69 2b 2b 29 20 7b 0a 09 09 66 67 65 74 73  ; i++) {...fgets
1b20: 28 74 6d 70 62 75 66 66 65 72 2c 20 74 6d 70 62  (tmpbuffer, tmpb
1b30: 75 66 66 65 72 5f 6c 65 6e 2c 20 66 70 29 3b 0a  uffer_len, fp);.
1b40: 0a 09 09 69 66 20 28 73 74 72 6e 63 61 73 65 63  ...if (strncasec
1b50: 6d 70 28 74 6d 70 62 75 66 66 65 72 2c 20 22 52  mp(tmpbuffer, "R
1b60: 61 6e 67 65 3a 20 22 2c 20 37 29 20 3d 3d 20 30  ange: ", 7) == 0
1b70: 29 20 7b 0a 09 09 09 77 6f 72 6b 62 75 66 66 65  ) {....workbuffe
1b80: 72 20 3d 20 74 6d 70 62 75 66 66 65 72 20 2b 20  r = tmpbuffer + 
1b90: 37 3b 0a 0a 09 09 09 69 66 20 28 73 74 72 6e 63  7;.....if (strnc
1ba0: 61 73 65 63 6d 70 28 77 6f 72 6b 62 75 66 66 65  asecmp(workbuffe
1bb0: 72 2c 20 22 62 79 74 65 73 3d 22 2c 20 36 29 20  r, "bytes=", 6) 
1bc0: 3d 3d 20 30 29 20 7b 0a 09 09 09 09 77 6f 72 6b  == 0) {.....work
1bd0: 62 75 66 66 65 72 20 2b 3d 20 36 3b 0a 0a 09 09  buffer += 6;....
1be0: 09 09 72 61 6e 67 65 5f 72 65 71 75 65 73 74 20  ..range_request 
1bf0: 3d 20 31 3b 0a 0a 09 09 09 09 72 61 6e 67 65 5f  = 1;......range_
1c00: 73 74 61 72 74 20 3d 20 73 74 72 74 6f 75 6c 6c  start = strtoull
1c10: 28 77 6f 72 6b 62 75 66 66 65 72 2c 20 26 77 6f  (workbuffer, &wo
1c20: 72 6b 62 75 66 66 65 72 5f 6e 65 78 74 2c 20 31  rkbuffer_next, 1
1c30: 30 29 3b 0a 0a 09 09 09 09 77 6f 72 6b 62 75 66  0);......workbuf
1c40: 66 65 72 20 3d 20 77 6f 72 6b 62 75 66 66 65 72  fer = workbuffer
1c50: 5f 6e 65 78 74 3b 0a 0a 09 09 09 09 69 66 20 28  _next;......if (
1c60: 2a 77 6f 72 6b 62 75 66 66 65 72 20 3d 3d 20 27  *workbuffer == '
1c70: 2d 27 29 20 7b 0a 09 09 09 09 09 77 6f 72 6b 62  -') {......workb
1c80: 75 66 66 65 72 2b 2b 3b 0a 0a 09 09 09 09 09 69  uffer++;.......i
1c90: 66 20 28 2a 77 6f 72 6b 62 75 66 66 65 72 20 21  f (*workbuffer !
1ca0: 3d 20 27 5c 72 27 20 26 26 20 2a 77 6f 72 6b 62  = '\r' && *workb
1cb0: 75 66 66 65 72 20 21 3d 20 27 5c 6e 27 29 20 7b  uffer != '\n') {
1cc0: 0a 09 09 09 09 09 09 72 61 6e 67 65 5f 65 6e 64  .......range_end
1cd0: 20 3d 20 73 74 72 74 6f 75 6c 6c 28 77 6f 72 6b   = strtoull(work
1ce0: 62 75 66 66 65 72 2c 20 26 77 6f 72 6b 62 75 66  buffer, &workbuf
1cf0: 66 65 72 5f 6e 65 78 74 2c 20 31 30 29 3b 0a 09  fer_next, 10);..
1d00: 09 09 09 09 7d 0a 09 09 09 09 7d 0a 09 09 09 7d  ....}.....}....}
1d10: 0a 09 09 7d 0a 0a 09 09 69 66 20 28 6d 65 6d 63  ...}....if (memc
1d20: 6d 70 28 74 6d 70 62 75 66 66 65 72 2c 20 22 5c  mp(tmpbuffer, "\
1d30: 72 5c 6e 22 2c 20 32 29 20 3d 3d 20 30 29 20 7b  r\n", 2) == 0) {
1d40: 0a 09 09 09 62 72 65 61 6b 3b 0a 09 09 7d 0a 09  ....break;...}..
1d50: 7d 0a 0a 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73  }...filed_log_ms
1d60: 67 28 22 47 4f 54 5f 48 45 41 44 45 52 53 20 46  g("GOT_HEADERS F
1d70: 44 3d 2e 2e 2e 22 29 3b 0a 0a 09 2f 2a 20 57 65  D=...");.../* We
1d80: 20 6f 6e 6c 79 20 68 61 6e 64 6c 65 20 74 68 65   only handle the
1d90: 20 22 47 45 54 22 20 6d 65 74 68 6f 64 20 2a 2f   "GET" method */
1da0: 0a 09 69 66 20 28 73 74 72 63 61 73 65 63 6d 70  ..if (strcasecmp
1db0: 28 6d 65 74 68 6f 64 2c 20 22 67 65 74 22 29 20  (method, "get") 
1dc0: 21 3d 20 30 29 20 7b 0a 09 09 72 65 74 75 72 6e  != 0) {...return
1dd0: 28 4e 55 4c 4c 29 3b 0a 09 7d 0a 0a 09 2f 2a 20  (NULL);..}.../* 
1de0: 44 65 74 65 72 6d 69 6e 65 20 72 61 6e 67 65 20  Determine range 
1df0: 2a 2f 0a 09 69 66 20 28 72 61 6e 67 65 5f 65 6e  */..if (range_en
1e00: 64 20 21 3d 20 30 29 20 7b 0a 09 09 69 66 20 28  d != 0) {...if (
1e10: 72 61 6e 67 65 5f 65 6e 64 20 3c 3d 20 72 61 6e  range_end <= ran
1e20: 67 65 5f 73 74 61 72 74 29 20 7b 0a 09 09 09 72  ge_start) {....r
1e30: 65 74 75 72 6e 28 4e 55 4c 4c 29 3b 0a 09 09 7d  eturn(NULL);...}
1e40: 0a 0a 09 09 72 61 6e 67 65 5f 6c 65 6e 67 74 68  ....range_length
1e50: 20 3d 20 72 61 6e 67 65 5f 65 6e 64 20 2d 20 72   = range_end - r
1e60: 61 6e 67 65 5f 73 74 61 72 74 3b 0a 0a 09 09 66  ange_start;....f
1e70: 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 5f 64 65 62  iled_log_msg_deb
1e80: 75 67 28 22 43 6f 6d 70 75 74 69 6e 67 20 6c 65  ug("Computing le
1e90: 6e 67 74 68 20 70 61 72 61 6d 65 74 65 72 3a 20  ngth parameter: 
1ea0: 25 6c 6c 75 20 3d 20 25 6c 6c 75 20 2d 20 25 6c  %llu = %llu - %l
1eb0: 6c 75 22 2c 0a 09 09 09 28 75 6e 73 69 67 6e 65  lu",....(unsigne
1ec0: 64 20 6c 6f 6e 67 20 6c 6f 6e 67 29 20 72 61 6e  d long long) ran
1ed0: 67 65 5f 6c 65 6e 67 74 68 2c 0a 09 09 09 28 75  ge_length,....(u
1ee0: 6e 73 69 67 6e 65 64 20 6c 6f 6e 67 20 6c 6f 6e  nsigned long lon
1ef0: 67 29 20 72 61 6e 67 65 5f 65 6e 64 2c 0a 09 09  g) range_end,...
1f00: 09 28 75 6e 73 69 67 6e 65 64 20 6c 6f 6e 67 20  .(unsigned long 
1f10: 6c 6f 6e 67 29 20 72 61 6e 67 65 5f 73 74 61 72  long) range_star
1f20: 74 0a 09 09 29 3b 0a 09 7d 0a 0a 09 2f 2a 20 46  t...);..}.../* F
1f30: 69 6c 6c 20 75 70 20 73 74 72 75 63 74 75 72 65  ill up structure
1f40: 20 74 6f 20 72 65 74 75 72 6e 20 2a 2f 0a 09 62   to return */..b
1f50: 75 66 66 65 72 5f 73 74 2d 3e 70 61 74 68 20 20  uffer_st->path  
1f60: 20 3d 20 70 61 74 68 3b 0a 09 62 75 66 66 65 72   = path;..buffer
1f70: 5f 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e  _st->headers.ran
1f80: 67 65 2e 70 72 65 73 65 6e 74 20 3d 20 72 61 6e  ge.present = ran
1f90: 67 65 5f 72 65 71 75 65 73 74 3b 0a 09 62 75 66  ge_request;..buf
1fa0: 66 65 72 5f 73 74 2d 3e 68 65 61 64 65 72 73 2e  fer_st->headers.
1fb0: 72 61 6e 67 65 2e 6f 66 66 73 65 74 20 20 3d 20  range.offset  = 
1fc0: 72 61 6e 67 65 5f 73 74 61 72 74 3b 0a 09 62 75  range_start;..bu
1fd0: 66 66 65 72 5f 73 74 2d 3e 68 65 61 64 65 72 73  ffer_st->headers
1fe0: 2e 72 61 6e 67 65 2e 6c 65 6e 67 74 68 20 20 3d  .range.length  =
1ff0: 20 72 61 6e 67 65 5f 6c 65 6e 67 74 68 3b 0a 0a   range_length;..
2000: 09 72 65 74 75 72 6e 28 62 75 66 66 65 72 5f 73  .return(buffer_s
2010: 74 29 3b 0a 7d 0a 0a 2f 2a 20 52 65 74 75 72 6e  t);.}../* Return
2020: 20 61 6e 20 65 72 72 6f 72 20 70 61 67 65 20 2a   an error page *
2030: 2f 0a 73 74 61 74 69 63 20 76 6f 69 64 20 66 69  /.static void fi
2040: 6c 65 64 5f 65 72 72 6f 72 5f 70 61 67 65 28 46  led_error_page(F
2050: 49 4c 45 20 2a 66 70 2c 20 63 6f 6e 73 74 20 63  ILE *fp, const c
2060: 68 61 72 20 2a 64 61 74 65 5f 63 75 72 72 65 6e  har *date_curren
2070: 74 2c 20 69 6e 74 20 65 72 72 6f 72 5f 6e 75 6d  t, int error_num
2080: 62 65 72 29 20 7b 0a 09 63 68 61 72 20 2a 65 72  ber) {..char *er
2090: 72 6f 72 5f 73 74 72 69 6e 67 20 3d 20 22 3c 68  ror_string = "<h
20a0: 74 6d 6c 3e 3c 68 65 61 64 3e 3c 74 69 74 6c 65  tml><head><title
20b0: 3e 45 52 52 4f 52 3c 2f 74 69 74 6c 65 3e 3c 2f  >ERROR</title></
20c0: 68 65 61 64 3e 3c 62 6f 64 79 3e 55 6e 61 62 6c  head><body>Unabl
20d0: 65 20 74 6f 20 70 72 6f 63 65 73 73 20 72 65 71  e to process req
20e0: 75 65 73 74 3c 2f 62 6f 64 79 3e 3c 2f 68 74 6d  uest</body></htm
20f0: 6c 3e 22 3b 0a 0a 09 66 70 72 69 6e 74 66 28 66  l>";...fprintf(f
2100: 70 2c 20 22 48 54 54 50 2f 31 2e 31 20 25 69 20  p, "HTTP/1.1 %i 
2110: 4f 4b 5c 72 5c 6e 44 61 74 65 3a 20 25 73 5c 72  OK\r\nDate: %s\r
2120: 5c 6e 53 65 72 76 65 72 3a 20 66 69 6c 65 64 5c  \nServer: filed\
2130: 72 5c 6e 4c 61 73 74 2d 4d 6f 64 69 66 69 65 64  r\nLast-Modified
2140: 3a 20 25 73 5c 72 5c 6e 43 6f 6e 74 65 6e 74 2d  : %s\r\nContent-
2150: 4c 65 6e 67 74 68 3a 20 25 6c 6c 75 5c 72 5c 6e  Length: %llu\r\n
2160: 43 6f 6e 74 65 6e 74 2d 54 79 70 65 3a 20 25 73  Content-Type: %s
2170: 5c 72 5c 6e 43 6f 6e 6e 65 63 74 69 6f 6e 3a 20  \r\nConnection: 
2180: 63 6c 6f 73 65 5c 72 5c 6e 5c 72 5c 6e 25 73 22  close\r\n\r\n%s"
2190: 2c 0a 09 09 65 72 72 6f 72 5f 6e 75 6d 62 65 72  ,...error_number
21a0: 2c 0a 09 09 64 61 74 65 5f 63 75 72 72 65 6e 74  ,...date_current
21b0: 2c 0a 09 09 64 61 74 65 5f 63 75 72 72 65 6e 74  ,...date_current
21c0: 2c 0a 09 09 28 75 6e 73 69 67 6e 65 64 20 6c 6f  ,...(unsigned lo
21d0: 6e 67 20 6c 6f 6e 67 29 20 73 74 72 6c 65 6e 28  ng long) strlen(
21e0: 65 72 72 6f 72 5f 73 74 72 69 6e 67 29 2c 0a 09  error_string),..
21f0: 09 22 74 65 78 74 2f 68 74 6d 6c 22 2c 0a 09 09  ."text/html",...
2200: 65 72 72 6f 72 5f 73 74 72 69 6e 67 0a 09 29 3b  error_string..);
2210: 0a 7d 0a 0a 2f 2a 20 48 61 6e 64 6c 65 20 61 20  .}../* Handle a 
2220: 73 69 6e 67 6c 65 20 72 65 71 75 65 73 74 20 66  single request f
2230: 72 6f 6d 20 61 20 63 6c 69 65 6e 74 20 2a 2f 0a  rom a client */.
2240: 73 74 61 74 69 63 20 76 6f 69 64 20 66 69 6c 65  static void file
2250: 64 5f 68 61 6e 64 6c 65 5f 63 6c 69 65 6e 74 28  d_handle_client(
2260: 69 6e 74 20 66 64 2c 20 73 74 72 75 63 74 20 66  int fd, struct f
2270: 69 6c 65 64 5f 68 74 74 70 5f 72 65 71 75 65 73  iled_http_reques
2280: 74 20 2a 72 65 71 75 65 73 74 29 20 7b 0a 09 73  t *request) {..s
2290: 74 72 75 63 74 20 66 69 6c 65 64 5f 66 69 6c 65  truct filed_file
22a0: 69 6e 66 6f 20 2a 66 69 6c 65 69 6e 66 6f 3b 0a  info *fileinfo;.
22b0: 09 73 73 69 7a 65 5f 74 20 73 65 6e 64 66 69 6c  .ssize_t sendfil
22c0: 65 5f 72 65 74 3b 0a 09 73 69 7a 65 5f 74 20 73  e_ret;..size_t s
22d0: 65 6e 64 66 69 6c 65 5f 6c 65 6e 2c 20 73 65 6e  endfile_len, sen
22e0: 64 66 69 6c 65 5f 73 65 6e 74 2c 20 73 65 6e 64  dfile_sent, send
22f0: 66 69 6c 65 5f 73 69 7a 65 3b 0a 09 6f 66 66 5f  file_size;..off_
2300: 74 20 73 65 6e 64 66 69 6c 65 5f 6f 66 66 73 65  t sendfile_offse
2310: 74 3b 0a 09 63 68 61 72 20 2a 70 61 74 68 3b 0a  t;..char *path;.
2320: 09 63 68 61 72 20 2a 64 61 74 65 5f 63 75 72 72  .char *date_curr
2330: 65 6e 74 2c 20 64 61 74 65 5f 63 75 72 72 65 6e  ent, date_curren
2340: 74 5f 62 5b 36 34 5d 3b 0a 09 69 6e 74 20 68 74  t_b[64];..int ht
2350: 74 70 5f 63 6f 64 65 3b 0a 09 46 49 4c 45 20 2a  tp_code;..FILE *
2360: 66 70 3b 0a 0a 09 2f 2a 20 44 65 74 65 72 6d 69  fp;.../* Determi
2370: 6e 65 20 63 75 72 72 65 6e 74 20 74 69 6d 65 20  ne current time 
2380: 2a 2f 0a 09 64 61 74 65 5f 63 75 72 72 65 6e 74  */..date_current
2390: 20 3d 20 66 69 6c 65 64 5f 66 6f 72 6d 61 74 5f   = filed_format_
23a0: 74 69 6d 65 28 64 61 74 65 5f 63 75 72 72 65 6e  time(date_curren
23b0: 74 5f 62 2c 20 73 69 7a 65 6f 66 28 64 61 74 65  t_b, sizeof(date
23c0: 5f 63 75 72 72 65 6e 74 5f 62 29 2c 20 74 69 6d  _current_b), tim
23d0: 65 28 4e 55 4c 4c 29 29 3b 0a 0a 09 2f 2a 20 4f  e(NULL));.../* O
23e0: 70 65 6e 20 73 6f 63 6b 65 74 20 61 73 20 41 4e  pen socket as AN
23f0: 53 49 20 49 2f 4f 20 66 6f 72 20 65 61 73 65 20  SI I/O for ease 
2400: 6f 66 20 75 73 65 20 2a 2f 0a 09 66 70 20 3d 20  of use */..fp = 
2410: 66 64 6f 70 65 6e 28 66 64 2c 20 22 77 2b 62 22  fdopen(fd, "w+b"
2420: 29 3b 0a 09 69 66 20 28 66 70 20 3d 3d 20 4e 55  );..if (fp == NU
2430: 4c 4c 29 20 7b 0a 09 09 63 6c 6f 73 65 28 66 64  LL) {...close(fd
2440: 29 3b 0a 0a 09 09 72 65 74 75 72 6e 3b 0a 09 7d  );....return;..}
2450: 0a 0a 09 72 65 71 75 65 73 74 20 3d 20 66 69 6c  ...request = fil
2460: 65 64 5f 67 65 74 5f 68 74 74 70 5f 72 65 71 75  ed_get_http_requ
2470: 65 73 74 28 66 70 2c 20 72 65 71 75 65 73 74 29  est(fp, request)
2480: 3b 0a 0a 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73  ;...filed_log_ms
2490: 67 28 22 50 52 4f 43 45 53 53 5f 52 45 50 4c 59  g("PROCESS_REPLY
24a0: 5f 53 54 41 52 54 20 46 44 3d 2e 2e 2e 20 50 41  _START FD=... PA
24b0: 54 48 3d 2e 2e 2e 20 52 41 4e 47 45 5f 53 54 41  TH=... RANGE_STA
24c0: 52 54 3d 2e 2e 2e 20 52 41 4e 47 45 5f 4c 45 4e  RT=... RANGE_LEN
24d0: 47 54 48 3d 2e 2e 2e 22 29 3b 0a 0a 09 69 66 20  GTH=...");...if 
24e0: 28 72 65 71 75 65 73 74 20 3d 3d 20 4e 55 4c 4c  (request == NULL
24f0: 20 7c 7c 20 72 65 71 75 65 73 74 2d 3e 70 61 74   || request->pat
2500: 68 20 3d 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09 66  h == NULL) {...f
2510: 69 6c 65 64 5f 65 72 72 6f 72 5f 70 61 67 65 28  iled_error_page(
2520: 66 70 2c 20 64 61 74 65 5f 63 75 72 72 65 6e 74  fp, date_current
2530: 2c 20 35 30 30 29 3b 0a 0a 09 09 66 69 6c 65 64  , 500);....filed
2540: 5f 6c 6f 67 5f 6d 73 67 28 22 50 52 4f 43 45 53  _log_msg("PROCES
2550: 53 5f 52 45 50 4c 59 5f 43 4f 4d 50 4c 45 54 45  S_REPLY_COMPLETE
2560: 20 46 44 3d 2e 2e 2e 20 45 52 52 4f 52 3d 35 30   FD=... ERROR=50
2570: 30 22 29 3b 0a 0a 09 09 66 63 6c 6f 73 65 28 66  0");....fclose(f
2580: 70 29 3b 0a 0a 09 09 72 65 74 75 72 6e 3b 0a 09  p);....return;..
2590: 7d 0a 0a 09 70 61 74 68 20 3d 20 72 65 71 75 65  }...path = reque
25a0: 73 74 2d 3e 70 61 74 68 3b 0a 0a 09 68 74 74 70  st->path;...http
25b0: 5f 63 6f 64 65 20 3d 20 2d 31 3b 0a 0a 09 66 69  _code = -1;...fi
25c0: 6c 65 69 6e 66 6f 20 3d 20 66 69 6c 65 64 5f 6f  leinfo = filed_o
25d0: 70 65 6e 5f 66 69 6c 65 28 70 61 74 68 2c 20 26  pen_file(path, &
25e0: 72 65 71 75 65 73 74 2d 3e 66 69 6c 65 69 6e 66  request->fileinf
25f0: 6f 29 3b 0a 09 69 66 20 28 66 69 6c 65 69 6e 66  o);..if (fileinf
2600: 6f 20 3d 3d 20 4e 55 4c 4c 29 20 7b 0a 09 09 66  o == NULL) {...f
2610: 69 6c 65 64 5f 65 72 72 6f 72 5f 70 61 67 65 28  iled_error_page(
2620: 66 70 2c 20 64 61 74 65 5f 63 75 72 72 65 6e 74  fp, date_current
2630: 2c 20 34 30 34 29 3b 0a 0a 09 09 66 69 6c 65 64  , 404);....filed
2640: 5f 6c 6f 67 5f 6d 73 67 28 22 50 52 4f 43 45 53  _log_msg("PROCES
2650: 53 5f 52 45 50 4c 59 5f 43 4f 4d 50 4c 45 54 45  S_REPLY_COMPLETE
2660: 20 46 44 3d 2e 2e 2e 20 45 52 52 4f 52 3d 34 30   FD=... ERROR=40
2670: 34 22 29 3b 0a 09 7d 20 65 6c 73 65 20 7b 0a 09  4");..} else {..
2680: 09 69 66 20 28 72 65 71 75 65 73 74 2d 3e 68 65  .if (request->he
2690: 61 64 65 72 73 2e 72 61 6e 67 65 2e 6f 66 66 73  aders.range.offs
26a0: 65 74 20 21 3d 20 30 20 7c 7c 20 72 65 71 75 65  et != 0 || reque
26b0: 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e 67  st->headers.rang
26c0: 65 2e 6c 65 6e 67 74 68 20 3e 3d 20 30 29 20 7b  e.length >= 0) {
26d0: 0a 09 09 09 69 66 20 28 28 73 69 7a 65 5f 74 29  ....if ((size_t)
26e0: 20 72 65 71 75 65 73 74 2d 3e 68 65 61 64 65 72   request->header
26f0: 73 2e 72 61 6e 67 65 2e 6f 66 66 73 65 74 20 3e  s.range.offset >
2700: 3d 20 66 69 6c 65 69 6e 66 6f 2d 3e 6c 65 6e 29  = fileinfo->len)
2710: 20 7b 0a 09 09 09 09 66 69 6c 65 64 5f 6c 6f 67   {.....filed_log
2720: 5f 6d 73 67 28 22 50 52 4f 43 45 53 53 5f 52 45  _msg("PROCESS_RE
2730: 50 4c 59 5f 43 4f 4d 50 4c 45 54 45 20 46 44 3d  PLY_COMPLETE FD=
2740: 2e 2e 2e 20 45 52 52 4f 52 3d 34 31 36 22 29 3b  ... ERROR=416");
2750: 0a 0a 09 09 09 09 66 69 6c 65 64 5f 65 72 72 6f  ......filed_erro
2760: 72 5f 70 61 67 65 28 66 70 2c 20 64 61 74 65 5f  r_page(fp, date_
2770: 63 75 72 72 65 6e 74 2c 20 34 31 36 29 3b 0a 09  current, 416);..
2780: 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 69  ..} else {.....i
2790: 66 20 28 72 65 71 75 65 73 74 2d 3e 68 65 61 64  f (request->head
27a0: 65 72 73 2e 72 61 6e 67 65 2e 6c 65 6e 67 74 68  ers.range.length
27b0: 20 3c 20 30 29 20 7b 0a 09 09 09 09 09 66 69 6c   < 0) {......fil
27c0: 65 64 5f 6c 6f 67 5f 6d 73 67 5f 64 65 62 75 67  ed_log_msg_debug
27d0: 28 22 43 6f 6d 70 75 74 69 6e 67 20 6c 65 6e 67  ("Computing leng
27e0: 74 68 20 74 6f 20 66 69 74 20 69 6e 20 62 6f 75  th to fit in bou
27f0: 6e 64 73 3a 20 66 69 6c 65 69 6e 66 6f 2d 3e 6c  nds: fileinfo->l
2800: 65 6e 20 3d 20 25 6c 6c 75 2c 20 72 65 71 75 65  en = %llu, reque
2810: 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e 67  st->headers.rang
2820: 65 2e 6f 66 66 73 65 74 20 3d 20 25 6c 6c 75 22  e.offset = %llu"
2830: 2c 0a 09 09 09 09 09 09 28 75 6e 73 69 67 6e 65  ,.......(unsigne
2840: 64 20 6c 6f 6e 67 20 6c 6f 6e 67 29 20 66 69 6c  d long long) fil
2850: 65 69 6e 66 6f 2d 3e 6c 65 6e 2c 0a 09 09 09 09  einfo->len,.....
2860: 09 09 28 75 6e 73 69 67 6e 65 64 20 6c 6f 6e 67  ..(unsigned long
2870: 20 6c 6f 6e 67 29 20 72 65 71 75 65 73 74 2d 3e   long) request->
2880: 68 65 61 64 65 72 73 2e 72 61 6e 67 65 2e 6f 66  headers.range.of
2890: 66 73 65 74 0a 09 09 09 09 09 29 3b 0a 0a 09 09  fset......);....
28a0: 09 09 09 72 65 71 75 65 73 74 2d 3e 68 65 61 64  ...request->head
28b0: 65 72 73 2e 72 61 6e 67 65 2e 6c 65 6e 67 74 68  ers.range.length
28c0: 20 3d 20 66 69 6c 65 69 6e 66 6f 2d 3e 6c 65 6e   = fileinfo->len
28d0: 20 2d 20 72 65 71 75 65 73 74 2d 3e 68 65 61 64   - request->head
28e0: 65 72 73 2e 72 61 6e 67 65 2e 6f 66 66 73 65 74  ers.range.offset
28f0: 3b 0a 09 09 09 09 7d 0a 0a 09 09 09 09 66 69 6c  ;.....}......fil
2900: 65 64 5f 6c 6f 67 5f 6d 73 67 5f 64 65 62 75 67  ed_log_msg_debug
2910: 28 22 50 61 72 74 69 61 6c 20 72 65 71 75 65 73  ("Partial reques
2920: 74 2c 20 73 74 61 72 74 69 6e 67 20 61 74 3a 20  t, starting at: 
2930: 25 6c 6c 75 20 61 6e 64 20 72 75 6e 6e 69 6e 67  %llu and running
2940: 20 66 6f 72 20 25 6c 6c 75 20 62 79 74 65 73 22   for %llu bytes"
2950: 2c 20 28 75 6e 73 69 67 6e 65 64 20 6c 6f 6e 67  , (unsigned long
2960: 20 6c 6f 6e 67 29 20 72 65 71 75 65 73 74 2d 3e   long) request->
2970: 68 65 61 64 65 72 73 2e 72 61 6e 67 65 2e 6f 66  headers.range.of
2980: 66 73 65 74 2c 20 28 75 6e 73 69 67 6e 65 64 20  fset, (unsigned 
2990: 6c 6f 6e 67 20 6c 6f 6e 67 29 20 72 65 71 75 65  long long) reque
29a0: 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e 67  st->headers.rang
29b0: 65 2e 6c 65 6e 67 74 68 29 3b 0a 0a 09 09 09 09  e.length);......
29c0: 68 74 74 70 5f 63 6f 64 65 20 3d 20 32 30 36 3b  http_code = 206;
29d0: 0a 09 09 09 7d 0a 09 09 7d 20 65 6c 73 65 20 7b  ....}...} else {
29e0: 0a 09 09 09 69 66 20 28 72 65 71 75 65 73 74 2d  ....if (request-
29f0: 3e 68 65 61 64 65 72 73 2e 72 61 6e 67 65 2e 70  >headers.range.p
2a00: 72 65 73 65 6e 74 29 20 7b 0a 09 09 09 09 68 74  resent) {.....ht
2a10: 74 70 5f 63 6f 64 65 20 3d 20 32 30 36 3b 0a 09  tp_code = 206;..
2a20: 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09 09 68  ..} else {.....h
2a30: 74 74 70 5f 63 6f 64 65 20 3d 20 32 30 30 3b 0a  ttp_code = 200;.
2a40: 09 09 09 7d 0a 09 09 09 72 65 71 75 65 73 74 2d  ...}....request-
2a50: 3e 68 65 61 64 65 72 73 2e 72 61 6e 67 65 2e 6f  >headers.range.o
2a60: 66 66 73 65 74 20 3d 20 30 3b 0a 09 09 09 72 65  ffset = 0;....re
2a70: 71 75 65 73 74 2d 3e 68 65 61 64 65 72 73 2e 72  quest->headers.r
2a80: 61 6e 67 65 2e 6c 65 6e 67 74 68 20 3d 20 66 69  ange.length = fi
2a90: 6c 65 69 6e 66 6f 2d 3e 6c 65 6e 3b 0a 09 09 7d  leinfo->len;...}
2aa0: 0a 0a 09 09 69 66 20 28 68 74 74 70 5f 63 6f 64  ....if (http_cod
2ab0: 65 20 3e 20 30 29 20 7b 0a 09 09 09 66 70 72 69  e > 0) {....fpri
2ac0: 6e 74 66 28 66 70 2c 20 22 48 54 54 50 2f 31 2e  ntf(fp, "HTTP/1.
2ad0: 31 20 25 69 20 4f 4b 5c 72 5c 6e 44 61 74 65 3a  1 %i OK\r\nDate:
2ae0: 20 25 73 5c 72 5c 6e 53 65 72 76 65 72 3a 20 66   %s\r\nServer: f
2af0: 69 6c 65 64 5c 72 5c 6e 4c 61 73 74 2d 4d 6f 64  iled\r\nLast-Mod
2b00: 69 66 69 65 64 3a 20 25 73 5c 72 5c 6e 43 6f 6e  ified: %s\r\nCon
2b10: 74 65 6e 74 2d 4c 65 6e 67 74 68 3a 20 25 6c 6c  tent-Length: %ll
2b20: 75 5c 72 5c 6e 41 63 63 65 70 74 2d 52 61 6e 67  u\r\nAccept-Rang
2b30: 65 73 3a 20 62 79 74 65 73 5c 72 5c 6e 43 6f 6e  es: bytes\r\nCon
2b40: 74 65 6e 74 2d 54 79 70 65 3a 20 25 73 5c 72 5c  tent-Type: %s\r\
2b50: 6e 43 6f 6e 6e 65 63 74 69 6f 6e 3a 20 63 6c 6f  nConnection: clo
2b60: 73 65 5c 72 5c 6e 22 2c 0a 09 09 09 09 68 74 74  se\r\n",.....htt
2b70: 70 5f 63 6f 64 65 2c 0a 09 09 09 09 64 61 74 65  p_code,.....date
2b80: 5f 63 75 72 72 65 6e 74 2c 0a 09 09 09 09 66 69  _current,.....fi
2b90: 6c 65 69 6e 66 6f 2d 3e 6c 61 73 74 6d 6f 64 2c  leinfo->lastmod,
2ba0: 0a 09 09 09 09 28 75 6e 73 69 67 6e 65 64 20 6c  .....(unsigned l
2bb0: 6f 6e 67 20 6c 6f 6e 67 29 20 72 65 71 75 65 73  ong long) reques
2bc0: 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e 67 65  t->headers.range
2bd0: 2e 6c 65 6e 67 74 68 2c 0a 09 09 09 09 66 69 6c  .length,.....fil
2be0: 65 69 6e 66 6f 2d 3e 74 79 70 65 0a 09 09 09 29  einfo->type....)
2bf0: 3b 0a 09 09 09 69 66 20 28 68 74 74 70 5f 63 6f  ;....if (http_co
2c00: 64 65 20 3d 3d 20 32 30 36 29 20 7b 0a 09 09 09  de == 206) {....
2c10: 09 66 70 72 69 6e 74 66 28 66 70 2c 20 22 43 6f  .fprintf(fp, "Co
2c20: 6e 74 65 6e 74 2d 52 61 6e 67 65 3a 20 62 79 74  ntent-Range: byt
2c30: 65 73 20 25 6c 6c 75 2d 25 6c 6c 75 2f 25 6c 6c  es %llu-%llu/%ll
2c40: 75 5c 72 5c 6e 22 2c 0a 09 09 09 09 09 28 75 6e  u\r\n",......(un
2c50: 73 69 67 6e 65 64 20 6c 6f 6e 67 20 6c 6f 6e 67  signed long long
2c60: 29 20 72 65 71 75 65 73 74 2d 3e 68 65 61 64 65  ) request->heade
2c70: 72 73 2e 72 61 6e 67 65 2e 6f 66 66 73 65 74 2c  rs.range.offset,
2c80: 0a 09 09 09 09 09 28 75 6e 73 69 67 6e 65 64 20  ......(unsigned 
2c90: 6c 6f 6e 67 20 6c 6f 6e 67 29 20 28 72 65 71 75  long long) (requ
2ca0: 65 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e  est->headers.ran
2cb0: 67 65 2e 6f 66 66 73 65 74 20 2b 20 72 65 71 75  ge.offset + requ
2cc0: 65 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e  est->headers.ran
2cd0: 67 65 2e 6c 65 6e 67 74 68 20 2d 20 31 29 2c 0a  ge.length - 1),.
2ce0: 09 09 09 09 09 28 75 6e 73 69 67 6e 65 64 20 6c  .....(unsigned l
2cf0: 6f 6e 67 20 6c 6f 6e 67 29 20 66 69 6c 65 69 6e  ong long) filein
2d00: 66 6f 2d 3e 6c 65 6e 0a 09 09 09 09 29 3b 0a 09  fo->len.....);..
2d10: 09 09 7d 0a 09 09 09 66 70 72 69 6e 74 66 28 66  ..}....fprintf(f
2d20: 70 2c 20 22 5c 72 5c 6e 22 29 3b 0a 09 09 09 66  p, "\r\n");....f
2d30: 66 6c 75 73 68 28 66 70 29 3b 0a 0a 09 09 09 66  flush(fp);.....f
2d40: 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22 50 52  iled_log_msg("PR
2d50: 4f 43 45 53 53 5f 52 45 50 4c 59 5f 43 4f 4d 50  OCESS_REPLY_COMP
2d60: 4c 45 54 45 20 46 44 3d 2e 2e 2e 20 53 54 41 54  LETE FD=... STAT
2d70: 55 53 3d 32 30 58 22 29 3b 0a 0a 23 69 66 64 65  US=20X");..#ifde
2d80: 66 20 46 49 4c 45 44 5f 4e 4f 4e 42 4c 4f 43 4b  f FILED_NONBLOCK
2d90: 5f 48 54 54 50 0a 09 09 09 69 6e 74 20 73 6f 63  _HTTP....int soc
2da0: 6b 65 74 5f 66 6c 61 67 73 3b 0a 09 09 09 66 64  ket_flags;....fd
2db0: 5f 73 65 74 20 72 66 64 2c 20 77 66 64 3b 0a 09  _set rfd, wfd;..
2dc0: 09 09 63 68 61 72 20 73 69 6e 6b 62 75 66 5b 38  ..char sinkbuf[8
2dd0: 31 39 32 5d 3b 0a 09 09 09 73 73 69 7a 65 5f 74  192];....ssize_t
2de0: 20 72 65 61 64 5f 72 65 74 3b 0a 0a 09 09 09 46   read_ret;.....F
2df0: 44 5f 5a 45 52 4f 28 26 72 66 64 29 3b 0a 09 09  D_ZERO(&rfd);...
2e00: 09 46 44 5f 5a 45 52 4f 28 26 77 66 64 29 3b 0a  .FD_ZERO(&wfd);.
2e10: 09 09 09 46 44 5f 53 45 54 28 66 64 2c 20 26 72  ...FD_SET(fd, &r
2e20: 66 64 29 3b 0a 09 09 09 46 44 5f 53 45 54 28 66  fd);....FD_SET(f
2e30: 64 2c 20 26 77 66 64 29 3b 0a 0a 09 09 09 73 6f  d, &wfd);.....so
2e40: 63 6b 65 74 5f 66 6c 61 67 73 20 3d 20 66 63 6e  cket_flags = fcn
2e50: 74 6c 28 66 64 2c 20 46 5f 47 45 54 46 4c 29 3b  tl(fd, F_GETFL);
2e60: 0a 09 09 09 66 63 6e 74 6c 28 66 64 2c 20 46 5f  ....fcntl(fd, F_
2e70: 53 45 54 46 4c 2c 20 73 6f 63 6b 65 74 5f 66 6c  SETFL, socket_fl
2e80: 61 67 73 20 7c 20 4f 5f 4e 4f 4e 42 4c 4f 43 4b  ags | O_NONBLOCK
2e90: 29 3b 0a 23 65 6e 64 69 66 0a 0a 09 09 09 66 69  );.#endif.....fi
2ea0: 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22 53 45 4e  led_log_msg("SEN
2eb0: 44 5f 53 54 41 52 54 20 49 46 44 3d 2e 2e 2e 20  D_START IFD=... 
2ec0: 4f 46 44 3d 2e 2e 2e 20 42 59 54 45 53 3d 2e 2e  OFD=... BYTES=..
2ed0: 2e 22 29 3b 0a 0a 09 09 09 73 65 6e 64 66 69 6c  .");.....sendfil
2ee0: 65 5f 6f 66 66 73 65 74 20 3d 20 72 65 71 75 65  e_offset = reque
2ef0: 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e 67  st->headers.rang
2f00: 65 2e 6f 66 66 73 65 74 3b 0a 09 09 09 73 65 6e  e.offset;....sen
2f10: 64 66 69 6c 65 5f 6c 65 6e 20 3d 20 72 65 71 75  dfile_len = requ
2f20: 65 73 74 2d 3e 68 65 61 64 65 72 73 2e 72 61 6e  est->headers.ran
2f30: 67 65 2e 6c 65 6e 67 74 68 3b 0a 09 09 09 73 65  ge.length;....se
2f40: 6e 64 66 69 6c 65 5f 73 65 6e 74 20 3d 20 30 3b  ndfile_sent = 0;
2f50: 0a 09 09 09 77 68 69 6c 65 20 28 31 29 20 7b 0a  ....while (1) {.
2f60: 09 09 09 09 69 66 20 28 73 65 6e 64 66 69 6c 65  ....if (sendfile
2f70: 5f 6c 65 6e 20 3e 20 46 49 4c 45 44 5f 53 45 4e  _len > FILED_SEN
2f80: 44 46 49 4c 45 5f 4d 41 58 29 20 7b 0a 09 09 09  DFILE_MAX) {....
2f90: 09 09 73 65 6e 64 66 69 6c 65 5f 73 69 7a 65 20  ..sendfile_size 
2fa0: 3d 20 46 49 4c 45 44 5f 53 45 4e 44 46 49 4c 45  = FILED_SENDFILE
2fb0: 5f 4d 41 58 3b 0a 09 09 09 09 7d 20 65 6c 73 65  _MAX;.....} else
2fc0: 20 7b 0a 09 09 09 09 09 73 65 6e 64 66 69 6c 65   {......sendfile
2fd0: 5f 73 69 7a 65 20 3d 20 73 65 6e 64 66 69 6c 65  _size = sendfile
2fe0: 5f 6c 65 6e 3b 0a 09 09 09 09 7d 0a 0a 09 09 09  _len;.....}.....
2ff0: 09 73 65 6e 64 66 69 6c 65 5f 72 65 74 20 3d 20  .sendfile_ret = 
3000: 73 65 6e 64 66 69 6c 65 28 66 64 2c 20 66 69 6c  sendfile(fd, fil
3010: 65 69 6e 66 6f 2d 3e 66 64 2c 20 26 73 65 6e 64  einfo->fd, &send
3020: 66 69 6c 65 5f 6f 66 66 73 65 74 2c 20 73 65 6e  file_offset, sen
3030: 64 66 69 6c 65 5f 73 69 7a 65 29 3b 0a 09 09 09  dfile_size);....
3040: 09 69 66 20 28 73 65 6e 64 66 69 6c 65 5f 72 65  .if (sendfile_re
3050: 74 20 3c 3d 20 30 29 20 7b 0a 23 69 66 64 65 66  t <= 0) {.#ifdef
3060: 20 46 49 4c 45 44 5f 4e 4f 4e 42 4c 4f 43 4b 5f   FILED_NONBLOCK_
3070: 48 54 54 50 0a 09 09 09 09 09 69 66 20 28 65 72  HTTP......if (er
3080: 72 6e 6f 20 3d 3d 20 45 41 47 41 49 4e 29 20 7b  rno == EAGAIN) {
3090: 0a 09 09 09 09 09 09 73 65 6e 64 66 69 6c 65 5f  .......sendfile_
30a0: 72 65 74 20 3d 20 30 3b 0a 0a 09 09 09 09 09 09  ret = 0;........
30b0: 77 68 69 6c 65 20 28 31 29 20 7b 0a 09 09 09 09  while (1) {.....
30c0: 09 09 09 73 65 6c 65 63 74 28 66 64 20 2b 20 31  ...select(fd + 1
30d0: 2c 20 26 72 66 64 2c 20 26 77 66 64 2c 20 4e 55  , &rfd, &wfd, NU
30e0: 4c 4c 2c 20 4e 55 4c 4c 29 3b 0a 09 09 09 09 09  LL, NULL);......
30f0: 09 09 69 66 20 28 46 44 5f 49 53 53 45 54 28 66  ..if (FD_ISSET(f
3100: 64 2c 20 26 72 66 64 29 29 20 7b 0a 09 09 09 09  d, &rfd)) {.....
3110: 09 09 09 09 72 65 61 64 5f 72 65 74 20 3d 20 72  ....read_ret = r
3120: 65 61 64 28 66 64 2c 20 73 69 6e 6b 62 75 66 2c  ead(fd, sinkbuf,
3130: 20 73 69 7a 65 6f 66 28 73 69 6e 6b 62 75 66 29   sizeof(sinkbuf)
3140: 29 3b 0a 0a 09 09 09 09 09 09 09 09 69 66 20 28  );..........if (
3150: 72 65 61 64 5f 72 65 74 20 3c 3d 20 30 29 20 7b  read_ret <= 0) {
3160: 0a 09 09 09 09 09 09 09 09 09 62 72 65 61 6b 3b  ..........break;
3170: 0a 09 09 09 09 09 09 09 09 7d 0a 09 09 09 09 09  .........}......
3180: 09 09 7d 0a 0a 09 09 09 09 09 09 09 69 66 20 28  ..}.........if (
3190: 46 44 5f 49 53 53 45 54 28 66 64 2c 20 26 77 66  FD_ISSET(fd, &wf
31a0: 64 29 29 20 7b 0a 09 09 09 09 09 09 09 09 72 65  d)) {.........re
31b0: 61 64 5f 72 65 74 20 3d 20 31 3b 0a 0a 09 09 09  ad_ret = 1;.....
31c0: 09 09 09 09 09 62 72 65 61 6b 3b 0a 09 09 09 09  .....break;.....
31d0: 09 09 09 7d 0a 09 09 09 09 09 09 7d 0a 0a 09 09  ...}.......}....
31e0: 09 09 09 09 69 66 20 28 72 65 61 64 5f 72 65 74  ....if (read_ret
31f0: 20 3c 3d 20 30 29 20 7b 0a 09 09 09 09 09 09 09   <= 0) {........
3200: 62 72 65 61 6b 3b 0a 09 09 09 09 09 09 7d 0a 09  break;.......}..
3210: 09 09 09 09 7d 20 65 6c 73 65 20 7b 0a 09 09 09  ....} else {....
3220: 09 09 09 62 72 65 61 6b 3b 0a 09 09 09 09 09 7d  ...break;......}
3230: 0a 23 65 6c 73 65 0a 09 09 09 09 09 62 72 65 61  .#else......brea
3240: 6b 3b 0a 23 65 6e 64 69 66 0a 09 09 09 09 7d 0a  k;.#endif.....}.
3250: 0a 09 09 09 09 73 65 6e 64 66 69 6c 65 5f 6c 65  .....sendfile_le
3260: 6e 20 2d 3d 20 73 65 6e 64 66 69 6c 65 5f 72 65  n -= sendfile_re
3270: 74 3b 0a 09 09 09 09 73 65 6e 64 66 69 6c 65 5f  t;.....sendfile_
3280: 73 65 6e 74 20 2b 3d 20 73 65 6e 64 66 69 6c 65  sent += sendfile
3290: 5f 72 65 74 3b 0a 09 09 09 09 69 66 20 28 73 65  _ret;.....if (se
32a0: 6e 64 66 69 6c 65 5f 6c 65 6e 20 3d 3d 20 30 29  ndfile_len == 0)
32b0: 20 7b 0a 09 09 09 09 09 62 72 65 61 6b 3b 0a 09   {......break;..
32c0: 09 09 09 7d 0a 09 09 09 7d 0a 0a 09 09 09 66 69  ...}....}.....fi
32d0: 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22 53 45 4e  led_log_msg("SEN
32e0: 44 5f 43 4f 4d 50 4c 45 54 45 20 53 54 41 54 55  D_COMPLETE STATU
32f0: 53 3d 2e 2e 2e 20 49 46 44 3d 2e 2e 2e 20 4f 46  S=... IFD=... OF
3300: 44 3d 2e 2e 2e 20 42 59 54 45 53 3d 2e 2e 2e 20  D=... BYTES=... 
3310: 42 59 54 45 53 5f 53 45 4e 54 3d 2e 2e 2e 22 29  BYTES_SENT=...")
3320: 3b 0a 09 09 7d 0a 0a 09 09 63 6c 6f 73 65 28 66  ;...}....close(f
3330: 69 6c 65 69 6e 66 6f 2d 3e 66 64 29 3b 0a 0a 09  ileinfo->fd);...
3340: 09 66 69 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22  .filed_log_msg("
3350: 43 4c 4f 53 45 5f 46 49 4c 45 20 46 44 3d 2e 2e  CLOSE_FILE FD=..
3360: 2e 22 29 3b 0a 09 7d 0a 0a 09 66 69 6c 65 64 5f  .");..}...filed_
3370: 6c 6f 67 5f 6d 73 67 28 22 43 4c 4f 53 45 5f 43  log_msg("CLOSE_C
3380: 4f 4e 4e 45 43 54 49 4f 4e 20 46 44 3d 2e 2e 2e  ONNECTION FD=...
3390: 22 29 3b 0a 0a 09 66 63 6c 6f 73 65 28 66 70 29  ");...fclose(fp)
33a0: 3b 0a 0a 09 72 65 74 75 72 6e 3b 0a 7d 0a 0a 2f  ;...return;.}../
33b0: 2a 20 48 61 6e 64 6c 65 20 69 6e 63 6f 6d 69 6e  * Handle incomin
33c0: 67 20 63 6f 6e 6e 65 63 74 69 6f 6e 73 20 2a 2f  g connections */
33d0: 0a 73 74 61 74 69 63 20 76 6f 69 64 20 2a 66 69  .static void *fi
33e0: 6c 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65 61  led_worker_threa
33f0: 64 28 76 6f 69 64 20 2a 61 72 67 5f 76 29 20 7b  d(void *arg_v) {
3400: 0a 09 73 74 72 75 63 74 20 66 69 6c 65 64 5f 77  ..struct filed_w
3410: 6f 72 6b 65 72 5f 74 68 72 65 61 64 5f 61 72 67  orker_thread_arg
3420: 73 20 2a 61 72 67 3b 0a 09 73 74 72 75 63 74 20  s *arg;..struct 
3430: 66 69 6c 65 64 5f 68 74 74 70 5f 72 65 71 75 65  filed_http_reque
3440: 73 74 20 72 65 71 75 65 73 74 3b 0a 09 73 74 72  st request;..str
3450: 75 63 74 20 73 6f 63 6b 61 64 64 72 5f 69 6e 36  uct sockaddr_in6
3460: 20 61 64 64 72 3b 0a 09 73 6f 63 6b 6c 65 6e 5f   addr;..socklen_
3470: 74 20 61 64 64 72 6c 65 6e 3b 0a 09 69 6e 74 20  t addrlen;..int 
3480: 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 20 3d 20  failure_count = 
3490: 30 2c 20 6d 61 78 5f 66 61 69 6c 75 72 65 5f 63  0, max_failure_c
34a0: 6f 75 6e 74 20 3d 20 4d 41 58 5f 46 41 49 4c 55  ount = MAX_FAILU
34b0: 52 45 5f 43 4f 55 4e 54 3b 0a 09 69 6e 74 20 6d  RE_COUNT;..int m
34c0: 61 73 74 65 72 5f 66 64 2c 20 66 64 3b 0a 0a 09  aster_fd, fd;...
34d0: 2f 2a 20 52 65 61 64 20 61 72 67 75 6d 65 6e 74  /* Read argument
34e0: 73 20 2a 2f 0a 09 61 72 67 20 3d 20 61 72 67 5f  s */..arg = arg_
34f0: 76 3b 0a 0a 09 6d 61 73 74 65 72 5f 66 64 20 3d  v;...master_fd =
3500: 20 61 72 67 2d 3e 66 64 3b 0a 0a 09 77 68 69 6c   arg->fd;...whil
3510: 65 20 28 31 29 20 7b 0a 09 09 2f 2a 20 46 61 69  e (1) {.../* Fai
3520: 6c 75 72 65 20 6c 6f 6f 70 20 70 72 65 76 65 6e  lure loop preven
3530: 74 69 6f 6e 20 2a 2f 0a 09 09 69 66 20 28 66 61  tion */...if (fa
3540: 69 6c 75 72 65 5f 63 6f 75 6e 74 20 3e 20 6d 61  ilure_count > ma
3550: 78 5f 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 29  x_failure_count)
3560: 20 7b 0a 09 09 09 62 72 65 61 6b 3b 0a 09 09 7d   {....break;...}
3570: 0a 0a 09 09 2f 2a 20 41 63 63 65 70 74 20 61 20  ..../* Accept a 
3580: 6e 65 77 20 63 6c 69 65 6e 74 20 2a 2f 0a 09 09  new client */...
3590: 61 64 64 72 6c 65 6e 20 3d 20 73 69 7a 65 6f 66  addrlen = sizeof
35a0: 28 61 64 64 72 29 3b 0a 09 09 66 64 20 3d 20 61  (addr);...fd = a
35b0: 63 63 65 70 74 28 6d 61 73 74 65 72 5f 66 64 2c  ccept(master_fd,
35c0: 20 28 73 74 72 75 63 74 20 73 6f 63 6b 61 64 64   (struct sockadd
35d0: 72 20 2a 29 20 26 61 64 64 72 2c 20 26 61 64 64  r *) &addr, &add
35e0: 72 6c 65 6e 29 3b 0a 0a 09 09 2f 2a 0a 09 09 20  rlen);..../*... 
35f0: 2a 20 49 66 20 77 65 20 66 61 69 6c 2c 20 6d 61  * If we fail, ma
3600: 6b 65 20 61 20 6e 6f 74 65 20 6f 66 20 69 74 20  ke a note of it 
3610: 73 6f 20 77 65 20 64 6f 6e 27 74 20 67 6f 20 69  so we don't go i
3620: 6e 74 6f 20 61 20 6c 6f 6f 70 20 6f 66 0a 09 09  nto a loop of...
3630: 20 2a 20 61 63 63 65 70 74 28 29 20 66 61 69 6c   * accept() fail
3640: 69 6e 67 0a 09 09 20 2a 2f 0a 09 09 69 66 20 28  ing... */...if (
3650: 66 64 20 3c 20 30 29 20 7b 0a 09 09 09 2f 2a 20  fd < 0) {..../* 
3660: 4c 6f 67 20 74 68 65 20 6e 65 77 20 63 6f 6e 6e  Log the new conn
3670: 65 63 74 69 6f 6e 20 2a 2f 0a 09 09 09 66 69 6c  ection */....fil
3680: 65 64 5f 6c 6f 67 5f 6d 73 67 28 22 41 43 43 45  ed_log_msg("ACCE
3690: 50 54 5f 46 41 49 4c 45 44 22 29 3b 0a 0a 09 09  PT_FAILED");....
36a0: 09 66 61 69 6c 75 72 65 5f 63 6f 75 6e 74 2b 2b  .failure_count++
36b0: 3b 0a 0a 09 09 09 63 6f 6e 74 69 6e 75 65 3b 0a  ;.....continue;.
36c0: 09 09 7d 0a 0a 09 09 2f 2a 20 4c 6f 67 20 74 68  ..}..../* Log th
36d0: 65 20 6e 65 77 20 63 6f 6e 6e 65 63 74 69 6f 6e  e new connection
36e0: 20 2a 2f 0a 09 09 66 69 6c 65 64 5f 6c 6f 67 5f   */...filed_log_
36f0: 6d 73 67 28 22 4e 45 57 5f 43 4f 4e 4e 45 43 54  msg("NEW_CONNECT
3700: 49 4f 4e 20 53 52 43 5f 41 44 44 52 3d 2e 2e 2e  ION SRC_ADDR=...
3710: 20 53 52 43 5f 50 4f 52 54 3d 2e 2e 2e 20 46 44   SRC_PORT=... FD
3720: 3d 2e 2e 2e 22 29 3b 0a 0a 09 09 2f 2a 20 52 65  =...");..../* Re
3730: 73 65 74 20 66 61 69 6c 75 72 65 20 63 6f 75 6e  set failure coun
3740: 74 2a 2f 0a 09 09 66 61 69 6c 75 72 65 5f 63 6f  t*/...failure_co
3750: 75 6e 74 20 3d 20 30 3b 0a 0a 09 09 2f 2a 20 48  unt = 0;..../* H
3760: 61 6e 64 6c 65 20 73 6f 63 6b 65 74 20 2a 2f 0a  andle socket */.
3770: 09 09 66 69 6c 65 64 5f 68 61 6e 64 6c 65 5f 63  ..filed_handle_c
3780: 6c 69 65 6e 74 28 66 64 2c 20 26 72 65 71 75 65  lient(fd, &reque
3790: 73 74 29 3b 0a 09 7d 0a 0a 09 2f 2a 20 52 65 70  st);..}.../* Rep
37a0: 6f 72 74 20 65 72 72 6f 72 20 2a 2f 0a 09 66 69  ort error */..fi
37b0: 6c 65 64 5f 6c 6f 67 5f 6d 73 67 28 22 54 48 52  led_log_msg("THR
37c0: 45 41 44 5f 44 49 45 44 20 41 42 4e 4f 52 4d 41  EAD_DIED ABNORMA
37d0: 4c 22 29 3b 0a 0a 09 72 65 74 75 72 6e 28 4e 55  L");...return(NU
37e0: 4c 4c 29 3b 0a 7d 0a 0a 2f 2a 20 43 72 65 61 74  LL);.}../* Creat
37f0: 65 20 77 6f 72 6b 65 72 20 74 68 72 65 61 64 73  e worker threads
3800: 20 2a 2f 0a 73 74 61 74 69 63 20 69 6e 74 20 66   */.static int f
3810: 69 6c 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65  iled_worker_thre
3820: 61 64 73 5f 69 6e 69 74 28 69 6e 74 20 66 64 2c  ads_init(int fd,
3830: 20 69 6e 74 20 74 68 72 65 61 64 5f 63 6f 75 6e   int thread_coun
3840: 74 29 20 7b 0a 09 73 74 72 75 63 74 20 66 69 6c  t) {..struct fil
3850: 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65 61 64  ed_worker_thread
3860: 5f 61 72 67 73 20 2a 61 72 67 3b 0a 09 70 74 68  _args *arg;..pth
3870: 72 65 61 64 5f 74 20 74 68 72 65 61 64 69 64 3b  read_t threadid;
3880: 0a 09 69 6e 74 20 70 74 68 72 65 61 64 5f 72 65  ..int pthread_re
3890: 74 3b 0a 09 69 6e 74 20 69 3b 0a 0a 09 66 6f 72  t;..int i;...for
38a0: 20 28 69 20 3d 20 30 3b 20 69 20 3c 20 74 68 72   (i = 0; i < thr
38b0: 65 61 64 5f 63 6f 75 6e 74 3b 20 69 2b 2b 29 20  ead_count; i++) 
38c0: 7b 0a 09 09 61 72 67 20 3d 20 6d 61 6c 6c 6f 63  {...arg = malloc
38d0: 28 73 69 7a 65 6f 66 28 2a 61 72 67 29 29 3b 0a  (sizeof(*arg));.
38e0: 0a 09 09 61 72 67 2d 3e 66 64 20 3d 20 66 64 3b  ...arg->fd = fd;
38f0: 0a 0a 09 09 70 74 68 72 65 61 64 5f 72 65 74 20  ....pthread_ret 
3900: 3d 20 70 74 68 72 65 61 64 5f 63 72 65 61 74 65  = pthread_create
3910: 28 26 74 68 72 65 61 64 69 64 2c 20 4e 55 4c 4c  (&threadid, NULL
3920: 2c 20 66 69 6c 65 64 5f 77 6f 72 6b 65 72 5f 74  , filed_worker_t
3930: 68 72 65 61 64 2c 20 61 72 67 29 3b 0a 09 09 69  hread, arg);...i
3940: 66 20 28 70 74 68 72 65 61 64 5f 72 65 74 20 21  f (pthread_ret !
3950: 3d 20 30 29 20 7b 0a 09 09 09 72 65 74 75 72 6e  = 0) {....return
3960: 28 2d 31 29 3b 0a 09 09 7d 0a 09 7d 0a 0a 09 72  (-1);...}..}...r
3970: 65 74 75 72 6e 28 30 29 3b 0a 7d 0a 0a 2f 2a 20  eturn(0);.}../* 
3980: 52 75 6e 20 70 72 6f 63 65 73 73 20 2a 2f 0a 69  Run process */.i
3990: 6e 74 20 6d 61 69 6e 28 69 6e 74 20 61 72 67 63  nt main(int argc
39a0: 2c 20 63 68 61 72 20 2a 2a 61 72 67 76 29 20 7b  , char **argv) {
39b0: 0a 09 69 6e 74 20 70 6f 72 74 20 3d 20 50 4f 52  ..int port = POR
39c0: 54 2c 20 74 68 72 65 61 64 5f 63 6f 75 6e 74 20  T, thread_count 
39d0: 3d 20 54 48 52 45 41 44 5f 43 4f 55 4e 54 3b 0a  = THREAD_COUNT;.
39e0: 09 63 6f 6e 73 74 20 63 68 61 72 20 2a 62 69 6e  .const char *bin
39f0: 64 5f 61 64 64 72 20 3d 20 42 49 4e 44 5f 41 44  d_addr = BIND_AD
3a00: 44 52 3b 0a 09 69 6e 74 20 69 6e 69 74 5f 72 65  DR;..int init_re
3a10: 74 3b 0a 09 69 6e 74 20 66 64 3b 0a 0a 09 2f 2a  t;..int fd;.../*
3a20: 20 58 58 58 3a 20 54 4f 44 4f 3a 20 50 72 6f 63   XXX: TODO: Proc
3a30: 65 73 73 20 61 72 67 75 6d 65 6e 74 73 20 2a 2f  ess arguments */
3a40: 0a 09 61 72 67 63 20 3d 20 61 72 67 63 3b 0a 09  ..argc = argc;..
3a50: 61 72 67 76 20 3d 20 61 72 67 76 3b 0a 0a 09 2f  argv = argv;.../
3a60: 2a 20 43 72 65 61 74 65 20 6c 69 73 74 65 6e 69  * Create listeni
3a70: 6e 67 20 73 6f 63 6b 65 74 20 2a 2f 0a 09 66 64  ng socket */..fd
3a80: 20 3d 20 66 69 6c 65 64 5f 6c 69 73 74 65 6e 28   = filed_listen(
3a90: 62 69 6e 64 5f 61 64 64 72 2c 20 70 6f 72 74 29  bind_addr, port)
3aa0: 3b 0a 09 69 66 20 28 66 64 20 3c 20 30 29 20 7b  ;..if (fd < 0) {
3ab0: 0a 09 09 70 65 72 72 6f 72 28 22 66 69 6c 65 64  ...perror("filed
3ac0: 5f 6c 69 73 74 65 6e 22 29 3b 0a 0a 09 09 72 65  _listen");....re
3ad0: 74 75 72 6e 28 31 29 3b 0a 09 7d 0a 0a 09 2f 2a  turn(1);..}.../*
3ae0: 20 42 65 63 6f 6d 65 20 61 20 64 61 65 6d 6f 6e   Become a daemon
3af0: 20 2a 2f 0a 09 2f 2a 20 58 58 58 3a 54 4f 44 4f   */../* XXX:TODO
3b00: 3a 20 42 65 63 6f 6d 65 20 61 20 64 61 65 6d 6f  : Become a daemo
3b10: 6e 20 2a 2f 0a 0a 09 2f 2a 20 49 6e 69 74 69 61  n */.../* Initia
3b20: 6c 69 7a 65 20 2a 2f 0a 09 69 6e 69 74 5f 72 65  lize */..init_re
3b30: 74 20 3d 20 66 69 6c 65 64 5f 69 6e 69 74 28 29  t = filed_init()
3b40: 3b 0a 09 69 66 20 28 69 6e 69 74 5f 72 65 74 20  ;..if (init_ret 
3b50: 21 3d 20 30 29 20 7b 0a 09 09 70 65 72 72 6f 72  != 0) {...perror
3b60: 28 22 66 69 6c 65 64 5f 69 6e 69 74 22 29 3b 0a  ("filed_init");.
3b70: 0a 09 09 72 65 74 75 72 6e 28 33 29 3b 0a 09 7d  ...return(3);..}
3b80: 0a 0a 09 2f 2a 20 43 72 65 61 74 65 20 6c 6f 67  .../* Create log
3b90: 67 69 6e 67 20 74 68 72 65 61 64 20 2a 2f 0a 09  ging thread */..
3ba0: 69 6e 69 74 5f 72 65 74 20 3d 20 66 69 6c 65 64  init_ret = filed
3bb0: 5f 6c 6f 67 67 69 6e 67 5f 74 68 72 65 61 64 5f  _logging_thread_
3bc0: 69 6e 69 74 28 29 3b 0a 09 69 66 20 28 69 6e 69  init();..if (ini
3bd0: 74 5f 72 65 74 20 21 3d 20 30 29 20 7b 0a 09 09  t_ret != 0) {...
3be0: 70 65 72 72 6f 72 28 22 66 69 6c 65 64 5f 6c 6f  perror("filed_lo
3bf0: 67 67 69 6e 67 5f 74 68 72 65 61 64 5f 69 6e 69  gging_thread_ini
3c00: 74 22 29 3b 0a 0a 09 09 72 65 74 75 72 6e 28 34  t");....return(4
3c10: 29 3b 0a 09 7d 0a 0a 09 2f 2a 20 43 72 65 61 74  );..}.../* Creat
3c20: 65 20 77 6f 72 6b 65 72 20 74 68 72 65 61 64 73  e worker threads
3c30: 20 2a 2f 0a 09 69 6e 69 74 5f 72 65 74 20 3d 20   */..init_ret = 
3c40: 66 69 6c 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72  filed_worker_thr
3c50: 65 61 64 73 5f 69 6e 69 74 28 66 64 2c 20 74 68  eads_init(fd, th
3c60: 72 65 61 64 5f 63 6f 75 6e 74 29 3b 0a 09 69 66  read_count);..if
3c70: 20 28 69 6e 69 74 5f 72 65 74 20 21 3d 20 30 29   (init_ret != 0)
3c80: 20 7b 0a 09 09 70 65 72 72 6f 72 28 22 66 69 6c   {...perror("fil
3c90: 65 64 5f 77 6f 72 6b 65 72 5f 74 68 72 65 61 64  ed_worker_thread
3ca0: 73 5f 69 6e 69 74 22 29 3b 0a 0a 09 09 72 65 74  s_init");....ret
3cb0: 75 72 6e 28 34 29 3b 0a 09 7d 0a 0a 09 2f 2a 20  urn(4);..}.../* 
3cc0: 57 61 69 74 20 66 6f 72 20 74 68 72 65 61 64 73  Wait for threads
3cd0: 20 74 6f 20 65 78 69 74 20 2a 2f 0a 09 2f 2a 20   to exit */../* 
3ce0: 58 58 58 3a 54 4f 44 4f 3a 20 4d 6f 6e 69 74 6f  XXX:TODO: Monito
3cf0: 72 20 74 68 72 65 61 64 20 75 73 61 67 65 20 2a  r thread usage *
3d00: 2f 0a 09 77 68 69 6c 65 20 28 31 29 20 7b 0a 09  /..while (1) {..
3d10: 09 73 6c 65 65 70 28 36 30 29 3b 0a 09 7d 0a 0a  .sleep(60);..}..
3d20: 09 2f 2a 20 52 65 74 75 72 6e 20 69 6e 20 66 61  ./* Return in fa
3d30: 69 6c 75 72 65 20 2a 2f 0a 09 72 65 74 75 72 6e  ilure */..return
3d40: 28 32 29 3b 0a 7d 0a                             (2);.}.