Searched refs:openSockets (Results 1 – 3 of 3) sorted by relevance
51 private val openSockets: MutableSet<Socket> = Collections.newSetFromMap(ConcurrentHashMap()) in <lambda>() constant in okio.samples.KotlinSocksProxyServer74 openSockets.add(from) in <lambda>()80 for (socket in openSockets) { in <lambda>()129 openSockets.add(toSocket) in <lambda>()149 openSockets.remove(fromSocket) in <lambda>()172 openSockets.remove(sourceSocket) in <lambda>()
54 private final Set<Socket> openSockets = field in SocksProxyServer76 openSockets.add(from); in acceptSockets()82 for (Socket socket : openSockets) { in acceptSockets()132 openSockets.add(toSocket); in handleSocket()152 openSockets.remove(fromSocket); in handleSocket()174 openSockets.remove(sourceSocket); in transfer()
51 this.openSockets=[]; property in anonymousFunction1897a8f20100.TcpServer102 for (var i=0; i<this.openSockets.length; i++) {104 this.openSockets[i].close();109 this.openSockets=[]; property152 if (this.openSockets.length >= this.maxConnections) {158 this.openSockets.push(tcpConnection);