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 00032 #pragma once 00033 00034 00035 #include <libOOOgg/IOggCallback.h> 00036 #include <libOOOgg/INotifyComplete.h> 00037 #include <libOOOgg/OggMuxStream.h> 00038 00039 #include <vector> 00040 //#include <fstream> // Debugging only 00041 00042 00061 using namespace std; 00062 00063 00064 class LIBOOOGG_API OggPageInterleaver 00065 : public INotifyArrival 00066 { 00067 public: 00069 OggPageInterleaver(IOggCallback* inDataWriter, INotifyComplete* inNotifier); 00070 virtual ~OggPageInterleaver(void); 00071 00073 virtual OggMuxStream* newStream(); 00074 00075 virtual void processData(); 00076 00078 virtual LOOG_INT64 progressTime(); 00079 00081 virtual LOOG_INT64 bytesWritten(); 00082 00083 //INotifyArrival Implementation 00084 virtual void notifyArrival(); 00085 00086 protected: 00088 virtual void writeLowest(); 00089 00091 virtual bool isProcessable(); 00092 00094 virtual bool isAllEOS(); 00095 00097 virtual bool isAllEmpty(); 00098 00099 vector<OggMuxStream*> mInputStreams; 00100 IOggCallback* mFileWriter; //TODO::: Shuoldn't be called filewriter. 00101 INotifyComplete* mNotifier; 00102 00103 LOOG_INT64 mBytesWritten; 00104 LOOG_INT64 mProgressTime; 00105 //DEBUG ONLY 00106 fstream debugLog; 00107 // 00108 private: 00109 OggPageInterleaver& operator=(const OggPageInterleaver& other); /* Don't assign me */ 00110 OggPageInterleaver(const OggPageInterleaver& other); /* Don't copy me */ 00111 };