00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034 #include "stdafx.h"
00035 #include ".\anxmuxinputpin.h"
00036 #include "AnxMuxFilter.h"
00037 AnxMuxInputPin::AnxMuxInputPin(AnxMuxFilter* inOwningFilter, CCritSec* inFilterLock, HRESULT* inHR, OggMuxStream* inMuxStream, unsigned long inAnxVersionMajor, unsigned long inAnxVersionMinor)
00038 : OggMuxInputPin(inOwningFilter, inFilterLock, inHR, inMuxStream)
00039 , mAnxDataPacket(NULL)
00040 , mFishBonePacket(NULL)
00041
00042 , mAnxVersionMajor(inAnxVersionMajor)
00043 , mAnxVersionMinor(inAnxVersionMinor)
00044 {
00045 #ifdef OGGCODECS_LOGGING
00046 debugLog.open("g:\\logs\\anxmuxinputpin.log", ios_base::out);
00047 #endif
00048 mExtraPackets.clear();
00049 }
00050
00051 AnxMuxInputPin::~AnxMuxInputPin(void)
00052 {
00053 }
00054
00055
00056 HRESULT AnxMuxInputPin::CompleteConnect(IPin* inReceivePin) {
00057
00058
00059 IMediaSeeking* locSeeker = NULL;
00060 inReceivePin->QueryInterface(IID_IMediaSeeking, (void**)&locSeeker);
00061 SetDelegate(locSeeker);
00062
00063 mMuxStream->setIsActive(true);
00064
00065 HRESULT locHR = mParentFilter->addAnotherPin();
00066 if ((locHR == S_OK)) {
00067
00068 if ((mAnxVersionMajor == 2) && (mAnxVersionMinor == 0) && (mAnxDataPacket != NULL)) {
00069 mPaginator.acceptStampedOggPacket(mAnxDataPacket);
00070 return S_OK;
00071 } else if ((mAnxVersionMajor == 3) && (mAnxVersionMinor == 0) && (mFishBonePacket != NULL)) {
00072
00073 if (mExtraPackets.size() != 0) {
00074 for (size_t i = 0; i < mExtraPackets.size(); i++) {
00075 mPaginator.acceptStampedOggPacket(mExtraPackets[i]);
00076 }
00077 }
00078 return S_OK;
00079 } else {
00080 return S_FALSE;
00081 }
00082
00083 } else {
00084 return S_FALSE;
00085 }
00086 }
00087
00088
00089 HRESULT AnxMuxInputPin::SetMediaType(const CMediaType* inMediaType)
00090 {
00091
00092 bool locWasOK = false;
00093 unsigned __int64 locGranRateNum = 0;
00094 unsigned __int64 locGranRateDenom = 0;
00095 unsigned long locNumHeaders = 0;
00096 unsigned long locPreroll = 0;
00097 unsigned long locGranuleShift = 0;
00098 StreamHeaders::eCodecType locCodecID = StreamHeaders::NONE;
00099
00100
00101 if ((inMediaType->majortype == MEDIATYPE_Video) && (inMediaType->subtype == MEDIASUBTYPE_Theora)) {
00102
00103
00104 sTheoraFormatBlock* locTheora = (sTheoraFormatBlock*)inMediaType->pbFormat;
00105
00106
00107 mMuxStream->setConversionParams(locTheora->frameRateNumerator, locTheora->frameRateDenominator, 10000000, locTheora->maxKeyframeInterval);
00108 mMuxStream->setNumHeaders(3);
00109 mPaginator.setNumHeaders(3);
00110
00111 locGranuleShift = locTheora->maxKeyframeInterval;
00112 locWasOK = true;
00113 locGranRateNum = locTheora->frameRateNumerator;
00114 locGranRateDenom = locTheora->frameRateDenominator;
00115 locNumHeaders = 3;
00116 locCodecID = StreamHeaders::THEORA;
00117
00118 } else if (inMediaType->majortype == MEDIATYPE_Audio) {
00119 if (inMediaType->subtype == MEDIASUBTYPE_Vorbis) {
00120
00121 sVorbisFormatBlock* locVorbis = (sVorbisFormatBlock*)inMediaType->pbFormat;
00122
00123 mMuxStream->setConversionParams(locVorbis->samplesPerSec, 1, 10000000);
00124 mMuxStream->setNumHeaders(3);
00125 mPaginator.setNumHeaders(3);
00126
00127 locWasOK = true;
00128 locGranRateNum = locVorbis->samplesPerSec;
00129 locGranRateDenom = 1;
00130 locNumHeaders = 3;
00131 locPreroll = 2;
00132
00133 locCodecID = StreamHeaders::VORBIS;
00134
00135
00136 } else if (inMediaType->subtype == MEDIASUBTYPE_Speex) {
00137
00138 sSpeexFormatBlock* locSpeex = (sSpeexFormatBlock*)inMediaType->pbFormat;
00139 mMuxStream->setConversionParams(locSpeex->samplesPerSec, 1, 10000000);
00140 mMuxStream->setNumHeaders(2);
00141 mPaginator.setNumHeaders(2);
00142
00143
00144 locWasOK = true;
00145 locGranRateNum = locSpeex->samplesPerSec;
00146 locGranRateDenom = 1;
00147 locNumHeaders = 2;
00148 locCodecID = StreamHeaders::SPEEX;
00149 }
00150
00151
00152
00153
00154
00155
00156
00157
00158
00159
00160
00161
00162
00163
00164
00165
00166
00167
00168
00169
00170 } else if(inMediaType->majortype == MEDIATYPE_Text) {
00171 if (inMediaType->subtype == MEDIASUBTYPE_CMML) {
00172
00173 sCMMLFormatBlock* locCMML = (sCMMLFormatBlock*)inMediaType->pbFormat;
00174
00175
00176
00177
00178 if ((mAnxVersionMajor == 3) && (mAnxVersionMinor == 0)) {
00179 mMuxStream->setConversionParams(locCMML->granuleNumerator, locCMML->granuleDenominator, 10000000, 5);
00180
00181 locNumHeaders = 3;
00182 } else {
00183 mMuxStream->setConversionParams(locCMML->granuleNumerator, locCMML->granuleDenominator, 10000000);
00184 locNumHeaders = 1;
00185 }
00186
00187 mPaginator.setNumHeaders(locNumHeaders);
00188 mPaginator.parameters()->mMaxPacksPerPage = 1;
00189 mMuxStream->setNumHeaders(locNumHeaders);
00190
00191
00192 locWasOK = true;
00193 locGranRateNum = locCMML->granuleNumerator;
00194 locGranRateDenom = locCMML->granuleDenominator;
00195
00196
00197 locCodecID = StreamHeaders::CMML;
00198 }
00199 }
00200 if (locWasOK) {
00201
00202
00203
00204 if ((mAnxVersionMajor == 2) && (mAnxVersionMinor == 0)) {
00205
00206 mAnxDataPacket = AnxPacketMaker::makeAnxData_2_0(2, 0, locGranRateNum, locGranRateDenom, locNumHeaders, AnxPacketMaker::makeMessageHeaders(locCodecID));
00207 } else if ((mAnxVersionMajor == 3) && (mAnxVersionMinor == 0)) {
00208 mFishBonePacket = FishSkeleton::makeFishBone_3_0(locGranRateNum, locGranRateDenom, 0, locNumHeaders, mPaginator.parameters()->mSerialNo, locGranuleShift, locPreroll, AnxPacketMaker::makeMessageHeaders(locCodecID));
00209 if (locCodecID == StreamHeaders::CMML) {
00210 mExtraPackets.push_back(FishSkeleton::makeCMMLBOS());
00211 mExtraPackets.push_back(FishSkeleton::makeCMML_XML_Thing());
00212 } else {
00213 mExtraPackets.clear();
00214
00215 }
00216 }
00217 return S_OK;
00218 } else {
00219 return S_FALSE;
00220 }
00221 }