sync-protocol-adapter.hpp

Go to the documentation of this file.

/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
#ifndef NLSR_SYNC_PROTOCOL_ADAPTER_HPP
#define NLSR_SYNC_PROTOCOL_ADAPTER_HPP

#include "conf-parameter.hpp"

#include <ndn-cxx/face.hpp>
#include <ChronoSync/logic.hpp>
#include <PSync/full-producer.hpp>

namespace nlsr {

typedef std::function<void(const ndn::Name& updateName,
                           uint64_t seqNo)> SyncUpdateCallback;

class SyncProtocolAdapter
{
public:
  SyncProtocolAdapter(ndn::Face& facePtr,
                      int32_t syncProtocol,
                      const ndn::Name& syncPrefix,
                      const ndn::Name& userPrefix,
                      ndn::time::milliseconds syncInterestLifetime,
                      const SyncUpdateCallback& syncUpdateCallback);

  void
  addUserNode(const ndn::Name& userPrefix);

  void
  publishUpdate(const ndn::Name& userPrefix, uint64_t seq);

PUBLIC_WITH_TESTS_ELSE_PRIVATE:
  void
  onChronoSyncUpdate(const std::vector<chronosync::MissingDataInfo>& updates);

  void
  onPSyncUpdate(const std::vector<psync::MissingDataInfo>& updates);

private:
  int32_t m_syncProtocol;
  SyncUpdateCallback m_syncUpdateCallback;
  std::shared_ptr<chronosync::Logic> m_chronoSyncLogic;
  std::shared_ptr<psync::FullProducer> m_psyncLogic;
};

} // namespace nlsr

#endif // NLSR_SYNC_PROTOCOL_ADAPTER_HPP