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

#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