zhiyua-git
commented
4 years ago Hi @indoorrobot ,
To work around this you can make code changes as below, this will stop the gstreamer pipeline when it hits stream latency pressure. You can tune the setting by adding "max-latency=n" to your gstreamer pipeline to get stream latency setting to n seconds like gst-launch-1.0 -v v4l2src device=/dev/video3 ! h264parse ! video/x-h264,stream-frmat=avc,alignment=au,width=1920,height=1080,framerate=30/1 ! kvssink name=sink stream-name=${ROBOT_CLOUD_ID}_fc access-key=$AWS_ACCESS_KEY_ID secret-key=$AWS_SECRET_ACCESS_KEY max-latency=10. Please note in this case, the data in the buffer remaining for that many seconds would be dropped.
diff --git a/kinesis-video-gstreamer-plugin/src/gstkvssink.cpp b/kinesis-video-gstreamer-plugin/src/gstkvssink.cpp
index 046f5fa..2d556a9 100644
--- a/kinesis-video-gstreamer-plugin/src/gstkvssink.cpp
+++ b/kinesis-video-gstreamer-plugin/src/gstkvssink.cpp
@@ -1053,9 +1053,11 @@ gst_kvs_sink_handle_buffer (GstCollectPads * pads,
goto CleanUp;
} else {
// resetStream, note that this will flush out producer buffer
- data->kinesis_video_stream->resetStream();
+ //data->kinesis_video_stream->resetStream();
// reset state
- data->stream_status = STATUS_SUCCESS;
+ //data->stream_status = STATUS_SUCCESS;
+ ret = GST_FLOW_ERROR;
+ goto CleanUp;
}
}
diff --git a/kinesis-video-gstreamer-plugin/src/KvsSinkStreamCallbackProvider.cpp b/kinesis-video-gstreamer-plugin/src/KvsSinkStreamCallbackProvider.cpp
index afbe275..9d3560b 100644
--- a/kinesis-video-gstreamer-plugin/src/KvsSinkStreamCallbackProvider.cpp
+++ b/kinesis-video-gstreamer-plugin/src/KvsSinkStreamCallbackProvider.cpp
@@ -34,7 +34,7 @@ STATUS
KvsSinkStreamCallbackProvider::droppedFrameReportHandler(UINT64 custom_data,
STREAM_HANDLE stream_handle,
UINT64 dropped_frame_timecode) {
- UNUSED_PARAM(custom_data);
+ ((CustomData*) (custom_data))->stream_status = STATUS_INTERNAL_ERROR;
LOG_WARN("Reported droppedFrame callback for stream handle " << stream_handle << ". Dropped frame timecode in 100ns: " << dropped_frame_timecode);
return STATUS_SUCCESS; // continue streaming
}
@@ -43,7 +43,7 @@ STATUS
KvsSinkStreamCallbackProvider::streamLatencyPressureHandler(UINT64 custom_data,
STREAM_HANDLE stream_handle,
UINT64 current_buffer_duration) {
- UNUSED_PARAM(custom_data);
+ ((CustomData*) (custom_data))->stream_status = STATUS_INTERNAL_ERROR;
LOG_DEBUG("Reported streamLatencyPressure callback for stream handle " << stream_handle << ". Current buffer duration in 100ns: " << current_buffer_duration);
return STATUS_SUCCESS;
}We will work on improving the producer SDK retry behavior to auto-recover on these case.
Thanks, -ZH
Nomidia
indoorrobot
MushMal
chehefen
Hi I am constantly streaming video to KVS (from 2 h264 cameras) using gst, but after a few seconds / minutes I am getting the error:
See logs:
The way I am running the stream is using a bash script:
What am I missing?