| /third_party/libuv/test/ |
| D | test-shutdown-close.c | 31 static uv_shutdown_t shutdown_req; variable
40 ASSERT(req == &shutdown_req); in shutdown_cb()
57 r = uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in connect_cb()
|
| D | blackhole-server.c | 30 uv_shutdown_t shutdown_req; member
83 r = uv_shutdown(&conn->shutdown_req, stream, shutdown_cb); in read_cb()
89 conn_rec* conn = container_of(req, conn_rec, shutdown_req); in shutdown_cb()
|
| D | test-shutdown-simultaneous.c | 29 static uv_shutdown_t shutdown_req; variable
45 ASSERT_PTR_EQ(req, &shutdown_req); in shutdown_cb()
68 uv_shutdown(&shutdown_req, (uv_stream_t*) &tcp, shutdown_cb); in read_cb()
|
| D | test-tcp-open.c | 39 static uv_shutdown_t shutdown_req; variable
105 ASSERT(req == &shutdown_req); in shutdown_cb()
179 r = uv_shutdown(&shutdown_req, (uv_stream_t*) &client, shutdown_cb); in timer_cb()
200 r = uv_shutdown(&shutdown_req, stream, shutdown_cb); in connect_cb()
354 ASSERT(0 == uv_shutdown(&shutdown_req, (uv_stream_t*) &client, shutdown_cb)); in TEST_IMPL()
|
| D | test-tcp-writealot.c | 49 static uv_shutdown_t shutdown_req; variable
68 ASSERT(req == &shutdown_req); in shutdown_cb()
138 r = uv_shutdown(&shutdown_req, stream, shutdown_cb); in connect_cb()
|
| D | test-shutdown-eof.c | 31 static uv_shutdown_t shutdown_req; variable
75 ASSERT(req == &shutdown_req); in shutdown_cb()
107 uv_shutdown(&shutdown_req, (uv_stream_t*) &tcp, shutdown_cb); in connect_cb()
|
| D | test-not-writable-after-shutdown.c | 25 static uv_shutdown_t shutdown_req; variable
39 r = uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in connect_cb()
|
| D | test-ref.c | 30 static uv_shutdown_t shutdown_req; variable
72 ASSERT(req == &shutdown_req); in shutdown_cb()
79 uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in write_cb()
97 uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in connect_and_shutdown()
|
| D | test-tcp-close-reset.c | 33 static uv_shutdown_t shutdown_req; variable
66 ASSERT(0 == uv_shutdown(&shutdown_req, (uv_stream_t*) handle, shutdown_cb)); in do_close()
70 ASSERT(UV_ENOTCONN == uv_shutdown(&shutdown_req, (uv_stream_t*) handle, shutdown_cb)); in do_close()
|
| D | test-tcp-shutdown-after-write.c | 32 static uv_shutdown_t shutdown_req; variable
71 r = uv_shutdown(&shutdown_req, (uv_stream_t*)&conn, shutdown_cb); in timer_cb()
|
| D | benchmark-tcp-write-batch.c | 40 static uv_shutdown_t shutdown_req; variable
66 r = uv_shutdown(&shutdown_req, req->handle, shutdown_cb); in connect_cb()
|
| D | test-callback-stack.c | 37 static uv_shutdown_t shutdown_req; variable
99 if (uv_shutdown(&shutdown_req, (uv_stream_t*)tcp, shutdown_cb)) { in read_cb()
|
| D | test-ipc-heavy-traffic-deadlock-bug.c | 44 static uv_shutdown_t shutdown_req; variable
107 r = uv_shutdown(&shutdown_req, handle, shutdown_cb); in read_cb()
|
| D | benchmark-ping-pongs.c | 37 uv_shutdown_t shutdown_req; member
152 uv_shutdown(&pinger->shutdown_req, in pinger_read_cb()
|
| D | test-tcp-bind-error.c | 267 uv_shutdown_t shutdown_req; in TEST_IMPL() local
284 r = uv_shutdown(&shutdown_req, (uv_stream_t*) &server, NULL); in TEST_IMPL()
|
| /third_party/libuv/src/unix/ |
| D | stream.c | 82 stream->shutdown_req = NULL; in uv__stream_init()
457 if (stream->shutdown_req) { in uv__stream_destroy()
463 uv__req_unregister(stream->loop, stream->shutdown_req); in uv__stream_destroy()
464 stream->shutdown_req->cb(stream->shutdown_req, UV_ECANCELED); in uv__stream_destroy()
465 stream->shutdown_req = NULL; in uv__stream_destroy()
677 assert(stream->shutdown_req); in uv__drain()
679 req = stream->shutdown_req; in uv__drain()
680 stream->shutdown_req = NULL; in uv__drain()
1285 stream->shutdown_req = req; in uv_shutdown()
|
| D | pipe.c | 35 handle->shutdown_req = NULL; in uv_pipe_init()
|
| /third_party/libuv/src/win/ |
| D | stream-inl.h | 39 handle->stream.conn.shutdown_req = NULL; in uv__stream_init()
|
| D | tty.c | 2241 if (handle->stream.conn.shutdown_req != NULL &&
2273 handle->stream.conn.shutdown_req != NULL &&
2275 UNREGISTER_HANDLE_REQ(loop, handle, handle->stream.conn.shutdown_req);
2278 if (handle->stream.conn.shutdown_req->cb) {
2280 handle->stream.conn.shutdown_req->cb(handle->stream.conn.shutdown_req, UV_ECANCELED);
2282 handle->stream.conn.shutdown_req->cb(handle->stream.conn.shutdown_req, 0);
2286 handle->stream.conn.shutdown_req = NULL;
|
| D | tcp.c | 214 handle->stream.conn.shutdown_req != NULL && in uv__tcp_endgame()
217 UNREGISTER_HANDLE_REQ(loop, handle, handle->stream.conn.shutdown_req); in uv__tcp_endgame()
226 if (handle->stream.conn.shutdown_req->cb) { in uv__tcp_endgame()
227 handle->stream.conn.shutdown_req->cb(handle->stream.conn.shutdown_req, in uv__tcp_endgame()
231 handle->stream.conn.shutdown_req = NULL; in uv__tcp_endgame()
1163 if (handle->stream.conn.shutdown_req != NULL) { in uv__process_tcp_write_req()
|
| D | stream.c | 216 handle->stream.conn.shutdown_req = req; in uv_shutdown()
|
| D | pipe.c | 591 handle->stream.conn.shutdown_req != NULL && in uv__pipe_endgame()
593 req = handle->stream.conn.shutdown_req; in uv__pipe_endgame()
596 handle->stream.conn.shutdown_req = NULL; in uv__pipe_endgame()
2097 if (handle->stream.conn.shutdown_req != NULL && in uv__process_pipe_write_req()
|
| /third_party/libuv/include/uv/ |
| D | unix.h | 288 uv_shutdown_t *shutdown_req; \
|
| D | win.h | 422 uv_shutdown_t* shutdown_req;
|
| /third_party/libuv/ |
| D | ChangeLog | 2091 * win, pipe: null-initialize stream->shutdown_req (Jameson Nash)
|