Mercurial > hg > nginx-quic
view src/os/unix/ngx_pthread_thread.c @ 5110:0bbdd966a383
Request body: next upstream fix.
After introduction of chunked request body handling in 1.3.9 (r4931),
r->request_body->bufs buffers have b->start pointing to original buffer
start (and b->pos pointing to real data of this particular buffer).
While this is ok as per se, it caused bad things (usually original request
headers included before the request body) after reinit of the request
chain in ngx_http_upstream_reinit() while sending the request to a next
upstream server (which used to do b->pos = b->start for each buffer
in the request chain).
Patch by Piotr Sikora.
author | Maxim Dounin <mdounin@mdounin.ru> |
---|---|
date | Thu, 14 Mar 2013 12:28:53 +0000 |
parents | d620f497c50f |
children |
line wrap: on
line source
/* * Copyright (C) Igor Sysoev * Copyright (C) Nginx, Inc. */ #include <ngx_config.h> #include <ngx_core.h> static ngx_uint_t nthreads; static ngx_uint_t max_threads; static pthread_attr_t thr_attr; ngx_err_t ngx_create_thread(ngx_tid_t *tid, ngx_thread_value_t (*func)(void *arg), void *arg, ngx_log_t *log) { int err; if (nthreads >= max_threads) { ngx_log_error(NGX_LOG_CRIT, log, 0, "no more than %ui threads can be created", max_threads); return NGX_ERROR; } err = pthread_create(tid, &thr_attr, func, arg); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, log, err, "pthread_create() failed"); return err; } ngx_log_debug1(NGX_LOG_DEBUG_CORE, log, 0, "thread is created: " NGX_TID_T_FMT, *tid); nthreads++; return err; } ngx_int_t ngx_init_threads(int n, size_t size, ngx_cycle_t *cycle) { int err; max_threads = n; err = pthread_attr_init(&thr_attr); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cycle->log, err, "pthread_attr_init() failed"); return NGX_ERROR; } err = pthread_attr_setstacksize(&thr_attr, size); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cycle->log, err, "pthread_attr_setstacksize() failed"); return NGX_ERROR; } ngx_threaded = 1; return NGX_OK; } ngx_mutex_t * ngx_mutex_init(ngx_log_t *log, ngx_uint_t flags) { int err; ngx_mutex_t *m; m = ngx_alloc(sizeof(ngx_mutex_t), log); if (m == NULL) { return NULL; } m->log = log; err = pthread_mutex_init(&m->mutex, NULL); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, m->log, err, "pthread_mutex_init() failed"); return NULL; } return m; } void ngx_mutex_destroy(ngx_mutex_t *m) { int err; err = pthread_mutex_destroy(&m->mutex); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, m->log, err, "pthread_mutex_destroy(%p) failed", m); } ngx_free(m); } void ngx_mutex_lock(ngx_mutex_t *m) { int err; if (!ngx_threaded) { return; } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "lock mutex %p", m); err = pthread_mutex_lock(&m->mutex); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, m->log, err, "pthread_mutex_lock(%p) failed", m); ngx_abort(); } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "mutex %p is locked", m); return; } ngx_int_t ngx_mutex_trylock(ngx_mutex_t *m) { int err; if (!ngx_threaded) { return NGX_OK; } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "try lock mutex %p", m); err = pthread_mutex_trylock(&m->mutex); if (err == NGX_EBUSY) { return NGX_AGAIN; } if (err != 0) { ngx_log_error(NGX_LOG_ALERT, m->log, err, "pthread_mutex_trylock(%p) failed", m); ngx_abort(); } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "mutex %p is locked", m); return NGX_OK; } void ngx_mutex_unlock(ngx_mutex_t *m) { int err; if (!ngx_threaded) { return; } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "unlock mutex %p", m); err = pthread_mutex_unlock(&m->mutex); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, m->log, err, "pthread_mutex_unlock(%p) failed", m); ngx_abort(); } ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "mutex %p is unlocked", m); return; } ngx_cond_t * ngx_cond_init(ngx_log_t *log) { int err; ngx_cond_t *cv; cv = ngx_alloc(sizeof(ngx_cond_t), log); if (cv == NULL) { return NULL; } cv->log = log; err = pthread_cond_init(&cv->cond, NULL); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cv->log, err, "pthread_cond_init() failed"); return NULL; } return cv; } void ngx_cond_destroy(ngx_cond_t *cv) { int err; err = pthread_cond_destroy(&cv->cond); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cv->log, err, "pthread_cond_destroy(%p) failed", cv); } ngx_free(cv); } ngx_int_t ngx_cond_wait(ngx_cond_t *cv, ngx_mutex_t *m) { int err; ngx_log_debug1(NGX_LOG_DEBUG_CORE, cv->log, 0, "cv %p wait", cv); err = pthread_cond_wait(&cv->cond, &m->mutex); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cv->log, err, "pthread_cond_wait(%p) failed", cv); return NGX_ERROR; } ngx_log_debug1(NGX_LOG_DEBUG_CORE, cv->log, 0, "cv %p is waked up", cv); ngx_log_debug1(NGX_LOG_DEBUG_MUTEX, m->log, 0, "mutex %p is locked", m); return NGX_OK; } ngx_int_t ngx_cond_signal(ngx_cond_t *cv) { int err; ngx_log_debug1(NGX_LOG_DEBUG_CORE, cv->log, 0, "cv %p to signal", cv); err = pthread_cond_signal(&cv->cond); if (err != 0) { ngx_log_error(NGX_LOG_ALERT, cv->log, err, "pthread_cond_signal(%p) failed", cv); return NGX_ERROR; } ngx_log_debug1(NGX_LOG_DEBUG_CORE, cv->log, 0, "cv %p is signaled", cv); return NGX_OK; }