ReceiveTempSMS
/
Sweden-Number
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

winegstreamer: Move sample sending to a helper function. 

Signed-off-by: Anton Baskanov <baskanov@gmail.com>
Signed-off-by: Zebediah Figura <z.figura12@gmail.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
This commit is contained in:
Anton Baskanov 2020-12-31 19:52:48 +07:00 committed by Alexandre Julliard
parent 221fdb09b4
commit 291d5a9c10
1 changed files with 40 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

74
dlls/winegstreamer/gstdemux.c
View File

@ -793,51 +793,20 @@ static DWORD CALLBACK push_data(LPVOID iface)
return 0; return 0;
} }
static GstFlowReturn got_data_sink(GstPad *pad, GstObject *parent, GstBuffer *buf) static HRESULT send_sample(struct gstdemux_source *pin, IMediaSample *sample, GstBuffer *buf, GstMapInfo *info)
{ {
struct gstdemux_source *pin = gst_pad_get_element_private(pad);
struct gstdemux *This = impl_from_strmbase_filter(pin->pin.pin.filter);
HRESULT hr; HRESULT hr;
BYTE *ptr = NULL; BYTE *ptr = NULL;
IMediaSample *sample;
GstMapInfo info;
TRACE("%p %p\n", pad, buf); hr = IMediaSample_SetActualDataLength(sample, info->size);
if (This->initial) {
gst_buffer_unref(buf);
return GST_FLOW_OK;
}
hr = BaseOutputPinImpl_GetDeliveryBuffer(&pin->pin, &sample, NULL, NULL, 0);
if (hr == VFW_E_NOT_CONNECTED) {
gst_buffer_unref(buf);
return GST_FLOW_NOT_LINKED;
}
if (FAILED(hr)) {
gst_buffer_unref(buf);
ERR("Could not get a delivery buffer (%x), returning GST_FLOW_FLUSHING\n", hr);
return GST_FLOW_FLUSHING;
}
gst_buffer_map(buf, &info, GST_MAP_READ);
hr = IMediaSample_SetActualDataLength(sample, info.size);
if(FAILED(hr)){ if(FAILED(hr)){
IMediaSample_Release(sample);
gst_buffer_unmap(buf, &info);
gst_buffer_unref(buf);
WARN("SetActualDataLength failed: %08x\n", hr); WARN("SetActualDataLength failed: %08x\n", hr);
return GST_FLOW_FLUSHING; return hr;
} }
IMediaSample_GetPointer(sample, &ptr); IMediaSample_GetPointer(sample, &ptr);
memcpy(ptr, info.data, info.size); memcpy(ptr, info->data, info->size);
gst_buffer_unmap(buf, &info);
if (GST_BUFFER_PTS_IS_VALID(buf)) { if (GST_BUFFER_PTS_IS_VALID(buf)) {
REFERENCE_TIME rtStart = gst_segment_to_running_time(pin->segment, GST_FORMAT_TIME, buf->pts); REFERENCE_TIME rtStart = gst_segment_to_running_time(pin->segment, GST_FORMAT_TIME, buf->pts);
@ -874,8 +843,43 @@ static GstFlowReturn got_data_sink(GstPad *pad, GstObject *parent, GstBuffer *bu
TRACE("sending sample returned: %08x\n", hr); TRACE("sending sample returned: %08x\n", hr);
return hr;
}
static GstFlowReturn got_data_sink(GstPad *pad, GstObject *parent, GstBuffer *buf)
{
struct gstdemux_source *pin = gst_pad_get_element_private(pad);
struct gstdemux *This = impl_from_strmbase_filter(pin->pin.pin.filter);
HRESULT hr;
IMediaSample *sample;
GstMapInfo info;
TRACE("%p %p\n", pad, buf);
if (This->initial) {
gst_buffer_unref(buf); gst_buffer_unref(buf);
return GST_FLOW_OK;
}
hr = BaseOutputPinImpl_GetDeliveryBuffer(&pin->pin, &sample, NULL, NULL, 0);
if (FAILED(hr))
{
if (hr != VFW_E_NOT_CONNECTED)
ERR("Could not get a delivery buffer (%x), returning GST_FLOW_FLUSHING\n", hr);
}
else
{
gst_buffer_map(buf, &info, GST_MAP_READ);
hr = send_sample(pin, sample, buf, &info);
gst_buffer_unmap(buf, &info);
IMediaSample_Release(sample); IMediaSample_Release(sample);
}
gst_buffer_unref(buf);
if (hr == VFW_E_NOT_CONNECTED) if (hr == VFW_E_NOT_CONNECTED)
return GST_FLOW_NOT_LINKED; return GST_FLOW_NOT_LINKED;