delayed-call-table.hpp

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

#include <deque>
#include <ndn-cpp/face.hpp>

namespace ndn {

class DelayedCallTable {
public:
  void
  callLater(Milliseconds delayMilliseconds, const Face::Callback& callback);

  void
  callTimedOut();

private:
  class Entry {
  public:
    Entry(Milliseconds delayMilliseconds, const Face::Callback& callback);

    MillisecondsSince1970
    getCallTime() const { return callTime_; }

    void
    callCallback() const { callback_(); }

    class Compare {
    public:
      bool
      operator()
        (const ptr_lib::shared_ptr<const Entry>& x,
         const ptr_lib::shared_ptr<const Entry>& y) const
      {
        return x->callTime_ < y->callTime_;
      }
    };

  private:
    const Face::Callback callback_;
    MillisecondsSince1970 callTime_;
  };

  // Use a deque so we can efficiently remove from the front.
  std::deque<ptr_lib::shared_ptr<Entry> > table_;
  Entry::Compare entryCompare_;
};

}

#endif