#include <algorithm>
#include <cassert>
#include <boost/lexical_cast.hpp>
#include "Log.h"
#include "util.h"
#include "ElGamal.h"
#include "Timestamp.h"
#include "NetDb.h"
#include "AddressBook.h"
#include "Destination.h"

namespace i2p
{
namespace client
{
    ClientDestination::ClientDestination (const i2p::data::PrivateKeys& keys, bool isPublic, 
            const std::map<std::string, std::string> * params):
        m_IsRunning (false), m_Thread (nullptr), m_Work (m_Service),    
        m_Keys (keys), m_IsPublic (isPublic), m_PublishReplyToken (0),
        m_DatagramDestination (nullptr), m_PublishConfirmationTimer (m_Service), m_CleanupTimer (m_Service)
    {
        i2p::crypto::GenerateElGamalKeyPair(i2p::context.GetRandomNumberGenerator (), m_EncryptionPrivateKey, m_EncryptionPublicKey);
        int inboundTunnelLen = DEFAULT_INBOUND_TUNNEL_LENGTH;
        int outboundTunnelLen = DEFAULT_OUTBOUND_TUNNEL_LENGTH;
        int inboundTunnelsQuantity = DEFAULT_INBOUND_TUNNELS_QUANTITY;
        int outboundTunnelsQuantity = DEFAULT_OUTBOUND_TUNNELS_QUANTITY;
        std::shared_ptr<std::vector<i2p::data::IdentHash> > explicitPeers;
        if (params)
        {
            auto it = params->find (I2CP_PARAM_INBOUND_TUNNEL_LENGTH);
            if (it != params->end ())
            {   
                int len = boost::lexical_cast<int>(it->second);
                if (len > 0)
                {
                    inboundTunnelLen = len;
                    LogPrint (eLogInfo, "Inbound tunnel length set to ", len);
                }
            }   
            it = params->find (I2CP_PARAM_OUTBOUND_TUNNEL_LENGTH);
            if (it != params->end ())
            {
                int len = boost::lexical_cast<int>(it->second);
                if (len > 0)
                {
                    outboundTunnelLen = len;
                    LogPrint (eLogInfo, "Outbound tunnel length set to ", len);
                }
            }   
            it = params->find (I2CP_PARAM_INBOUND_TUNNELS_QUANTITY);
            if (it != params->end ())
            {
                int quantity = boost::lexical_cast<int>(it->second);
                if (quantity > 0)
                {
                    inboundTunnelsQuantity = quantity;
                    LogPrint (eLogInfo, "Inbound tunnels quantity set to ", quantity);
                }   
            }
            it = params->find (I2CP_PARAM_OUTBOUND_TUNNELS_QUANTITY);
            if (it != params->end ())
            {
                int quantity = boost::lexical_cast<int>(it->second);
                if (quantity > 0)
                {
                    outboundTunnelsQuantity = quantity;
                    LogPrint (eLogInfo, "Outbound tunnels quantity set to ", quantity);
                }   
            }
            it = params->find (I2CP_PARAM_EXPLICIT_PEERS);
            if (it != params->end ())
            {
                explicitPeers = std::make_shared<std::vector<i2p::data::IdentHash> >();
                std::stringstream ss(it->second);
                std::string b64;
                while (std::getline (ss, b64, ','))
                {
                    i2p::data::IdentHash ident;
                    ident.FromBase64 (b64);
                    explicitPeers->push_back (ident);
                }
                LogPrint (eLogInfo, "Explicit peers set to ", it->second);
            }
        }   
        m_Pool = i2p::tunnel::tunnels.CreateTunnelPool (this, inboundTunnelLen, outboundTunnelLen, inboundTunnelsQuantity, outboundTunnelsQuantity);  
        if (explicitPeers)
            m_Pool->SetExplicitPeers (explicitPeers);
        if (m_IsPublic)
            LogPrint (eLogInfo, "Local address ", i2p::client::GetB32Address(GetIdentHash()), " created");
        m_StreamingDestination = std::make_shared<i2p::stream::StreamingDestination> (*this); // TODO:
    }

    ClientDestination::~ClientDestination ()
    {
        if (m_IsRunning)    
            Stop ();
        for (auto it: m_LeaseSetRequests)
            delete it.second;
        if (m_Pool)
            i2p::tunnel::tunnels.DeleteTunnelPool (m_Pool);     
        if (m_DatagramDestination)
            delete m_DatagramDestination;
    }   

