Mercurial > hg > nginx-quic

comparison src/event/ngx_event_posted.c @ 374:213f17e9f776

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
nginx-0.0.7-2004-07-02-09:47:00 import
author Igor Sysoev <igor@sysoev.ru>
date Fri, 02 Jul 2004 05:47:00 +0000
parents 018569a8f09c
children 744ccb59062d
comparison
equal deleted inserted replaced
373:018569a8f09c 374:213f17e9f776
74 if (ev == NULL) { 74 if (ev == NULL) {
75 ngx_mutex_unlock(ngx_posted_events_mutex); 75 ngx_mutex_unlock(ngx_posted_events_mutex);
76 return NGX_OK; 76 return NGX_OK;
77 } 77 }
78 78
79 ngx_log_debug2(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
80 "posted event lock:%d " PTR_FMT,
81 *(ev->lock), ev->lock);
82
79 if (ngx_trylock(ev->lock) == 0) { 83 if (ngx_trylock(ev->lock) == 0) {
80 84
81 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0, 85 ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle->log, 0,
82 "posted event " PTR_FMT " is busy", ev); 86 "posted event " PTR_FMT " is busy", ev);
83 87
105 ev = ev->next; 109 ev = ev->next;
106 110
107 continue; 111 continue;
108 } 112 }
109 113
110 ngx_mutex_unlock(ngx_posted_events_mutex); 114 ev->locked = 1;
111 115
112 if (ev->posted) { 116 if (ev->posted) {
117 ev->ready = ev->posted_ready;
118 ev->timedout = ev->posted_timedout;
119 ev->available = ev->posted_available;
120 ev->kq_eof = ev->posted_eof;
121 #if (HAVE_KQUEUE)
122 ev->kq_errno = ev->posted_errno;
123 #endif
113 ev->posted = 0; 124 ev->posted = 0;
114 if (!ev->timedout) {
115 ev->ready = 1;
116 }
117 } 125 }
126
127 ngx_mutex_unlock(ngx_posted_events_mutex);
118 128
119 ev->event_handler(ev); 129 ev->event_handler(ev);
120 130
121 ngx_unlock(ev->lock);
122
123 if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) { 131 if (ngx_mutex_lock(ngx_posted_events_mutex) == NGX_ERROR) {
124 return NGX_ERROR; 132 return NGX_ERROR;
133 }
134
135 if (ev->locked) {
136 ngx_unlock(ev->lock);
125 } 137 }
126 138
127 break; 139 break;
128 } 140 }
129 } 141 }