RPCCallStoreImpl¶
-
template<class
_T
>
classkanzi::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.
Inserts item into the callstore.
- Parameters
item
: to insert. Saved as weak pointer thus pointer can get destroyed while in store.
-