|
|
|
@ -118,6 +118,8 @@ event_route[xhttp:request] |
|
|
|
exit; |
|
|
|
} |
|
|
|
|
|
|
|
route_if_exists("WS_ON_BEFORE_HANSHAKE"); |
|
|
|
|
|
|
|
if (ws_handle_handshake()) { |
|
|
|
$var(count) = $shtinc(websockets=>$var(ws_orig_ip)::count); |
|
|
|
$sht(websockets=>$ws_conid::ws_orig_ip) = $var(ws_orig_ip); |
|
|
|
@ -127,6 +129,7 @@ event_route[xhttp:request] |
|
|
|
} else { |
|
|
|
xlog("L_INFO", "websocket|log|opened websocket $ws_conid from $var(ws_orig_ip):$sp\n"); |
|
|
|
} |
|
|
|
route_if_exists("WS_ON_SUCCESSFULL_HANSHAKE"); |
|
|
|
exit; |
|
|
|
} |
|
|
|
|
|
|
|
@ -138,7 +141,7 @@ event_route[websocket:closed] |
|
|
|
{ |
|
|
|
$var(ws_orig_ip) = $sht(websockets=>$ws_conid::ws_orig_ip); |
|
|
|
$sht(websockets=>$ws_conid::ws_orig_ip) = $null; |
|
|
|
|
|
|
|
|
|
|
|
$var(count) = $shtdec(websockets=>$si::count); |
|
|
|
if($var(ws_orig_ip) != $null && $si != $var(ws_orig_ip)) { |
|
|
|
$var(countip) = $shtdec(websockets=>$var(ws_orig_ip)::count); |
|
|
|
@ -148,4 +151,5 @@ event_route[websocket:closed] |
|
|
|
xlog("L_INFO", "websocket|log|closed websocket $ws_conid from $var(ws_orig_ip):$sp\n"); |
|
|
|
} |
|
|
|
if ($var(count) < 1) $sht(websockets=>$si::count) = $null; |
|
|
|
route_if_exists("WS_ON_CLOSE"); |
|
|
|
} |