| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 127 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
135 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), __FILE__, __LINE__) argument
136 #define TCP_REF(tcp, reason) tcp_ref((tcp), (reason), __FILE__, __LINE__) argument
137 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
149 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
159 #define TCP_UNREF(tcp, reason) tcp_unref((tcp)) argument
160 #define TCP_REF(tcp, reason) tcp_ref((tcp)) argument
161 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
167 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
172 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_read() local
[all …]
|
| D | tcp_posix.cc | 672 static void cover_self(grpc_tcp* tcp) { in cover_self()
698 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
703 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
719 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
723 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
738 grpc_tcp* tcp) { in tcp_annotate_error()
749 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
760 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), DEBUG_LOCATION) argument
761 #define TCP_REF(tcp, reason) tcp_ref((tcp), (reason), DEBUG_LOCATION) argument
762 static void tcp_unref(grpc_tcp* tcp, const char* reason, in tcp_unref()
[all …]
|
| /third_party/rust/rust/library/std/src/os/net/linux_ext/ |
| D | mod.rs | 9 pub(crate) mod tcp; module
|
| /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-tcp-write-in-a-row.c | 93 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) {} in read_cb()
95 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
|
| D | test-multiple-listen.c | 40 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb()
|
| D | test-tcp-try-write-error.c | 62 static void connection_cb(uv_stream_t* tcp, int status) { in connection_cb()
|
| D | test-tcp-rst.c | 25 static uv_tcp_t tcp; variable
|
| D | test-shutdown-simultaneous.c | 27 static uv_tcp_t tcp; variable
|
| D | test-connection-fail.c | 29 static uv_tcp_t tcp; variable
|
| D | test-tcp-open.c | 113 static void read_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read_cb()
127 static void read1_cb(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) { in read1_cb()
|
| /third_party/libuv/docs/src/ |
| D | tcp.rst | 2 .. _tcp: target
|
| /third_party/libuv/src/unix/ |
| D | tcp.c | 113 int uv_tcp_init_ex(uv_loop_t* loop, uv_tcp_t* tcp, unsigned int flags) { in uv_tcp_init_ex()
146 int uv_tcp_init(uv_loop_t* loop, uv_tcp_t* tcp) { in uv_tcp_init()
151 int uv__tcp_bind(uv_tcp_t* tcp, in uv__tcp_bind()
415 int uv__tcp_listen(uv_tcp_t* tcp, int backlog, uv_connection_cb cb) { in uv__tcp_listen()
|
| /third_party/rust/rust/library/std/src/net/ |
| D | mod.rs | 41 mod tcp; module
|
| /third_party/iptables/include/linux/netfilter_ipv4/ |
| D | ipt_ECN.h | 29 } tcp; member
|
| /third_party/iptables/include/linux/netfilter/ |
| D | xt_ecn.h | 29 } tcp; member
|
| /third_party/ffmpeg/libavformat/ |
| D | tls.h | 42 URLContext *tcp; member
|
| /third_party/grpc/src/core/xds/grpc/ |
| D | xds_listener.cc | 170 [](const TcpListener& tcp) { in ToString()
|
| /third_party/grpc/test/core/test_util/ |
| D | reconnect_server.cc | 57 static void on_connect(void* arg, grpc_endpoint* tcp, in on_connect()
|
| /third_party/openhitls/testcode/sdv/testcase/bsl/sal/ |
| D | test_suite_sdv_sal_socket.c | 61 int32_t tcp = BSL_SAL_Socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in SDV_BSL_SAL_SOCKET_FUNC_TC001() local
|