Method startBusWatch

src/cinder/CaptureImplGStreamer.cpp:1048–1096

Starts background thread to monitor pipeline messages. GStreamer "bus" is the message system for errors, state changes, etc.

// Starts background thread to monitor pipeline messages. GStreamer "bus" is the message system for errors, state changes, etc.
void CaptureImplGStreamer::startBusWatch()
{
	if( ! mBus || mRunBusWatch )
		return;

	if( mBusWatchThread.joinable() )
		mBusWatchThread.join();

	mRunBusWatch = true;
	mBusWatchThread = std::thread( [this]() {
		while( mRunBusWatch ) {
			GstMessage* message = gst_bus_timed_pop( mBus, GST_MSECOND * 100 );
			if( ! message )
				continue;

			switch( GST_MESSAGE_TYPE( message ) ) {
				case GST_MESSAGE_ERROR:
					{
						GError* err = nullptr;
						gchar*	dbg = nullptr;
						gst_message_parse_error( message, &err, &dbg );
						if( err && err->message )
							CI_LOG_E( "Capture error: " << err->message );
						if( dbg )
							CI_LOG_E( "Debug info: " << dbg );

						// Mark as not capturing when pipeline errors occur
						// This handles device disconnection and other critical failures
						mIsCapturing = false;
						CI_LOG_W( "Device disconnection or pipeline failure detected - marking capture as stopped" );

						if( err )
							g_error_free( err );
						if( dbg )
							g_free( dbg );
						mRunBusWatch = false;
						break;
					}
				case GST_MESSAGE_EOS:
					mRunBusWatch = false;
					break;
				default:
					break;
			}

			gst_message_unref( message );
		}
	} );
}

// Stops bus monitoring thread and waits for it to finish.
void CaptureImplGStreamer::stopBusWatch()