diff options
author | 2015-05-12 14:08:56 -0700 | |
---|---|---|
committer | 2015-05-12 14:08:56 -0700 | |
commit | 54478f8562b812595b0d9102fc4703cdb04a627f (patch) | |
tree | 818aacc26522a41fe7921e12e9adb360c9bc1183 /src/php/ext | |
parent | 6efa6eb5b35ca660651c78b03243366908a9d187 (diff) | |
parent | a468c36601dd5997580129bbd66b5ebed02521f8 (diff) |
Merge github.com:grpc/grpc into bye-bye-completion-queue-pie
Diffstat (limited to 'src/php/ext')
-rw-r--r-- | src/php/ext/grpc/server.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/php/ext/grpc/server.c b/src/php/ext/grpc/server.c index c5defa4dd2..c2e00b16f4 100644 --- a/src/php/ext/grpc/server.c +++ b/src/php/ext/grpc/server.c @@ -114,12 +114,13 @@ PHP_METHOD(Server, __construct) { } server->queue = grpc_completion_queue_create(); if (args_array == NULL) { - server->wrapped = grpc_server_create(server->queue, NULL); + server->wrapped = grpc_server_create(NULL); } else { php_grpc_read_args_array(args_array, &args); - server->wrapped = grpc_server_create(server->queue, &args); + server->wrapped = grpc_server_create(&args); efree(args.args); } + grpc_server_register_completion_queue(server->wrapped, server->queue); } /** @@ -141,8 +142,9 @@ PHP_METHOD(Server, requestCall) { object_init(result); grpc_call_details_init(&details); grpc_metadata_array_init(&metadata); - error_code = grpc_server_request_call(server->wrapped, &call, &details, - &metadata, server->queue, NULL); + error_code = + grpc_server_request_call(server->wrapped, &call, &details, &metadata, + server->queue, server->queue, NULL); if (error_code != GRPC_CALL_OK) { zend_throw_exception(spl_ce_LogicException, "request_call failed", (long)error_code TSRMLS_CC); |