RPCCallStoreImpl

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

Public Functions

inline 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.

Parameters

handle – the handle of operation

Returns

true if object is held, false otherwise.

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

Retrieve object from store.

Parameters

handle – idenfier of the object to retrieve.

Returns

shared pointer to object.

inline 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.