[vlc-commits] demux: adaptative: use threaded http chunks

[Francois Cartegnie]

vlc | branch: master | Francois Cartegnie <fcvlcdev at free.fr> | Thu Nov 19 14:44:07 2015 +0100| [e2caa22e04bbb0a05bea96a0f3bda6e00db982db] | committer: Francois Cartegnie

demux: adaptative: use threaded http chunks

> http://git.videolan.org/gitweb.cgi/vlc.git/?a=commit;h=e2caa22e04bbb0a05bea96a0f3bda6e00db982db
---

 modules/demux/adaptative/playlist/Segment.cpp |    5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/modules/demux/adaptative/playlist/Segment.cpp b/modules/demux/adaptative/playlist/Segment.cpp
index 4b5a1e3..f23d37f 100644
--- a/modules/demux/adaptative/playlist/Segment.cpp
+++ b/modules/demux/adaptative/playlist/Segment.cpp
@@ -31,6 +31,8 @@
 #include "AbstractPlaylist.hpp"
 #include "SegmentChunk.hpp"
 #include "../http/BytesRange.hpp"
+#include "../http/HTTPConnectionManager.h"
+#include "../http/Downloader.hpp"
 #include <cassert>
 
 using namespace adaptative::http;
@@ -61,9 +63,10 @@ ISegment::~ISegment()
 
 SegmentChunk * ISegment::getChunk(const std::string &url, HTTPConnectionManager *connManager)
 {
-    HTTPChunkSource *source = new HTTPChunkSource(url, connManager);
+    HTTPChunkBufferedSource *source = new HTTPChunkBufferedSource(url, connManager);
     if(startByte != endByte)
         source->setBytesRange(BytesRange(startByte, endByte));
+    connManager->downloader->schedule(source);
     return new (std::nothrow) SegmentChunk(this, source);
 }