libmoost
|
#include <queue.hpp>
Public Types | |
typedef dataT | value_type |
Public Member Functions | |
BasePersistedTQ (std::string const &rootDir, std::string const &queueId) | |
~BasePersistedTQ () | |
size_t | size () const |
bool | empty () const |
value_type & | front () |
void | push_back (value_type const &data) |
void | pop_front () |
Protected Member Functions | |
std::string | GenerateSerialiseKey (uint32_t key) const |
void | push_back_ (uint32_t key, value_type const &data) |
uint32_t | push_back_ (value_type const &data) |
Protected Attributes | |
queueT< std::pair< uint32_t, dataT > > | m_queue |
serializerT | m_serializer |
Private Attributes | |
uint32_t | m_nextKey |
boost::filesystem::path | m_rootDir |
std::string | m_guid |
std::string | m_queueId |
typedef dataT moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::value_type |
Reimplemented from moost::transaction::ITransactionQueue< dataT >.
moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::BasePersistedTQ | ( | std::string const & | rootDir, |
std::string const & | queueId | ||
) | [inline] |
moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::~BasePersistedTQ | ( | ) | [inline] |
bool moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::empty | ( | ) | const [inline, virtual] |
Implements moost::transaction::ITransactionQueue< dataT >.
value_type& moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::front | ( | ) | [inline, virtual] |
Implements moost::transaction::ITransactionQueue< dataT >.
Reimplemented in moost::transaction::PartiallyPersistedTQ< dataT, serializerT, queueT >.
std::string moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::GenerateSerialiseKey | ( | uint32_t | key | ) | const [inline, protected] |
void moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::pop_front | ( | ) | [inline, virtual] |
Implements moost::transaction::ITransactionQueue< dataT >.
Definition at line 248 of file queue.hpp.
void moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::push_back | ( | value_type const & | data | ) | [inline, virtual] |
Implements moost::transaction::ITransactionQueue< dataT >.
Reimplemented in moost::transaction::FullyPersistedTQ< dataT, serializerT, queueT >.
Definition at line 243 of file queue.hpp.
void moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::push_back_ | ( | uint32_t | key, |
value_type const & | data | ||
) | [inline, protected] |
uint32_t moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::push_back_ | ( | value_type const & | data | ) | [inline, protected] |
size_t moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::size | ( | ) | const [inline, virtual] |
Implements moost::transaction::ITransactionQueue< dataT >.
std::string moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_guid [private] |
uint32_t moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_nextKey [private] |
queueT<std::pair<uint32_t, dataT> > moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_queue [protected] |
std::string moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_queueId [private] |
boost::filesystem::path moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_rootDir [private] |
serializerT moost::transaction::BasePersistedTQ< dataT, serializerT, queueT >::m_serializer [protected] |