X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=http_send_api.c;h=73aa0b6c4a1bd053a6c986259e250c1cd7dc8bd5;hb=9a35b7682fede86cb0167d21a67fea38a6e85181;hp=764d2ac85481623309c1ed9ab37b00b5f2b534d4;hpb=902d195a198f4976c8ff081a95cdd3e315c14f5f;p=m6w6%2Fext-http diff --git a/http_send_api.c b/http_send_api.c index 764d2ac..73aa0b6 100644 --- a/http_send_api.c +++ b/http_send_api.c @@ -48,18 +48,24 @@ static inline void _http_flush(TSRMLS_D) /* {{{ static inline void http_sleep() */ static inline void _http_sleep(TSRMLS_D) { - if (HTTP_G(send).throttle_delay >= 0.001) { +#define HTTP_MSEC(s) (s * 1000) +#define HTTP_USEC(s) (HTTP_MSEC(s) * 1000) +#define HTTP_NSEC(s) (HTTP_USEC(s) * 1000) +#define HTTP_NANOSEC (1000 * 1000 * 1000) +#define HTTP_DIFFSEC (0.001) + + if (HTTP_G(send).throttle_delay >= HTTP_DIFFSEC) { #if defined(PHP_WIN32) - Sleep((DWORD) (HTTP_G(send).throttle_delay * 1000)); + Sleep((DWORD) HTTP_MSEC(HTTP_G(send).throttle_delay)); #elif defined(HAVE_USLEEP) - usleep(HTTP_G(send).throttle_delay * 1000000); + usleep(HTTP_USEC(HTTP_G(send).throttle_delay)); #elif defined(HAVE_NANOSLEEP) struct timespec req, rem; req.tv_sec = (time_t) HTTP_G(send).throttle_delay; - req.tv_nsec = (HTTP_G(send).throttle_delay * 1000000000) % 1000000000; + req.tv_nsec = HTTP_NSEC(HTTP_G(send).throttle_delay) % HTTP_NANOSEC; - while (nanosleep(&req, &rem) && (errno == EINTR) && (rem.tv_nsec > 1000000)) { + while (nanosleep(&req, &rem) && (errno == EINTR) && (HTTP_NSEC(rem.tv_sec) + rem.tv_nsec) > HTTP_NSEC(HTTP_DIFFSEC))) { req.tv_sec = rem.tv_sec; req.tv_nsec = rem.tv_nsec; } @@ -149,7 +155,7 @@ PHP_HTTP_API STATUS _http_send_status_header_ex(int status, const char *header, STATUS ret; sapi_header_line h = {(char *) header, header ? strlen(header) : 0, status}; if (SUCCESS != (ret = sapi_header_op(replace ? SAPI_HEADER_REPLACE : SAPI_HEADER_ADD, &h TSRMLS_CC))) { - http_error_ex(E_WARNING, HTTP_E_HEADER, "Could not send header: %s (%d)", header, status); + http_error_ex(HE_WARNING, HTTP_E_HEADER, "Could not send header: %s (%d)", header, status); } return ret; } @@ -180,7 +186,7 @@ PHP_HTTP_API STATUS _http_send_etag(const char *etag, size_t etag_len TSRMLS_DC) char *etag_header; if (!etag_len){ - http_error_ex(E_WARNING, HTTP_E_HEADER, "Attempt to send empty ETag (previous: %s)\n", HTTP_G(send).unquoted_etag); + http_error_ex(HE_WARNING, HTTP_E_HEADER, "Attempt to send empty ETag (previous: %s)\n", HTTP_G(send).unquoted_etag); return FAILURE; } @@ -216,7 +222,7 @@ PHP_HTTP_API STATUS _http_send_content_type(const char *content_type, size_t ct_ char *ct_header; if (!strchr(content_type, '/')) { - http_error_ex(E_WARNING, HTTP_E_PARAM, "Content-Type '%s' doesn't seem to consist of a primary and a secondary part", content_type); + http_error_ex(HE_WARNING, HTTP_E_INVALID_PARAM, "Content-Type '%s' doesn't seem to consist of a primary and a secondary part", content_type); return FAILURE; } @@ -273,7 +279,7 @@ PHP_HTTP_API STATUS _http_send_ranges(HashTable *ranges, const void *data, size_ http_send_status(206); /* send content range header */ - snprintf(range_header, 255, "Content-Range: bytes %d-%d/%d", **begin, **end, size); + snprintf(range_header, 255, "Content-Range: bytes %ld-%ld/%lu", **begin, **end, (ulong) size); http_send_header(range_header); /* send requested chunk */ @@ -289,7 +295,7 @@ PHP_HTTP_API STATUS _http_send_ranges(HashTable *ranges, const void *data, size_ http_send_status(206); /* send multipart/byteranges header */ - snprintf(bound, 22, "--%d%0.9f", time(NULL), php_combined_lcg(TSRMLS_C)); + snprintf(bound, 22, "--%lu%0.9f", (ulong) time(NULL), php_combined_lcg(TSRMLS_C)); strncat(multi_header, bound + 2, 21); http_send_header(multi_header); @@ -303,7 +309,7 @@ PHP_HTTP_API STATUS _http_send_ranges(HashTable *ranges, const void *data, size_ snprintf(preface, 1023, HTTP_CRLF "%s" HTTP_CRLF "Content-Type: %s" - HTTP_CRLF "Content-Range: bytes %ld-%ld/%ld" + HTTP_CRLF "Content-Range: bytes %ld-%ld/%lu" HTTP_CRLF HTTP_CRLF, @@ -311,7 +317,7 @@ PHP_HTTP_API STATUS _http_send_ranges(HashTable *ranges, const void *data, size_ HTTP_G(send).content_type ? HTTP_G(send).content_type : "application/x-octetstream", **begin, **end, - size + (ulong) size ); PHPWRITE(preface, strlen(preface)); @@ -376,7 +382,7 @@ PHP_HTTP_API STATUS _http_send(const void *data_ptr, size_t data_size, http_send char *etag = NULL; if (!(etag = http_etag(data_ptr, data_size, data_mode))) { - http_error(E_NOTICE, HTTP_E_PARAM, "Failed to generate ETag for data source"); + http_error(HE_NOTICE, HTTP_E_RUNTIME, "Failed to generate ETag for data source"); } else { http_send_etag(etag, 32); if (http_match_etag("HTTP_IF_NONE_MATCH", etag)) {