aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/lib/iomgr/udp_server.h
diff options
context:
space:
mode:
authorGravatar Dan Zhang <danzh@google.com>2017-12-20 15:07:38 -0500
committerGravatar Dan Zhang <danzh@google.com>2017-12-20 15:07:38 -0500
commit0d18814106f19197e80366ee147b4c1565fadf96 (patch)
tree01d301d2d43417ee07c6d2668bea42b1a6ffc347 /src/core/lib/iomgr/udp_server.h
parent9d77be167a1c2bc8ccbe73b7aa0fda207b32b999 (diff)
Add a start_cb to grpc_udp_listener to be called when listener is
created.
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);