Home
last modified time | relevance | path

Searched refs:send_handle (Results 1 - 25 of 29) sorted by relevance

12

/third_party/libuv/src/win/
H A Dstream.c150 uv_stream_t* send_handle, in uv_write2()
155 if (send_handle == NULL) { in uv_write2()
166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
196 uv_stream_t* send_handle) { in uv_try_write2()
197 if (send_handle != NULL) in uv_try_write2()
146 uv_write2(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
H A Dpipe.c1594 req->send_handle = NULL; in uv__pipe_write_data()
1752 uv_stream_t* send_handle, in uv__pipe_write_ipc()
1772 if (send_handle != NULL) { in uv__pipe_write_ipc()
1773 uv_tcp_t* send_tcp_handle = (uv_tcp_t*) send_handle; in uv__pipe_write_ipc()
1775 /* Verify that `send_handle` it is indeed a tcp handle. */ in uv__pipe_write_ipc()
1790 if (send_handle != NULL) in uv__pipe_write_ipc()
1810 if (send_handle != NULL) { in uv__pipe_write_ipc()
1854 uv_stream_t* send_handle, in uv__pipe_write()
1858 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb); in uv__pipe_write()
1861 assert(send_handle in uv__pipe_write()
1747 uv__pipe_write_ipc(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t data_bufs[], size_t data_buf_count, uv_stream_t* send_handle, uv_write_cb cb) uv__pipe_write_ipc() argument
1849 uv__pipe_write(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t bufs[], size_t nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv__pipe_write() argument
[all...]
H A Dinternal.h136 uv_stream_t* send_handle,
/third_party/node/deps/uv/src/win/
H A Dstream.c150 uv_stream_t* send_handle, in uv_write2()
155 if (send_handle == NULL) { in uv_write2()
166 loop, req, (uv_pipe_t*) handle, bufs, nbufs, send_handle, cb); in uv_write2()
196 uv_stream_t* send_handle) { in uv_try_write2()
197 if (send_handle != NULL) in uv_try_write2()
146 uv_write2(uv_write_t* req, uv_stream_t* handle, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
193 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
H A Dpipe.c1499 req->send_handle = NULL; in uv__pipe_write_data()
1653 uv_stream_t* send_handle, in uv__pipe_write_ipc()
1673 if (send_handle != NULL) { in uv__pipe_write_ipc()
1674 uv_tcp_t* send_tcp_handle = (uv_tcp_t*) send_handle; in uv__pipe_write_ipc()
1676 /* Verify that `send_handle` it is indeed a tcp handle. */ in uv__pipe_write_ipc()
1691 if (send_handle != NULL) in uv__pipe_write_ipc()
1711 if (send_handle != NULL) { in uv__pipe_write_ipc()
1755 uv_stream_t* send_handle, in uv__pipe_write()
1759 return uv__pipe_write_ipc(loop, req, handle, bufs, nbufs, send_handle, cb); in uv__pipe_write()
1762 assert(send_handle in uv__pipe_write()
1648 uv__pipe_write_ipc(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t data_bufs[], size_t data_buf_count, uv_stream_t* send_handle, uv_write_cb cb) uv__pipe_write_ipc() argument
1750 uv__pipe_write(uv_loop_t* loop, uv_write_t* req, uv_pipe_t* handle, const uv_buf_t bufs[], size_t nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv__pipe_write() argument
[all...]
H A Dinternal.h134 uv_stream_t* send_handle,
/third_party/libuv/src/unix/
H A Dstream.c756 uv_stream_t* send_handle) { in uv__try_write()
779 if (send_handle != NULL) { in uv__try_write()
784 if (uv__is_closing(send_handle)) in uv__try_write()
787 fd_to_send = uv__handle_fd((uv_handle_t*) send_handle); in uv__try_write()
864 req->send_handle); in uv__write()
868 req->send_handle = NULL; in uv__write()
1292 uv_stream_t* send_handle) { in uv__check_before_write()
1305 if (send_handle != NULL) { in uv__check_before_write()
1315 if (uv__handle_fd((uv_handle_t*) send_handle) < 0) in uv__check_before_write()
1332 uv_stream_t* send_handle, in uv_write2()
753 uv__try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv__try_write() argument
1290 uv__check_before_write(uv_stream_t* stream, unsigned int nbufs, uv_stream_t* send_handle) uv__check_before_write() argument
1328 uv_write2(uv_write_t* req, uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
1416 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
/third_party/node/deps/uv/src/unix/
H A Dstream.c789 uv_stream_t* send_handle) { in uv__try_write()
812 if (send_handle != NULL) { in uv__try_write()
821 if (uv__is_closing(send_handle)) in uv__try_write()
824 fd_to_send = uv__handle_fd((uv_handle_t*) send_handle); in uv__try_write()
901 req->send_handle); in uv__write()
905 req->send_handle = NULL; in uv__write()
1359 uv_stream_t* send_handle) { in uv__check_before_write()
1372 if (send_handle != NULL) { in uv__check_before_write()
1382 if (uv__handle_fd((uv_handle_t*) send_handle) < 0) in uv__check_before_write()
1399 uv_stream_t* send_handle, in uv_write2()
786 uv__try_write(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv__try_write() argument
1357 uv__check_before_write(uv_stream_t* stream, unsigned int nbufs, uv_stream_t* send_handle) uv__check_before_write() argument
1395 uv_write2(uv_write_t* req, uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle, uv_write_cb cb) uv_write2() argument
1483 uv_try_write2(uv_stream_t* stream, const uv_buf_t bufs[], unsigned int nbufs, uv_stream_t* send_handle) uv_try_write2() argument
[all...]
/third_party/node/src/
H A Dstream_base.cc84 uv_stream_t* send_handle, in Write()
94 if (send_handle == nullptr && !skip_try_write) { in Write()
116 err = DoWrite(req_wrap, bufs, count, send_handle); in Write()
311 uv_stream_t* send_handle = nullptr; in WriteBuffer() local
318 send_handle = reinterpret_cast<uv_stream_t*>(wrap->GetHandle()); in WriteBuffer()
328 StreamWriteResult res = Write(&buf, 1, send_handle, req_wrap_obj); in WriteBuffer()
420 uv_stream_t* send_handle = nullptr; in WriteString() local
425 send_handle = reinterpret_cast<uv_stream_t*>(wrap->GetHandle()); in WriteString()
435 StreamWriteResult res = Write(&buf, 1, send_handle, req_wrap_obj, try_write); in WriteString()
82 Write(uv_buf_t* bufs, size_t count, uv_stream_t* send_handle, v8::Local<v8::Object> req_wrap_obj, bool skip_try_write) Write() argument
H A Djs_stream.h29 uv_stream_t* send_handle) override;
H A Djs_stream.cc113 uv_stream_t* send_handle) { in DoWrite()
114 CHECK_NULL(send_handle); in DoWrite()
110 DoWrite(WriteWrap* w, uv_buf_t* bufs, size_t count, uv_stream_t* send_handle) DoWrite() argument
H A Dstream_wrap.h58 uv_stream_t* send_handle) override;
H A Dstream_base.h263 uv_stream_t* send_handle) = 0;
358 uv_stream_t* send_handle = nullptr,
H A Dstream_wrap.cc395 uv_stream_t* send_handle) { in DoWrite()
401 send_handle, in DoWrite()
392 DoWrite(WriteWrap* req_wrap, uv_buf_t* bufs, size_t count, uv_stream_t* send_handle) DoWrite() argument
H A Dheap_utils.cc321 uv_stream_t* send_handle) override {
H A Dnode_file.h332 uv_stream_t* send_handle) override;
/third_party/python/Lib/multiprocessing/
H A Dreduction.py21 __all__ = ['send_handle', 'recv_handle', 'ForkingPickler', 'register', 'dump']
95 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
H A Dresource_sharer.py50 reduction.send_handle(conn, new_fd, pid)
/third_party/node/src/quic/
H A Dlogstream.h48 uv_stream_t* send_handle) override;
H A Dlogstream.cc122 uv_stream_t* send_handle) { in DoWrite()
119 DoWrite(WriteWrap* w, uv_buf_t* bufs, size_t count, uv_stream_t* send_handle) DoWrite() argument
/third_party/node/src/crypto/
H A Dcrypto_tls.h88 uv_stream_t* send_handle) override;
H A Dcrypto_tls.cc956 uv_stream_t* send_handle) { in DoWrite()
957 CHECK_NULL(send_handle); in DoWrite()
996 underlying_stream()->Write(bufs, count, send_handle); in DoWrite()
953 DoWrite(WriteWrap* w, uv_buf_t* bufs, size_t count, uv_stream_t* send_handle) DoWrite() argument
/third_party/libuv/include/
H A Duv.h572 uv_stream_t* send_handle,
580 uv_stream_t* send_handle);
586 uv_stream_t* send_handle; /* TODO: make private and unix-only in v2.x. */ member
/third_party/node/deps/uv/include/
H A 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/libuv/include/uv_ndk/
H A Duv.h520 uv_stream_t* send_handle,
530 uv_stream_t* send_handle; /* TODO: make private and unix-only in v2.x. */ member

Completed in 37 milliseconds

12