    void ClientDestination::Run ()
    {
        while (m_IsRunning)
        {
            try
            {   
                m_Service.run ();
            }
            catch (std::exception& ex)
            {
                LogPrint ("Destination: ", ex.what ());
            }   
        }   
    }   

    void ClientDestination::Start ()
    {   
        if (!m_IsRunning)
        {   
            m_IsRunning = true;
            m_Pool->SetLocalDestination (this);
            m_Pool->SetActive (true);
            m_Thread = new std::thread (std::bind (&ClientDestination::Run, this));
            m_StreamingDestination->Start ();   
            for (auto it: m_StreamingDestinationsByPorts)
                it.second->Start ();
            
            m_CleanupTimer.expires_from_now (boost::posix_time::minutes (DESTINATION_CLEANUP_TIMEOUT));
            m_CleanupTimer.async_wait (std::bind (&ClientDestination::HandleCleanupTimer,
                this, std::placeholders::_1));
        }   
    }
        
    void ClientDestination::Stop ()
    {   
        if (m_IsRunning)
        {   
            m_CleanupTimer.cancel ();
            m_IsRunning = false;
            m_StreamingDestination->Stop ();    
            for (auto it: m_StreamingDestinationsByPorts)
                it.second->Stop ();
            if (m_DatagramDestination)
            {
                auto d = m_DatagramDestination;
                m_DatagramDestination = nullptr;
                delete d;
            }   
            if (m_Pool)
            {   
                m_Pool->SetLocalDestination (nullptr);
                i2p::tunnel::tunnels.StopTunnelPool (m_Pool);
            }   
            m_Service.stop ();
            if (m_Thread)
            {   
                m_Thread->join (); 
                delete m_Thread;
                m_Thread = 0;
            }   
        }   
    }   

    std::shared_ptr<const i2p::data::LeaseSet> ClientDestination::FindLeaseSet (const i2p::data::IdentHash& ident)
    {
        auto it = m_RemoteLeaseSets.find (ident);
        if (it != m_RemoteLeaseSets.end ())
        {   
            if (it->second->HasNonExpiredLeases ())
                return it->second;
            else
                LogPrint ("All leases of remote LeaseSet expired");
        }   
        else
        {   
            auto ls = i2p::data::netdb.FindLeaseSet (ident);
            if (ls)
            {
                m_RemoteLeaseSets[ident] = ls;          
                return ls;
            }   
        }
        return nullptr;
    }   

    std::shared_ptr<const i2p::data::LeaseSet> ClientDestination::GetLeaseSet ()
    {
        if (!m_Pool) return nullptr;
        if (!m_LeaseSet)
            UpdateLeaseSet ();
        return m_LeaseSet;
    }   

    void ClientDestination::UpdateLeaseSet ()
    {
        m_LeaseSet.reset (new i2p::data::LeaseSet (*m_Pool));
    }   

    bool ClientDestination::SubmitSessionKey (const uint8_t * key, const uint8_t * tag)
    {
        struct
        {
            uint8_t k[32], t[32];
        } data; 
        memcpy (data.k, key, 32);
        memcpy (data.t, tag, 32);
        m_Service.post ([this,data](void)
            {
                this->AddSessionKey (data.k, data.t);
            });
        return true;
    }

    void ClientDestination::ProcessGarlicMessage (std::shared_ptr<I2NPMessage> msg)
    {
        m_Service.post (std::bind (&ClientDestination::HandleGarlicMessage, this, msg)); 
    }

    void ClientDestination::ProcessDeliveryStatusMessage (std::shared_ptr<I2NPMessage> msg)
    {
        m_Service.post (std::bind (&ClientDestination::HandleDeliveryStatusMessage, this, msg)); 
    }

