Searched refs:grpc_tcp (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 102 typedef struct grpc_tcp { struct
128 } grpc_tcp; argument
130 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
142 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
155 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
168 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
174 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
179 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_read()
214 grpc_tcp* tcp = (grpc_tcp*)ep; in win_read()
273 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_write()
[all …]
|
| D | tcp_posix.cc | 73 struct grpc_tcp { struct
196 static void drop_uncovered(grpc_tcp* tcp) { in drop_uncovered()
207 static void cover_self(grpc_tcp* tcp) { in cover_self()
243 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
252 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
267 drop_uncovered(static_cast<grpc_tcp*>(arg)); in tcp_drop_uncovered_then_handle_write()
271 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
275 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
289 static size_t get_target_read_size(grpc_tcp* tcp) { in get_target_read_size()
307 static grpc_error* tcp_annotate_error(grpc_error* src_error, grpc_tcp* tcp) { in tcp_annotate_error()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 100 typedef struct grpc_tcp { struct
130 } grpc_tcp; argument
132 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
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()
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()
243 grpc_tcp* tcp = (grpc_tcp*)ep; in win_read()
317 grpc_tcp* tcp = (grpc_tcp*)tcpp; in on_write()
[all …]
|
| D | tcp_posix.cc | 355 struct grpc_tcp { struct
356 grpc_tcp(int max_sends, size_t send_bytes_threshold) in grpc_tcp() argument
431 static void ZerocopyDisableAndWaitForRemaining(grpc_tcp* tcp);
491 static void drop_uncovered(grpc_tcp* /*tcp*/) { in drop_uncovered() argument
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()
567 drop_uncovered(static_cast<grpc_tcp*>(arg)); in tcp_drop_uncovered_then_handle_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()
[all …]
|