diff options
| author |  Robbie Shade <rjshade@google.com> | 2015-10-07 10:13:53 -0400 |
|---|---|---|
| committer | Robbie Shade <rjshade@google.com> | 2015-10-07 10:13:53 -0400 |
| commit | c6787b263fbf31510fce389304d9a11da0d8aa2f (patch) | |
| tree | 089b6968d69dda337f68d7714f1e8ad52205c31f /src/core/iomgr | |
| parent | 57ee3db01deb5dd00ef4d76ffbd18dca9d8144e4 (diff) | |
Fix broken udp_server_test, by adding exec_ctx to read_cb
Diffstat (limited to 'src/core/iomgr')
| -rw-r--r-- | src/core/iomgr/udp_server.c | 2 | ||||
| -rw-r--r-- | src/core/iomgr/udp_server.h | 3 |
2 files changed, 3 insertions, 2 deletions
diff --git a/src/core/iomgr/udp_server.c b/src/core/iomgr/udp_server.c index 1304f2067e..9903e970e6 100644 --- a/src/core/iomgr/udp_server.c +++ b/src/core/iomgr/udp_server.c @@ -278,7 +278,7 @@ static void on_read(grpc_exec_ctx *exec_ctx, void *arg, int success) { /* Tell the registered callback that data is available to read. */ GPR_ASSERT(sp->read_cb); - sp->read_cb(sp->emfd, sp->server->grpc_server); + sp->read_cb(exec_ctx, sp->emfd, sp->server->grpc_server); /* Re-arm the notification event so we get another chance to read. */ grpc_fd_notify_on_read(exec_ctx, sp->emfd, &sp->read_closure); diff --git a/src/core/iomgr/udp_server.h b/src/core/iomgr/udp_server.h index dbbe097109..de5736c426 100644 --- a/src/core/iomgr/udp_server.h +++ b/src/core/iomgr/udp_server.h @@ -43,7 +43,8 @@ typedef struct grpc_server grpc_server; typedef struct grpc_udp_server grpc_udp_server; /* Called when data is available to read from the socket. */ -typedef void (*grpc_udp_server_read_cb)(grpc_fd *emfd, grpc_server *server); +typedef void (*grpc_udp_server_read_cb)(grpc_exec_ctx *exec_ctx, grpc_fd *emfd, + grpc_server *server); /* Create a server, initially not bound to any ports */ grpc_udp_server *grpc_udp_server_create(void); |