service.h 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293
  1. // Protocol Buffers - Google's data interchange format
  2. // Copyright 2008 Google Inc. All rights reserved.
  3. // https://developers.google.com/protocol-buffers/
  4. //
  5. // Redistribution and use in source and binary forms, with or without
  6. // modification, are permitted provided that the following conditions are
  7. // met:
  8. //
  9. // * Redistributions of source code must retain the above copyright
  10. // notice, this list of conditions and the following disclaimer.
  11. // * Redistributions in binary form must reproduce the above
  12. // copyright notice, this list of conditions and the following disclaimer
  13. // in the documentation and/or other materials provided with the
  14. // distribution.
  15. // * Neither the name of Google Inc. nor the names of its
  16. // contributors may be used to endorse or promote products derived from
  17. // this software without specific prior written permission.
  18. //
  19. // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  20. // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  21. // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  22. // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  23. // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  24. // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  25. // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  26. // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  27. // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  28. // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  29. // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  30. // Author: kenton@google.com (Kenton Varda)
  31. // Based on original Protocol Buffers design by
  32. // Sanjay Ghemawat, Jeff Dean, and others.
  33. //
  34. // DEPRECATED: This module declares the abstract interfaces underlying proto2
  35. // RPC services. These are intended to be independent of any particular RPC
  36. // implementation, so that proto2 services can be used on top of a variety
  37. // of implementations. Starting with version 2.3.0, RPC implementations should
  38. // not try to build on these, but should instead provide code generator plugins
  39. // which generate code specific to the particular RPC implementation. This way
  40. // the generated code can be more appropriate for the implementation in use
  41. // and can avoid unnecessary layers of indirection.
  42. //
  43. //
  44. // When you use the protocol compiler to compile a service definition, it
  45. // generates two classes: An abstract interface for the service (with
  46. // methods matching the service definition) and a "stub" implementation.
  47. // A stub is just a type-safe wrapper around an RpcChannel which emulates a
  48. // local implementation of the service.
  49. //
  50. // For example, the service definition:
  51. // service MyService {
  52. // rpc Foo(MyRequest) returns(MyResponse);
  53. // }
  54. // will generate abstract interface "MyService" and class "MyService::Stub".
  55. // You could implement a MyService as follows:
  56. // class MyServiceImpl : public MyService {
  57. // public:
  58. // MyServiceImpl() {}
  59. // ~MyServiceImpl() {}
  60. //
  61. // // implements MyService ---------------------------------------
  62. //
  63. // void Foo(google::protobuf::RpcController* controller,
  64. // const MyRequest* request,
  65. // MyResponse* response,
  66. // Closure* done) {
  67. // // ... read request and fill in response ...
  68. // done->Run();
  69. // }
  70. // };
  71. // You would then register an instance of MyServiceImpl with your RPC server
  72. // implementation. (How to do that depends on the implementation.)
  73. //
  74. // To call a remote MyServiceImpl, first you need an RpcChannel connected to it.
  75. // How to construct a channel depends, again, on your RPC implementation.
  76. // Here we use a hypothetical "MyRpcChannel" as an example:
  77. // MyRpcChannel channel("rpc:hostname:1234/myservice");
  78. // MyRpcController controller;
  79. // MyServiceImpl::Stub stub(&channel);
  80. // FooRequest request;
  81. // FooResponse response;
  82. //
  83. // // ... fill in request ...
  84. //
  85. // stub.Foo(&controller, request, &response, NewCallback(HandleResponse));
  86. //
  87. // On Thread-Safety:
  88. //
  89. // Different RPC implementations may make different guarantees about what
  90. // threads they may run callbacks on, and what threads the application is
  91. // allowed to use to call the RPC system. Portable software should be ready
  92. // for callbacks to be called on any thread, but should not try to call the
  93. // RPC system from any thread except for the ones on which it received the
  94. // callbacks. Realistically, though, simple software will probably want to
  95. // use a single-threaded RPC system while high-end software will want to
  96. // use multiple threads. RPC implementations should provide multiple
  97. // choices.
  98. #ifndef GOOGLE_PROTOBUF_SERVICE_H__
  99. #define GOOGLE_PROTOBUF_SERVICE_H__
  100. #include <string>
  101. #include "google/protobuf/stubs/callback.h"
  102. #include "google/protobuf/stubs/common.h"
  103. #include "google/protobuf/port.h"
  104. #ifdef SWIG
  105. #error "You cannot SWIG proto headers"
  106. #endif
  107. // Must be included last.
  108. #include "google/protobuf/port_def.inc"
  109. namespace google {
  110. namespace protobuf {
  111. // Defined in this file.
  112. class Service;
  113. class RpcController;
  114. class RpcChannel;
  115. // Defined in other files.
  116. class Descriptor; // descriptor.h
  117. class ServiceDescriptor; // descriptor.h
  118. class MethodDescriptor; // descriptor.h
  119. class Message; // message.h
  120. // Abstract base interface for protocol-buffer-based RPC services. Services
  121. // themselves are abstract interfaces (implemented either by servers or as
  122. // stubs), but they subclass this base interface. The methods of this
  123. // interface can be used to call the methods of the Service without knowing
  124. // its exact type at compile time (analogous to Reflection).
  125. class PROTOBUF_EXPORT Service {
  126. public:
  127. inline Service() {}
  128. Service(const Service&) = delete;
  129. Service& operator=(const Service&) = delete;
  130. virtual ~Service();
  131. // When constructing a stub, you may pass STUB_OWNS_CHANNEL as the second
  132. // parameter to the constructor to tell it to delete its RpcChannel when
  133. // destroyed.
  134. enum ChannelOwnership { STUB_OWNS_CHANNEL, STUB_DOESNT_OWN_CHANNEL };
  135. // Get the ServiceDescriptor describing this service and its methods.
  136. virtual const ServiceDescriptor* GetDescriptor() = 0;
  137. // Call a method of the service specified by MethodDescriptor. This is
  138. // normally implemented as a simple switch() that calls the standard
  139. // definitions of the service's methods.
  140. //
  141. // Preconditions:
  142. // * method->service() == GetDescriptor()
  143. // * request and response are of the exact same classes as the objects
  144. // returned by GetRequestPrototype(method) and
  145. // GetResponsePrototype(method).
  146. // * After the call has started, the request must not be modified and the
  147. // response must not be accessed at all until "done" is called.
  148. // * "controller" is of the correct type for the RPC implementation being
  149. // used by this Service. For stubs, the "correct type" depends on the
  150. // RpcChannel which the stub is using. Server-side Service
  151. // implementations are expected to accept whatever type of RpcController
  152. // the server-side RPC implementation uses.
  153. //
  154. // Postconditions:
  155. // * "done" will be called when the method is complete. This may be
  156. // before CallMethod() returns or it may be at some point in the future.
  157. // * If the RPC succeeded, "response" contains the response returned by
  158. // the server.
  159. // * If the RPC failed, "response"'s contents are undefined. The
  160. // RpcController can be queried to determine if an error occurred and
  161. // possibly to get more information about the error.
  162. virtual void CallMethod(const MethodDescriptor* method,
  163. RpcController* controller, const Message* request,
  164. Message* response, Closure* done) = 0;
  165. // CallMethod() requires that the request and response passed in are of a
  166. // particular subclass of Message. GetRequestPrototype() and
  167. // GetResponsePrototype() get the default instances of these required types.
  168. // You can then call Message::New() on these instances to construct mutable
  169. // objects which you can then pass to CallMethod().
  170. //
  171. // Example:
  172. // const MethodDescriptor* method =
  173. // service->GetDescriptor()->FindMethodByName("Foo");
  174. // Message* request = stub->GetRequestPrototype (method)->New();
  175. // Message* response = stub->GetResponsePrototype(method)->New();
  176. // request->ParseFromString(input);
  177. // service->CallMethod(method, *request, response, callback);
  178. virtual const Message& GetRequestPrototype(
  179. const MethodDescriptor* method) const = 0;
  180. virtual const Message& GetResponsePrototype(
  181. const MethodDescriptor* method) const = 0;
  182. };
  183. // An RpcController mediates a single method call. The primary purpose of
  184. // the controller is to provide a way to manipulate settings specific to the
  185. // RPC implementation and to find out about RPC-level errors.
  186. //
  187. // The methods provided by the RpcController interface are intended to be a
  188. // "least common denominator" set of features which we expect all
  189. // implementations to support. Specific implementations may provide more
  190. // advanced features (e.g. deadline propagation).
  191. class PROTOBUF_EXPORT RpcController {
  192. public:
  193. inline RpcController() {}
  194. RpcController(const RpcController&) = delete;
  195. RpcController& operator=(const RpcController&) = delete;
  196. virtual ~RpcController();
  197. // Client-side methods ---------------------------------------------
  198. // These calls may be made from the client side only. Their results
  199. // are undefined on the server side (may crash).
  200. // Resets the RpcController to its initial state so that it may be reused in
  201. // a new call. Must not be called while an RPC is in progress.
  202. virtual void Reset() = 0;
  203. // After a call has finished, returns true if the call failed. The possible
  204. // reasons for failure depend on the RPC implementation. Failed() must not
  205. // be called before a call has finished. If Failed() returns true, the
  206. // contents of the response message are undefined.
  207. virtual bool Failed() const = 0;
  208. // If Failed() is true, returns a human-readable description of the error.
  209. virtual std::string ErrorText() const = 0;
  210. // Advises the RPC system that the caller desires that the RPC call be
  211. // canceled. The RPC system may cancel it immediately, may wait awhile and
  212. // then cancel it, or may not even cancel the call at all. If the call is
  213. // canceled, the "done" callback will still be called and the RpcController
  214. // will indicate that the call failed at that time.
  215. virtual void StartCancel() = 0;
  216. // Server-side methods ---------------------------------------------
  217. // These calls may be made from the server side only. Their results
  218. // are undefined on the client side (may crash).
  219. // Causes Failed() to return true on the client side. "reason" will be
  220. // incorporated into the message returned by ErrorText(). If you find
  221. // you need to return machine-readable information about failures, you
  222. // should incorporate it into your response protocol buffer and should
  223. // NOT call SetFailed().
  224. virtual void SetFailed(const std::string& reason) = 0;
  225. // If true, indicates that the client canceled the RPC, so the server may
  226. // as well give up on replying to it. The server should still call the
  227. // final "done" callback.
  228. virtual bool IsCanceled() const = 0;
  229. // Asks that the given callback be called when the RPC is canceled. The
  230. // callback will always be called exactly once. If the RPC completes without
  231. // being canceled, the callback will be called after completion. If the RPC
  232. // has already been canceled when NotifyOnCancel() is called, the callback
  233. // will be called immediately.
  234. //
  235. // NotifyOnCancel() must be called no more than once per request.
  236. virtual void NotifyOnCancel(Closure* callback) = 0;
  237. };
  238. // Abstract interface for an RPC channel. An RpcChannel represents a
  239. // communication line to a Service which can be used to call that Service's
  240. // methods. The Service may be running on another machine. Normally, you
  241. // should not call an RpcChannel directly, but instead construct a stub Service
  242. // wrapping it. Example:
  243. // RpcChannel* channel = new MyRpcChannel("remotehost.example.com:1234");
  244. // MyService* service = new MyService::Stub(channel);
  245. // service->MyMethod(request, &response, callback);
  246. class PROTOBUF_EXPORT RpcChannel {
  247. public:
  248. inline RpcChannel() {}
  249. RpcChannel(const RpcChannel&) = delete;
  250. RpcChannel& operator=(const RpcChannel&) = delete;
  251. virtual ~RpcChannel();
  252. // Call the given method of the remote service. The signature of this
  253. // procedure looks the same as Service::CallMethod(), but the requirements
  254. // are less strict in one important way: the request and response objects
  255. // need not be of any specific class as long as their descriptors are
  256. // method->input_type() and method->output_type().
  257. virtual void CallMethod(const MethodDescriptor* method,
  258. RpcController* controller, const Message* request,
  259. Message* response, Closure* done) = 0;
  260. };
  261. } // namespace protobuf
  262. } // namespace google
  263. #include "google/protobuf/port_undef.inc"
  264. #endif // GOOGLE_PROTOBUF_SERVICE_H__