diff options
| author |  Mark D. Roth <roth@google.com> | 2017-01-26 12:08:11 -0800 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-01-26 12:08:11 -0800 |
| commit | 4ffcb2058df96c1fa0a319cd3e5d4aa9358e5bae (patch) | |
| tree | d7d7b7263992250585ca5084daf2ce1bb0705838 /test/core/fling/server.c | |
| parent | 890ccaedca87eb8f5c85889ce68d71f7b771d6f5 (diff) | |
| parent | db74844fb6331370b1804d0034025fe27e8098ce (diff) | |
Merge pull request #9465 from markdroth/core_api_change
Move parameters for all grpc_op types into their own sub-structs.
Diffstat (limited to 'test/core/fling/server.c')
| -rw-r--r-- | test/core/fling/server.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/test/core/fling/server.c b/test/core/fling/server.c index fd446f1128..79e5e35211 100644 --- a/test/core/fling/server.c +++ b/test/core/fling/server.c @@ -107,13 +107,13 @@ static void handle_unary_method(void) { op->data.send_initial_metadata.count = 0; op++; op->op = GRPC_OP_RECV_MESSAGE; - op->data.recv_message = &terminal_buffer; + op->data.recv_message.recv_message = &terminal_buffer; op++; op->op = GRPC_OP_SEND_MESSAGE; if (payload_buffer == NULL) { gpr_log(GPR_INFO, "NULL payload buffer !!!"); } - op->data.send_message = payload_buffer; + op->data.send_message.send_message = payload_buffer; op++; op->op = GRPC_OP_SEND_STATUS_FROM_SERVER; op->data.send_status_from_server.status = GRPC_STATUS_OK; @@ -144,7 +144,7 @@ static void start_read_op(int t) { grpc_call_error error; /* Starting read at server */ read_op.op = GRPC_OP_RECV_MESSAGE; - read_op.data.recv_message = &payload_buffer; + read_op.data.recv_message.recv_message = &payload_buffer; error = grpc_call_start_batch(call, &read_op, 1, tag(t), NULL); GPR_ASSERT(GRPC_CALL_OK == error); } @@ -157,7 +157,7 @@ static void start_write_op(void) { if (payload_buffer == NULL) { gpr_log(GPR_INFO, "NULL payload buffer !!!"); } - write_op.data.send_message = payload_buffer; + write_op.data.send_message.send_message = payload_buffer; error = grpc_call_start_batch(call, &write_op, 1, tagarg, NULL); GPR_ASSERT(GRPC_CALL_OK == error); } |