Skip to content

Commit 431072b

Browse files
committed
update to the latest oatpp API.
1 parent f8272f8 commit 431072b

File tree

12 files changed

+12
-12
lines changed

12 files changed

+12
-12
lines changed

async-server-rooms/src/rooms/Peer.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ oatpp::async::CoroutineStarter Peer::readMessage(const std::shared_ptr<AsyncWebS
5858
if(size == 0) { // message transfer finished
5959

6060
auto wholeMessage = m_messageBuffer.toString();
61-
m_messageBuffer.clear();
61+
m_messageBuffer.setCurrentPosition(0);
6262

6363
m_room->sendMessage(m_nickname + ": " + wholeMessage);
6464

async-server-rooms/src/rooms/Peer.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ class Peer : public oatpp::websocket::AsyncWebSocket::Listener {
1717
/**
1818
* Buffer for messages. Needed for multi-frame messages.
1919
*/
20-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
20+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
2121

2222
/**
2323
* Lock for synchronization of writes to the web socket.

async-server/src/websocket/WSListener.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ oatpp::async::CoroutineStarter WSListener::readMessage(const std::shared_ptr<Asy
2424
if(size == 0) { // message transfer finished
2525

2626
auto wholeMessage = m_messageBuffer.toString();
27-
m_messageBuffer.clear();
27+
m_messageBuffer.setCurrentPosition(0);
2828

2929
OATPP_LOGD(TAG, "onMessage message='%s'", wholeMessage->c_str());
3030

async-server/src/websocket/WSListener.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ class WSListener : public oatpp::websocket::AsyncWebSocket::Listener {
1515
/**
1616
* Buffer for messages. Needed for multi-frame messages.
1717
*/
18-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
18+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
1919
public:
2020

2121
/**

client-binance.com/src/WSListener.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
2222
if(size == 0) { // message transfer finished
2323

2424
auto wholeMessage = m_messageBuffer.toString();
25-
m_messageBuffer.clear();
25+
m_messageBuffer.setCurrentPosition(0);
2626
onCompleteMessage(wholeMessage);
2727

2828
} else if(size > 0) { // message frame received

client-binance.com/src/WSListener.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
1515
/**
1616
* Buffer for messages. Needed for multi-frame messages.
1717
*/
18-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
18+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
1919
public:
2020

2121
/**

client-mbedtls/src/WSListener.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
2323
if(size == 0) { // message transfer finished
2424

2525
auto wholeMessage = m_messageBuffer.toString();
26-
m_messageBuffer.clear();
26+
m_messageBuffer.setCurrentPosition(0);
2727

2828
OATPP_LOGD(TAG, "on message received '%s'", wholeMessage->c_str());
2929

client-mbedtls/src/WSListener.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
1616
/**
1717
* Buffer for messages. Needed for multi-frame messages.
1818
*/
19-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
19+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
2020
public:
2121

2222
WSListener(std::mutex& writeMutex)

client/src/WSListener.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
2323
if(size == 0) { // message transfer finished
2424

2525
auto wholeMessage = m_messageBuffer.toString();
26-
m_messageBuffer.clear();
26+
m_messageBuffer.setCurrentPosition(0);
2727

2828
OATPP_LOGD(TAG, "on message received '%s'", wholeMessage->c_str());
2929

client/src/WSListener.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
1616
/**
1717
* Buffer for messages. Needed for multi-frame messages.
1818
*/
19-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
19+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
2020
public:
2121

2222
WSListener(std::mutex& writeMutex)

server/src/websocket/WSListener.cpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
2222
if(size == 0) { // message transfer finished
2323

2424
auto wholeMessage = m_messageBuffer.toString();
25-
m_messageBuffer.clear();
25+
m_messageBuffer.setCurrentPosition(0);
2626

2727
OATPP_LOGD(TAG, "onMessage message='%s'", wholeMessage->c_str());
2828

server/src/websocket/WSListener.hpp

+1-1
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
1414
/**
1515
* Buffer for messages. Needed for multi-frame messages.
1616
*/
17-
oatpp::data::stream::ChunkedBuffer m_messageBuffer;
17+
oatpp::data::stream::BufferOutputStream m_messageBuffer;
1818
public:
1919

2020
/**

0 commit comments

Comments
 (0)