public class CallHomeMountSessionManager implements CallHomeMountSessionContext.CloseCallback {
- private final ConcurrentMap<SocketAddress, CallHomeMountSessionContext> contextByAddress = new ConcurrentHashMap<>();
- private final Multimap<PublicKey, CallHomeMountSessionContext> contextByPublicKey = MultimapBuilder.hashKeys().hashSetValues().build();
+ private final ConcurrentMap<SocketAddress, CallHomeMountSessionContext> contextByAddress =
+ new ConcurrentHashMap<>();
+ private final Multimap<PublicKey, CallHomeMountSessionContext> contextByPublicKey = MultimapBuilder.hashKeys()
+ .hashSetValues().build();
@Nullable
public CallHomeMountSessionContext getByAddress(InetSocketAddress remoteAddr) {
}
CallHomeMountSessionContext createSession(CallHomeProtocolSessionContext session,
- CallHomeChannelActivator activator, final CloseCallback onCloseHandler) {
+ CallHomeChannelActivator activator, final CloseCallback onCloseHandler) {
String name = session.getSessionName();
- CallHomeMountSessionContext deviceContext = new CallHomeMountSessionContext(name, session, activator, devCtxt -> {
- CallHomeMountSessionManager.this.onClosed(devCtxt);
- onCloseHandler.onClosed(devCtxt);
- });
+ CallHomeMountSessionContext deviceContext = new CallHomeMountSessionContext(name,
+ session, activator, devCtxt -> {
+ CallHomeMountSessionManager.this.onClosed(devCtxt);
+ onCloseHandler.onClosed(devCtxt);
+ });
contextByAddress.put(deviceContext.getRemoteAddress(), deviceContext);
contextByPublicKey.put(deviceContext.getRemoteServerKey(), deviceContext);
@Override
public synchronized void onClosed(CallHomeMountSessionContext deviceContext) {
contextByAddress.remove(deviceContext.getRemoteAddress());
- contextByPublicKey.remove(deviceContext.getRemoteServerKey(),deviceContext);
+ contextByPublicKey.remove(deviceContext.getRemoteServerKey(), deviceContext);
}
-
}