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 number

• remoteClientId: remote client identifier number

• rmeoteSessionId: 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.