source: source/ariba/overlay/LinkDescriptor.h@ 12772

#ifndef __LINK_DESCRIPTOR_H
#define __LINK_DESCRIPTOR_H

#include <iostream>
#include <sstream>
#include <ctime>
#include <deque>
#include <boost/foreach.hpp>

#include "ariba/utility/messages.h"
#include "ariba/utility/types.h"
#include "ariba/communication/EndpointDescriptor.h"
#include "ariba/CommunicationListener.h"

// reboost messages
#include "ariba/utility/transport/messages/message.hpp"
#include <ariba/utility/misc/sha1.h>

#include "ariba/overlay/SequenceNumber.h"


namespace ariba {
        class CommunicationListener;
}

using std::deque;
using ariba::utility::Message;
using ariba::utility::NodeID;
using ariba::utility::SpoVNetID;
using ariba::utility::ServiceID;
using ariba::utility::LinkID;
using ariba::CommunicationListener;
using ariba::communication::EndpointDescriptor;

namespace ariba {
namespace overlay {

class LinkDescriptor;

std::ostream& operator<<(std::ostream& s, const LinkDescriptor* ld );
std::ostream& operator<<(std::ostream& s, const LinkDescriptor& ld );

/// LinkDescriptor
class LinkDescriptor {
public:
    struct message_queue_entry
    {
        reboost::message_t message;
        uint8_t priority;
    };
    
        // ctor
        LinkDescriptor() {
            time_t now = time(NULL);
            
                // default values
                this->up = false;
//         this->closing = false;
        this->failed = false;
                this->fromRemote = false;
                this->remoteNode = NodeID::UNSPECIFIED;
                this->overlayId  = LinkID::create();
                this->communicationUp = false;
                this->communicationId = LinkID::UNSPECIFIED;
                this->keepAliveReceived = now;
                this->keepAliveSent = now;
                this->relaying     = false;
                this->timeRelaying = now;
                this->dropAfterRelaying = false;
                this->service  = ServiceID::UNSPECIFIED;
                this->listener = &CommunicationListener::DEFAULT;
                this->relayed = false;
                this->remoteLink = LinkID::UNSPECIFIED;
                this->autolink = false;
                this->lastuse = now;
                this->retryCounter = 0;
                this->hops = -1;
        
        this->transmit_seqnums = false; // XXX
        }

        // dtor
        ~LinkDescriptor() {
                flushQueue();
        }

        // general information about the link --------------------------------------
        bool up;           ///< flag whether this link is up and running
//      bool closing;      ///< flag, whether this link is in the regular process of closing
        bool failed;       ///< flag, whether communication is (assumed to be) not/no longer possible on this link
        bool fromRemote;   ///< flag, whether this link was requested from remote
        NodeID remoteNode; ///< remote end-point node


        // link identifiers --------------------------------------------------------
        LinkID overlayId;       ///< the base overlay link id
        LinkID communicationId; ///< the communication id
        bool   communicationUp;   ///< flag, whether the communication is up

        // sequence numbers --------------------------------------------------------
        SequenceNumber last_sent_seqnum;
    bool transmit_seqnums;
    
        // direct link retries -----------------------------------------------------
        EndpointDescriptor endpoint;
        int retryCounter;

        // link alive information --------------------------------------------------
        time_t keepAliveReceived; ///< the last time a keep-alive message was received
        time_t keepAliveSent;  ///< the number of missed keep-alive messages
        void setAlive() {
//              keepAliveSent = time(NULL);
                keepAliveReceived = time(NULL);
        }

        // relay information -------------------------------------------------------
        bool   relayed;    ///< flag whether this link is a relayed link
        LinkID remoteLink; ///< the remote link id
        vector<NodeID> routeRecord;
        int hops;

        // relay state -------------------------------------------------------------
        bool   relaying;     ///< flag, wheter this link has been used as relay
        bool   dropAfterRelaying;
        time_t timeRelaying; ///< last time the link has been used as relay
        void setRelaying() {
                relaying = true;
                timeRelaying = time(NULL);
        }

        // owner -------------------------------------------------------------------
        ServiceID service; ///< service using this link
        CommunicationListener* listener; ///< the listener using this node

        // auto links --------------------------------------------------------------
        bool autolink;  ///< flag, whether this link is a auto-link
        time_t lastuse; ///< time, when the link was last used XXX AUTO_LINK-ONLY
        deque<message_queue_entry> messageQueue; ///< waiting messages to be delivered
        void setAutoUsed() {
                if (autolink) lastuse = time(NULL);
        }
        /// drops waiting auto-link messages
        void flushQueue() {
//              BOOST_FOREACH( Message* msg, messageQueue )     delete msg;  // XXX MARIO: shouldn't be necessary anymore, since we're using shared pointers
                messageQueue.clear();
        }

        // string representation ---------------------------------------------------
        std::string to_string() const {
            time_t now = time(NULL);
            
                std::ostringstream s;
        if ( relayed )
            s << "[RELAYED-";
        else
            s << "[DIRECT-";
        s << "LINK] ";
        s << "id=" << overlayId.toString().substr(0,4) << " ";
        s << "serv=" << service.toString() << " ";
                s << "up=" << up << " ";
                s << "init=" << !fromRemote << " ";
                s << "node=" << remoteNode.toString().substr(0,4) << " ";
                s << "relaying=" << relaying << " ";
                s << "last_received=" << now - keepAliveReceived << "s ";
                s << "auto=" << autolink << " ";
                s << "hops=" << hops << " ";
                if ( relayed ) {
                        s << "| Relayed: ";
                        s << "remote link=" << remoteLink.toString().substr(0,4) << " ";
                        if (routeRecord.size()>0) {
                                s << "route record=";
                                for (size_t i=0; i<routeRecord.size(); i++)
                                        s << routeRecord[i].toString().substr(0,4) << " ";
                        }
                } else {
                        s << "| Direct: ";
                        s << "using [COMMUNICATION-LINK] id=" << communicationId.toString().substr(0,4) << " ";
                        s << "(up=" << communicationUp << ") ";
                }
                return s.str();
        }
};

}} // namespace ariba, overlay

#endif // __LINK_DESCRIPTOR_H