Overview
Comment: | Updated to use off_t to represent disk sizes |
---|---|
Downloads: | Tarball | ZIP archive | SQL archive |
Timelines: | family | ancestors | descendants | both | trunk |
Files: | files | file ages | folders |
SHA1: | b040037186fe2caf82c6c924f0f77f4ebd95d2e7 |
User & Date: | rkeene on 2014-02-06 08:42:02 |
Other Links: | manifest | tags |
Context
2014-02-06
| ||
20:43 | Updated to support arguments, updated hashing algorithm, and minor cleanup check-in: 613c9bd346 user: rkeene tags: trunk | |
08:42 | Updated to use off_t to represent disk sizes check-in: b040037186 user: rkeene tags: trunk | |
08:26 | Added additional debugging regarding range computation check-in: c35e6a2d15 user: rkeene tags: trunk | |
Changes
Modified filed.c from [c73ad10afc] to [5f7a2da005].
31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 .. 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 ... 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 ... 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 |
}; /* File information */ struct filed_fileinfo { pthread_mutex_t mutex; char *path; int fd; size_t len; char *lastmod; char lastmod_b[64]; char *type; }; /* Request variables */ struct filed_http_request { ................................................................................ /** HTTP Request information **/ char *path; /*** Path being requested ***/ struct { struct { int present; off_t offset; /*** Range start ***/ ssize_t length; /*** Range length ***/ } range; } headers; }; /* Global variables */ /** Open File cache **/ struct filed_fileinfo *filed_fileinfo_fdcache; ................................................................................ } /* Process an HTTP request and return the path requested */ static struct filed_http_request *filed_get_http_request(FILE *fp, struct filed_http_request *buffer_st) { char *method, *path; char *buffer, *tmpbuffer, *workbuffer, *workbuffer_next; size_t buffer_len, tmpbuffer_len; off_t range_start, range_end; ssize_t range_length; int range_request; int i; range_start = 0; range_end = 0; range_request = 0; range_length = -1; ................................................................................ fileinfo = filed_open_file(path, &request->fileinfo); if (fileinfo == NULL) { filed_error_page(fp, date_current, 404); filed_log_msg("PROCESS_REPLY_COMPLETE FD=... ERROR=404"); } else { if (request->headers.range.offset != 0 || request->headers.range.length >= 0) { if ((size_t) request->headers.range.offset >= fileinfo->len) { filed_log_msg("PROCESS_REPLY_COMPLETE FD=... ERROR=416"); filed_error_page(fp, date_current, 416); } else { if (request->headers.range.length < 0) { filed_log_msg_debug("Computing length to fit in bounds: fileinfo->len = %llu, request->headers.range.offset = %llu", (unsigned long long) fileinfo->len, (unsigned long long) request->headers.range.offset ); request->headers.range.length = fileinfo->len - request->headers.range.offset; } filed_log_msg_debug("Partial request, starting at: %llu and running for %llu bytes", (unsigned long long) request->headers.range.offset, (unsigned long long) request->headers.range.length); http_code = 206; } } else { if (request->headers.range.present) { http_code = 206; } else { |
| | | < | | > > > |
31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 .. 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 ... 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 ... 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 |
}; /* File information */ struct filed_fileinfo { pthread_mutex_t mutex; char *path; int fd; off_t len; char *lastmod; char lastmod_b[64]; char *type; }; /* Request variables */ struct filed_http_request { ................................................................................ /** HTTP Request information **/ char *path; /*** Path being requested ***/ struct { struct { int present; off_t offset; /*** Range start ***/ off_t length; /*** Range length ***/ } range; } headers; }; /* Global variables */ /** Open File cache **/ struct filed_fileinfo *filed_fileinfo_fdcache; ................................................................................ } /* Process an HTTP request and return the path requested */ static struct filed_http_request *filed_get_http_request(FILE *fp, struct filed_http_request *buffer_st) { char *method, *path; char *buffer, *tmpbuffer, *workbuffer, *workbuffer_next; size_t buffer_len, tmpbuffer_len; off_t range_start, range_end, range_length; int range_request; int i; range_start = 0; range_end = 0; range_request = 0; range_length = -1; ................................................................................ fileinfo = filed_open_file(path, &request->fileinfo); if (fileinfo == NULL) { filed_error_page(fp, date_current, 404); filed_log_msg("PROCESS_REPLY_COMPLETE FD=... ERROR=404"); } else { if (request->headers.range.offset != 0 || request->headers.range.length >= 0) { if (request->headers.range.offset >= fileinfo->len) { filed_log_msg("PROCESS_REPLY_COMPLETE FD=... ERROR=416"); filed_error_page(fp, date_current, 416); } else { if (request->headers.range.length < 0) { filed_log_msg_debug("Computing length to fit in bounds: fileinfo->len = %llu, request->headers.range.offset = %llu", (unsigned long long) fileinfo->len, (unsigned long long) request->headers.range.offset ); request->headers.range.length = fileinfo->len - request->headers.range.offset; } filed_log_msg_debug("Partial request, starting at: %llu and running for %llu bytes", (unsigned long long) request->headers.range.offset, (unsigned long long) request->headers.range.length ); http_code = 206; } } else { if (request->headers.range.present) { http_code = 206; } else { |