Skip to content

Commit ad5d3df

Browse files
committed
small update
1 parent 821c048 commit ad5d3df

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

include/internal/WebSocketContext.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
#pragma once
2+
#include "Logging.h"
23
#include "WS_Lite.h"
34
#include <chrono>
45
#include <functional>

include/internal/WebSocketProtocol.h

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -264,8 +264,7 @@ namespace WS_LITE {
264264
}
265265
}
266266

267-
template <bool isServer, class SOCKETTYPE>
268-
inline void ProcessMessage(const SOCKETTYPE &socket, size_t previoussize, const std::shared_ptr<asio::streambuf> &extradata)
267+
template <bool isServer, class SOCKETTYPE> inline void ProcessMessage(const SOCKETTYPE &socket, const std::shared_ptr<asio::streambuf> &extradata)
269268
{
270269

271270
auto opcode = static_cast<OpCode>(getOpCode(socket->ReceiveHeader));
@@ -463,15 +462,15 @@ namespace WS_LITE {
463462
auto buffer = socket->ReceiveBuffer + socket->ReceiveBufferSize - size;
464463
UnMaskMessage(size, buffer, isServer);
465464
socket->ReceiveBufferSize -= AdditionalBodyBytesToRead(isServer);
466-
return ProcessMessage<isServer>(socket, size - AdditionalBodyBytesToRead(isServer), extradata);
465+
return ProcessMessage<isServer>(socket, extradata);
467466
}
468467
else {
469468
return sendclosemessage<isServer>(socket, 1002, "ReadBody Error " + ec.message());
470469
}
471470
});
472471
}
473472
else {
474-
return ProcessMessage<isServer>(socket, 0, extradata);
473+
return ProcessMessage<isServer>(socket, extradata);
475474
}
476475
}
477476
else {

src/ClientImpl.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,7 @@ namespace WS_LITE {
5353
auto read_buffer(std::make_shared<asio::streambuf>());
5454
asio::async_read_until(socket->Socket, *read_buffer, "\r\n\r\n",
5555
[read_buffer, accept_sha1, socket, self](const std::error_code &ec, size_t bytes_transferred) {
56+
UNUSED(bytes_transferred);
5657
if (!ec) {
5758
SL_WS_LITE_LOG(Logging_Levels::INFO_log_level, "Read Handshake bytes " << bytes_transferred
5859
<< " sizeof read_buffer "

0 commit comments

Comments
 (0)