aboutsummaryrefslogtreecommitdiffhomepage
path: root/include
diff options
context:
space:
mode:
authorGravatar yang-g <yangg@google.com>2016-12-29 10:00:27 -0800
committerGravatar yang-g <yangg@google.com>2016-12-29 10:00:27 -0800
commit50993b7a4c083b8b202010aca1bb95cf9902cf74 (patch)
tree8bb902e5ff20d44903d8488de9aa8641de8fafb6 /include
parent1accb12408d89160055e687d49b3b346e57ad14a (diff)
async first take
Diffstat (limited to 'include')
-rw-r--r--include/grpc++/impl/codegen/server_interface.h7
-rw-r--r--include/grpc++/server.h3
2 files changed, 7 insertions, 3 deletions
diff --git a/include/grpc++/impl/codegen/server_interface.h b/include/grpc++/impl/codegen/server_interface.h
index 666b9ff66e..2acb174baf 100644
--- a/include/grpc++/impl/codegen/server_interface.h
+++ b/include/grpc++/impl/codegen/server_interface.h
@@ -159,7 +159,8 @@ class ServerInterface : public CallHook {
public:
RegisteredAsyncRequest(ServerInterface* server, ServerContext* context,
ServerAsyncStreamingInterface* stream,
- CompletionQueue* call_cq, void* tag);
+ CompletionQueue* call_cq, void* tag,
+ bool delete_on_finalize);
// uses BaseAsyncRequest::FinalizeResult
@@ -175,7 +176,7 @@ class ServerInterface : public CallHook {
ServerAsyncStreamingInterface* stream,
CompletionQueue* call_cq,
ServerCompletionQueue* notification_cq, void* tag)
- : RegisteredAsyncRequest(server, context, stream, call_cq, tag) {
+ : RegisteredAsyncRequest(server, context, stream, call_cq, tag, true) {
IssueRequest(registered_method, nullptr, notification_cq);
}
@@ -191,7 +192,7 @@ class ServerInterface : public CallHook {
CompletionQueue* call_cq,
ServerCompletionQueue* notification_cq, void* tag,
Message* request)
- : RegisteredAsyncRequest(server, context, stream, call_cq, tag),
+ : RegisteredAsyncRequest(server, context, stream, call_cq, tag, true),
request_(request) {
IssueRequest(registered_method, &payload_, notification_cq);
}
diff --git a/include/grpc++/server.h b/include/grpc++/server.h
index e3e9174c9c..9f31d00ef0 100644
--- a/include/grpc++/server.h
+++ b/include/grpc++/server.h
@@ -119,6 +119,9 @@ class Server final : public ServerInterface, private GrpcLibraryCodegen {
class UnimplementedAsyncRequest;
class UnimplementedAsyncResponse;
+ class HealthCheckAsyncRequestContext;
+ class HealthCheckAsyncRequest;
+
/// Server constructors. To be used by \a ServerBuilder only.
///
/// \param max_message_size Maximum message length that the channel can