Cleanup remaining payload channel references

versatica · Feb 2, 2024 · d7578e5 · d7578e5
1 parent 01075b1
commit d7578e5
Show file tree

Hide file tree

Showing 7 changed files with 2 additions and 15 deletions.
diff --git a/rust/src/worker/utils.rs b/rust/src/worker/utils.rs
@@ -80,8 +80,6 @@ where
                     version.as_ptr(),
                     0,
                     0,
-                    0,
-                    0,
                     channel_read_fn,
                     channel_read_ctx,
                     channel_write_fn,

diff --git a/worker/include/Channel/ChannelNotifier.hpp b/worker/include/Channel/ChannelNotifier.hpp
@@ -25,7 +25,7 @@ namespace Channel
 		  FBS::Notification::Body type,
 		  flatbuffers::Offset<Body>& body)
 		{
-			auto& builder     = ChannelNotifier::bufferBuilder;
+			auto& builder     = this->bufferBuilder;
 			auto notification = FBS::Notification::CreateNotificationDirect(
 			  builder, targetId.c_str(), event, type, body.Union());
 
@@ -50,7 +50,6 @@ namespace Channel
 			this->channel->Send(builder.GetBufferPointer(), builder.GetSize());
 			builder.Reset();
 		}
-		void Emit(const FBS::Notification::Notification& notification);
 
 	private:
 		// Passed by argument.

diff --git a/worker/include/lib.hpp b/worker/include/lib.hpp
@@ -6,8 +6,6 @@ extern "C" int mediasoup_worker_run(
   const char* version,
   int consumerChannelFd,
   int producerChannelFd,
-  int payloadConsumeChannelFd,
-  int payloadProduceChannelFd,
   ChannelReadFn channelReadFn,
   ChannelReadCtx channelReadCtx,
   ChannelWriteFn channelWriteFn,

diff --git a/worker/src/Channel/ChannelSocket.cpp b/worker/src/Channel/ChannelSocket.cpp
@@ -137,7 +137,7 @@ namespace Channel
 			return;
 		}
 
-		SendImpl(reinterpret_cast<const uint8_t*>(data), dataLen);
+		SendImpl(data, dataLen);
 	}
 
 	void ChannelSocket::SendLog(const char* data, uint32_t dataLen)

diff --git a/worker/src/lib.cpp b/worker/src/lib.cpp
@@ -32,8 +32,6 @@ extern "C" int mediasoup_worker_run(
   const char* version,
   int consumerChannelFd,
   int producerChannelFd,
-  int /*payloadConsumeChannelFd*/,
-  int /*payloadProduceChannelFd*/,
   ChannelReadFn channelReadFn,
   ChannelReadCtx channelReadCtx,
   ChannelWriteFn channelWriteFn,

diff --git a/worker/src/lib.rs b/worker/src/lib.rs
@@ -51,8 +51,6 @@ extern "C" {
         version: *const c_char,
         consumer_channel_fd: c_int,
         producer_channel_fd: c_int,
-        payload_consumer_channel_fd: c_int,
-        payload_producer_channel_fd: c_int,
         channel_read_fn: ChannelReadFn,
         channel_read_ctx: ChannelReadCtx,
         channel_write_fn: ChannelWriteFn,

diff --git a/worker/src/main.cpp b/worker/src/main.cpp
@@ -8,8 +8,6 @@
 
 static constexpr int ConsumerChannelFd{ 3 };
 static constexpr int ProducerChannelFd{ 4 };
-static constexpr int PayloadConsumerChannelFd{ 5 };
-static constexpr int PayloadProducerChannelFd{ 6 };
 
 int main(int argc, char* argv[])
 {
@@ -30,8 +28,6 @@ int main(int argc, char* argv[])
 	  version.c_str(),
 	  ConsumerChannelFd,
 	  ProducerChannelFd,
-	  PayloadConsumerChannelFd,
-	  PayloadProducerChannelFd,
 	  nullptr,
 	  nullptr,
 	  nullptr,
-Original file line number
+Diff line change
@@ Expand Up / @@ -137,7 +137,7 @@ namespace Channel @@
     			return;
     		}
-    		SendImpl(reinterpret_cast<const uint8_t*>(data), dataLen);
+    		SendImpl(data, dataLen);
     	}
     	void ChannelSocket::SendLog(const char* data, uint32_t dataLen)
@@ Expand Down @@