Skip to content

Commit 329fa9f

Browse files
committed
sendwrite fix
1 parent 0ce16c5 commit 329fa9f

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

include/internal/WebSocketProtocol.h

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -55,16 +55,17 @@ namespace SL {
5555
}
5656
}
5757
template<class PARENTTYPE, class SOCKETTYPE>inline void startwrite(const PARENTTYPE& parent, const SOCKETTYPE& socket) {
58-
if (!socket->SendMessageQueue.empty() && !socket->Writing){
58+
if(!socket->Writing){
59+
if (!socket->SendMessageQueue.empty()){
5960
socket->Writing = true;
6061
auto msg(socket->SendMessageQueue.front());
6162
socket->SendMessageQueue.pop_front();
6263
write(parent, socket, msg.msg);
63-
64-
}
65-
else {
66-
writeexpire_from_now(parent, socket, std::chrono::seconds(0));// make sure the write timer doesnt kick off
64+
} else {
65+
writeexpire_from_now(parent, socket, std::chrono::seconds(0));// make sure the write timer doesnt kick off
66+
}
6767
}
68+
6869
}
6970
template<class PARENTTYPE, class SOCKETTYPE>void sendImpl(const PARENTTYPE& parent, const SOCKETTYPE& socket, WSMessage& msg, bool compressmessage) {
7071
if (compressmessage) {

0 commit comments

Comments
 (0)