|
@@ -136,9 +136,9 @@ bool HttpHandler::SwitchWebSocket(hio_t* io) {
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
};
|
|
};
|
|
|
|
|
+ // NOTE: cancel keepalive timer, judge alive by heartbeat.
|
|
|
|
|
+ ws_channel->setKeepaliveTimeout(0);
|
|
|
if (ws_service && ws_service->ping_interval > 0) {
|
|
if (ws_service && ws_service->ping_interval > 0) {
|
|
|
- // NOTE: cancel keepalive timer, judge alive by heartbeat.
|
|
|
|
|
- ws_channel->setKeepaliveTimeout(0);
|
|
|
|
|
int ping_interval = MAX(ws_service->ping_interval, 1000);
|
|
int ping_interval = MAX(ws_service->ping_interval, 1000);
|
|
|
ws_channel->setHeartbeat(ping_interval, [this](){
|
|
ws_channel->setHeartbeat(ping_interval, [this](){
|
|
|
if (last_recv_pong_time < last_send_ping_time) {
|
|
if (last_recv_pong_time < last_send_ping_time) {
|