include/core/TCPConvergenceLayer.h

Go to the documentation of this file.

#ifndef TCPCONVERGENCELAYER_H_
#define TCPCONVERGENCELAYER_H_

#include "ConvergenceLayer.h"
#include "utils/Service.h"
#include "utils/MutexLock.h"
#include "utils/Mutex.h"
#include "data/NetworkFrame.h"
#include <list>

using namespace dtn::data;
using namespace dtn::utils;

namespace dtn
{
        namespace core
        {
                class TCPConnection;

                class TCPConvergenceLayer : public Service, public ConvergenceLayer
                {
                        friend class TCPConnection;

                public:
                        TCPConvergenceLayer(string localeid, string bind_addr, unsigned short port);

                        virtual ~TCPConvergenceLayer();

                        virtual TransmitReport transmit(const Bundle &b);

                        virtual TransmitReport transmit(const Bundle &b, const Node &node);

                        virtual void tick();

                protected:
                        void callbackBundleReceived(const TCPConnection &conn, Bundle &b);

                private:
                        TransmitReport transmit(TCPConnection *conn, const Bundle &b);
                        TCPConnection* newConnection(int socket);
                        bool build_select_list();
                        void setnonblocking(int sock);

                        int m_socket;

                        static const int DEFAULT_PORT;

                        string m_selfaddr;
                        unsigned int m_selfport;

                        Mutex m_writelock;
                        Mutex m_mutex_connections;

                        list<TCPConnection*> m_connections;

                        fd_set m_socks_recv;
                        fd_set m_socks_send;

                        int m_highsock;

                        NetworkFrame m_contactheader;

                        string m_localeid;
                };
        }
}

#endif /*TCPCONVERGENCELAYER_H_*/

---