Public Member Functions | |
ObjectStoreService (const ObjectWatcher &ow) | |
virtual const bool | isReplica () |
template<typename T > | |
derecho::rpc::QueryResults< std::tuple< version_t, uint64_t > > | _aio_put (const Object &object, const bool &force_client) |
template<typename T > | |
std::tuple< version_t, uint64_t > | _bio_put (const Object &object, const bool &force_client) |
virtual std::tuple< version_t, uint64_t > | bio_put (const Object &object, const bool &force_client) |
virtual derecho::rpc::QueryResults< std::tuple< version_t, uint64_t > > | aio_put (const Object &object, const bool &force_client) |
template<typename T > | |
derecho::rpc::QueryResults< std::tuple< version_t, uint64_t > > | _aio_remove (const OID &oid, const bool &force_client) |
template<typename T > | |
std::tuple< version_t, uint64_t > | _bio_remove (const OID &oid, const bool &force_client) |
virtual std::tuple< version_t, uint64_t > | bio_remove (const OID &oid, const bool &force_client) |
virtual derecho::rpc::QueryResults< std::tuple< version_t, uint64_t > > | aio_remove (const OID &oid, const bool &force_client) |
template<typename T > | |
derecho::rpc::QueryResults< const Object > | _aio_get (const OID &oid, const version_t &ver, const bool &force_client) |
template<typename T > | |
derecho::rpc::QueryResults< const Object > | _aio_get (const OID &oid, const uint64_t &ts_us) |
template<typename T > | |
Object | _bio_get (const OID &oid, const version_t &ver, const bool &force_client) |
template<typename T > | |
Object | _bio_get (const OID &oid, const uint64_t &ts_us) |
virtual Object | bio_get (const OID &oid, const version_t &ver, const bool &force_client) |
virtual Object | bio_get (const OID &oid, const uint64_t &ts_us) |
virtual derecho::rpc::QueryResults< const Object > | aio_get (const OID &oid, const version_t &ver, const bool &force_client) |
virtual derecho::rpc::QueryResults< const Object > | aio_get (const OID &oid, const uint64_t &ts_us) |
virtual void | leave (bool group_shutdown) |
virtual const ObjectWatcher & | getObjectWatcher () |
Public Member Functions inherited from mutils::RemoteDeserializationContext | |
RemoteDeserializationContext (const RemoteDeserializationContext &)=delete | |
RemoteDeserializationContext (const RemoteDeserializationContext &&)=delete | |
virtual | ~RemoteDeserializationContext () |
RemoteDeserializationContext () | |
Static Public Member Functions | |
static IObjectStoreService & | get (int argc, char **argv, const ObjectWatcher &ow={}) |
Static Public Member Functions inherited from objectstore::IObjectStoreService | |
static IObjectStoreService & | getObjectStoreService (int argc, char **argv, const ObjectWatcher &ow={}) |
Private Types | |
enum | OSSMode { VOLATILE_UNLOGGED, VOLATILE_LOGGED, PERSISTENT_UNLOGGED, PERSISTENT_LOGGED } |
Private Attributes | |
OSSMode | mode |
const ObjectWatcher & | object_watcher |
std::vector< node_id_t > | replicas |
const bool | bReplica |
const node_id_t | myid |
derecho::Group< VolatileUnloggedObjectStore, PersistentLoggedObjectStore > | group |
std::mutex | write_mutex |
Definition at line 646 of file ObjectStore.cpp.
|
private |
Enumerator | |
---|---|
VOLATILE_UNLOGGED | |
VOLATILE_LOGGED | |
PERSISTENT_UNLOGGED | |
PERSISTENT_LOGGED |
Definition at line 648 of file ObjectStore.cpp.
|
inline |
Definition at line 666 of file ObjectStore.cpp.
|
inline |
Definition at line 837 of file ObjectStore.cpp.
|
inline |
Definition at line 857 of file ObjectStore.cpp.
|
inline |
Definition at line 723 of file ObjectStore.cpp.
|
inline |
Definition at line 781 of file ObjectStore.cpp.
|
inline |
Definition at line 872 of file ObjectStore.cpp.
|
inline |
Definition at line 880 of file ObjectStore.cpp.
|
inline |
Definition at line 738 of file ObjectStore.cpp.
|
inline |
Definition at line 796 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 912 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 925 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 767 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 822 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 886 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 899 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 750 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 808 of file ObjectStore.cpp.
|
static |
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 945 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 718 of file ObjectStore.cpp.
|
inlinevirtual |
Implements objectstore::IObjectStoreService.
Definition at line 938 of file ObjectStore.cpp.
|
private |
Definition at line 657 of file ObjectStore.cpp.
|
private |
Definition at line 659 of file ObjectStore.cpp.
|
private |
Definition at line 654 of file ObjectStore.cpp.
|
private |
Definition at line 658 of file ObjectStore.cpp.
|
private |
Definition at line 655 of file ObjectStore.cpp.
|
private |
Definition at line 656 of file ObjectStore.cpp.
|
private |
Definition at line 662 of file ObjectStore.cpp.