diff options
author | Craig Tiller <ctiller@google.com> | 2015-10-02 16:17:10 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-10-02 16:17:10 -0700 |
commit | 548735efb8d27b61db8eae3752b4fffb1ae4bcd9 (patch) | |
tree | f3eb1b3a898e581afb52346b2395cf48a94e3604 /src | |
parent | 1270b2b36b8c40aec10cdae72a849ec4c6f3ce48 (diff) |
Commentary
Diffstat (limited to 'src')
-rw-r--r-- | src/core/iomgr/fd_posix.h | 4 | ||||
-rw-r--r-- | src/core/iomgr/pollset_posix.h | 4 |
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); |