| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | ctx.cpp | 80 _reaper (NULL), in ctx_t()
131 LIBZMQ_DELETE (_reaper); in ~ctx_t()
203 _reaper->stop (); in terminate()
251 _reaper->stop (); in shutdown()
431 if (!_reaper) { in start()
438 _reaper->start (); in start()
469 _reaper->stop (); in start()
470 delete _reaper; in start()
471 _reaper = NULL; in start()
534 _reaper->stop (); in destroy_socket()
[all …]
|
| H A D | ctx.hpp | 200 zmq::reaper_t *_reaper; member in zmq::ZMQ_FINAL
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | ctx.cpp | 80 _reaper (NULL), in ctx_t()
131 LIBZMQ_DELETE (_reaper); in ~ctx_t()
203 _reaper->stop (); in terminate()
251 _reaper->stop (); in shutdown()
431 if (!_reaper) { in start()
438 _reaper->start (); in start()
469 _reaper->stop (); in start()
470 delete _reaper; in start()
471 _reaper = NULL; in start()
534 _reaper->stop (); in destroy_socket()
[all …]
|
| H A D | ctx.hpp | 200 zmq::reaper_t *_reaper; member in zmq::ZMQ_FINAL
|
| /dports/devel/ice37/ice-3.7.2/cpp/src/IceGrid/ |
| H A D | ReapThread.cpp | 18 CloseCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in CloseCallbackI()
25 _reaper->connectionClosed(con); in closed()
30 const ReapThreadPtr _reaper; member in __anon684c89d80111::CloseCallbackI
37 HeartbeatCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in HeartbeatCallbackI()
44 _reaper->connectionHeartbeat(con); in heartbeat()
49 const ReapThreadPtr _reaper; member in __anon684c89d80111::HeartbeatCallbackI
|
| H A D | RegistryI.cpp | 395 _reaper = new ReapThread(); in startImpl()
396 _reaper->start(); in startImpl()
735 assert(_reaper); in setupInternalRegistry()
807 assert(_reaper); in setupClientSessionFactory()
858 assert(_reaper); in setupAdminSessionFactory()
924 if(_reaper) in stop()
926 _reaper->terminate(); in stop()
927 _reaper->getThreadControl().join(); in stop()
928 _reaper = 0; in stop()
1004 assert(_reaper && _adminSessionFactory); in createAdminSession()
[all …]
|
| H A D | InternalRegistryI.cpp | 31 _reaper(reaper), in InternalRegistryI()
106 _reaper->add(new SessionReapable<NodeSessionI>(logger, session), _nodeSessionTimeout); in registerNode()
173 _reaper->add(new SessionReapable<ReplicaSessionI>(logger, s), _replicaSessionTimeout); in registerReplica()
|
| H A D | InternalRegistryI.h | 64 const ReapThreadPtr _reaper; variable
|
| H A D | SessionI.cpp | 294 _reaper(reaper), in ClientSessionFactory()
340 …_reaper->add(new SessionReapable<SessionI>(_database->getTraceLevels()->logger, session), timeout); in createGlacier2Session()
|
| H A D | RegistryI.h | 114 ReapThreadPtr _reaper; variable
|
| /dports/devel/php-ice37/ice-3.7.2/cpp/src/IceGrid/ |
| H A D | ReapThread.cpp | 18 CloseCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in CloseCallbackI()
25 _reaper->connectionClosed(con); in closed()
30 const ReapThreadPtr _reaper; member in __anon1f78b68d0111::CloseCallbackI
37 HeartbeatCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in HeartbeatCallbackI()
44 _reaper->connectionHeartbeat(con); in heartbeat()
49 const ReapThreadPtr _reaper; member in __anon1f78b68d0111::HeartbeatCallbackI
|
| H A D | RegistryI.cpp | 395 _reaper = new ReapThread();
396 _reaper->start();
735 assert(_reaper);
807 assert(_reaper);
858 assert(_reaper);
924 if(_reaper)
926 _reaper->terminate();
927 _reaper->getThreadControl().join();
928 _reaper = 0;
1004 assert(_reaper && _adminSessionFactory);
[all …]
|
| H A D | InternalRegistryI.cpp | 31 _reaper(reaper), in InternalRegistryI()
106 _reaper->add(new SessionReapable<NodeSessionI>(logger, session), _nodeSessionTimeout); in registerNode()
173 _reaper->add(new SessionReapable<ReplicaSessionI>(logger, s), _replicaSessionTimeout); in registerReplica()
|
| H A D | InternalRegistryI.h | 64 const ReapThreadPtr _reaper; variable
|
| H A D | SessionI.cpp | 294 _reaper(reaper), in ClientSessionFactory()
340 …_reaper->add(new SessionReapable<SessionI>(_database->getTraceLevels()->logger, session), timeout); in createGlacier2Session()
|
| H A D | RegistryI.h | 114 ReapThreadPtr _reaper;
|
| /dports/devel/py-ice37/ice-3.7.2/cpp/src/IceGrid/ |
| H A D | ReapThread.cpp | 18 CloseCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in CloseCallbackI()
25 _reaper->connectionClosed(con); in closed()
30 const ReapThreadPtr _reaper; member in __anon3ade7bee0111::CloseCallbackI
37 HeartbeatCallbackI(const ReapThreadPtr& reaper) : _reaper(reaper) in HeartbeatCallbackI()
44 _reaper->connectionHeartbeat(con); in heartbeat()
49 const ReapThreadPtr _reaper; member in __anon3ade7bee0111::HeartbeatCallbackI
|
| H A D | RegistryI.cpp | 395 _reaper = new ReapThread(); in startImpl()
396 _reaper->start(); in startImpl()
735 assert(_reaper); in setupInternalRegistry()
807 assert(_reaper); in setupClientSessionFactory()
858 assert(_reaper); in setupAdminSessionFactory()
924 if(_reaper) in stop()
926 _reaper->terminate(); in stop()
927 _reaper->getThreadControl().join(); in stop()
928 _reaper = 0; in stop()
1004 assert(_reaper && _adminSessionFactory); in createAdminSession()
[all …]
|
| H A D | InternalRegistryI.cpp | 31 _reaper(reaper), in InternalRegistryI()
106 _reaper->add(new SessionReapable<NodeSessionI>(logger, session), _nodeSessionTimeout); in registerNode()
173 _reaper->add(new SessionReapable<ReplicaSessionI>(logger, s), _replicaSessionTimeout); in registerReplica()
|
| H A D | InternalRegistryI.h | 64 const ReapThreadPtr _reaper; variable
|
| H A D | SessionI.cpp | 294 _reaper(reaper), in ClientSessionFactory()
340 …_reaper->add(new SessionReapable<SessionI>(_database->getTraceLevels()->logger, session), timeout); in createGlacier2Session()
|
| H A D | RegistryI.h | 114 ReapThreadPtr _reaper; variable
|
| /dports/math/vtk6/VTK-6.2.0/Web/Python/vtk/web/ |
| H A D | wamp.py | 135 self._reaper = reactor.callLater(self._timeout, lambda: reactor.stop())
142 if self._reaper:
144 self._reaper.cancel()
145 self._reaper = None
154 if self._connection_count == 0 and not self._reaper:
156 self._reaper = reactor.callLater(self._timeout, lambda: reactor.stop())
|
| /dports/devel/p5-AnyMQ/AnyMQ-0.35/lib/AnyMQ/ |
| H A D | Queue.pm | 68 $self->{timer} = $self->_reaper;
73 sub _reaper { subroutine
127 $self->{timer} = $self->_reaper;
|
| /dports/audio/p5-Music-Audioscrobbler-MPD/Music-Audioscrobbler-MPD-0.13/lib/Music/Audioscrobbler/ |
| H A D | MPD.pm | 221 $self->_reaper();
830 sub _reaper { subroutine
|