Searched refs:BlockingChannelEndPoint (Results 1 – 1 of 1) sorted by relevance
61 …private final Set<BlockingChannelEndPoint> _endpoints = new ConcurrentHashSet<BlockingChannelEndPo…97 for (BlockingChannelEndPoint endp : _endpoints) in doStart()148 BlockingChannelEndPoint connection=new BlockingChannelEndPoint(channel); in accept()174 …private class BlockingChannelEndPoint extends ChannelEndPoint implements Runnable, ConnectedEndPoi… class in BlockingChannelConnector180 BlockingChannelEndPoint(ByteChannel channel) in BlockingChannelEndPoint() method in BlockingChannelConnector.BlockingChannelEndPoint305 try{BlockingChannelEndPoint.this.close();} in run()