55 lines
1.1 KiB
C++
55 lines
1.1 KiB
C++
/*
|
|
* File: P2PStorage.h
|
|
* Author: jgaebler
|
|
*
|
|
* Created on August 20, 2012, 11:39 AM
|
|
*/
|
|
#pragma once
|
|
|
|
#ifndef P2PSTORAGE_H
|
|
#define P2PSTORAGE_H
|
|
|
|
#include "common/Defines.h"
|
|
|
|
#if P2P_SYNC_ENABLED
|
|
|
|
#include "mob/sync/StorageService.h"
|
|
#include "mt/MulticastMessageQueue.h"
|
|
|
|
namespace ubeeme {
|
|
namespace moversight {
|
|
|
|
class MulticastMessage;
|
|
|
|
/**
|
|
* @brief Provides a service that uses the p2p overlay to store messages,
|
|
* which will be afterwards used to re-sync the peer with the group.
|
|
* @author Jan Gäbler
|
|
* @ingroup Moversight
|
|
* @class P2PStorage
|
|
*/
|
|
class P2PStorage : public StorageService {
|
|
public:
|
|
|
|
P2PStorage(Dispatcher & dis);
|
|
virtual ~P2PStorage();
|
|
|
|
void initialise();
|
|
void finalise();
|
|
|
|
virtual void store( MulticastMessage & m);
|
|
|
|
virtual MulticastMessageQueue retrieve(VirtualLogicalTime const & lastSeenLt);
|
|
|
|
private:
|
|
|
|
};
|
|
|
|
}
|
|
}
|
|
|
|
#endif /** P2P_SYNC_ENABLED **/
|
|
|
|
#endif /* P2PSTORAGE_H */
|
|
|