diff options
author | Yang Gao <yangg@google.com> | 2017-12-22 14:16:41 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-12-22 14:16:41 -0800 |
commit | 9aaa284fcb067fb5c07742b6f34de0878f079ecf (patch) | |
tree | a33c605253c3c9d6c2c50be25f7dd8a16172a0ad /src/core/lib/iomgr/udp_server.h | |
parent | e33d0272fd5b16521848535a98b6dbc8bd83233a (diff) | |
parent | 0c2fc922a62eedf02e0e3ad070685b8265347ec7 (diff) |
Merge pull request #13844 from danzh2010/startcb
Change grpc_udp_server interface
Diffstat (limited to 'src/core/lib/iomgr/udp_server.h')
-rw-r--r-- | src/core/lib/iomgr/udp_server.h | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/core/lib/iomgr/udp_server.h b/src/core/lib/iomgr/udp_server.h index 02e3acb7f5..a469ab9be5 100644 --- a/src/core/lib/iomgr/udp_server.h +++ b/src/core/lib/iomgr/udp_server.h @@ -30,9 +30,12 @@ struct grpc_server; /* Forward decl of grpc_udp_server */ typedef struct grpc_udp_server grpc_udp_server; +/* Called when grpc server starts to listening on the grpc_fd. */ +typedef void (*grpc_udp_server_start_cb)(grpc_fd* emfd, void* user_data); + /* Called when data is available to read from the socket. * Return true if there is more data to read from fd. */ -typedef bool (*grpc_udp_server_read_cb)(grpc_fd* emfd, void* user_data); +typedef bool (*grpc_udp_server_read_cb)(grpc_fd* emfd); /* Called when the socket is writeable. The given closure should be scheduled * when the socket becomes blocked next time. */ @@ -65,6 +68,7 @@ int grpc_udp_server_get_fd(grpc_udp_server* s, unsigned port_index); all of the multiple socket port matching logic in one place */ int grpc_udp_server_add_port(grpc_udp_server* s, const grpc_resolved_address* addr, + grpc_udp_server_start_cb start_cb, grpc_udp_server_read_cb read_cb, grpc_udp_server_write_cb write_cb, grpc_udp_server_orphan_cb orphan_cb); |