amazon-kinesis-video-streams-producer-sdk-cpp: [BUG] Not closing after EOS

Logging

03:53:24.591 postReadCallback(): Reported end-of-stream for stream my_stream. Upload handle: 262
03:53:24.591 writeHeaderCallback(): RequestId: ee1ff8b1-16be-4411-ac60-6c4c665d2dcc
03:53:24.591 getStreamingEndpointResultEvent(): Get streaming endpoint result event.
03:53:24.591 getStreamingTokenResultEvent(): Get streaming token result event.
03:53:24.591 putStreamResultEvent(): Put stream result event. New upload handle 264
03:53:24.591 writeHeaderCallback(): RequestId: ff327f9d-d0f4-2a99-a511-915a0d3cbc3c
03:53:24.591 getStreamData(): Handle 263 waiting for last persisted ack with ts 16385260865620000
03:53:24.591 getStreamData(): Indicating an EOS after last persisted ACK is received for stream upload handle 263
03:53:24.591 postReadCallback(): Reported end-of-stream for stream my_stream. Upload handle: 263
03:53:24.591 writeHeaderCallback(): RequestId: abcc507d-6372-4136-b8a0-eac62e16c79c
03:53:24.591 getStreamingEndpointResultEvent(): Get streaming endpoint result event.
03:53:24.591 getStreamingTokenResultEvent(): Get streaming token result event.
03:53:24.591 putStreamResultEvent(): Put stream result event. New upload handle 265
03:53:24.591 writeHeaderCallback(): RequestId: ec0db659-4e25-bb11-b62e-4128b78bae7b
03:53:24.591 getStreamData(): Handle 264 waiting for last persisted ack with ts 16385283064830000
03:53:24.591 getStreamData(): Indicating an EOS after last persisted ACK is received for stream upload handle 264
03:53:24.591 postReadCallback(): Reported end-of-stream for stream my_stream. Upload handle: 264
03:53:24.591 stopKinesisVideoStreamSync(): Synchronously stopping Kinesis Video Stream 000055a65914ac38.
03:53:24.591 postReadCallback(): Reported end-of-stream for stream my_stream. Upload handle: 265
03:53:24.591 WARNING: from element /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0: Could not read from resource.
03:53:24.591 Additional debug info:
03:53:24.591 gstrtspsrc.c(5289): gst_rtspsrc_loop_udp (): /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0:
03:53:24.591 Unhandled return value -7.
03:53:24.591 EOS on shutdown enabled -- waiting for EOS after Error
03:53:24.591 Waiting for EOS...
03:53:24.593 ERROR: from element /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0: Could not read from resource.
03:53:24.593 Additional debug info:
03:53:24.593 gstrtspsrc.c(5357): gst_rtspsrc_loop_udp (): /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0:
03:53:24.593 Could not receive message. (System error)
03:53:24.593 ERROR: from element /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0: Internal data stream error.
03:53:24.593 Additional debug info:
03:53:24.593 gstrtspsrc.c(5649): gst_rtspsrc_loop (): /GstPipeline:pipeline0/GstRTSPSrc:rtspsrc0:
03:53:24.593 streaming stopped, reason error (-5)
03:54:45.983 stopStreamSync(): Failed to stop Kinesis Video Stream - timed out.
03:54:45.984 stopKinesisVideoStreamSync(): operation returned status code: 0x0000000f
03:54:45.984 Failed to stop the stream with: 15
03:54:45.984 Sending eos
03:54:45.984 Got EOS from element "pipeline0".
03:54:45.984 EOS received - stopping pipeline...
03:54:45.984 Execution ended after 168:00:40.115686242
03:54:45.984 Setting pipeline to PAUSED ...
03:54:45.984 Setting pipeline to READY ...
03:54:45.985 Setting pipeline to NULL ...
03:54:45.986 Freeing pipeline ...

Describe the bug Occasionally, the process will remain open when there’s an EOS even though things have closed down

To Reproduce Don’t have a consistent reproducer yet, but it does happen occasionally

Expected behavior Process would close when EOS happens

SDK version number 3.2.0

Open source building Docker container

Platform (please complete the following information):

• OS: Debian
• Processor: x86-64
• Version: Buster