1 files changed, 100 insertions, 0 deletions
diff --git a/src/libdash/source/network/AbstractChunk.h b/src/libdash/source/network/AbstractChunk.h
new file mode 100644
index 00000000..794469fd
--- /dev/null
+++ b/src/libdash/source/network/AbstractChunk.h
@@ -0,0 +1,100 @@
+/*
+ * AbstractChunk.h
+ *****************************************************************************
+ * Copyright (C) 2012, bitmovin Softwareentwicklung OG, All Rights Reserved
+ *
+ * Email: libdash-dev@vicky.bitmovin.net
+ *
+ * This source code and its use and distribution, is subject to the terms
+ * and conditions of the applicable license agreement.
+ *****************************************************************************/
+
+#ifndef ABSTRACTCHUNK_H_
+#define ABSTRACTCHUNK_H_
+
+#include "config.h"
+
+#include "IDownloadableChunk.h"
+#include "DownloadStateManager.h"
+#include "../helpers/SyncedBlockStream.h"
+#include "../portable/Networking.h"
+#include <curl/curl.h>
+#include "../metrics/HTTPTransaction.h"
+#include "../metrics/TCPConnection.h"
+#include "../metrics/ThroughputMeasurement.h"
+#include "../helpers/Time.h"
+
+#include <chrono>
+
+namespace dash
+{
+    namespace network
+    {
+        class AbstractChunk : public virtual IDownloadableChunk
+        {
+            public:
+                AbstractChunk          ();
+                virtual ~AbstractChunk ();
+
+                /*
+                 * Pure virtual IChunk Interface
+                 */
+                virtual std::string&    AbsoluteURI     ()  = 0;
+                virtual std::string&    Host            ()  = 0;
+                virtual size_t          Port            ()  = 0;
+                virtual std::string&    Path            ()  = 0;
+                virtual std::string&    Range           ()  = 0;
+                virtual size_t          StartByte       ()  = 0;
+                virtual size_t          EndByte         ()  = 0;
+                virtual bool            HasByteRange    ()  = 0;
+                virtual dash::metrics::HTTPTransactionType  GetType() = 0;
+                /*
+                 * IDownloadableChunk Interface
+                 */
+                virtual bool    StartDownload           (IConnection *connection);
+                virtual bool    StartDownload           ();
+                virtual void    AbortDownload           ();
+                virtual int     Read                    (uint8_t *data, size_t len);
+                virtual int     Peek                    (uint8_t *data, size_t len);
+                virtual int     Peek                    (uint8_t *data, size_t len, size_t offset);
+                virtual void    AttachDownloadObserver  (IDownloadObserver *observer);
+                virtual void    DetachDownloadObserver  (IDownloadObserver *observer);
+                /*
+                 * Observer Notification
+                 */
+                void NotifyDownloadRateChanged (double bitrate);
+                void NotifyDownloadTimeChanged (double dnltime);
+                /*
+                 * IDASHMetrics
+                 */
+                const std::vector<dash::metrics::ITCPConnection *>&     GetTCPConnectionList    () const;
+                const std::vector<dash::metrics::IHTTPTransaction *>&   GetHTTPTransactionList  () const;
+
+            private:
+                std::vector<IDownloadObserver *>    observers;
+                THREAD_HANDLE                       dlThread;
+                IConnection                         *connection;
+                helpers::SyncedBlockStream          blockStream;
+                CURL                                *curl;
+                CURLM								*curlm;
+                CURLcode                            response;
+                uint64_t                            bytesDownloaded;
+                DownloadStateManager                stateManager;
+
+                std::vector<dash::metrics::TCPConnection *>     tcpConnections;
+                std::vector<dash::metrics::HTTPTransaction *>   httpTransactions;
+
+                static uint32_t BLOCKSIZE;
+
+                static void*    DownloadExternalConnection  (void *chunk);
+                static void*    DownloadInternalConnection  (void *chunk);
+                static size_t   CurlResponseCallback        (void *contents, size_t size, size_t nmemb, void *userp);
+                static size_t   CurlHeaderCallback          (void *headerData, size_t size, size_t nmemb, void *userdata);
+                static size_t   CurlDebugCallback           (CURL *url, curl_infotype infoType, char * data, size_t length, void *userdata);
+                void            HandleHeaderOutCallback     ();
+                void            HandleHeaderInCallback      (std::string data);
+        };
+    }
+}
+
+#endif /* ABSTRACTCHUNK_H_ */