diff options
author | Craig Tiller <ctiller@google.com> | 2015-05-06 12:42:47 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-05-06 12:42:47 -0700 |
commit | f5081450126977268bff21b2fea4caeece7102b7 (patch) | |
tree | 31a44052d3d621668e4ac1bd6e7a9316033ba327 /src/python | |
parent | f9e6adf998ed36479ccbb8eb3cdc58b02cc161dd (diff) |
Fix some wrapped languages
Diffstat (limited to 'src/python')
-rw-r--r-- | src/python/src/grpc/_adapter/_server.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/python/src/grpc/_adapter/_server.c b/src/python/src/grpc/_adapter/_server.c index e7c5917724..a6c20bf132 100644 --- a/src/python/src/grpc/_adapter/_server.c +++ b/src/python/src/grpc/_adapter/_server.c @@ -51,8 +51,9 @@ static int pygrpc_server_init(Server *self, PyObject *args, PyObject *kwds) { &completion_queue)) { return -1; } - self->c_server = grpc_server_create( - completion_queue->c_completion_queue, NULL); + self->c_server = grpc_server_create(NULL); + grpc_server_register_completion_queue(self->c_server, + completion_queue->c_completion_queue); self->completion_queue = completion_queue; Py_INCREF(completion_queue); return 0; @@ -122,7 +123,7 @@ static const PyObject *pygrpc_server_service(Server *self, PyObject *tag) { call_error = grpc_server_request_call( self->c_server, &c_tag->call->c_call, &c_tag->call->call_details, &c_tag->call->recv_metadata, self->completion_queue->c_completion_queue, - c_tag); + self->completion_queue->c_completion_queue, c_tag); result = pygrpc_translate_call_error(call_error); if (result != NULL) { |