1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
//
// Copyright (c) ZeroC, Inc. All rights reserved.
//
#ifndef GLACIER2_ROUTER_I_H
#define GLACIER2_ROUTER_I_H
#include <Ice/Ice.h>
#include <Glacier2/Router.h>
#include <Glacier2/ClientBlobject.h>
#include <Glacier2/ServerBlobject.h>
namespace Glacier2
{
class RoutingTable;
class RouterI;
class FilterManager;
class RouterI final : public Router
{
public:
RouterI(std::shared_ptr<Instance>, std::shared_ptr<Ice::Connection>, const std::string&,
std::shared_ptr<SessionPrx>, const Ice::Identity&, std::shared_ptr<FilterManager>, const Ice::Context&);
void destroy(std::function<void(std::exception_ptr)>);
std::shared_ptr<Ice::ObjectPrx> getClientProxy(Ice::optional<bool>&, const Ice::Current&) const override;
std::shared_ptr<Ice::ObjectPrx> getServerProxy(const Ice::Current&) const override;
Ice::ObjectProxySeq addProxies(Ice::ObjectProxySeq, const Ice::Current&) override;
std::string getCategoryForClient(const Ice::Current&) const override;
void createSessionAsync(std::string, std::string,
std::function<void(const std::shared_ptr<SessionPrx>& returnValue)>,
std::function<void(std::exception_ptr)>, const Ice::Current&) override;
void createSessionFromSecureConnectionAsync(
std::function<void(const std::shared_ptr<SessionPrx>& returnValue)>,
std::function<void(std::exception_ptr)>, const Ice::Current&) override;
void refreshSessionAsync(std::function<void()>,
std::function<void(std::exception_ptr)>,
const Ice::Current&) override;
void destroySession(const Ice::Current&) override;
long long int getSessionTimeout(const Ice::Current&) const override;
int getACMTimeout(const Ice::Current&) const override;
std::shared_ptr<ClientBlobject> getClientBlobject() const;
std::shared_ptr<ServerBlobject> getServerBlobject() const;
std::shared_ptr<SessionPrx> getSession() const;
std::chrono::steady_clock::time_point getTimestamp() const;
void updateTimestamp() const;
void updateObserver(const std::shared_ptr<Glacier2::Instrumentation::RouterObserver>&);
std::string toString() const;
private:
const std::shared_ptr<Instance> _instance;
const std::shared_ptr<RoutingTable> _routingTable;
const std::shared_ptr<Ice::ObjectPrx> _clientProxy;
const std::shared_ptr<Ice::ObjectPrx> _serverProxy;
const std::shared_ptr<ClientBlobject> _clientBlobject;
const std::shared_ptr<ServerBlobject> _serverBlobject;
const bool _clientBlobjectBuffered;
const bool _serverBlobjectBuffered;
const std::shared_ptr<Ice::Connection> _connection;
const std::string _userId;
const std::shared_ptr<SessionPrx> _session;
const Ice::Identity _controlId;
const Ice::Context _context;
const std::mutex _timestampMutex;
mutable std::chrono::steady_clock::time_point _timestamp;
std::shared_ptr<Glacier2::Instrumentation::SessionObserver> _observer;
};
}
#endif
|
