Searched refs:_endpoints (Results 1 – 2 of 2) sorted by relevance
61 …private final Set<BlockingChannelEndPoint> _endpoints = new ConcurrentHashSet<BlockingChannelEndPo… field in BlockingChannelConnector97 for (BlockingChannelEndPoint endp : _endpoints) in doStart()274 _endpoints.add(this); in run()323 _endpoints.remove(this); in run()
105 self._endpoints = endpoints.copy()207 logging.debug('Restoring snapshot with %s', snapshot._endpoints)208 for endpoint in snapshot._endpoints: