checking throughput of offline upload of file

[clogwog]

Hi,

i'm uploading footage to the kinesis stream directly by using a

timeout 120 gst-launch-1.0 filesrc -> kvssink

pipeline.
Sometimes the device has no connectivity it will time out, and we will try again later.

however sometimes we have bad connectivity, where to upload is progressing slowly but it still times out because of the fixed 120 sec timeout.

is there a way to check if there is any movement in the the upload ? so i can wait longer ?

i tried a plugin in the middle
filesrc -> data-throughput-checker -> kvssink

but the file gets streamed all to the kvssink in the first second (it must have a big internal buffer)
so i can not see what the actual sending part of the kvssink is up to.

Any suggestions on how i can get an indication of current throughput ?

[sirknightj]

One way you can do it is through the fragmentAckReceived callback.

amazon-kinesis-video-streams-producer-sdk-cpp/src/StreamCallbackProvider.h

Lines 202 to 204 in 7771598

	virtual FragmentAckReceivedFunc getFragmentAckReceivedCallback() {
	return nullptr;
	};

You will receive this callback for each chunk the SDK uploaded to KVS.

You can override the callback implementation here in the samples:

amazon-kinesis-video-streams-producer-sdk-cpp/samples/kvs_gstreamer_sample.cpp

Lines 155 to 158 in 7771598

	class SampleStreamCallbackProvider : public StreamCallbackProvider {
	UINT64 custom_data_;
	public:
	SampleStreamCallbackProvider(UINT64 custom_data) : custom_data_(custom_data) {}

[clogwog]

Thank you @sirknightj for a pointer in the right direction!

So inside the kvssink i would need to provide a subclass of a StreamCallbackProvider somewhere around here ?

https://github.com/awslabs/amazon-kinesis-video-streams-producer-sdk-cpp/blob/7771598527883545b2161b56a78160429def4fc1/src/gstreamer/gstkvssink.cpp#L274C40-L274C64