4 * Copyright 2005 Christian Costa
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
23 #include "quartz_private.h"
37 #include "wine/unicode.h"
38 #include "wine/debug.h"
40 #include "transform.h"
42 WINE_DEFAULT_DEBUG_CHANNEL(quartz
);
44 typedef struct ACMWrapperImpl
46 TransformFilterImpl tf
;
49 LPWAVEFORMATEX pWfOut
;
52 static HRESULT
ACMWrapper_ProcessSampleData(TransformFilterImpl
* pTransformFilter
, IMediaSample
*pSample
)
54 ACMWrapperImpl
* This
= (ACMWrapperImpl
*)pTransformFilter
;
56 IMediaSample
* pOutSample
= NULL
;
57 DWORD cbDstStream
, cbSrcStream
;
59 LPBYTE pbSrcStream
= NULL
;
61 BOOL unprepare_header
= FALSE
;
64 LONGLONG tStart
= -1, tStop
= -1, tMed
;
66 hr
= IMediaSample_GetPointer(pSample
, &pbSrcStream
);
69 ERR("Cannot get pointer to sample data (%x)\n", hr
);
73 IMediaSample_GetTime(pSample
, &tStart
, &tStop
);
74 cbSrcStream
= IMediaSample_GetActualDataLength(pSample
);
76 TRACE("Sample data ptr = %p, size = %ld\n", pbSrcStream
, (long)cbSrcStream
);
78 hr
= IPin_ConnectionMediaType(This
->tf
.ppPins
[0], &amt
);
80 ERR("Unable to retrieve media type\n");
84 ash
.pbSrc
= pbSrcStream
;
85 ash
.cbSrcLength
= cbSrcStream
;
87 while(hr
== S_OK
&& ash
.cbSrcLength
)
89 hr
= OutputPin_GetDeliveryBuffer((OutputPin
*)This
->tf
.ppPins
[1], &pOutSample
, NULL
, NULL
, 0);
91 ERR("Unable to get delivery buffer (%x)\n", hr
);
95 hr
= IMediaSample_SetActualDataLength(pOutSample
, 0);
98 hr
= IMediaSample_GetPointer(pOutSample
, &pbDstStream
);
100 ERR("Unable to get pointer to buffer (%x)\n", hr
);
103 cbDstStream
= IMediaSample_GetSize(pOutSample
);
105 ash
.cbStruct
= sizeof(ash
);
108 ash
.pbDst
= pbDstStream
;
109 ash
.cbDstLength
= cbDstStream
;
111 if ((res
= acmStreamPrepareHeader(This
->has
, &ash
, 0))) {
112 ERR("Cannot prepare header %d\n", res
);
115 unprepare_header
= TRUE
;
117 if (IMediaSample_IsDiscontinuity(pSample
) == S_OK
)
118 res
= acmStreamConvert(This
->has
, &ash
, ACM_STREAMCONVERTF_START
);
120 res
= acmStreamConvert(This
->has
, &ash
, 0);
125 if(res
!= MMSYSERR_MOREDATA
)
126 ERR("Cannot convert data header %d\n", res
);
130 TRACE("used in %u/%u, used out %u/%u\n", ash
.cbSrcLengthUsed
, ash
.cbSrcLength
, ash
.cbDstLengthUsed
, ash
.cbDstLength
);
132 hr
= IMediaSample_SetActualDataLength(pOutSample
, ash
.cbDstLengthUsed
);
135 if (!ash
.cbSrcLengthUsed
)
137 WARN("Sample was skipped\n");
142 TRACE("Sample start time: %u.%03u\n", (DWORD
)(tStart
/10000000), (DWORD
)((tStart
/10000)%1000));
143 if (ash
.cbSrcLengthUsed
== cbSrcStream
)
145 IMediaSample_SetTime(pOutSample
, &tStart
, &tStop
);
148 else if (tStop
!= tStart
)
150 tMed
= tStop
- tStart
;
151 tMed
= tStart
+ tMed
* ash
.cbSrcLengthUsed
/ cbSrcStream
;
152 IMediaSample_SetTime(pOutSample
, &tStart
, &tMed
);
157 ERR("No valid timestamp found\n");
158 IMediaSample_SetTime(pOutSample
, NULL
, NULL
);
160 TRACE("Sample stop time: %u.%03u\n", (DWORD
)(tStart
/10000000), (DWORD
)((tStart
/10000)%1000));
162 if (IMediaSample_IsDiscontinuity(pSample
) == S_FALSE
)
163 hr
= OutputPin_SendSample((OutputPin
*)This
->tf
.ppPins
[1], pOutSample
);
165 TRACE("Skipping first sample: Discontinuity\n");
167 if (hr
!= S_OK
&& hr
!= VFW_E_NOT_CONNECTED
) {
169 ERR("Error sending sample (%x)\n", hr
);
174 if (unprepare_header
&& (res
= acmStreamUnprepareHeader(This
->has
, &ash
, 0)))
175 ERR("Cannot unprepare header %d\n", res
);
176 unprepare_header
= FALSE
;
177 ash
.pbSrc
+= ash
.cbSrcLengthUsed
;
178 ash
.cbSrcLength
-= ash
.cbSrcLengthUsed
;
181 IMediaSample_Release(pOutSample
);
188 static HRESULT
ACMWrapper_ConnectInput(TransformFilterImpl
* pTransformFilter
, const AM_MEDIA_TYPE
* pmt
)
190 ACMWrapperImpl
* This
= (ACMWrapperImpl
*)pTransformFilter
;
193 TRACE("(%p)->(%p)\n", This
, pmt
);
195 /* Check root (GUID w/o FOURCC) */
196 if ((IsEqualIID(&pmt
->majortype
, &MEDIATYPE_Audio
)) &&
197 (!memcmp(((const char *)&pmt
->subtype
)+4, ((const char *)&MEDIATYPE_Audio
)+4, sizeof(GUID
)-4)) &&
198 (IsEqualIID(&pmt
->formattype
, &FORMAT_WaveFormatEx
)))
201 AM_MEDIA_TYPE
* outpmt
= &((OutputPin
*)This
->tf
.ppPins
[1])->pin
.mtCurrent
;
202 This
->pWfIn
= (LPWAVEFORMATEX
)pmt
->pbFormat
;
205 /* TRACE("ALIGN = %d\n", pACMWrapper->pWfIn->nBlockAlign); */
206 /* pACMWrapper->pWfIn->nBlockAlign = 1; */
208 /* Set output audio data to PCM */
209 CopyMediaType(outpmt
, pmt
);
210 outpmt
->subtype
.Data1
= WAVE_FORMAT_PCM
;
211 This
->pWfOut
= (WAVEFORMATEX
*)outpmt
->pbFormat
;
212 This
->pWfOut
->wFormatTag
= WAVE_FORMAT_PCM
;
213 This
->pWfOut
->wBitsPerSample
= 16;
214 This
->pWfOut
->nBlockAlign
= 4;
215 This
->pWfOut
->cbSize
= 0;
216 This
->pWfOut
->nAvgBytesPerSec
= This
->pWfOut
->nChannels
* This
->pWfOut
->nSamplesPerSec
217 * (This
->pWfOut
->wBitsPerSample
/8);
219 if (!(res
= acmStreamOpen(&drv
, NULL
, This
->pWfIn
, This
->pWfOut
, NULL
, 0, 0, 0)))
223 /* Update buffer size of media samples in output */
224 ((OutputPin
*)This
->tf
.ppPins
[1])->allocProps
.cbBuffer
= This
->pWfOut
->nAvgBytesPerSec
/ 2;
225 TRACE("Connection accepted\n");
229 FIXME("acmStreamOpen returned %d\n", res
);
230 FreeMediaType(outpmt
);
231 TRACE("Unable to find a suitable ACM decompressor\n");
234 TRACE("Connection refused\n");
235 return VFW_E_TYPE_NOT_ACCEPTED
;
238 static HRESULT
ACMWrapper_Cleanup(TransformFilterImpl
* pTransformFilter
)
240 ACMWrapperImpl
* This
= (ACMWrapperImpl
*)pTransformFilter
;
242 TRACE("(%p)->()\n", This
);
245 acmStreamClose(This
->has
, 0);
252 static const TransformFuncsTable ACMWrapper_FuncsTable
= {
254 ACMWrapper_ProcessSampleData
,
257 ACMWrapper_ConnectInput
,
261 HRESULT
ACMWrapper_create(IUnknown
* pUnkOuter
, LPVOID
* ppv
)
264 ACMWrapperImpl
* This
;
266 TRACE("(%p, %p)\n", pUnkOuter
, ppv
);
271 return CLASS_E_NOAGGREGATION
;
273 /* Note: This memory is managed by the transform filter once created */
274 This
= CoTaskMemAlloc(sizeof(ACMWrapperImpl
));
275 ZeroMemory(This
, sizeof(ACMWrapperImpl
));
277 hr
= TransformFilter_Create(&(This
->tf
), &CLSID_ACMWrapper
, &ACMWrapper_FuncsTable
, NULL
, NULL
, NULL
);