diff options
Diffstat (limited to 'include/grpc++')
-rw-r--r-- | include/grpc++/channel.h | 3 | ||||
-rw-r--r-- | include/grpc++/client_context.h | 3 | ||||
-rw-r--r-- | include/grpc++/completion_queue.h | 3 | ||||
-rw-r--r-- | include/grpc++/generic/generic_stub.h | 3 | ||||
-rw-r--r-- | include/grpc++/impl/codegen/channel_interface.h | 11 | ||||
-rw-r--r-- | include/grpc++/impl/codegen/server_interface.h | 3 | ||||
-rw-r--r-- | include/grpc++/server.h | 9 |
7 files changed, 21 insertions, 14 deletions
diff --git a/include/grpc++/channel.h b/include/grpc++/channel.h index f4035eee63..d6f55a8bf6 100644 --- a/include/grpc++/channel.h +++ b/include/grpc++/channel.h @@ -59,7 +59,8 @@ class Channel GRPC_FINAL : public ChannelInterface, private: template <class InputMessage, class OutputMessage> - friend Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, + friend Status BlockingUnaryCall(ChannelInterface* channel, + const RpcMethod& method, ClientContext* context, const InputMessage& request, OutputMessage* result); diff --git a/include/grpc++/client_context.h b/include/grpc++/client_context.h index 6ce1c85539..a926ed0505 100644 --- a/include/grpc++/client_context.h +++ b/include/grpc++/client_context.h @@ -316,7 +316,8 @@ class ClientContext { template <class R> friend class ::grpc::ClientAsyncResponseReader; template <class InputMessage, class OutputMessage> - friend Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, + friend Status BlockingUnaryCall(ChannelInterface* channel, + const RpcMethod& method, ClientContext* context, const InputMessage& request, OutputMessage* result); diff --git a/include/grpc++/completion_queue.h b/include/grpc++/completion_queue.h index adae9265a6..c1f4172322 100644 --- a/include/grpc++/completion_queue.h +++ b/include/grpc++/completion_queue.h @@ -172,7 +172,8 @@ class CompletionQueue : public GrpcLibrary { friend class ::grpc::Server; friend class ::grpc::ServerContext; template <class InputMessage, class OutputMessage> - friend Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, + friend Status BlockingUnaryCall(ChannelInterface* channel, + const RpcMethod& method, ClientContext* context, const InputMessage& request, OutputMessage* result); diff --git a/include/grpc++/generic/generic_stub.h b/include/grpc++/generic/generic_stub.h index a24fcb4fed..5ac0371efb 100644 --- a/include/grpc++/generic/generic_stub.h +++ b/include/grpc++/generic/generic_stub.h @@ -47,7 +47,8 @@ typedef ClientAsyncReaderWriter<ByteBuffer, ByteBuffer> // by name. class GenericStub GRPC_FINAL { public: - explicit GenericStub(std::shared_ptr<ChannelInterface> channel) : channel_(channel) {} + explicit GenericStub(std::shared_ptr<ChannelInterface> channel) + : channel_(channel) {} // begin a call to a named method std::unique_ptr<GenericClientAsyncReaderWriter> Call( diff --git a/include/grpc++/impl/codegen/channel_interface.h b/include/grpc++/impl/codegen/channel_interface.h index 353f52cef9..d83b3fadfe 100644 --- a/include/grpc++/impl/codegen/channel_interface.h +++ b/include/grpc++/impl/codegen/channel_interface.h @@ -101,20 +101,21 @@ class ChannelInterface { template <class R> friend class ::grpc::ClientAsyncResponseReader; template <class InputMessage, class OutputMessage> - friend Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, + friend Status BlockingUnaryCall(ChannelInterface* channel, + const RpcMethod& method, ClientContext* context, const InputMessage& request, OutputMessage* result); friend class ::grpc::RpcMethod; virtual Call CreateCall(const RpcMethod& method, ClientContext* context, - CompletionQueue* cq) = 0; + CompletionQueue* cq) = 0; virtual void PerformOpsOnCall(CallOpSetInterface* ops, Call* call) = 0; virtual void* RegisterMethod(const char* method) = 0; virtual void NotifyOnStateChangeImpl(grpc_connectivity_state last_observed, - gpr_timespec deadline, CompletionQueue* cq, - void* tag) = 0; + gpr_timespec deadline, + CompletionQueue* cq, void* tag) = 0; virtual bool WaitForStateChangeImpl(grpc_connectivity_state last_observed, - gpr_timespec deadline) = 0; + gpr_timespec deadline) = 0; }; } // namespace grpc diff --git a/include/grpc++/impl/codegen/server_interface.h b/include/grpc++/impl/codegen/server_interface.h index 5c16fd4653..1364bfe20f 100644 --- a/include/grpc++/impl/codegen/server_interface.h +++ b/include/grpc++/impl/codegen/server_interface.h @@ -100,7 +100,8 @@ class ServerInterface : public CallHook { /// \return bound port number on sucess, 0 on failure. /// /// \warning It's an error to call this method on an already started server. - virtual int AddListeningPort(const grpc::string& addr, ServerCredentials* creds) = 0; + virtual int AddListeningPort(const grpc::string& addr, + ServerCredentials* creds) = 0; /// Start the server. /// diff --git a/include/grpc++/server.h b/include/grpc++/server.h index 7ae94eba07..c6af748c51 100644 --- a/include/grpc++/server.h +++ b/include/grpc++/server.h @@ -62,8 +62,7 @@ class ThreadPoolInterface; /// Models a gRPC server. /// /// Servers are configured and started via \a grpc::ServerBuilder. -class Server GRPC_FINAL : public ServerInterface, - public GrpcLibrary { +class Server GRPC_FINAL : public ServerInterface, public GrpcLibrary { public: ~Server(); @@ -113,7 +112,8 @@ class Server GRPC_FINAL : public ServerInterface, /// Register a service. This call does not take ownership of the service. /// The service must exist for the lifetime of the Server instance. - bool RegisterService(const grpc::string* host, Service* service) GRPC_OVERRIDE; + bool RegisterService(const grpc::string* host, + Service* service) GRPC_OVERRIDE; /// Register a generic service. This call does not take ownership of the /// service. The service must exist for the lifetime of the Server instance. @@ -130,7 +130,8 @@ class Server GRPC_FINAL : public ServerInterface, /// \return bound port number on sucess, 0 on failure. /// /// \warning It's an error to call this method on an already started server. - int AddListeningPort(const grpc::string& addr, ServerCredentials* creds) GRPC_OVERRIDE; + int AddListeningPort(const grpc::string& addr, + ServerCredentials* creds) GRPC_OVERRIDE; /// Start the server. /// |