mirror of
https://github.com/nginx/nginx.git
synced 2025-06-11 04:12:40 +08:00
Removed stub implementation of win32 mutexes.
This commit is contained in:
parent
090fb6f3fb
commit
07de3f538b
@ -835,8 +835,6 @@ ngx_get_connection(ngx_socket_t s, ngx_log_t *log)
|
|||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* ngx_mutex_lock */
|
|
||||||
|
|
||||||
c = ngx_cycle->free_connections;
|
c = ngx_cycle->free_connections;
|
||||||
|
|
||||||
if (c == NULL) {
|
if (c == NULL) {
|
||||||
@ -849,16 +847,12 @@ ngx_get_connection(ngx_socket_t s, ngx_log_t *log)
|
|||||||
"%ui worker_connections are not enough",
|
"%ui worker_connections are not enough",
|
||||||
ngx_cycle->connection_n);
|
ngx_cycle->connection_n);
|
||||||
|
|
||||||
/* ngx_mutex_unlock */
|
|
||||||
|
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
ngx_cycle->free_connections = c->data;
|
ngx_cycle->free_connections = c->data;
|
||||||
ngx_cycle->free_connection_n--;
|
ngx_cycle->free_connection_n--;
|
||||||
|
|
||||||
/* ngx_mutex_unlock */
|
|
||||||
|
|
||||||
if (ngx_cycle->files) {
|
if (ngx_cycle->files) {
|
||||||
ngx_cycle->files[s] = c;
|
ngx_cycle->files[s] = c;
|
||||||
}
|
}
|
||||||
@ -896,14 +890,10 @@ ngx_get_connection(ngx_socket_t s, ngx_log_t *log)
|
|||||||
void
|
void
|
||||||
ngx_free_connection(ngx_connection_t *c)
|
ngx_free_connection(ngx_connection_t *c)
|
||||||
{
|
{
|
||||||
/* ngx_mutex_lock */
|
|
||||||
|
|
||||||
c->data = ngx_cycle->free_connections;
|
c->data = ngx_cycle->free_connections;
|
||||||
ngx_cycle->free_connections = c;
|
ngx_cycle->free_connections = c;
|
||||||
ngx_cycle->free_connection_n++;
|
ngx_cycle->free_connection_n++;
|
||||||
|
|
||||||
/* ngx_mutex_unlock */
|
|
||||||
|
|
||||||
if (ngx_cycle->files) {
|
if (ngx_cycle->files) {
|
||||||
ngx_cycle->files[c->fd] = NULL;
|
ngx_cycle->files[c->fd] = NULL;
|
||||||
}
|
}
|
||||||
|
@ -44,8 +44,6 @@ typedef struct ngx_http_upstream_rr_peers_s ngx_http_upstream_rr_peers_t;
|
|||||||
struct ngx_http_upstream_rr_peers_s {
|
struct ngx_http_upstream_rr_peers_s {
|
||||||
ngx_uint_t number;
|
ngx_uint_t number;
|
||||||
|
|
||||||
/* ngx_mutex_t *mutex; */
|
|
||||||
|
|
||||||
ngx_uint_t total_weight;
|
ngx_uint_t total_weight;
|
||||||
|
|
||||||
unsigned single:1;
|
unsigned single:1;
|
||||||
|
@ -67,44 +67,3 @@ ngx_thread_set_tls(ngx_tls_key_t *key, void *data)
|
|||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
ngx_mutex_t *
|
|
||||||
ngx_mutex_init(ngx_log_t *log, ngx_uint_t flags)
|
|
||||||
{
|
|
||||||
ngx_mutex_t *m;
|
|
||||||
|
|
||||||
m = ngx_alloc(sizeof(ngx_mutex_t), log);
|
|
||||||
if (m == NULL) {
|
|
||||||
return NULL;
|
|
||||||
}
|
|
||||||
|
|
||||||
m->log = log;
|
|
||||||
|
|
||||||
/* STUB */
|
|
||||||
|
|
||||||
return m;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
/* STUB */
|
|
||||||
|
|
||||||
void
|
|
||||||
ngx_mutex_lock(ngx_mutex_t *m) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
ngx_int_t
|
|
||||||
ngx_mutex_trylock(ngx_mutex_t *m) {
|
|
||||||
return NGX_OK;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
void
|
|
||||||
ngx_mutex_unlock(ngx_mutex_t *m) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**/
|
|
||||||
|
@ -18,12 +18,6 @@ typedef DWORD ngx_tls_key_t;
|
|||||||
typedef DWORD ngx_thread_value_t;
|
typedef DWORD ngx_thread_value_t;
|
||||||
|
|
||||||
|
|
||||||
typedef struct {
|
|
||||||
HANDLE mutex;
|
|
||||||
ngx_log_t *log;
|
|
||||||
} ngx_mutex_t;
|
|
||||||
|
|
||||||
|
|
||||||
ngx_err_t ngx_create_thread(ngx_tid_t *tid,
|
ngx_err_t ngx_create_thread(ngx_tid_t *tid,
|
||||||
ngx_thread_value_t (__stdcall *func)(void *arg), void *arg, ngx_log_t *log);
|
ngx_thread_value_t (__stdcall *func)(void *arg), void *arg, ngx_log_t *log);
|
||||||
ngx_int_t ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle);
|
ngx_int_t ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle);
|
||||||
@ -34,25 +28,10 @@ ngx_err_t ngx_thread_set_tls(ngx_tls_key_t *key, void *data);
|
|||||||
#define ngx_thread_set_tls_n "TlsSetValue()"
|
#define ngx_thread_set_tls_n "TlsSetValue()"
|
||||||
#define ngx_thread_get_tls TlsGetValue
|
#define ngx_thread_get_tls TlsGetValue
|
||||||
|
|
||||||
|
|
||||||
#define ngx_thread_volatile volatile
|
|
||||||
|
|
||||||
#define ngx_log_tid GetCurrentThreadId()
|
#define ngx_log_tid GetCurrentThreadId()
|
||||||
#define NGX_TID_T_FMT "%ud"
|
#define NGX_TID_T_FMT "%ud"
|
||||||
|
|
||||||
|
|
||||||
ngx_mutex_t *ngx_mutex_init(ngx_log_t *log, ngx_uint_t flags);
|
|
||||||
|
|
||||||
void ngx_mutex_lock(ngx_mutex_t *m);
|
|
||||||
ngx_int_t ngx_mutex_trylock(ngx_mutex_t *m);
|
|
||||||
void ngx_mutex_unlock(ngx_mutex_t *m);
|
|
||||||
|
|
||||||
|
|
||||||
/* STUB */
|
|
||||||
#define NGX_MUTEX_LIGHT 0
|
|
||||||
/**/
|
|
||||||
|
|
||||||
|
|
||||||
extern ngx_int_t ngx_threads_n;
|
extern ngx_int_t ngx_threads_n;
|
||||||
|
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user