nginx-0.0.7-2004-06-27-22:01:57 import

7 files changed, 113 insertions, 63 deletions

diff --git a/src/core/ngx_atomic.h b/src/core/ngx_atomic.h
index 5511ea765..bbf4a7685 100644
--- a/src/core/ngx_atomic.h
+++ b/src/core/ngx_atomic.h
@@ -93,4 +93,18 @@ typedef volatile uint32_t  ngx_atomic_t;
 #endif
 
 
+static ngx_inline ngx_int_t ngx_trylock(ngx_atomic_t *lock)
+{
+    if (*lock) {
+        return NGX_BUSY;
+    }
+
+    if (ngx_atomic_cmp_set(lock, 0, 1)) {
+        return NGX_OK;
+    }
+
+    return NGX_BUSY;
+}
+
+
 #endif /* _NGX_ATOMIC_H_INCLUDED_ */
diff --git a/src/core/ngx_config.h b/src/core/ngx_config.h
index 465e1bfe1..a6e5b092a 100644
--- a/src/core/ngx_config.h
+++ b/src/core/ngx_config.h
@@ -75,10 +75,6 @@ typedef long               ngx_flag_t;
 /* TODO: auto */
 #define NGX_INT32_LEN      sizeof("-2147483648") - 1
 #define NGX_INT64_LEN      sizeof("-9223372036854775808") - 1
-#if 0
-#define NGX_TIME_T_LEN     sizeof("-2147483648") - 1
-#endif
-#define NGX_TIME_T_LEN     sizeof("-9223372036854775808") - 1
 #define NGX_OFF_T_LEN      sizeof("-9223372036854775808") - 1
 
 
diff --git a/src/core/ngx_connection.h b/src/core/ngx_connection.h
index 67275bd5e..09684c53f 100644
--- a/src/core/ngx_connection.h
+++ b/src/core/ngx_connection.h
@@ -108,6 +108,10 @@ struct ngx_connection_s {
 #if (HAVE_IOCP)
     unsigned          accept_context_updated:1;
 #endif
+
+#if (NGX_THREADS)
+    ngx_atomic_t      lock;
+#endif
 };
 
 
diff --git a/src/core/ngx_core.h b/src/core/ngx_core.h
index ed6e3737a..58b1d1238 100644
--- a/src/core/ngx_core.h
+++ b/src/core/ngx_core.h
@@ -15,6 +15,15 @@ typedef struct ngx_event_s       ngx_event_t;
 typedef struct ngx_connection_s  ngx_connection_t;
 
 
+#define  NGX_OK          0
+#define  NGX_ERROR      -1
+#define  NGX_AGAIN      -2
+#define  NGX_BUSY       -3
+#define  NGX_DONE       -4
+#define  NGX_DECLINED   -5
+#define  NGX_ABORT      -6
+
+
 #include <ngx_atomic.h>
 #include <ngx_time.h>
 #include <ngx_socket.h>
@@ -49,16 +58,6 @@ typedef struct ngx_connection_s  ngx_connection_t;
 #include <ngx_connection.h>
 
 
-
-#define  NGX_OK          0
-#define  NGX_ERROR      -1
-#define  NGX_AGAIN      -2
-#define  NGX_BUSY       -3
-#define  NGX_DONE       -4
-#define  NGX_DECLINED   -5
-#define  NGX_ABORT      -6
-
-
 #define LF     (u_char) 10
 #define CR     (u_char) 13
 #define CRLF   "\x0d\x0a"