    void ClientDestination::HandleI2NPMessage (const uint8_t * buf, size_t len, std::shared_ptr<i2p::tunnel::InboundTunnel> from)
    {
        uint8_t typeID = buf[I2NP_HEADER_TYPEID_OFFSET];
        switch (typeID)
        {   
            case eI2NPData:
                HandleDataMessage (buf + I2NP_HEADER_SIZE, bufbe16toh (buf + I2NP_HEADER_SIZE_OFFSET));
            break;
            case eI2NPDeliveryStatus:
                // we assume tunnel tests non-encrypted
                HandleDeliveryStatusMessage (CreateI2NPMessage (buf, GetI2NPMessageLength (buf), from));
            break;  
            case eI2NPDatabaseStore:
                HandleDatabaseStoreMessage (buf + I2NP_HEADER_SIZE, bufbe16toh (buf + I2NP_HEADER_SIZE_OFFSET));
            break;
            case eI2NPDatabaseSearchReply:
                HandleDatabaseSearchReplyMessage (buf + I2NP_HEADER_SIZE, bufbe16toh (buf + I2NP_HEADER_SIZE_OFFSET));
            break;  
            default:
                i2p::HandleI2NPMessage (CreateI2NPMessage (buf, GetI2NPMessageLength (buf), from));
        }       
    }   

    void ClientDestination::HandleDatabaseStoreMessage (const uint8_t * buf, size_t len)
    {
        uint32_t replyToken = bufbe32toh (buf + DATABASE_STORE_REPLY_TOKEN_OFFSET);
        size_t offset = DATABASE_STORE_HEADER_SIZE;
        if (replyToken) 
        {
            LogPrint (eLogInfo, "Reply token is ignored for DatabaseStore");
            offset += 36;
        }
        std::shared_ptr<i2p::data::LeaseSet> leaseSet;
        if (buf[DATABASE_STORE_TYPE_OFFSET] == 1) // LeaseSet
        {
            LogPrint (eLogDebug, "Remote LeaseSet");
            auto it = m_RemoteLeaseSets.find (buf + DATABASE_STORE_KEY_OFFSET);
            if (it != m_RemoteLeaseSets.end ())
            {
                leaseSet = it->second;
                leaseSet->Update (buf + offset, len - offset); 
                if (leaseSet->IsValid ())
                    LogPrint (eLogDebug, "Remote LeaseSet updated");
                else
                {
                    LogPrint (eLogDebug, "Remote LeaseSet update failed");
                    m_RemoteLeaseSets.erase (it);
                    leaseSet = nullptr;
                }
            }
            else
            {   
                leaseSet = std::make_shared<i2p::data::LeaseSet> (buf + offset, len - offset);
                if (leaseSet->IsValid ())
                {
                    LogPrint (eLogDebug, "New remote LeaseSet added");
                    m_RemoteLeaseSets[buf + DATABASE_STORE_KEY_OFFSET] = leaseSet;
                }
                else
                {
                    LogPrint (eLogError, "New remote LeaseSet verification failed");
                    leaseSet = nullptr;
                }
            }   
        }   
        else
            LogPrint (eLogError, "Unexpected client's DatabaseStore type ", buf[DATABASE_STORE_TYPE_OFFSET], ". Dropped");
        
        auto it1 = m_LeaseSetRequests.find (buf + DATABASE_STORE_KEY_OFFSET);
        if (it1 != m_LeaseSetRequests.end ())
        {
            it1->second->requestTimeoutTimer.cancel ();
            if (it1->second->requestComplete) it1->second->requestComplete (leaseSet);
            delete it1->second;
            m_LeaseSetRequests.erase (it1);
        }   
    }

    void ClientDestination::HandleDatabaseSearchReplyMessage (const uint8_t * buf, size_t len)
    {
        i2p::data::IdentHash key (buf);
        int num = buf[32]; // num
        LogPrint ("DatabaseSearchReply for ", key.ToBase64 (), " num=", num);
        auto it = m_LeaseSetRequests.find (key);
        if (it != m_LeaseSetRequests.end ())
        {
            LeaseSetRequest * request = it->second;
            bool found = false;
            if (request->excluded.size () < MAX_NUM_FLOODFILLS_PER_REQUEST)
            {   
                for (int i = 0; i < num; i++)
                {
                    i2p::data::IdentHash peerHash (buf + 33 + i*32);
                    auto floodfill = i2p::data::netdb.FindRouter (peerHash);
                    if (floodfill)
                    {
                        LogPrint (eLogInfo, "Requesting ", key.ToBase64 (), " at ", peerHash.ToBase64 ());
                        if (SendLeaseSetRequest (key, floodfill, request))
                            found = true;
                    }   
                    else
                    {   
                        LogPrint (eLogInfo, "Found new floodfill. Request it");
                        i2p::data::netdb.RequestDestination (peerHash);
                    }   
                }
                if (!found)
                    LogPrint (eLogError, "Suggested floodfills are not presented in netDb"); 
            }   
            else
                LogPrint (eLogInfo, key.ToBase64 (), " was not found on ",  MAX_NUM_FLOODFILLS_PER_REQUEST," floodfills");
            if (!found)
            {
                if (request->requestComplete) request->requestComplete (nullptr);
                delete request;
                m_LeaseSetRequests.erase (key);
            }   
        }   
        else    
            LogPrint ("Request for ", key.ToBase64 (), " not found");
    }   
        
    void ClientDestination::HandleDeliveryStatusMessage (std::shared_ptr<I2NPMessage> msg)
    {
        uint32_t msgID = bufbe32toh (msg->GetPayload () + DELIVERY_STATUS_MSGID_OFFSET);
        if (msgID == m_PublishReplyToken)
        {
            LogPrint (eLogDebug, "Publishing confirmed");
            m_ExcludedFloodfills.clear ();
            m_PublishReplyToken = 0;
        }
        else
            i2p::garlic::GarlicDestination::HandleDeliveryStatusMessage (msg);
    }   

    void ClientDestination::SetLeaseSetUpdated ()
    {
        i2p::garlic::GarlicDestination::SetLeaseSetUpdated ();  
        UpdateLeaseSet ();
        if (m_IsPublic)
            Publish ();
    }
        
    void ClientDestination::Publish ()
    {   
        if (!m_LeaseSet || !m_Pool) 
        {
            LogPrint (eLogError, "Can't publish non-existing LeaseSet");
            return;
        }
        if (m_PublishReplyToken)
        {
            LogPrint (eLogInfo, "Publishing is pending");
            return;
        }
        auto outbound = m_Pool->GetNextOutboundTunnel ();
        if (!outbound)
        {
            LogPrint ("Can't publish LeaseSet. No outbound tunnels");
            return;
        }
        std::set<i2p::data::IdentHash> excluded; 
        auto floodfill = i2p::data::netdb.GetClosestFloodfill (m_LeaseSet->GetIdentHash (), m_ExcludedFloodfills);  
        if (!floodfill)
        {
            LogPrint ("Can't publish LeaseSet. No more floodfills found");
            m_ExcludedFloodfills.clear ();
            return;
        }   
        m_ExcludedFloodfills.insert (floodfill->GetIdentHash ());
        LogPrint (eLogDebug, "Publish LeaseSet of ", GetIdentHash ().ToBase32 ());
        m_PublishReplyToken = i2p::context.GetRandomNumberGenerator ().GenerateWord32 ();
        auto msg = WrapMessage (floodfill, i2p::CreateDatabaseStoreMsg (m_LeaseSet, m_PublishReplyToken));          
        m_PublishConfirmationTimer.expires_from_now (boost::posix_time::seconds(PUBLISH_CONFIRMATION_TIMEOUT));
        m_PublishConfirmationTimer.async_wait (std::bind (&ClientDestination::HandlePublishConfirmationTimer,
            this, std::placeholders::_1));  
        outbound->SendTunnelDataMsg (floodfill->GetIdentHash (), 0, msg);   
    }

    void ClientDestination::HandlePublishConfirmationTimer (const boost::system::error_code& ecode)
    {
        if (ecode != boost::asio::error::operation_aborted)
        {   
            if (m_PublishReplyToken)
            {
                LogPrint (eLogWarning, "Publish confirmation was not received in ", PUBLISH_CONFIRMATION_TIMEOUT,  "seconds. Try again");
                m_PublishReplyToken = 0;
                Publish ();
            }
        }
    }

    void ClientDestination::HandleDataMessage (const uint8_t * buf, size_t len)
    {
        uint32_t length = bufbe32toh (buf);
        buf += 4;
        // we assume I2CP payload
        uint16_t fromPort = bufbe16toh (buf + 4), // source
            toPort = bufbe16toh (buf + 6); // destination 
        switch (buf[9])
        {
            case PROTOCOL_TYPE_STREAMING:
            {
                // streaming protocol
                auto dest = GetStreamingDestination (toPort);
                if (dest)
                    dest->HandleDataMessagePayload (buf, length);
                else
                    LogPrint ("Missing streaming destination");
            }
            break;
            case PROTOCOL_TYPE_DATAGRAM:
                // datagram protocol
                if (m_DatagramDestination)
                    m_DatagramDestination->HandleDataMessagePayload (fromPort, toPort, buf, length);
                else
                    LogPrint ("Missing streaming destination");
            break;
            default:
                LogPrint ("Data: unexpected protocol ", buf[9]);
        }
    }   

    void ClientDestination::CreateStream (StreamRequestComplete streamRequestComplete, const i2p::data::IdentHash& dest, int port) {
        assert(streamRequestComplete);
        auto leaseSet = FindLeaseSet (dest);
        if (leaseSet)
            streamRequestComplete(CreateStream (leaseSet, port));
        else
        {
            RequestDestination (dest,
                [this, streamRequestComplete, port](std::shared_ptr<i2p::data::LeaseSet> ls)
                {
                    if (ls)
                        streamRequestComplete(CreateStream (ls, port));
                    else
                        streamRequestComplete (nullptr);
                });
        }
    }

    std::shared_ptr<i2p::stream::Stream> ClientDestination::CreateStream (std::shared_ptr<const i2p::data::LeaseSet> remote, int port)
    {
        if (m_StreamingDestination)
            return m_StreamingDestination->CreateNewOutgoingStream (remote, port);
        else
            return nullptr;
    }

    std::shared_ptr<i2p::stream::StreamingDestination> ClientDestination::GetStreamingDestination (int port) const 
    { 
        if (port) 
        {
            auto it = m_StreamingDestinationsByPorts.find (port);
            if (it != m_StreamingDestinationsByPorts.end ())
                return it->second;
        }   
        // if port is zero or not found, use default destination
        return m_StreamingDestination; 
    }
        
    void ClientDestination::AcceptStreams (const i2p::stream::StreamingDestination::Acceptor& acceptor)
    {
        if (m_StreamingDestination)
            m_StreamingDestination->SetAcceptor (acceptor);
    }

    void ClientDestination::StopAcceptingStreams ()
    {
        if (m_StreamingDestination)
            m_StreamingDestination->ResetAcceptor ();
    }
        
    bool ClientDestination::IsAcceptingStreams () const
    {
        if (m_StreamingDestination)
            return m_StreamingDestination->IsAcceptorSet ();
        return false;
    }   

    std::shared_ptr<i2p::stream::StreamingDestination> ClientDestination::CreateStreamingDestination (int port)
    {
        auto dest = std::make_shared<i2p::stream::StreamingDestination> (*this, port); 
        if (port)
            m_StreamingDestinationsByPorts[port] = dest;
        else // update default 
            m_StreamingDestination = dest;
        return dest;
    }   
        
    i2p::datagram::DatagramDestination * ClientDestination::CreateDatagramDestination ()
    {
        if (!m_DatagramDestination)
            m_DatagramDestination = new i2p::datagram::DatagramDestination (*this);
        return m_DatagramDestination;   
    }

    bool ClientDestination::RequestDestination (const i2p::data::IdentHash& dest, RequestComplete requestComplete)
    {
        if (!m_Pool || !IsReady ()) 
        {   
            if (requestComplete) requestComplete (false);
            return false;
        }   
        m_Service.post (std::bind (&ClientDestination::RequestLeaseSet, this, dest, requestComplete));
        return true;
    }

    void ClientDestination::RequestLeaseSet (const i2p::data::IdentHash& dest, RequestComplete requestComplete)
    {
        std::set<i2p::data::IdentHash> excluded;
        auto floodfill = i2p::data::netdb.GetClosestFloodfill (dest, excluded);
        if (floodfill)
        {
            LeaseSetRequest * request = new LeaseSetRequest (m_Service);
            request->requestComplete = requestComplete;
            auto ret = m_LeaseSetRequests.insert (std::pair<i2p::data::IdentHash, LeaseSetRequest *>(dest,request));
            if (ret.second) // inserted
            {
                if (!SendLeaseSetRequest (dest, floodfill, request))
                {
                    // request failed
                    if (request->requestComplete) request->requestComplete (nullptr);
                    delete request;
                    m_LeaseSetRequests.erase (dest);
                }
            }   
            else // duplicate
            {
                LogPrint (eLogError, "Request of ", dest.ToBase64 (), " is pending already");
                // TODO: queue up requests
                if (request->requestComplete) request->requestComplete (nullptr);
                delete request;
            }   
        }   
        else
            LogPrint (eLogError, "No floodfills found");    
    }   
        
