Searched refs:grpc_tcp (Results 1 – 4 of 4) sorted by relevance
| /aosp_15_r20/external/grpc-grpc/src/core/lib/iomgr/ |
| H A D | tcp_posix.cc | 479 struct grpc_tcp { struct
480 explicit grpc_tcp(const grpc_core::PosixTcpOptions& tcp_options) in grpc_tcp() function
606 static void ZerocopyDisableAndWaitForRemaining(grpc_tcp* tcp);
665 static void drop_uncovered(grpc_tcp* /*tcp*/) { in drop_uncovered() argument
686 static void cover_self(grpc_tcp* tcp) { in cover_self()
716 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
723 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
739 drop_uncovered(static_cast<grpc_tcp*>(arg)); in tcp_drop_uncovered_then_handle_write()
743 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
747 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
[all …]
|
| H A D | tcp_windows.cc | 101 typedef struct grpc_tcp { struct
129 } grpc_tcp; argument
131 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
141 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
154 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
167 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
173 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
178 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_read()
240 grpc_tcp* tcp = (grpc_tcp*)ep; in win_read()
316 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_write()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_posix.cc | 472 struct grpc_tcp { struct
473 explicit grpc_tcp(const grpc_core::PosixTcpOptions& tcp_options) in grpc_tcp() function
558 static void ZerocopyDisableAndWaitForRemaining(grpc_tcp* tcp);
617 static void drop_uncovered(grpc_tcp* /*tcp*/) { in drop_uncovered() argument
638 static void cover_self(grpc_tcp* tcp) { in cover_self()
668 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
675 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
691 drop_uncovered(static_cast<grpc_tcp*>(arg)); in tcp_drop_uncovered_then_handle_write()
695 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
699 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
[all …]
|
| D | tcp_windows.cc | 101 typedef struct grpc_tcp { struct
129 } grpc_tcp; argument
131 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
141 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
154 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
167 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
173 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
178 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_read()
242 grpc_tcp* tcp = (grpc_tcp*)ep; in win_read()
318 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_write()
[all …]
|