diff --git a/src/core/ngx_garbage_collector.c b/src/core/ngx_garbage_collector.c
index 3b673300f..924f11add 100644
--- a/src/core/ngx_garbage_collector.c
+++ b/src/core/ngx_garbage_collector.c
@@ -254,7 +254,7 @@ int ngx_garbage_collector_temp_handler(ngx_gc_t *ctx, ngx_str_t *name,
      *    Unices have the mount option "noatime".
      */
 
-    if (ngx_cached_time - ngx_de_mtime(dir) < 3600) {
+    if (ngx_time() - ngx_de_mtime(dir) < 3600) {
         return NGX_OK;
     }
 
diff --git a/src/core/ngx_times.c b/src/core/ngx_times.c
index aa461c56f..2717d5c5b 100644
--- a/src/core/ngx_times.c
+++ b/src/core/ngx_times.c
@@ -3,32 +3,62 @@
 #include <ngx_core.h>
 
 
+ngx_epoch_msec_t  ngx_elapsed_msec;
+ngx_epoch_msec_t  ngx_old_elapsed_msec;
+ngx_epoch_msec_t  ngx_start_msec;
+
+static ngx_tm_t   ngx_cached_gmtime;
+static ngx_int_t  ngx_gmtoff;
+
+
+/*
+ * In the threaded mode only one thread updates cached time and strings
+ * and these operations are protected by the mutex.  The reading of the cached
+ * time and strings is not protected by the mutex.  To avoid the race
+ * conditions for non-atomic values we use the NGX_TIME_SLOTS slots to store
+ * time value and strings.  Thus thread may get the corrupted values only
+ * if it is preempted while copying and then it is not scheduled to run
+ * more than NGX_TIME_SLOTS seconds.
+ */
+
 #if (NGX_THREADS)
-static ngx_mutex_t  *ngx_time_mutex;
+
+#define NGX_TIME_SLOTS  60
+static ngx_uint_t       slot = NGX_TIME_SLOTS;
+
+static ngx_mutex_t     *ngx_time_mutex;
+
+#else
+
+#define NGX_TIME_SLOTS  1
+#define slot            0
+
 #endif
 
 
-ngx_epoch_msec_t    ngx_elapsed_msec;
-ngx_epoch_msec_t    ngx_old_elapsed_msec;
-ngx_epoch_msec_t    ngx_start_msec;
+#if (NGX_THREADS && (TIME_T_SIZE > SIG_ATOMIC_T_SIZE))
 
-volatile time_t     ngx_cached_time;
+volatile time_t  *ngx_cached_time;
+static time_t     cached_time[NGX_TIME_SLOTS];
 
-volatile ngx_str_t  ngx_cached_err_log_time;
-volatile ngx_str_t  ngx_cached_http_time;
-volatile ngx_str_t  ngx_cached_http_log_time;
+#else
+
+volatile time_t   ngx_cached_time;
+
+#endif
 
-static ngx_tm_t     ngx_cached_gmtime;
-static ngx_int_t    ngx_gmtoff;
 
-static u_char       cached_err_log_time0[] = "1970/09/28 12:00:00";
-static u_char       cached_err_log_time1[] = "1970/09/28 12:00:00";
+ngx_thread_volatile ngx_str_t  ngx_cached_err_log_time;
+ngx_thread_volatile ngx_str_t  ngx_cached_http_time;
+ngx_thread_volatile ngx_str_t  ngx_cached_http_log_time;
 
-static u_char       cached_http_time0[] = "Mon, 28 Sep 1970 06:00:00 GMT";
-static u_char       cached_http_time1[] = "Mon, 28 Sep 1970 06:00:00 GMT";
 
-static u_char       cached_http_log_time0[] = "28/Sep/1970:12:00:00 +0600";
-static u_char       cached_http_log_time1[] = "28/Sep/1970:12:00:00 +0600";
+static u_char  cached_err_log_time[NGX_TIME_SLOTS]
+                                               [sizeof("1970/09/28 12:00:00")];
+static u_char  cached_http_time[NGX_TIME_SLOTS]
+                                     [sizeof("Mon, 28 Sep 1970 06:00:00 GMT")];
+static u_char  cached_http_log_time[NGX_TIME_SLOTS]
+                                        [sizeof("28/Sep/1970:12:00:00 +0600")];
 
 
 static char  *week[] = { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" };
@@ -45,16 +75,13 @@ void ngx_time_init()
     ngx_cached_gmtime.ngx_tm_zone = "GMT";
 #endif
 
-    ngx_cached_err_log_time.len = sizeof(cached_err_log_time0) - 1;
-    ngx_cached_err_log_time.data = cached_err_log_time0;
+    ngx_cached_err_log_time.len = sizeof("1970/09/28 12:00:00") - 1;
+    ngx_cached_http_time.len = sizeof("Mon, 28 Sep 1970 06:00:00 GMT") - 1;
+    ngx_cached_http_log_time.len = sizeof("28/Sep/1970:12:00:00 +0600") - 1;
 
-    ngx_cached_http_time.len = sizeof(cached_http_time0) - 1;
-    ngx_cached_http_time.data = cached_http_time0;
-
-    ngx_cached_http_log_time.len = sizeof(cached_http_log_time0) - 1;
-    ngx_cached_http_log_time.data = cached_http_log_time0;
-
-    ngx_cached_time = 0;
+#if (TIME_T_SIZE > SIG_ATOMIC_T_SIZE)
+    ngx_cached_time = &cached_time[0];
+#endif
 
     ngx_gettimeofday(&tv);
 
@@ -89,26 +116,34 @@ void ngx_time_update(time_t s)
     u_char    *p;
     ngx_tm_t   tm;
 
-    if (ngx_cached_time == s) {
+    if (ngx_time() == s) {
         return;
     }
 
 #if (NGX_THREADS)
+
     if (ngx_mutex_trylock(ngx_time_mutex) != NGX_OK) {
         return;
     }
+
+    if (slot == NGX_TIME_SLOTS) {
+        slot = 0;
+    } else {
+        slot++;
+    }
+
+#if (TIME_T_SIZE > SIG_ATOMIC_T_SIZE)
+    ngx_cached_time = &cached_time[slot];
 #endif
 
-    ngx_cached_time = s;
+#endif
 
-    ngx_gmtime(ngx_cached_time, &ngx_cached_gmtime);
+    ngx_time() = s;
 
+    ngx_gmtime(s, &ngx_cached_gmtime);
 
-    if (ngx_cached_http_time.data == cached_http_time0) {
-        p = cached_http_time1;
-    } else {
-        p = cached_http_time0;
-    }
+
+    p = cached_http_time[slot];
 
     ngx_snprintf((char *) p, sizeof("Mon, 28 Sep 1970 06:00:00 GMT"),
                  "%s, %02d %s %4d %02d:%02d:%02d GMT",
@@ -126,7 +161,7 @@ void ngx_time_update(time_t s)
 #if (HAVE_GETTIMEZONE)
 
     ngx_gmtoff = ngx_gettimezone();
-    ngx_gmtime(ngx_cached_time + ngx_gmtoff * 60, &tm);
+    ngx_gmtime(s + ngx_gmtoff * 60, &tm);
 
 #elif (HAVE_GMTOFF)
 
@@ -141,11 +176,7 @@ void ngx_time_update(time_t s)
 #endif
 
 
-    if (ngx_cached_err_log_time.data == cached_err_log_time0) {
-        p = cached_err_log_time1;
-    } else {
-        p = cached_err_log_time0;
-    }
+    p = cached_err_log_time[slot];
 
     ngx_snprintf((char *) p, sizeof("1970/09/28 12:00:00"),
                  "%4d/%02d/%02d %02d:%02d:%02d",
@@ -156,11 +187,7 @@ void ngx_time_update(time_t s)
     ngx_cached_err_log_time.data = p;
 
 
-    if (ngx_cached_http_log_time.data == cached_http_log_time0) {
-        p = cached_http_log_time1;
-    } else {
-        p = cached_http_log_time0;
-    }
+    p = cached_http_log_time[slot];
 
     ngx_snprintf((char *) p, sizeof("28/Sep/1970:12:00:00 +0600"),
                  "%02d/%s/%d:%02d:%02d:%02d %c%02d%02d",
diff --git a/src/core/ngx_times.h b/src/core/ngx_times.h
index 8fdf685df..1fb712d44 100644
--- a/src/core/ngx_times.h
+++ b/src/core/ngx_times.h
@@ -7,17 +7,27 @@
 
 
 void ngx_time_init();
-#if (NGX_THREADS)
-ngx_int_t ngx_time_mutex_init(ngx_log_t *log);
-#endif
 void ngx_time_update(time_t s);
 size_t ngx_http_time(u_char *buf, time_t t);
 void ngx_gmtime(time_t t, ngx_tm_t *tp);
 
-#define ngx_time()   ngx_cached_time
+#if (NGX_THREADS)
+ngx_int_t ngx_time_mutex_init(ngx_log_t *log);
+#endif
+
+#if (NGX_THREADS && (TIME_T_SIZE > SIG_ATOMIC_T_SIZE))
+
+#define ngx_time()        *ngx_cached_time
+extern volatile time_t    *ngx_cached_time;
 
+#else
 
+#define ngx_time()         ngx_cached_time
 extern volatile time_t     ngx_cached_time;
+
+#endif
+
+
 extern volatile ngx_str_t  ngx_cached_err_log_time;
 extern volatile ngx_str_t  ngx_cached_http_time;
 extern volatile ngx_str_t  ngx_cached_http_log_time;