| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_custom.cc | 76 custom_tcp_endpoint* tcp = in tcp_free() local
88 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), __FILE__, __LINE__) argument
89 #define TCP_REF(tcp, reason) tcp_ref((tcp), (reason), __FILE__, __LINE__) argument
90 static void tcp_unref(custom_tcp_endpoint* tcp, const char* reason, in tcp_unref()
103 static void tcp_ref(custom_tcp_endpoint* tcp, const char* reason, in tcp_ref()
114 #define TCP_UNREF(tcp, reason) tcp_unref((tcp)) argument
115 #define TCP_REF(tcp, reason) tcp_ref((tcp)) argument
116 static void tcp_unref(custom_tcp_endpoint* tcp) { in tcp_unref()
122 static void tcp_ref(custom_tcp_endpoint* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
125 static void call_read_cb(custom_tcp_endpoint* tcp, grpc_error* error) { in call_read_cb()
[all …]
|
| D | tcp_windows.cc | 132 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
142 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), __FILE__, __LINE__) argument
143 #define TCP_REF(tcp, reason) tcp_ref((tcp), (reason), __FILE__, __LINE__) argument
144 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
157 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
168 #define TCP_UNREF(tcp, reason) tcp_unref((tcp)) argument
169 #define TCP_REF(tcp, reason) tcp_ref((tcp)) argument
170 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
176 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
181 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_read() local
[all …]
|
| D | tcp_posix.cc | 510 static void cover_self(grpc_tcp* tcp) { in cover_self()
546 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
553 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
571 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
575 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
589 static size_t get_target_read_size(grpc_tcp* tcp) { in get_target_read_size()
607 static grpc_error* tcp_annotate_error(grpc_error* src_error, grpc_tcp* tcp) { in tcp_annotate_error()
622 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_shutdown() local
628 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
645 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), DEBUG_LOCATION) argument
[all …]
|
| /third_party/boost/boost/beast/_experimental/test/ |
| D | tcp.hpp | 29 net::basic_stream_socket<net::ip::tcp, Executor>& s1, in connect()
|
| /third_party/boost/boost/asio/ip/ |
| D | tcp.hpp | 46 class tcp class
143 explicit tcp(int protocol_family) BOOST_ASIO_NOEXCEPT in tcp() function in boost::asio::ip::tcp
|
| /third_party/boost/libs/beast/example/websocket/server/chat-multi/ |
| D | net.hpp | 16 using tcp = boost::asio::ip::tcp; // from <boost/asio/ip/tcp.hpp> typedef
|
| /third_party/libuv/test/ |
| D | benchmark-ping-pongs.c | 35 uv_tcp_t tcp; member
56 static void buf_alloc(uv_handle_t* tcp, size_t size, uv_buf_t* buf) { in buf_alloc()
124 static void pinger_read_cb(uv_stream_t* tcp, in pinger_read_cb()
|
| D | test-tcp-try-write.c | 78 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb()
89 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb()
|
| D | test-delayed-accept.c | 78 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb()
118 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| D | test-tcp-writealot.c | 66 uv_tcp_t* tcp; in shutdown_cb() local
84 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb()
|
| D | test-socket-buffer-size.c | 30 static uv_tcp_t tcp; variable
|
| D | test-handle-fileno.c | 51 uv_tcp_t tcp; in TEST_IMPL() local
|
| /third_party/libuv/docs/src/ |
| D | tcp.rst | 2 .. _tcp: target
|
| /third_party/libuv/src/unix/ |
| D | tcp.c | 114 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* tcp, unsigned int flags) { in uv_tcp_init_ex()
143 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* tcp) { in uv_tcp_init()
148 int uv__tcp_bind(uv_tcp_t* tcp, in uv__tcp_bind()
331 int uv__tcp_listen(uv_tcp_t* tcp, int backlog, uv_connection_cb cb) { in uv__tcp_listen()
|
| /third_party/boost/libs/beast/test/beast/core/ |
| D | tcp_stream.cpp | 22 using tcp = net::ip::tcp; typedef in boost::beast::tcp_stream_test
|
| /third_party/node/test/parallel/ |
| D | test-net-connect-buffer.js | 27 const tcp = net.Server(common.mustCall((s) => { constant
|
| D | test-net-bytes-stats.js | 31 const tcp = net.Server(function(s) { constant
|
| /third_party/boost/libs/asio/example/cpp03/http/server4/ |
| D | server.hpp | 43 typedef boost::asio::ip::tcp tcp; typedef in http::server4::server
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/http/server4/ |
| D | server.hpp | 43 typedef boost::asio::ip::tcp tcp; typedef in http::server4::server
|
| /third_party/boost/libs/beast/example/websocket/client/sync/ |
| D | websocket_client_sync.cpp | 30 using tcp = boost::asio::ip::tcp; // from <boost/asio/ip/tcp.hpp> typedef
|
| /third_party/boost/libs/beast/example/http/client/sync/ |
| D | http_client_sync.cpp | 30 using tcp = net::ip::tcp; // from <boost/asio/ip/tcp.hpp> typedef
|
| /third_party/boost/libs/beast/example/websocket/client/sync-ssl/ |
| D | websocket_client_sync_ssl.cpp | 34 using tcp = boost::asio::ip::tcp; // from <boost/asio/ip/tcp.hpp> typedef
|
| /third_party/boost/libs/beast/test/doc/ |
| D | core_snippets.cpp | 38 using tcp = net::ip::tcp; in fxx() typedef
|
| /third_party/boost/libs/beast/example/websocket/server/sync/ |
| D | websocket_server_sync.cpp | 29 using tcp = boost::asio::ip::tcp; // from <boost/asio/ip/tcp.hpp> typedef
|
| /third_party/node/src/ |
| D | inspector_socket.cc | 29 uv_tcp_t* tcp() { in tcp() function in node::inspector::TcpHolder
318 WsHandler(InspectorSocket* inspector, TcpHolder::Pointer tcp) in WsHandler()
430 explicit HttpHandler(InspectorSocket* inspector, TcpHolder::Pointer tcp) in HttpHandler()
599 TcpHolder::Pointer tcp) in ProtocolHandler()
646 uv_stream_t* tcp = reinterpret_cast<uv_stream_t*>(&result->tcp_); in Accept() local
691 void TcpHolder::OnDataReceivedCb(uv_stream_t* tcp, ssize_t nread, in OnDataReceivedCb()
733 auto tcp = TcpHolder::Accept(server, std::move(delegate)); in Accept() local
|