55 /// Represents a gRPC server.
58 /// \a Server instances.
59 class Server : public ServerInterface, private GrpcLibraryCodegen {
61   ~Server() override;
63   /// Block until the server shuts down.
65   /// \warning The server must be either shutting down or some other thread must
69   /// Global callbacks are a set of hooks that are called when server
73   /// \a Server instances in an application and can be set exactly
78     /// Called before server is created.
80     /// Called before application callback for each synchronous server request
82     /// Called after application callback for each synchronous server request
84     /// Called before server is started.
85     virtual void PreServerStart(Server* /*server*/) {}  in PreServerStart()  argument
86     /// Called after a server port is added.
87     virtual void AddPort(Server* /*server*/, const std::string& /*addr*/,  in AddPort()  argument
92   /// to be alive until all server objects in the process have been destroyed.
94   /// application and is shared among all \a Server objects.
114     explicit experimental_type(Server* server) : server_(server) {}  in experimental_type()  argument
125     Server* server_;
135   /// The service must exist for the lifetime of the Server instance.
138   /// Try binding the server to the given \a addr endpoint
142   /// starting the server.
144   /// \param addr The address to try to bind to the server (eg, localhost:1234,
146   /// \param creds The credentials associated with the server.
150   /// \warning It is an error to call this method on an already started server.
154   /// NOTE: This is *NOT* a public API. The server constructors are supposed to
158   /// Server constructors. To be used by \a ServerBuilder only.
162   /// \param sync_server_cqs The completion queues to use if the server is a
163   /// synchronous server (or a hybrid server). The server polls for new RPCs on
166   /// \param min_pollers The minimum number of polling threads per server
168   /// incoming requests (used only in case of sync server)
170   /// \param max_pollers The maximum number of polling threads per server
172   /// incoming requests (used only in case of sync server)
175   /// server completion queues passed via sync_server_cqs param.
176   Server(ChannelArguments* args,
189   /// Start the server.
192   /// caller is required to keep all completion queues live until the server is
197   grpc_server* server() override { return server_; }  in server()  function
230   /// This is only used in case of a Sync server (i.e a server exposing a sync
235   /// service. The service must exist for the lifetime of the Server instance.
241   /// Server instance.
246   /// TODO(vjpai): Move these contents to the public API of Server when
251     explicit experimental_registration_type(Server* server) : server_(server) {}  in experimental_registration_type()  argument
258     Server* server_;
286   // Functions to manage the server shutdown ref count. Things that increase
287   // the ref count are the running state of the server (take a ref at start and
307   /// i.e. if the server has any services with sync methods. The server uses
322   // Server status
363   // with this server (if any). It is set on the first call to CallbackCQ().
364   // It is _not owned_ by the server; ownership belongs with its internal
368   // List of CQs passed in by user that must be Shutdown only after Server is