Lines Matching refs:WsSession
48 import nginx.unit.websocket.WsSession;
80 private final Map<String,Set<WsSession>> authenticatedSessions = new ConcurrentHashMap<>();
340 protected void registerSession(Endpoint endpoint, WsSession wsSession) { in registerSession()
357 protected void unregisterSession(Endpoint endpoint, WsSession wsSession) { in unregisterSession()
367 private void registerAuthenticatedSession(WsSession wsSession, in registerAuthenticatedSession()
369 Set<WsSession> wsSessions = authenticatedSessions.get(httpSessionId); in registerAuthenticatedSession()
372 new ConcurrentHashMap<WsSession,Boolean>()); in registerAuthenticatedSession()
380 private void unregisterAuthenticatedSession(WsSession wsSession, in unregisterAuthenticatedSession()
382 Set<WsSession> wsSessions = authenticatedSessions.get(httpSessionId); in unregisterAuthenticatedSession()
391 Set<WsSession> wsSessions = authenticatedSessions.remove(httpSessionId); in closeAuthenticatedSession()
394 for (WsSession wsSession : wsSessions) { in closeAuthenticatedSession()