mirror of
https://github.com/uroni/urbackup_backend.git
synced 2025-10-26 11:36:50 +00:00
52 lines
1.2 KiB
C++
52 lines
1.2 KiB
C++
#ifndef MEMPIPE_H_
|
|
#define MEMPIPE_H_
|
|
|
|
#include "Interface/Pipe.h"
|
|
#include <deque>
|
|
#include <string>
|
|
#include "Interface/Mutex.h"
|
|
#include "Interface/Condition.h"
|
|
|
|
class CMemoryPipe : public IPipe
|
|
{
|
|
public:
|
|
CMemoryPipe(void);
|
|
~CMemoryPipe(void);
|
|
|
|
virtual size_t Read(char *buffer, size_t bsize, int timeoutms);
|
|
virtual bool Write(const char *buffer, size_t bsize, int timeoutms, bool flush);
|
|
virtual size_t Read(std::string *ret, int timeoutms);
|
|
virtual bool Write(const std::string &str, int timeoutms, bool flush);
|
|
|
|
virtual bool isWritable(int timeoutms);
|
|
virtual bool isReadable(int timeoutms);
|
|
|
|
virtual bool hasError(void);
|
|
|
|
virtual void shutdown(void);
|
|
|
|
virtual size_t getNumElements(void);
|
|
virtual size_t getNumWaiters();
|
|
|
|
virtual void addThrottler(IPipeThrottler *throttler);
|
|
virtual void addOutgoingThrottler(IPipeThrottler *throttler);
|
|
virtual void addIncomingThrottler(IPipeThrottler *throttler);
|
|
|
|
virtual _i64 getTransferedBytes(void);
|
|
virtual void resetTransferedBytes(void);
|
|
|
|
virtual bool Flush( int timeoutms=-1 );
|
|
|
|
|
|
private:
|
|
std::deque<std::string> queue;
|
|
|
|
IMutex *mutex;
|
|
ICondition *cond;
|
|
|
|
size_t waiters;
|
|
bool has_error;
|
|
};
|
|
|
|
#endif /*MEMPIPE_H_*/
|