RPCCallStoreImpl

template<class _T>
class kanzi::connect::RPCCallStoreImpl

Public Functions

RPCCallStoreImpl(recursive_mutex &mutex)

Constructor.

Parameters

  • mutex: mutex to guard the internal structures.

void completeLinkBroken()

Completes RPC calls with link broken status.

void completeTimedOut(const chrono::steady_clock::time_point &now)

Completes timed out object (or otherwise discarded, objects.

Parameters

  • now: the current timestamp

bool contains(RPCTypes::CommHandle handle)

Determines whether this particular object exists in the store.

Return

true if object is held, false otherwise.

Parameters

  • handle: the handle of operation

shared_ptr<_T> get(RPCTypes::CommHandle handle)

Retrieve object from store.

Return

shared pointer to object.

Parameters

  • handle: idenfier of the object to retrieve.

void put(shared_ptr<_T> item)

Inserts item into the callstore.

Parameters

  • item: to insert. Saved as weak pointer thus pointer can get destroyed while in store.