//------------------------------------------------------------------------------
/*
    Copyright (c) 2011-2013, OpenCoin, Inc.
*/
//==============================================================================

#ifndef RIPPLE_PEERSET_H
#define RIPPLE_PEERSET_H

/** A set of peers used to acquire data.

    A peer set is used to acquire a ledger or a transaction set.
*/
class PeerSet
{
public:
    uint256 const& getHash () const
    {
        return mHash;
    }
    bool isComplete () const
    {
        return mComplete;
    }
    bool isFailed () const
    {
        return mFailed;
    }
    int getTimeouts () const
    {
        return mTimeouts;
    }

    bool isActive ();
    void progress ()
    {
        mProgress = true;
        mAggressive = false;
    }
    bool isProgress ()
    {
        return mProgress;
    }
    void touch ()
    {
        mLastAction = UptimeTimer::getInstance ().getElapsedSeconds ();
    }
    int getLastAction ()
    {
        return mLastAction;
    }

    void peerHas (Peer::ref);
    void badPeer (Peer::ref);
    void setTimer ();

    int takePeerSetFrom (const PeerSet& s);
    int getPeerCount () const;
    virtual bool isDone () const
    {
        return mComplete || mFailed;
    }

private:
    static void TimerEntry (boost::weak_ptr<PeerSet>, const boost::system::error_code& result);
    static void TimerJobEntry (Job&, boost::shared_ptr<PeerSet>);

    // VFALCO TODO try to make some of these private
protected:
    PeerSet (uint256 const& hash, int interval);
    virtual ~PeerSet () { }

    virtual void newPeer (Peer::ref) = 0;
    virtual void onTimer (bool progress) = 0;
    virtual boost::weak_ptr<PeerSet> pmDowncast () = 0;

    void setComplete ()
    {
        mComplete = true;
    }
    void setFailed ()
    {
        mFailed = true;
    }
    void invokeOnTimer ();

    void sendRequest (const protocol::TMGetLedger& message);
    void sendRequest (const protocol::TMGetLedger& message, Peer::ref peer);

protected:
    uint256 mHash;
    int mTimerInterval;
    int mTimeouts;
    bool mComplete;
    bool mFailed;
    bool mProgress;
    bool mAggressive;
    int mLastAction;


    boost::recursive_mutex                  mLock;
    // VFALCO TODO move the responsibility for the timer to a higher level
    boost::asio::deadline_timer             mTimer;

    // VFALCO TODO Verify that these are used in the way that the names suggest.
    typedef uint64 PeerIdentifier;
    typedef int ReceivedChunkCount;
    boost::unordered_map <PeerIdentifier, ReceivedChunkCount> mPeers;
};

#endif