hcengineering/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2024-12-23 03:22:19 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

UBERF-8280: Ping properly from server (#6733)

Browse Source 
Signed-off-by: Andrey Sobolev <haiodo@gmail.com>
This commit is contained in:
Andrey Sobolev 2024-09-26 16:52:09 +07:00 committed by GitHub
parent 28fffa883f
commit cc67c2792e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/server/src/client.ts
View File

@ -57,6 +57,8 @@ export class ClientSession implements Session {
sessionId = '' sessionId = ''
lastRequest = Date.now() lastRequest = Date.now()
lastPing: number = Date.now()
total: StatisticsElement = { find: 0, tx: 0 } total: StatisticsElement = { find: 0, tx: 0 }
current: StatisticsElement = { find: 0, tx: 0 } current: StatisticsElement = { find: 0, tx: 0 }
mins5: StatisticsElement = { find: 0, tx: 0 } mins5: StatisticsElement = { find: 0, tx: 0 }

7
server/server/src/sessionManager.ts
View File

@ -198,8 +198,13 @@ class TSessionManager implements SessionManager {
void this.close(this.ctx, s[1].socket, wsId) void this.close(this.ctx, s[1].socket, wsId)
continue continue
} }
if (lastRequestDiff + (1 / 10) * lastRequestDiff > this.timeouts.pingTimeout) { if (
lastRequestDiff + (1 / 10) * lastRequestDiff > this.timeouts.pingTimeout &&
now - s[1].session.lastPing > this.timeouts.pingTimeout
) {
// We need to check state and close socket if it broken // We need to check state and close socket if it broken
// And ping other wize
s[1].session.lastPing = now
if (s[1].socket.checkState()) { if (s[1].socket.checkState()) {
s[1].socket.send( s[1].socket.send(
workspace.context, workspace.context,

1
server/server/src/types.ts
View File

@ -74,6 +74,7 @@ export interface Session {
mins5: StatisticsElement mins5: StatisticsElement
lastRequest: number lastRequest: number
lastPing: number
isUpgradeClient: () => boolean isUpgradeClient: () => boolean