src/communication/nlsr_slh.hpp

#ifndef NLSR_SLH_HPP
#define NLSR_SLH_HPP

#include <iostream>

#include <ndn-cpp-dev/face.hpp>
#include <nsync/sync-socket.h>
#include <ndn-cpp-dev/security/validator-null.hpp>
#include <ndn-cpp-dev/util/scheduler.hpp>

#include "nlsr_sm.hpp"

class KeyManager;

extern "C" {
#include <unistd.h>
}

using namespace ndn;
using namespace Sync;
using namespace std;

class InterestManager;
class ConfParameter;

namespace nlsr
{
  class SyncLogicHandler
  {
  public:
    SyncLogicHandler(ndn::shared_ptr<boost::asio::io_service> ioService)
      : m_validator(new ndn::ValidatorNull())
      , m_syncFace(new ndn::Face(ioService))
    {}


    void createSyncSocket(Nlsr& pnlsr);
    void nsyncUpdateCallBack(const vector<MissingDataInfo>& v,
                             SyncSocket *socket, Nlsr& pnlsr );
    void nsyncRemoveCallBack(const string& prefix, Nlsr& pnlsr);
    void removeRouterFromSyncing(string& routerPrefix);
    void publishRoutingUpdate(SequencingManager& sm, string updatePrefix);
    void publishKeyUpdate(KeyManager& km);
    void publishIdentityUpdate(string identityName);
    void setSyncPrefix(string sp)
    {
      m_syncPrefix.clear();
      m_syncPrefix.set(sp);
    }
  private:
    void processUpdateFromSync(std::string updateName, uint64_t seqNo,
                               Nlsr& pnlsr);
    void processRoutingUpdateFromSync(std::string routerName, uint64_t seqNo,
                                      Nlsr& pnlsr);
    void processKeysUpdateFromSync(std::string certName, uint64_t seqNo,
                                   Nlsr& pnlsr);
    void publishSyncUpdate(string updatePrefix, uint64_t seqNo);
  private:
    ndn::shared_ptr<ndn::ValidatorNull> m_validator;
    ndn::shared_ptr<ndn::Face> m_syncFace;
    ndn::shared_ptr<SyncSocket> m_syncSocket;
    ndn::Name m_syncPrefix;
  };
}
#endif