ping / pong support / fix bug in dispatching received message type
This commit is contained in:
parent
977feae1d6
commit
2bc38acbb1
@ -70,6 +70,18 @@ namespace
|
|||||||
<< str;
|
<< str;
|
||||||
log(ss.str());
|
log(ss.str());
|
||||||
}
|
}
|
||||||
|
else if (messageType == ix::WebSocket_MessageType_Ping)
|
||||||
|
{
|
||||||
|
ss << "ws_connect: received ping message: "
|
||||||
|
<< str;
|
||||||
|
log(ss.str());
|
||||||
|
}
|
||||||
|
else if (messageType == ix::WebSocket_MessageType_Pong)
|
||||||
|
{
|
||||||
|
ss << "ws_connect: received pong message: "
|
||||||
|
<< str;
|
||||||
|
log(ss.str());
|
||||||
|
}
|
||||||
else if (messageType == ix::WebSocket_MessageType_Error)
|
else if (messageType == ix::WebSocket_MessageType_Error)
|
||||||
{
|
{
|
||||||
ss << "Connection error: " << error.reason << std::endl;
|
ss << "Connection error: " << error.reason << std::endl;
|
||||||
@ -78,7 +90,7 @@ namespace
|
|||||||
ss << "HTTP Status: " << error.http_status << std::endl;
|
ss << "HTTP Status: " << error.http_status << std::endl;
|
||||||
log(ss.str());
|
log(ss.str());
|
||||||
}
|
}
|
||||||
else if (messageType == ix::WebSocket_MessageType_Pong)
|
else
|
||||||
{
|
{
|
||||||
ss << "Invalid ix::WebSocketMessageType";
|
ss << "Invalid ix::WebSocketMessageType";
|
||||||
log(ss.str());
|
log(ss.str());
|
||||||
|
@ -1,4 +1,9 @@
|
|||||||
#!/bin/sh
|
#!/bin/sh
|
||||||
|
|
||||||
|
test -d build || {
|
||||||
|
mkdir -p build
|
||||||
|
cd build
|
||||||
|
cmake ..
|
||||||
|
}
|
||||||
(cd build ; make)
|
(cd build ; make)
|
||||||
./build/ping_pong ws://localhost:5678
|
./build/ping_pong ws://localhost:5678
|
||||||
|
@ -199,7 +199,7 @@ namespace ix {
|
|||||||
} break;
|
} break;
|
||||||
}
|
}
|
||||||
|
|
||||||
_onMessageCallback(WebSocket_MessageType_Message, msg, WebSocketErrorInfo());
|
_onMessageCallback(webSocketMessageType, msg, WebSocketErrorInfo());
|
||||||
|
|
||||||
WebSocket::invokeTrafficTrackerCallback(msg.size(), true);
|
WebSocket::invokeTrafficTrackerCallback(msg.size(), true);
|
||||||
});
|
});
|
||||||
|
Loading…
x
Reference in New Issue
Block a user