Lines Matching defs:tcp

209 static void drop_uncovered(grpc_tcp* tcp) {  in drop_uncovered()
227 static void cover_self(grpc_tcp* tcp) { in cover_self()
263 static void notify_on_read(grpc_tcp* tcp) { in notify_on_read()
270 static void notify_on_write(grpc_tcp* tcp) { in notify_on_write()
288 static void add_to_estimate(grpc_tcp* tcp, size_t bytes) { in add_to_estimate()
292 static void finish_estimate(grpc_tcp* tcp) { in finish_estimate()
306 static size_t get_target_read_size(grpc_tcp* tcp) { in get_target_read_size()
324 static grpc_error* tcp_annotate_error(grpc_error* src_error, grpc_tcp* tcp) { in tcp_annotate_error()
339 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_shutdown() local
344 static void tcp_free(grpc_tcp* tcp) { in tcp_free()
362 #define TCP_UNREF(tcp, reason) tcp_unref((tcp), (reason), __FILE__, __LINE__) argument
363 #define TCP_REF(tcp, reason) tcp_ref((tcp), (reason), __FILE__, __LINE__) argument
364 static void tcp_unref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_unref()
377 static void tcp_ref(grpc_tcp* tcp, const char* reason, const char* file, in tcp_ref()
388 #define TCP_UNREF(tcp, reason) tcp_unref((tcp)) argument
389 #define TCP_REF(tcp, reason) tcp_ref((tcp)) argument
390 static void tcp_unref(grpc_tcp* tcp) { in tcp_unref()
396 static void tcp_ref(grpc_tcp* tcp) { gpr_ref(&tcp->refcount); } in tcp_ref()
400 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_destroy() local
409 static void call_read_cb(grpc_tcp* tcp, grpc_error* error) { in call_read_cb()
434 static void tcp_do_read(grpc_tcp* tcp) { in tcp_do_read()
581 grpc_tcp* tcp = static_cast<grpc_tcp*>(tcpp); in tcp_read_allocation_done() local
596 static void tcp_continue_read(grpc_tcp* tcp) { in tcp_continue_read()
615 grpc_tcp* tcp = static_cast<grpc_tcp*>(arg); in tcp_handle_read() local
632 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_read() local
687 static bool tcp_write_with_timestamps(grpc_tcp* tcp, struct msghdr* msg, in tcp_write_with_timestamps()
738 struct cmsghdr* process_timestamp(grpc_tcp* tcp, msghdr* msg, in process_timestamp()
792 static void process_errors(grpc_tcp* tcp) { in process_errors()
864 grpc_tcp* tcp = static_cast<grpc_tcp*>(arg); in tcp_handle_error() local
888 static bool tcp_write_with_timestamps(grpc_tcp* tcp, struct msghdr* msg, in tcp_write_with_timestamps()
904 void tcp_shutdown_buffer_list(grpc_tcp* tcp) { in tcp_shutdown_buffer_list()
921 static bool tcp_flush(grpc_tcp* tcp, grpc_error** error) { in tcp_flush()
1029 grpc_tcp* tcp = static_cast<grpc_tcp*>(arg); in tcp_handle_write() local
1060 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_write() local
1112 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_add_to_pollset() local
1118 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_add_to_pollset_set() local
1124 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_delete_from_pollset_set() local
1129 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_get_peer() local
1134 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_get_fd() local
1139 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_get_resource_user() local
1144 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in tcp_can_track_err() local
1213 grpc_tcp* tcp = static_cast<grpc_tcp*>(gpr_malloc(sizeof(grpc_tcp))); in grpc_tcp_create() local
1284 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in grpc_tcp_fd() local
1291 grpc_tcp* tcp = reinterpret_cast<grpc_tcp*>(ep); in grpc_tcp_destroy_and_release_fd() local