aboutsummaryrefslogtreecommitdiffhomepage
path: root/src
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-10-02 16:17:10 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-10-02 16:17:10 -0700
commit548735efb8d27b61db8eae3752b4fffb1ae4bcd9 (patch)
treef3eb1b3a898e581afb52346b2395cf48a94e3604 /src
parent1270b2b36b8c40aec10cdae72a849ec4c6f3ce48 (diff)
Commentary
Diffstat (limited to 'src')
-rw-r--r--src/core/iomgr/fd_posix.h4
-rw-r--r--src/core/iomgr/pollset_posix.h4
2 files changed, 7 insertions, 1 deletions
diff --git a/src/core/iomgr/fd_posix.h b/src/core/iomgr/fd_posix.h
index ca3d065abc..b85c74b52b 100644
--- a/src/core/iomgr/fd_posix.h
+++ b/src/core/iomgr/fd_posix.h
@@ -128,7 +128,9 @@ gpr_uint32 grpc_fd_begin_poll(grpc_fd *fd, grpc_pollset *pollset,
grpc_pollset_worker *worker, gpr_uint32 read_mask,
gpr_uint32 write_mask, grpc_fd_watcher *rec);
/* Complete polling previously started with grpc_fd_begin_poll
- MUST NOT be called with a pollset lock taken */
+ MUST NOT be called with a pollset lock taken
+ if got_read or got_write are 1, also does the notify_on_{read,write} as
+ appropriate. */
void grpc_fd_end_poll(grpc_exec_ctx *exec_ctx, grpc_fd_watcher *rec,
int got_read, int got_write);
diff --git a/src/core/iomgr/pollset_posix.h b/src/core/iomgr/pollset_posix.h
index d375207643..f0ec07ebce 100644
--- a/src/core/iomgr/pollset_posix.h
+++ b/src/core/iomgr/pollset_posix.h
@@ -112,8 +112,12 @@ void grpc_kick_drain(grpc_pollset *p);
int grpc_poll_deadline_to_millis_timeout(gpr_timespec deadline,
gpr_timespec now);
+/* Allow kick to wakeup the currently polling worker */
#define GRPC_POLLSET_CAN_KICK_SELF 1
+/* Force the wakee to repoll when awoken */
#define GRPC_POLLSET_REEVALUATE_POLLING_ON_WAKEUP 2
+/* As per grpc_pollset_kick, with an extended set of flags (defined above)
+ -- mostly for fd_posix's use. */
void grpc_pollset_kick_ex(grpc_pollset *p, grpc_pollset_worker *specific_worker,
gpr_uint32 flags);