Searched refs:grpc_tcp (Results 1 – 2 of 2) sorted by relevance
100 typedef struct grpc_tcp { struct130 } grpc_tcp; argument132 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 …]
355 struct grpc_tcp { struct356 grpc_tcp(int max_sends, size_t send_bytes_threshold) in grpc_tcp() argument431 static void ZerocopyDisableAndWaitForRemaining(grpc_tcp* tcp);491 static void drop_uncovered(grpc_tcp* /*tcp*/) { in drop_uncovered() argument510 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 …]