29 if (request->has_client_id())
30 response->mutable_client_id()->CopyFrom(request->client_id());
32 std::chrono::system_clock::duration now = std::chrono::system_clock::now().time_since_epoch();
34 response->mutable_server_id()->set_label(
GetPID());
35 response->mutable_server_id()->set_epoch(std::chrono::duration_cast<Seconds>(now).count());
36 response->set_server_time(std::chrono::duration_cast<Milliseconds>(now).count());
38 response->set_use_bindless_rpc(request->use_bindless_rpc());
51 ForceDisconnect(&disconnectNotification);
53 _session->DelayedCloseSocket();
uint32 HandleKeepAlive(NoData const *request) override
uint32 HandleRequestDisconnect(connection::v1::DisconnectRequest const *request) override
uint32 HandleConnect(connection::v1::ConnectRequest const *request, connection::v1::ConnectResponse *response, std::function< void(ServiceBase *, uint32, ::google::protobuf::Message const *)> &continuation) override
Connection(Session *session)
void set_error_code(::google::protobuf::uint32 value)