We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f34fa57 commit 46d2f20Copy full SHA for 46d2f20
vpr/src/server/gateio.cpp
@@ -91,6 +91,8 @@ void GateIO::startListening()
91
92
std::optional<sockpp::tcp6_socket> clientOpt;
93
94
+ std::string receivedMessage;
95
+
96
/// comm event loop
97
while(m_isRunning.load()) {
98
bool isCommunicationProblemDetected = false;
@@ -156,8 +158,9 @@ void GateIO::startListening()
156
158
} // release lock
157
159
160
/// handle receiving
- std::string receivedMessage;
- receivedMessage.resize(chunkMaxBytesNum);
161
+ if (receivedMessage.size() != chunkMaxBytesNum) {
162
+ receivedMessage.resize(chunkMaxBytesNum);
163
+ }
164
std::size_t bytesActuallyReceived{0};
165
try {
166
bytesActuallyReceived = client.read_n(&receivedMessage[0], chunkMaxBytesNum);
0 commit comments