Searched refs:_pending_connections (Results 1 – 9 of 9) sorted by relevance
50 _pending_connections (0), in NNTP_Pool()183 --_pending_connections; in on_socket_created()252 --_pending_connections; in on_nntp_done()278 setme_pending = _pending_connections; in get_counts()303 ++_pending_connections; in request_nntp()
115 int _pending_connections; variable
103 self._pending_connections = EmptyableSet(209 self._pending_connections.discard(c)241 d = self._pending_connections.when_next_empty()242 [c.disconnect() for c in self._pending_connections]249 self._pending_connections.clear()389 self._pending_connections.add(p)392 p.when_disconnected().addCallback(self._pending_connections.discard)
164 pending_connections_t copy = _pending_connections; in terminate()772 _pending_connections.ZMQ_MAP_INSERT_OR_EMPLACE (addr_, in pend_connection()788 pending = _pending_connections.equal_range (addr_); in connect_pending()794 _pending_connections.erase (pending.first, pending.second); in connect_pending()
219 pending_connections_t _pending_connections; member in zmq::ZMQ_FINAL
432 self._pending_connections = set()442 for d in list(self._pending_connections):460 self._pending_connections.add(d)465 self._pending_connections.remove(d)
255 … mock.call.when_disconnected().addCallback(c._pending_connections.discard)])