p2p::P2PServer::RuntimeContentProxy¶
-
class
kanzi::connect::p2p::P2PServer::RuntimeContentProxy¶ Runtime proxy for a single subscription.
Public Functions
-
inline
RuntimeContentProxy(int localClientId, int remoteClientId, int renoteSessionId)¶ Constructor.
- Parameters
localClientId – local client identifier number
remoteClientId – remote client identifier number
rmeoteSessionId – session identifier
-
inline void
clearUpdatePending()¶ Clears update pending flag from this runtime data proxy.
-
inline CreditFlowControl &
getFlowControl()¶ retrieve flow control instance
- Returns
flow control instance
-
inline int
getLocalClientId() const¶ Getter for local client identifier.
- Returns
local client identifier
-
inline int
getRemoteClientId() const¶ Getter for remote client identifier.
- Returns
remote client identifier
-
inline int
getRemoteSessionId() const¶ Getter for remote session identifier.
- Returns
remote session identifier
-
inline bool
hasUpdatePending() const¶ Determine whether update is pending for this runtime data proxy.
- Returns
true if update is pending, likely due the lack of send credits.
-
inline void
markUpdatePending()¶ Marks that this runtime data proxy has updated pending.
-
inline