daemon/src/net/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/TransferCompletedEvent.h"
#include "net/TransferAbortedEvent.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 ConvergenceLayer::Job &job);

                        virtual const std::string getName() const;


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

                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();
                        void __cancellation();

                private:
                        std::istream _stream;
                };

        }
}

#endif /* HTTPCONVERGENCELAYER_H_ */