diff options
author | cjihrig <cjihrig@gmail.com> | 2018-08-16 22:14:55 -0400 |
---|---|---|
committer | cjihrig <cjihrig@gmail.com> | 2018-08-20 08:39:30 -0400 |
commit | 4e7d82945dfc3f9e264c258ef29c45910b7fd8bc (patch) | |
tree | 5f0cd0d759bc8e5075b672b3d410757103330ca8 /deps/uv/src/unix/stream.c | |
parent | 95b0e2c1331415e18d171d60d843a2c1328ffbe3 (diff) | |
download | android-node-v8-4e7d82945dfc3f9e264c258ef29c45910b7fd8bc.tar.gz android-node-v8-4e7d82945dfc3f9e264c258ef29c45910b7fd8bc.tar.bz2 android-node-v8-4e7d82945dfc3f9e264c258ef29c45910b7fd8bc.zip |
deps: upgrade to libuv 1.23.0
Notable changes:
- Restores compatibility with the old IPC protocol.
- Adds uv_open_osfhandle().
- Adds uv_os_{get,set}priority().
PR-URL: https://github.com/nodejs/node/pull/22365
Fixes: https://github.com/nodejs/node/issues/21671
Fixes: https://github.com/nodejs/node/issues/15433
Refs: https://github.com/nodejs/node/pull/21675
Refs: https://github.com/nodejs/node-addon-api/issues/304
Refs: https://github.com/nodejs/abi-stable-node/issues/318
Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Diffstat (limited to 'deps/uv/src/unix/stream.c')
-rw-r--r-- | deps/uv/src/unix/stream.c | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/deps/uv/src/unix/stream.c b/deps/uv/src/unix/stream.c index 4d62a23f1b..5a96b66b17 100644 --- a/deps/uv/src/unix/stream.c +++ b/deps/uv/src/unix/stream.c @@ -950,10 +950,16 @@ error: static void uv__write_callbacks(uv_stream_t* stream) { uv_write_t* req; QUEUE* q; + QUEUE pq; - while (!QUEUE_EMPTY(&stream->write_completed_queue)) { + if (QUEUE_EMPTY(&stream->write_completed_queue)) + return; + + QUEUE_MOVE(&stream->write_completed_queue, &pq); + + while (!QUEUE_EMPTY(&pq)) { /* Pop a req off write_completed_queue. */ - q = QUEUE_HEAD(&stream->write_completed_queue); + q = QUEUE_HEAD(&pq); req = QUEUE_DATA(q, uv_write_t, queue); QUEUE_REMOVE(q); uv__req_unregister(stream->loop, req); @@ -969,8 +975,6 @@ static void uv__write_callbacks(uv_stream_t* stream) { if (req->cb) req->cb(req, req->error); } - - assert(QUEUE_EMPTY(&stream->write_completed_queue)); } |