HTTPConvergenceLayer.h

Go to the documentation of this file.

#ifndef HTTPCONVERGENCELAYER_H_
#define HTTPCONVERGENCELAYER_H_

#include "Component.h"

#include "core/BundleCore.h"
#include "core/BundleEvent.h"

#include <ibrdtn/data/Serializer.h>

#include "net/ConvergenceLayer.h"
#include "net/BundleReceivedEvent.h"

#include <ibrcommon/data/BLOB.h>
#include <ibrcommon/data/iobuffer.h>

#include <ibrcommon/net/vinterface.h>
#include <ibrcommon/net/vaddress.h>
#include <ibrcommon/thread/MutexLock.h>
#include <ibrcommon/thread/Mutex.h>
#include <ibrcommon/thread/Thread.h>
#include <ibrcommon/Exceptions.h>
#include <ibrcommon/Logger.h>

#include <curl/curl.h>
#include <curl/easy.h>


#include <iostream>

namespace dtn
{
        namespace net
        {
                class HTTPConvergenceLayer : public ConvergenceLayer, public dtn::daemon::IndependentComponent
                {
                public:
                        HTTPConvergenceLayer(const std::string &server);
                        virtual ~HTTPConvergenceLayer();

                        dtn::core::Node::Protocol getDiscoveryProtocol() const;

                        void queue(const dtn::core::Node &n, const dtn::net::BundleTransfer &job);

                        virtual const std::string getName() const;


                protected:
                        virtual void componentUp() throw ();
                        virtual void componentRun() throw ();
                        virtual void componentDown() throw ();
                        void __cancellation() throw ();

                private:
                        const std::string _server;

                        ibrcommon::Mutex _push_iob_mutex;
                        ibrcommon::iobuffer *_push_iob;
                        bool _running;
                };

                class DownloadThread : public ibrcommon::JoinableThread
                {
                public:

                        DownloadThread(ibrcommon::iobuffer &buf);
                        virtual ~DownloadThread();

                protected:
                        void run() throw ();
                        void __cancellation() throw ();

                private:
                        std::istream _stream;
                };

        }
}

#endif /* HTTPCONVERGENCELAYER_H_ */