nginx-0.0.1-2003-11-13-09:14:05 import

src/core/nginx.c

@@ -70,7 +70,9 @@ int main(int argc, char *const *argv)
     ngx_log_t        *log;
     ngx_cycle_t      *cycle;
     ngx_open_file_t  *file;
+#if !(WIN32)
     ngx_core_conf_t  *ccf;
+#endif
 
 #if (NGX_DEBUG) && (__FreeBSD__)
 #if __FreeBSD_version >= 500014
@@ -83,6 +85,8 @@ int main(int argc, char *const *argv)
 
     /* TODO */ ngx_max_sockets = -1;
 
+    ngx_init_time();
+
     log = ngx_log_init_errlog();
 
     if (ngx_os_init(log) == NGX_ERROR) {

src/core/ngx_log.c

@@ -60,7 +60,6 @@ void ngx_log_error_core(int level, ngx_log_t *log, ngx_err_t err,
 #endif
 {
     char      errstr[MAX_ERROR_STR];
-    ngx_tm_t  tm;
     size_t    len;
 #if (HAVE_VARIADIC_MACROS)
     va_list   args;
@@ -73,10 +72,17 @@ void ngx_log_error_core(int level, ngx_log_t *log, ngx_err_t err,
         return;
     }
 
+    ngx_memcpy(errstr, ngx_cached_err_log_time.data,
+               ngx_cached_err_log_time.len);
+
+    len = ngx_cached_err_log_time.len;
+
+#if 0
     ngx_localtime(&tm);
     len = ngx_snprintf(errstr, sizeof(errstr), "%4d/%02d/%02d %02d:%02d:%02d",
                        tm.ngx_tm_year, tm.ngx_tm_mon, tm.ngx_tm_mday,
                        tm.ngx_tm_hour, tm.ngx_tm_min, tm.ngx_tm_sec);
+#endif
 
     len += ngx_snprintf(errstr + len, sizeof(errstr) - len - 1,
                         " [%s] ", err_levels[level]);

src/core/ngx_times.c

@@ -5,6 +5,11 @@
 
 time_t       ngx_cached_time;
 
+ngx_tm_t     ngx_cached_gmtime;
+
+static char  cached_err_log_time[] = "1970/09/28 12:00:00";
+ngx_str_t    ngx_cached_err_log_time;
+
 static char  cached_http_time[] = "Mon, 28 Sep 1970 06:00:00 GMT";
 ngx_str_t    ngx_cached_http_time;
 
@@ -12,56 +17,62 @@ static char  cached_http_log_time[] = "28/Sep/1970:12:00:00";
 ngx_str_t    ngx_cached_http_log_time;
 
 
+static char  *week[] = { "Sun", "Mon", "Tue", "Wed", "Thu", "Fir", "Sat" };
+static char  *months[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun",
+                           "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" };
+
+
+void ngx_init_time()
+{
+    struct timeval  tv;
+
+    ngx_memzero(&ngx_cached_gmtime, sizeof(ngx_tm_t));
+#ifdef ngx_tm_zone
+    ngx_cached_gmtime.ngx_tm_zone = "GMT";
+#endif
+
+    ngx_cached_err_log_time.data = cached_err_log_time;
+    ngx_cached_http_time.data = cached_http_time;
+    ngx_cached_http_log_time.data = cached_http_log_time;
+
+    ngx_gettimeofday(&tv);
+    ngx_cached_time = tv.tv_sec;
+    ngx_time_update();
+}
+
+
 time_t ngx_time()
 {
     return ngx_cached_time;
 }
 
 
-/* TODO:
- *   cache ngx_tm_t
- *   write own gmtime()
- *   remove strftime()
- *   we can remove localtime_r
- */
-
 void ngx_time_update()
 {
-    ngx_tm_t     *tp, tm;
+    ngx_tm_t  tm;
-    static char  *months[] = { "Jan", "Feb", "Mar", "Apr", "May", "Jun",
-                               "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" };
 
-    /* STUB: need to move to ngx_init_time() */
+    ngx_gmtime(ngx_cached_time, &ngx_cached_gmtime);
-    ngx_cached_http_time.data = cached_http_time;
-    ngx_cached_http_log_time.data = cached_http_log_time;
-
-#if 0
-
-    days = sec / 86400;
-    days = days - 31 - 28 + 719527;
-
-    year = days * 400 / (365 * 400 + 100 - 4 + 1);
-    yday = days - (365 * year + year / 4 - year / 100 + year / 400);
-
-    month = (yday + 30) * 12 / 367;
-    mday = yday - (month * 367 / 12 - 31);
-
-    if (++month > 11) {
-        month -= 12;
-        year++;
-    }
-
-#endif
-
-    tp = gmtime(&ngx_cached_time);
-
-    ngx_cached_http_time.len = strftime(ngx_cached_http_time.data,
-                                        sizeof("Mon, 28 Sep 1970 06:00:00 GMT"),
-                                        "%a, %d %b %Y %H:%M:%S GMT", tp);
 
+    ngx_cached_http_time.len = ngx_snprintf(ngx_cached_http_time.data,
+                                       sizeof("Mon, 28 Sep 1970 06:00:00 GMT"),
+                                       "%s, %02d %s %4d %02d:%02d:%02d GMT",
+                                       week[ngx_cached_gmtime.ngx_tm_wday],
+                                       ngx_cached_gmtime.ngx_tm_mday,
+                                       months[ngx_cached_gmtime.ngx_tm_mon - 1],
+                                       ngx_cached_gmtime.ngx_tm_year,
+                                       ngx_cached_gmtime.ngx_tm_hour,
+                                       ngx_cached_gmtime.ngx_tm_min,
+                                       ngx_cached_gmtime.ngx_tm_sec);
 
     ngx_localtime(&tm);
 
+    ngx_cached_err_log_time.len = ngx_snprintf(ngx_cached_err_log_time.data,
+                                       sizeof("1970/09/28 12:00:00"),
+                                       "%4d/%02d/%02d %02d:%02d:%02d",
+                                       tm.ngx_tm_year, tm.ngx_tm_mon,
+                                       tm.ngx_tm_mday, tm.ngx_tm_hour,
+                                       tm.ngx_tm_min, tm.ngx_tm_sec);
+
     ngx_cached_http_log_time.len = ngx_snprintf(ngx_cached_http_log_time.data,
                                        sizeof("28/Sep/1970:12:00:00"),
                                        "%02d/%s/%d:%02d:%02d:%02d",
@@ -72,3 +83,90 @@ void ngx_time_update()
                                        tm.ngx_tm_min,
                                        tm.ngx_tm_sec);
 }
+
+
+size_t ngx_http_time(char *buf, time_t t)
+{
+    ngx_tm_t  tm;
+
+    ngx_gmtime(t, &tm);
+
+    return ngx_snprintf(buf, sizeof("Mon, 28 Sep 1970 06:00:00 GMT"),
+                                       "%s, %02d %s %4d %02d:%02d:%02d GMT",
+                                       week[tm.ngx_tm_wday],
+                                       tm.ngx_tm_mday,
+                                       months[tm.ngx_tm_mon - 1],
+                                       tm.ngx_tm_year,
+                                       tm.ngx_tm_hour,
+                                       tm.ngx_tm_min,
+                                       tm.ngx_tm_sec);
+}
+
+
+void ngx_gmtime(time_t t, ngx_tm_t *tp)
+{
+    int  sec, min, hour, mday, mon, year, wday, yday, days;
+
+    days = t / 86400;
+
+    /* Jaunary 1, 1970 was Thursday */
+    wday = (4 + days) % 7;
+
+    t %= 86400;
+    hour = t / 3600;
+    t %= 3600;
+    min = t / 60; 
+    sec = t % 60;
+
+    /* the algorithm based on Gauss's formula */
+    
+    days = days - (31 + 28) + 719527;
+
+    year = days * 400 / (365 * 400 + 100 - 4 + 1);
+    yday = days - (365 * year + year / 4 - year / 100 + year / 400);
+
+    mon = (yday + 31) * 12 / 367;
+    mday = yday - (mon * 367 / 12 - 31);
+
+    mon += 2;
+
+    if (yday >= 306) {
+        yday -= 306;
+        year++;
+        mon -= 12;
+
+        if (mday == 0) {
+            /* Jaunary 31 */
+            mon = 1;
+            mday = 31;
+
+        } else if (mon == 2) {
+
+            if ((year % 4 == 0) && (year % 100 || (year % 400 == 0))) {
+                if (mday > 29) {
+                    mon = 3;
+                    mday -= 29;
+                }
+
+            } else if (mday > 28) {
+                mon = 3;
+                mday -= 28;
+            }
+        }
+
+    } else {
+        yday += 31 + 28;
+
+        if ((year % 4 == 0) && (year % 100 || (year % 400 == 0))) {
+             yday++;
+        }
+    }
+
+    tp->ngx_tm_sec = sec;
+    tp->ngx_tm_min = min;
+    tp->ngx_tm_hour = hour;
+    tp->ngx_tm_mday = mday;
+    tp->ngx_tm_mon = mon;
+    tp->ngx_tm_year = year;
+    tp->ngx_tm_wday = wday;
+}

src/core/ngx_times.h

@@ -6,11 +6,15 @@
 #include <ngx_core.h>
 
 
+void ngx_init_time();
 time_t ngx_time();
 void ngx_time_update();
+size_t ngx_http_time(char *buf, time_t t);
+void ngx_gmtime(time_t t, ngx_tm_t *tp);
 
 
 extern time_t     ngx_cached_time;
+extern ngx_str_t  ngx_cached_err_log_time;
 extern ngx_str_t  ngx_cached_http_time;
 extern ngx_str_t  ngx_cached_http_log_time;
 

src/http/ngx_http_get_time.c

@@ -1,12 +0,0 @@
-
-#include <ngx_config.h>
-#include <ngx_core.h>
-
-
-size_t ngx_http_get_time(char *buf, time_t t)
-{
-    struct tm  *tp;
-
-    tp = gmtime(&t);
-    return strftime(buf, 30, "%a, %d %b %Y %H:%M:%S GMT", tp);
-}

src/http/ngx_http_header_filter.c

@@ -335,8 +335,7 @@ static int ngx_http_header_filter(ngx_http_request_t *r)
 #if (NGX_HTTP_LOG_ALL_HEADERS_OUT)
         p = h->last;
 #endif
-        h->last += ngx_http_get_time(h->last,
+        h->last += ngx_http_time(h->last, r->headers_out.last_modified_time);
-                                     r->headers_out.last_modified_time);
 
 #if (NGX_HTTP_LOG_ALL_HEADERS_OUT)
         r->headers_out.last_modified = ngx_palloc(r->pool,

src/os/unix/ngx_files.c

@@ -14,6 +14,8 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
     ngx_log_debug(file->log, "read: %d, %x, %d, %qd" _
                   file->fd _ buf _ size _ offset);
 
+#if (HAVE_PREAD)
+
     n = pread(file->fd, buf, size, offset);
 
     if (n == -1) {
@@ -21,6 +23,24 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
         return NGX_ERROR;
     }
 
+#else
+
+    if (file->offset != offset) {
+        if (lseek(file->fd, offset, SEEK_SET) == -1) {
+            ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "lseek() failed");
+            return NGX_ERROR;
+        }
+    }
+
+    n = read(file->fd, buf, size);
+
+    if (n == -1) {
+        ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "read() failed");
+        return NGX_ERROR;
+    }
+
+#endif
+
     file->offset += n;
 
     return n;
@@ -31,6 +51,8 @@ ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
 {
     ssize_t n;
 
+#if (HAVE_PWRITE)
+
     n = pwrite(file->fd, buf, size, offset);
 
     if (n == -1) {
@@ -44,6 +66,30 @@ ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
         return NGX_ERROR;
     }
 
+#else
+
+    if (file->offset != offset) {
+        if (lseek(file->fd, offset, SEEK_SET) == -1) {
+            ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "lseek() failed");
+            return NGX_ERROR;
+        }
+    }
+
+    n = write(file->fd, buf, size);
+
+    if (n == -1) {
+        ngx_log_error(NGX_LOG_CRIT, file->log, ngx_errno, "write() failed");
+        return NGX_ERROR;
+    }
+
+    if ((size_t) n != size) {
+        ngx_log_error(NGX_LOG_CRIT, file->log, 0,
+                      "write() has written only %d of %d", n, size);
+        return NGX_ERROR;
+    }
+
+#endif
+
     file->offset += n;
 
     return n;

src/os/unix/ngx_freebsd_config.h

@@ -76,6 +76,12 @@
 #endif
 
 
+/* STUB */
+#define HAVE_PREAD         1
+#define HAVE_PWRITE        1
+#define HAVE_LOCALTIME_R   1
+
+
        /* FreeBSD sendfile */
 
 #if __FreeBSD_version >= 300007

src/os/unix/ngx_time.h

@@ -20,6 +20,7 @@ typedef struct tm      ngx_tm_t;
 #define ngx_tm_mon     tm_mon
 #define ngx_tm_year    tm_year
 #define ngx_tm_wday    tm_wday
+#define ngx_tm_zone    tm_zone
 
 
 void ngx_localtime(ngx_tm_t *tm);

src/os/win32/ngx_files.c

@@ -5,9 +5,37 @@
 
 ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
 {
-    size_t n;
+    size_t      n;
+    long        high_offset;
+    ngx_err_t   err;
+    OVERLAPPED  ovlp, *povlp;
 
-    if (ReadFile(file->fd, buf, size, &n, NULL) == 0) {
+    if (ngx_win32_version < NGX_WIN_NT) {
+        high_offset = (long) (offset >> 32);
+        if (SetFilePointer(file->fd, (long) offset, &high_offset, FILE_BEGIN)
+                                                                 == 0xFFFFFFFF)
+        {
+            err = ngx_errno;
+            if (err != NO_ERROR) {
+                ngx_log_error(NGX_LOG_ERR, file->log, err,
+                              "SeekFilePointer() failed");
+                return NGX_ERROR;
+            }
+        }
+
+        povlp = NULL;
+
+    } else {
+        ovlp.Internal = 0;
+        ovlp.InternalHigh = 0;
+        ovlp.Offset = (DWORD) offset;
+        ovlp.OffsetHigh = (DWORD) (offset >> 32);
+        ovlp.hEvent = NULL;
+
+        povlp = &ovlp;
+    }
+
+    if (ReadFile(file->fd, buf, size, &n, povlp) == 0) {
         ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "ReadFile() failed");
         return NGX_ERROR;
     }
@@ -18,6 +46,25 @@ ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
 }
 
 
+/* TODO: as read file */
+
+ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset)
+{
+    size_t n;
+
+    if (WriteFile(file->fd, buf, size, &n, NULL) == 0) {
+        ngx_log_error(NGX_LOG_ERR, file->log, ngx_errno, "WriteFile() failed");
+        return NGX_ERROR;
+    }
+
+    file->offset += n;
+
+    return n;
+}
+
+
+/* TODO: log error */
+
 int ngx_file_append_mode(ngx_fd_t fd)
 {
     if (SetFilePointer(fd, 0, NULL, FILE_END) == 0xFFFFFFFF) {

src/os/win32/ngx_files.h

@@ -85,6 +85,12 @@ int ngx_file_type(char *filename, ngx_file_info_t *fi);
 ssize_t ngx_read_file(ngx_file_t *file, char *buf, size_t size, off_t offset);
 #define ngx_read_file_n             "ReadFile()"
 
+ssize_t ngx_write_file(ngx_file_t *file, char *buf, size_t size, off_t offset);
+
+ssize_t ngx_write_chain_to_file(ngx_file_t *file, ngx_chain_t *ce,
+                                off_t offset, ngx_pool_t *pool);
+
+
 
 #define STDERR_FILENO               (HANDLE) 2
 

src/os/win32/ngx_win32_config.h

@@ -2,7 +2,13 @@
 #define _NGX_WIN32_CONFIG_H_INCLUDED_
 
 
-#define WIN32 1
+#define WIN32       1
+
+/* STUB */
+#define NGX_WIN_NT  200000
+extern int  ngx_win32_version;
+/**/
+
 
 
 #include <winsock2.h>
@@ -12,8 +18,6 @@
 #include <stdlib.h>
 #include <stdarg.h>
 
-#include <time.h>      /* gmtime, strftime */
-
 
 #define ngx_inline   __inline