Searched refs:grpc_tcp (Results 1 – 2 of 2) sorted by relevance
102 typedef struct grpc_tcp { struct128 } grpc_tcp; argument130 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 …]
73 struct grpc_tcp { struct196 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 …]