Home
last modified time | relevance | path

Searched refs:send_handle (Results 1 – 24 of 24) sorted by relevance

/third_party/libuv/src/win/
Dstream.c148 uv_stream_t* send_handle, in uv_write2() argument
153 if (send_handle == NULL) { in uv_write2()
164 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
194 uv_stream_t* send_handle) { in uv_try_write2() argument
195 if (send_handle != NULL) in uv_try_write2()
Dpipe.c1524 req->send_handle = NULL; in uv__pipe_write_data()
1678 uv_stream_t* send_handle, in uv__pipe_write_ipc() argument
1698 if (send_handle != NULL) { in uv__pipe_write_ipc()
1699 uv_tcp_t* send_tcp_handle = (uv_tcp_t*) send_handle; in uv__pipe_write_ipc()
1716 if (send_handle != NULL) in uv__pipe_write_ipc()
1736 if (send_handle != NULL) { in uv__pipe_write_ipc()
1780 uv_stream_t* send_handle, in uv__pipe_write() argument
1784 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb); in uv__pipe_write()
1787 assert(send_handle == NULL); in uv__pipe_write()
Dinternal.h131 uv_stream_t* send_handle,
/third_party/libuv/src/unix/
Dstream.c791 uv_stream_t* send_handle) { in uv__try_write() argument
814 if (send_handle != NULL) { in uv__try_write()
823 if (uv__is_closing(send_handle)) in uv__try_write()
826 fd_to_send = uv__handle_fd((uv_handle_t*) send_handle); in uv__try_write()
903 req->send_handle); in uv__write()
907 req->send_handle = NULL; in uv__write()
1404 uv_stream_t* send_handle) { in uv__check_before_write() argument
1417 if (send_handle != NULL) { in uv__check_before_write()
1427 if (uv__handle_fd((uv_handle_t*) send_handle) < 0) in uv__check_before_write()
1444 uv_stream_t* send_handle, in uv_write2() argument
[all …]
/third_party/python/Lib/multiprocessing/
Dreduction.py95 def send_handle(conn, handle, destination_pid): function
181 def send_handle(conn, handle, destination_pid): function
258 send_handle = send_handle variable in AbstractReducer
Dresource_sharer.py50 reduction.send_handle(conn, new_fd, pid)
/third_party/node/src/
Dstream_base.cc193 uv_stream_t* send_handle = nullptr; in WriteBuffer() local
200 send_handle = reinterpret_cast<uv_stream_t*>(wrap->GetHandle()); in WriteBuffer()
208 StreamWriteResult res = Write(&buf, 1, send_handle, req_wrap_obj); in WriteBuffer()
297 uv_stream_t* send_handle = nullptr; in WriteString() local
302 send_handle = reinterpret_cast<uv_stream_t*>(wrap->GetHandle()); in WriteString()
310 StreamWriteResult res = Write(&buf, 1, send_handle, req_wrap_obj); in WriteString()
Dstream_base-inl.h165 uv_stream_t* send_handle, in Write() argument
175 if (send_handle == nullptr) { in Write()
197 err = DoWrite(req_wrap, bufs, count, send_handle); in Write()
Djs_stream.h29 uv_stream_t* send_handle) override;
Djs_stream.cc112 uv_stream_t* send_handle) { in DoWrite() argument
113 CHECK_NULL(send_handle); in DoWrite()
Dstream_wrap.h57 uv_stream_t* send_handle) override;
Dstream_base.h256 uv_stream_t* send_handle) = 0;
345 uv_stream_t* send_handle = nullptr,
Dstream_wrap.cc374 uv_stream_t* send_handle) { in DoWrite() argument
380 send_handle, in DoWrite()
Dtls_wrap.h77 uv_stream_t* send_handle) override;
Dtls_wrap.cc704 uv_stream_t* send_handle) { in DoWrite() argument
705 CHECK_NULL(send_handle); in DoWrite()
744 underlying_stream()->Write(bufs, count, send_handle); in DoWrite()
Dheap_utils.cc288 uv_stream_t* send_handle) override { in DoWrite() argument
Dnode_file.h269 uv_stream_t* send_handle) override;
Dnode_http2.h430 uv_stream_t* send_handle) override;
Dnode_http2.cc2239 uv_stream_t* send_handle) { in DoWrite() argument
2240 CHECK_NULL(send_handle); in DoWrite()
Dnode_file.cc192 uv_stream_t* send_handle) { in DoWrite() argument
/third_party/libuv/docs/src/
Dstream.rst97 .. c:member:: uv_stream_t* uv_write_t.send_handle
190 …eam_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb)
196 `send_handle` must be a TCP, pipe and UDP handle on Unix, or a TCP
211 …ry_write2(uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle)
/third_party/libuv/include/
Duv.h528 uv_stream_t* send_handle,
536 uv_stream_t* send_handle);
542 uv_stream_t* send_handle; /* TODO: make private and unix-only in v2.x. */ member
/third_party/python/Lib/test/
D_test_multiprocessing.py3205 reduction.send_handle(conn, fd, p.pid)
3236 reduction.send_handle(conn, newfd, p.pid)
/third_party/libuv/
DChangeLog328 * doc: more accurate list of valid send_handle's (twosee)
1710 * win,pipe: properly set uv_write_t.send_handle in uv_write2() (Bert Belder)