LibUring: Enable liburing usage for SCTP data delivery (#1249)

liburing: Enable liburing usage for SCTP data delivery

CHANGELOG.md

@@ -1,6 +1,11 @@
 # Changelog
 
 
+### Next
+
+* LibUring: Enable liburing usage for SCTP data delivery ([PR 1249](https://github.com/versatica/mediasoup/pull/1249)).
+
+
 ### 3.13.7
 
 * Update worker dependencies ([PR #1201](https://github.com/versatica/mediasoup/pull/1201)):

worker/src/DepUsrSCTP.cpp

@@ -2,6 +2,9 @@
 // #define MS_LOG_DEV_LEVEL 3
 
 #include "DepUsrSCTP.hpp"
+#ifdef MS_LIBURING_SUPPORTED
+#include "DepLibUring.hpp"
+#endif
 #include "DepLibUV.hpp"
 #include "Logger.hpp"
 #include <usrsctp.h>
@@ -249,7 +252,21 @@ void DepUsrSCTP::Checker::OnTimer(TimerHandle* /*timer*/)
 	auto nowMs          = DepLibUV::GetTimeMs();
 	const int elapsedMs = this->lastCalledAtMs ? static_cast<int>(nowMs - this->lastCalledAtMs) : 0;
 
+#ifdef MS_LIBURING_SUPPORTED
+	// Activate liburing usage.
+	// 'usrsctp_handle_timers()' will synchronously call the send/recv
+	// callbacks for the pending data. If there are multiple messages to be
+	// sent over the network then we will send those messages within a single
+	// system call.
+	DepLibUring::SetActive();
+#endif
+
 	usrsctp_handle_timers(elapsedMs);
 
+#ifdef MS_LIBURING_SUPPORTED
+	// Submit all prepared submission entries.
+	DepLibUring::Submit();
+#endif
+
 	this->lastCalledAtMs = nowMs;
 }

worker/src/RTC/Router.cpp

@@ -921,9 +921,24 @@ namespace RTC
 
 		auto& dataConsumers = this->mapDataProducerDataConsumers.at(dataProducer);
 
-		for (auto* dataConsumer : dataConsumers)
+		if (!dataConsumers.empty())
 		{
-			dataConsumer->SendMessage(msg, len, ppid, subchannels, requiredSubchannel);
+#ifdef MS_LIBURING_SUPPORTED
+			// Activate liburing usage.
+			// The effective sending could be synchronous, thus we would send those
+			// messages within a single system call.
+			DepLibUring::SetActive();
+#endif
+
+			for (auto* dataConsumer : dataConsumers)
+			{
+				dataConsumer->SendMessage(msg, len, ppid, subchannels, requiredSubchannel);
+			}
+
+#ifdef MS_LIBURING_SUPPORTED
+			// Submit all prepared submission entries.
+			DepLibUring::Submit();
+#endif
 		}
 	}