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