    bool ClientDestination::SendLeaseSetRequest (const i2p::data::IdentHash& dest, 
        std::shared_ptr<const i2p::data::RouterInfo>  nextFloodfill, LeaseSetRequest * request)
    {
        auto replyTunnel = m_Pool->GetNextInboundTunnel ();
        if (!replyTunnel) LogPrint (eLogError, "No inbound tunnels found"); 
        
        auto outboundTunnel = m_Pool->GetNextOutboundTunnel ();
        if (!outboundTunnel) LogPrint (eLogError, "No outbound tunnels found");     
            
        if (replyTunnel && outboundTunnel)
        {   
            request->excluded.insert (nextFloodfill->GetIdentHash ());
            request->requestTime = i2p::util::GetSecondsSinceEpoch ();
            request->requestTimeoutTimer.cancel ();

            CryptoPP::AutoSeededRandomPool rnd;
            uint8_t replyKey[32], replyTag[32];
            rnd.GenerateBlock (replyKey, 32); // random session key 
            rnd.GenerateBlock (replyTag, 32); // random session tag
            AddSessionKey (replyKey, replyTag);

            auto msg = WrapMessage (nextFloodfill,
                CreateLeaseSetDatabaseLookupMsg (dest, request->excluded, 
                    replyTunnel.get (), replyKey, replyTag));
            outboundTunnel->SendTunnelDataMsg (
                {
                    i2p::tunnel::TunnelMessageBlock 
                    { 
                        i2p::tunnel::eDeliveryTypeRouter,
                        nextFloodfill->GetIdentHash (), 0, msg
                    }
                }); 
            request->requestTimeoutTimer.expires_from_now (boost::posix_time::seconds(LEASESET_REQUEST_TIMEOUT));
            request->requestTimeoutTimer.async_wait (std::bind (&ClientDestination::HandleRequestTimoutTimer,
                this, std::placeholders::_1, dest));
        }   
        else
            return false;
        return true;
    }   

    void ClientDestination::HandleRequestTimoutTimer (const boost::system::error_code& ecode, const i2p::data::IdentHash& dest)
    {
        if (ecode != boost::asio::error::operation_aborted)
        {
            auto it = m_LeaseSetRequests.find (dest);
            if (it != m_LeaseSetRequests.end ())
            {
                bool done = false;
                uint64_t ts = i2p::util::GetSecondsSinceEpoch ();
                if (ts < it->second->requestTime + MAX_LEASESET_REQUEST_TIMEOUT)
                {
                    auto floodfill = i2p::data::netdb.GetClosestFloodfill (dest, it->second->excluded);
                    if (floodfill)
                         done = !SendLeaseSetRequest (dest, floodfill, it->second);
                    else
                        done = true;
                }
                else
                {   
                    LogPrint (eLogInfo, dest.ToBase64 (), " was not found within ",  MAX_LEASESET_REQUEST_TIMEOUT, " seconds");
                    done = true;
                }
                
                if (done)
                {
                    if (it->second->requestComplete) it->second->requestComplete (false);
                    delete it->second;
                    m_LeaseSetRequests.erase (it);
                }   
            }   
        }   
    }

    void ClientDestination::HandleCleanupTimer (const boost::system::error_code& ecode)
    {
        if (ecode != boost::asio::error::operation_aborted)
        {
            CleanupRoutingSessions ();
            CleanupRemoteLeaseSets ();
            m_CleanupTimer.expires_from_now (boost::posix_time::minutes (DESTINATION_CLEANUP_TIMEOUT));
            m_CleanupTimer.async_wait (std::bind (&ClientDestination::HandleCleanupTimer,
                this, std::placeholders::_1));
        }
    }   

    void ClientDestination::CleanupRemoteLeaseSets ()
    {
        for (auto it = m_RemoteLeaseSets.begin (); it != m_RemoteLeaseSets.end ();)
        {
            if (!it->second->HasNonExpiredLeases ()) // all leases expired
            {
                LogPrint ("Remote LeaseSet ", it->second->GetIdentHash ().ToBase64 (), " expired");
                it = m_RemoteLeaseSets.erase (it);
            }   
            else 
                it++;
        }
    }
}
}