00001 //=========================================================================== 00002 //Copyright (C) 2003, 2004 Zentaro Kavanagh 00003 // 00004 //Redistribution and use in source and binary forms, with or without 00005 //modification, are permitted provided that the following conditions 00006 //are met: 00007 // 00008 //- Redistributions of source code must retain the above copyright 00009 // notice, this list of conditions and the following disclaimer. 00010 // 00011 //- Redistributions in binary form must reproduce the above copyright 00012 // notice, this list of conditions and the following disclaimer in the 00013 // documentation and/or other materials provided with the distribution. 00014 // 00015 //- Neither the name of Zentaro Kavanagh nor the names of contributors 00016 // may be used to endorse or promote products derived from this software 00017 // without specific prior written permission. 00018 // 00019 //THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 00020 //``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 00021 //LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A 00022 //PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ORGANISATION OR 00023 //CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 00024 //EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 00025 //PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 00026 //PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 00027 //LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 00028 //NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 00029 //SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00030 //=========================================================================== 00031 #pragma once 00032 #include "oggdllstuff.h" 00033 #include <winsock.h> 00034 #include "HTTPSocket.h" 00035 #include "SingleMediaFileCache.h" 00036 #include <string> 00037 #include <sstream> 00038 #include <fstream> 00039 00040 using namespace std; 00041 00042 class OGG_DEMUX_API HTTPFileSource 00043 : public IFilterDataSource 00044 , public CAMThread 00045 , protected HTTPSocket 00046 { 00047 public: 00048 HTTPFileSource(void); 00049 virtual ~HTTPFileSource(void); 00050 00051 //Thread commands 00052 static const int THREAD_RUN = 0; 00053 static const int THREAD_EXIT = 1; 00054 00055 //IFilterDataSource Interface 00056 virtual unsigned long seek(unsigned long inPos); 00057 virtual void close() ; 00058 virtual bool open(string inSourceLocation); 00059 virtual void clear(); 00060 virtual bool isEOF(); 00061 virtual unsigned long read(char* outBuffer, unsigned long inNumBytes); 00062 00063 //CAMThread pure virtuals 00064 DWORD HTTPFileSource::ThreadProc(); 00065 00066 protected: 00067 void unChunk(unsigned char* inBuff, unsigned long inNumBytes); 00068 bool startThread(); 00069 void DataProcessLoop(); 00070 00071 SingleMediaFileCache mFileCache; 00072 00073 bool mIsChunked; 00074 unsigned long mChunkRemains; 00075 00076 bool mIsFirstChunk; 00077 00078 fstream debugLog; 00079 fstream fileDump; 00080 fstream rawDump; 00081 00082 unsigned char* mInterBuff; 00083 unsigned long mNumLeftovers; 00084 static const unsigned long RECV_BUFF_SIZE = 1024; 00085 00086 CCritSec* mBufferLock; 00087 };