flatbuffer builder reuse

worker/include/Channel/ChannelNotifier.hpp

@@ -34,7 +34,7 @@ namespace Channel
 
 			builder.FinishSizePrefixed(message);
 			this->channel->Send(builder.GetBufferPointer(), builder.GetSize());
-			builder.Reset();
+			builder.Clear();
 		}
 
 		void Emit(const std::string& targetId, FBS::Notification::Event event)
@@ -48,7 +48,7 @@ namespace Channel
 
 			builder.FinishSizePrefixed(message);
 			this->channel->Send(builder.GetBufferPointer(), builder.GetSize());
-			builder.Reset();
+			builder.Clear();
 		}
 
 	private:

worker/include/Channel/ChannelRequest.hpp

@@ -22,14 +22,15 @@ namespace Channel
 
 	public:
 		static absl::flat_hash_map<FBS::Request::Method, const char*> method2String;
+		thread_local static flatbuffers::FlatBufferBuilder bufferBuilder;
 
 	public:
 		ChannelRequest(Channel::ChannelSocket* channel, const FBS::Request::Request* request);
 		~ChannelRequest() = default;
 
 		flatbuffers::FlatBufferBuilder& GetBufferBuilder()
 		{
-			return this->bufferBuilder;
+			return ChannelRequest::bufferBuilder;
 		}
 		void Accept();
 		template<class Body>
@@ -39,15 +40,15 @@ namespace Channel
 
 			this->replied = true;
 
-			auto& builder = this->bufferBuilder;
+			auto& builder = ChannelRequest::bufferBuilder;
 			auto response = FBS::Response::CreateResponse(builder, this->id, true, type, body.Union());
 
 			auto message =
 			  FBS::Message::CreateMessage(builder, FBS::Message::Body::Response, response.Union());
 
 			builder.FinishSizePrefixed(message);
 			this->Send(builder.GetBufferPointer(), builder.GetSize());
-			builder.Reset();
+			builder.Clear();
 		}
 		void Error(const char* reason = nullptr);
 		void TypeError(const char* reason = nullptr);
@@ -61,7 +62,6 @@ namespace Channel
 		Channel::ChannelSocket* channel{ nullptr };
 		const FBS::Request::Request* data{ nullptr };
 		// Others.
-		flatbuffers::FlatBufferBuilder bufferBuilder{};
 		uint32_t id{ 0u };
 		Method method;
 		const char* methodCStr;

worker/src/Channel/ChannelRequest.cpp

@@ -83,7 +83,7 @@ namespace Channel
 		{ FBS::Request::Method::RTPOBSERVER_REMOVE_PRODUCER,                    "rtpObserver.removeProducer"                 },
 	};
 	// clang-format on
-
+	thread_local flatbuffers::FlatBufferBuilder ChannelRequest::bufferBuilder{};
 	/* Instance methods. */
 
 	/**
@@ -119,7 +119,7 @@ namespace Channel
 
 		this->replied = true;
 
-		auto& builder = this->bufferBuilder;
+		auto& builder = ChannelRequest::bufferBuilder;
 		auto response =
 		  FBS::Response::CreateResponse(builder, this->id, true, FBS::Response::Body::NONE, 0);
 
@@ -134,7 +134,7 @@ namespace Channel
 
 		this->replied = true;
 
-		auto& builder = this->bufferBuilder;
+		auto& builder = ChannelRequest::bufferBuilder;
 		auto response = FBS::Response::CreateResponseDirect(
 		  builder, this->id, false /*accepted*/, FBS::Response::Body::NONE, 0, "Error" /*Error*/, reason);
 
@@ -149,7 +149,7 @@ namespace Channel
 
 		this->replied = true;
 
-		auto& builder = this->bufferBuilder;
+		auto& builder = ChannelRequest::bufferBuilder;
 		auto response = FBS::Response::CreateResponseDirect(
 		  builder, this->id, false /*accepted*/, FBS::Response::Body::NONE, 0, "TypeError" /*Error*/, reason);
 
@@ -163,12 +163,12 @@ namespace Channel
 
 	void ChannelRequest::SendResponse(const flatbuffers::Offset<FBS::Response::Response>& response)
 	{
-		auto& builder = this->bufferBuilder;
+		auto& builder = ChannelRequest::bufferBuilder;
 		auto message =
 		  FBS::Message::CreateMessage(builder, FBS::Message::Body::Response, response.Union());
 
 		builder.FinishSizePrefixed(message);
 		this->Send(builder.GetBufferPointer(), builder.GetSize());
-		builder.Reset();
+		builder.Clear();
 	}
 } // namespace Channel

worker/src/Channel/ChannelSocket.cpp

@@ -162,7 +162,7 @@ namespace Channel
 
 		this->bufferBuilder.FinishSizePrefixed(message);
 		this->Send(this->bufferBuilder.GetBufferPointer(), this->bufferBuilder.GetSize());
-		this->bufferBuilder.Reset();
+		this->bufferBuilder.Clear();
 	}
 
 	bool ChannelSocket::CallbackRead()