diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-02-03 12:07:07 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-02-03 12:07:07 -0800 |
| commit | fb189f826e2e5edc9128155ef0847c447a47c6ce (patch) | |
| tree | 91324ea580d473ca31670d024fccb2429d40462d /src/core/surface/server.c | |
| parent | 034929cc31fe46d4943913939a4de678edf3507a (diff) | |
Flesh out batch API
Diffstat (limited to 'src/core/surface/server.c')
| -rw-r--r-- | src/core/surface/server.c | 16 |
1 files changed, 9 insertions, 7 deletions
diff --git a/src/core/surface/server.c b/src/core/surface/server.c index a057694f13..4cba41d1f8 100644 --- a/src/core/surface/server.c +++ b/src/core/surface/server.c @@ -121,7 +121,9 @@ typedef enum { ZOMBIED } call_state; -typedef struct legacy_data { grpc_metadata_array *initial_metadata; } legacy_data; +typedef struct legacy_data { + grpc_metadata_array *initial_metadata; +} legacy_data; struct call_data { grpc_call *call; @@ -343,7 +345,7 @@ static void channel_op(grpc_channel_element *elem, switch (op->type) { case GRPC_ACCEPT_CALL: /* create a call */ - grpc_call_create(chand->channel, + grpc_call_create(chand->channel, NULL, op->data.accept_call.transport_server_data); break; case GRPC_TRANSPORT_CLOSED: @@ -709,11 +711,11 @@ static void begin_request(grpc_server *server, grpc_completion_queue *cq, abort(); } -grpc_call_error grpc_server_request_call( - grpc_server *server, grpc_call_details *details, - grpc_metadata_array *initial_metadata, grpc_completion_queue *cq, - void *tag) { - grpc_cq_begin_op(cq, NULL, GRPC_IOREQ); +grpc_call_error grpc_server_request_call(grpc_server *server, + grpc_call_details *details, + grpc_metadata_array *initial_metadata, + grpc_completion_queue *cq, void *tag) { + grpc_cq_begin_op(cq, NULL, GRPC_OP_COMPLETE); return queue_call_request(server, cq, initial_metadata, begin_request, tag); } |