Searched refs:outgoing_buffer (Results 1 – 2 of 2) sorted by relevance
80 grpc_slice_buffer outgoing_buffer; member105 grpc_slice_buffer_reset_and_unref(&state.outgoing_buffer); in handle_write()106 grpc_slice_buffer_add(&state.outgoing_buffer, slice); in handle_write()107 grpc_endpoint_write(state.tcp, &state.outgoing_buffer, &on_write, nullptr); in handle_write()141 grpc_slice_buffer_init(&state.outgoing_buffer); in on_connect()223 grpc_slice_buffer_destroy_internal(&state.outgoing_buffer); in cleanup_rpc()
92 grpc_slice_buffer* outgoing_buffer; member585 grpc_slice_buffer_reset_and_unref_internal(tcp->outgoing_buffer); in tcp_write_with_timestamps()802 for (iov_size = 0; outgoing_slice_idx != tcp->outgoing_buffer->count && in tcp_flush()807 tcp->outgoing_buffer->slices[outgoing_slice_idx]) + in tcp_flush()810 GRPC_SLICE_LENGTH(tcp->outgoing_buffer->slices[outgoing_slice_idx]) - in tcp_flush()844 grpc_slice_buffer_take_first(tcp->outgoing_buffer)); in tcp_flush()849 grpc_slice_buffer_reset_and_unref_internal(tcp->outgoing_buffer); in tcp_flush()853 grpc_slice_buffer_reset_and_unref_internal(tcp->outgoing_buffer); in tcp_flush()866 GRPC_SLICE_LENGTH(tcp->outgoing_buffer->slices[outgoing_slice_idx]); in tcp_flush()874 if (outgoing_slice_idx == tcp->outgoing_buffer->count) { in tcp_flush()[all …]