Browse Source

Merge pull request #1086 from Nyran/feature/add_max_message_size_to_websocket_config

Add maxMessageSize to Websocket configuration
Paul-Louis Ageneau 1 year ago
parent
commit
5d34614f72
3 changed files with 3 additions and 2 deletions
  1. 1 0
      include/rtc/websocket.hpp
  2. 1 1
      src/impl/websocket.cpp
  3. 1 1
      src/websocket.cpp

+ 1 - 0
include/rtc/websocket.hpp

@@ -43,6 +43,7 @@ public:
 		optional<string> certificatePemFile;
 		optional<string> certificatePemFile;
 		optional<string> keyPemFile;
 		optional<string> keyPemFile;
 		optional<string> keyPemPass;
 		optional<string> keyPemPass;
+		optional<size_t> maxMessageSize;
 	};
 	};
 
 
 	WebSocket();
 	WebSocket();

+ 1 - 1
src/impl/websocket.cpp

@@ -156,7 +156,7 @@ bool WebSocket::isOpen() const { return state == State::Open; }
 
 
 bool WebSocket::isClosed() const { return state == State::Closed; }
 bool WebSocket::isClosed() const { return state == State::Closed; }
 
 
-size_t WebSocket::maxMessageSize() const { return DEFAULT_MAX_MESSAGE_SIZE; }
+size_t WebSocket::maxMessageSize() const { return config.maxMessageSize.value_or(DEFAULT_MAX_MESSAGE_SIZE); }
 
 
 optional<message_variant> WebSocket::receive() {
 optional<message_variant> WebSocket::receive() {
 	auto next = mRecvQueue.pop();
 	auto next = mRecvQueue.pop();

+ 1 - 1
src/websocket.cpp

@@ -41,7 +41,7 @@ bool WebSocket::isOpen() const { return impl()->state.load() == State::Open; }
 
 
 bool WebSocket::isClosed() const { return impl()->state.load() == State::Closed; }
 bool WebSocket::isClosed() const { return impl()->state.load() == State::Closed; }
 
 
-size_t WebSocket::maxMessageSize() const { return DEFAULT_MAX_MESSAGE_SIZE; }
+size_t WebSocket::maxMessageSize() const { return impl()->maxMessageSize(); }
 
 
 void WebSocket::open(const string &url) { impl()->open(url); }
 void WebSocket::open(const string &url) { impl()->open(url); }