diff options
author | Robbie Shade <rjshade@google.com> | 2017-02-02 11:30:20 -0500 |
---|---|---|
committer | Robbie Shade <rjshade@google.com> | 2017-02-02 11:32:30 -0500 |
commit | c23feddd2cc4d48b9dc5b1d4d89afd6aceca5677 (patch) | |
tree | 173136b0819bdda16b9536510d48f29eadcfdc15 /src/core/lib/iomgr/udp_server.h | |
parent | 086fddd8735e2bac7a18c64d15ee304fcd41b006 (diff) |
Add an on_write callback to the UDP server.
Diffstat (limited to 'src/core/lib/iomgr/udp_server.h')
-rw-r--r-- | src/core/lib/iomgr/udp_server.h | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/core/lib/iomgr/udp_server.h b/src/core/lib/iomgr/udp_server.h index f3c466a031..ce068cbf04 100644 --- a/src/core/lib/iomgr/udp_server.h +++ b/src/core/lib/iomgr/udp_server.h @@ -49,6 +49,10 @@ typedef struct grpc_udp_server grpc_udp_server; typedef void (*grpc_udp_server_read_cb)(grpc_exec_ctx *exec_ctx, grpc_fd *emfd, struct grpc_server *server); +/* Called when the socket is writeable. */ +typedef void (*grpc_udp_server_write_cb)(grpc_exec_ctx *exec_ctx, + grpc_fd *emfd); + /* Called when the grpc_fd is about to be orphaned (and the FD closed). */ typedef void (*grpc_udp_server_orphan_cb)(grpc_fd *emfd); @@ -75,6 +79,7 @@ int grpc_udp_server_get_fd(grpc_udp_server *s, unsigned port_index); int grpc_udp_server_add_port(grpc_udp_server *s, const grpc_resolved_address *addr, grpc_udp_server_read_cb read_cb, + grpc_udp_server_write_cb write_cb, grpc_udp_server_orphan_cb orphan_cb); void grpc_udp_server_destroy(grpc_exec_ctx *exec_ctx, grpc_udp_server *server, |