aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/surface/server.c
diff options
context:
space:
mode:
authorGravatar Julien Boeuf <jboeuf@google.com>2015-05-29 15:15:09 -0700
committerGravatar Julien Boeuf <jboeuf@google.com>2015-05-29 15:15:09 -0700
commitf720bc5428562f9d08e4c96bb32187a7f9162514 (patch)
tree89ab8a84d31f3fc5d5082ba842b9c1a8f5a37765 /src/core/surface/server.c
parentb7bf14f51680d112af8276817c1ea6572c670fe5 (diff)
parenteaee2bcb32e203a9ae79e514f552f31e254d74f6 (diff)
Merge branch 'master' of github.com:grpc/grpc into server_auth_context
Diffstat (limited to 'src/core/surface/server.c')
-rw-r--r--src/core/surface/server.c12
1 files changed, 12 insertions, 0 deletions
diff --git a/src/core/surface/server.c b/src/core/surface/server.c
index 82386b10bb..60606c75e4 100644
--- a/src/core/surface/server.c
+++ b/src/core/surface/server.c
@@ -1010,6 +1010,9 @@ grpc_call_error grpc_server_request_call(
grpc_completion_queue *cq_bound_to_call,
grpc_completion_queue *cq_for_notification, void *tag) {
requested_call rc;
+ GRPC_SERVER_LOG_REQUEST_CALL(GPR_INFO, server, call, details,
+ initial_metadata, cq_bound_to_call,
+ cq_for_notification, tag);
grpc_cq_begin_op(cq_for_notification, NULL);
rc.type = BATCH_CALL;
rc.tag = tag;
@@ -1128,3 +1131,12 @@ static void publish_registered_or_batch(grpc_call *call, int success,
const grpc_channel_args *grpc_server_get_channel_args(grpc_server *server) {
return server->channel_args;
}
+
+int grpc_server_has_open_connections(grpc_server *server) {
+ int r;
+ gpr_mu_lock(&server->mu);
+ r = server->root_channel_data.next != &server->root_channel_data;
+ gpr_mu_unlock(&server->mu);
+ return r;
+}
+