gre-ilya/libuv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

uv-unix: defer uv_pipe_connect callback to next tick

Browse Source
This commit is contained in:
Ben Noordhuis 2011-07-20 23:06:44 +02:00
parent 685c083c79
commit 332bbecd19
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/uv-unix.c
View File

@ -877,6 +877,8 @@ static void uv__stream_io(EV_P_ ev_io* watcher, int revents) {
if (stream->connect_req) { if (stream->connect_req) {
uv__stream_connect(stream); uv__stream_connect(stream);
} else { } else {
assert(revents & (EV_READ | EV_WRITE));
if (revents & EV_READ) { if (revents & EV_READ) {
uv__read((uv_stream_t*)stream); uv__read((uv_stream_t*)stream);
} }
@ -1909,15 +1911,16 @@ int uv_pipe_connect(uv_connect_t* req,
status = 0; status = 0;
out: out:
uv__req_init((uv_req_t*)req); handle->delayed_error = status; /* Passed to callback. */
handle->connect_req = req;
req->handle = (uv_stream_t*)handle; req->handle = (uv_stream_t*)handle;
req->type = UV_CONNECT; req->type = UV_CONNECT;
req->cb = cb; req->cb = cb;
ngx_queue_init(&req->queue); ngx_queue_init(&req->queue);
if (cb) { /* Run callback on next tick. */
cb(req, status); ev_feed_event(EV_DEFAULT_ &handle->read_watcher, EV_CUSTOM);
} assert(ev_is_pending(&handle->read_watcher));
/* Mimic the Windows pipe implementation, always /* Mimic the Windows pipe implementation, always
* return 0 and let the callback handle errors. * return 0 and let the callback handle errors.