diff options
author | 2018-10-25 19:24:30 -0700 | |
---|---|---|
committer | 2018-10-25 19:24:30 -0700 | |
commit | a094b7b3127ffcb607e11486a64fc905e92a2565 (patch) | |
tree | b06a812825433b90c4818468677503f57b9776eb /include/grpcpp/impl/codegen/server_interface.h | |
parent | 281de1bb3003e51d4b59445827b25a23b33ba509 (diff) |
Added server async tests
Diffstat (limited to 'include/grpcpp/impl/codegen/server_interface.h')
-rw-r--r-- | include/grpcpp/impl/codegen/server_interface.h | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/include/grpcpp/impl/codegen/server_interface.h b/include/grpcpp/impl/codegen/server_interface.h index aa7dbe8b70..532fff7a54 100644 --- a/include/grpcpp/impl/codegen/server_interface.h +++ b/include/grpcpp/impl/codegen/server_interface.h @@ -173,8 +173,6 @@ class ServerInterface : public internal::CallHook { internal::Call call_wrapper_; internal::InterceptorBatchMethodsImpl interceptor_methods_; bool done_intercepting_; - void* dummy_alarm_; /* This should have been Alarm, but we cannot depend on - alarm.h here */ }; class RegisteredAsyncRequest : public BaseAsyncRequest { @@ -186,6 +184,7 @@ class ServerInterface : public internal::CallHook { const char* name); virtual bool FinalizeResult(void** tag, bool* status) override { + gpr_log(GPR_ERROR, "finalize registeredasyncrequest"); /* If we are done intercepting, then there is nothing more for us to do */ if (done_intercepting_) { return BaseAsyncRequest::FinalizeResult(tag, status); @@ -239,6 +238,7 @@ class ServerInterface : public internal::CallHook { notification_cq_(notification_cq), tag_(tag), request_(request) { + gpr_log(GPR_ERROR, "new payload request"); IssueRequest(registered_method->server_tag(), payload_.bbuf_ptr(), notification_cq); } @@ -248,6 +248,7 @@ class ServerInterface : public internal::CallHook { } bool FinalizeResult(void** tag, bool* status) override { + gpr_log(GPR_ERROR, "finalize PayloadAsyncRequest"); /* If we are done intercepting, then there is nothing more for us to do */ if (done_intercepting_) { return RegisteredAsyncRequest::FinalizeResult(tag, status); @@ -312,6 +313,7 @@ class ServerInterface : public internal::CallHook { ServerCompletionQueue* notification_cq, void* tag, Message* message) { GPR_CODEGEN_ASSERT(method); + gpr_log(GPR_ERROR, "request async method with payload"); new PayloadAsyncRequest<Message>(method, this, context, stream, call_cq, notification_cq, tag, message); } @@ -322,6 +324,7 @@ class ServerInterface : public internal::CallHook { CompletionQueue* call_cq, ServerCompletionQueue* notification_cq, void* tag) { GPR_CODEGEN_ASSERT(method); + gpr_log(GPR_ERROR, "request async method with no payload"); new NoPayloadAsyncRequest(method, this, context, stream, call_cq, notification_cq, tag); } @@ -331,6 +334,7 @@ class ServerInterface : public internal::CallHook { CompletionQueue* call_cq, ServerCompletionQueue* notification_cq, void* tag) { + gpr_log(GPR_ERROR, "request async generic call"); new GenericAsyncRequest(this, context, stream, call_cq, notification_cq, tag, true); } |