#include <rpcresult.hpp>
Public Member Functions | |
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. | |
bool | contains (RPCTypes::CommHandle handle) |
Determines whether this particular object exists in the store. | |
shared_ptr< _T > | get (RPCTypes::CommHandle handle) |
Retrieve object from store. | |
void | put (shared_ptr< _T > item) |
Inserts item into the callstore. | |
RPCCallStoreImpl (recursive_mutex &mutex) | |
Constructor. | |
|
inline |
Constructor.
mutex | mutex to guard the internal structures. |
void kanzi::connect::RPCCallStoreImpl< _T >::completeLinkBroken | ( | ) |
Completes RPC calls with link broken status.
void kanzi::connect::RPCCallStoreImpl< _T >::completeTimedOut | ( | const chrono::steady_clock::time_point & | now | ) |
Completes timed out object (or otherwise discarded, objects.
now | the current timestamp |
bool kanzi::connect::RPCCallStoreImpl< _T >::contains | ( | RPCTypes::CommHandle | handle | ) |
Determines whether this particular object exists in the store.
handle | the handle of operation |
|
inline |
Retrieve object from store.
handle | idenfier of the object to retrieve. |
|
inline |
Inserts item into the callstore.
item | to insert. Saved as weak pointer thus pointer can get destroyed while in store. |