From f443f185b3dd4b694e9719d7e730e98396416ce8 Mon Sep 17 00:00:00 2001 From: Sree Kuchibhotla Date: Fri, 28 Sep 2018 19:48:38 -0700 Subject: Address feedback comment --- src/core/lib/iomgr/tcp_posix.cc | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) (limited to 'src/core/lib/iomgr') diff --git a/src/core/lib/iomgr/tcp_posix.cc b/src/core/lib/iomgr/tcp_posix.cc index 4aad83915f..e40bf81c90 100644 --- a/src/core/lib/iomgr/tcp_posix.cc +++ b/src/core/lib/iomgr/tcp_posix.cc @@ -204,15 +204,13 @@ static void drop_uncovered(grpc_tcp* tcp) { GPR_ASSERT(old_count != 1); } -/* gRPC API considers a Write operation to be done the moment it clears ‘flow - control’ i.e., and not necessarily sent on the wire. This means that the - application MAY NOT call `grpc_completion_queue_next/pluck` in a timely - manner when its `Write()` API is acked. - - We need to ensure that the fd is 'covered' (i.e being monitored by some - polling thread and progress is made) and hence add it to a backup poller - here */ - +// gRPC API considers a Write operation to be done the moment it clears ‘flow +// control’ i.e., not necessarily sent on the wire. This means that the +// application MIGHT not call `grpc_completion_queue_next/pluck` in a timely +// manner when its `Write()` API is acked. +// +// We need to ensure that the fd is 'covered' (i.e being monitored by some +// polling thread and progress is made) and hence add it to a backup poller here static void cover_self(grpc_tcp* tcp) { backup_poller* p; gpr_atm old_count = -- cgit v1.2.3