Glenn Maynard
74 lines
2.0 KiB
C++
74 lines
2.0 KiB
C++
#ifndef CRYPTOPP_MQUEUE_H
|
|
#define CRYPTOPP_MQUEUE_H
|
|
|
|
#include "queue.h"
|
|
#include "filters.h"
|
|
#include <deque>
|
|
|
|
namespace CryptoPP {
|
|
|
|
//! Message Queue
|
|
class MessageQueue : public AutoSignaling<BufferedTransformation>
|
|
{
|
|
public:
|
|
MessageQueue(unsigned int nodeSize=256);
|
|
|
|
void IsolatedInitialize(const NameValuePairs ¶meters)
|
|
{m_queue.IsolatedInitialize(parameters); m_lengths.assign(1, 0U); m_messageCounts.assign(1, 0U);}
|
|
unsigned int Put2(const byte *begin, unsigned int length, int messageEnd, bool blocking)
|
|
{
|
|
m_queue.Put(begin, length);
|
|
m_lengths.back() += length;
|
|
if (messageEnd)
|
|
{
|
|
m_lengths.push_back(0);
|
|
m_messageCounts.back()++;
|
|
}
|
|
return 0;
|
|
}
|
|
bool IsolatedFlush(bool hardFlush, bool blocking) {return false;}
|
|
bool IsolatedMessageSeriesEnd(bool blocking)
|
|
{m_messageCounts.push_back(0); return false;}
|
|
|
|
unsigned long MaxRetrievable() const
|
|
{return m_lengths.front();}
|
|
bool AnyRetrievable() const
|
|
{return m_lengths.front() > 0;}
|
|
|
|
unsigned int TransferTo2(BufferedTransformation &target, unsigned long &transferBytes, const std::string &channel=NULL_CHANNEL, bool blocking=true);
|
|
unsigned int CopyRangeTo2(BufferedTransformation &target, unsigned long &begin, unsigned long end=ULONG_MAX, const std::string &channel=NULL_CHANNEL, bool blocking=true) const;
|
|
|
|
unsigned long TotalBytesRetrievable() const
|
|
{return m_queue.MaxRetrievable();}
|
|
unsigned int NumberOfMessages() const
|
|
{return m_lengths.size()-1;}
|
|
bool GetNextMessage();
|
|
|
|
unsigned int NumberOfMessagesInThisSeries() const
|
|
{return m_messageCounts[0];}
|
|
unsigned int NumberOfMessageSeries() const
|
|
{return m_messageCounts.size()-1;}
|
|
|
|
unsigned int CopyMessagesTo(BufferedTransformation &target, unsigned int count=UINT_MAX, const std::string &channel=NULL_CHANNEL) const;
|
|
|
|
const byte * Spy(unsigned int &contiguousSize) const;
|
|
|
|
void swap(MessageQueue &rhs);
|
|
|
|
private:
|
|
ByteQueue m_queue;
|
|
std::deque<unsigned long> m_lengths, m_messageCounts;
|
|
};
|
|
|
|
|
|
}
|
|
|
|
NAMESPACE_BEGIN(std)
|
|
template<> inline void swap(CryptoPP::MessageQueue &a, CryptoPP::MessageQueue &b)
|
|
{
|
|
a.swap(b);
|
|
}
|
|
}
|
|
|
|
#endif
|