aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/iomgr/udp_server.h
diff options
context:
space:
mode:
authorGravatar Yang Gao <yangg@google.com>2017-12-22 14:16:41 -0800
committerGravatar GitHub <noreply@github.com>2017-12-22 14:16:41 -0800
commit9aaa284fcb067fb5c07742b6f34de0878f079ecf (patch)
treea33c605253c3c9d6c2c50be25f7dd8a16172a0ad /src/core/lib/iomgr/udp_server.h
parente33d0272fd5b16521848535a98b6dbc8bd83233a (diff)
parent0c2fc922a62eedf02e0e3ad070685b8265347ec7 (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.h6
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);