Home
last modified time | relevance | path

Searched refs:on_node_down (Results 1 – 14 of 14) sorted by relevance

/dports/devel/py-celery/celery-4.4.7/celery/apps/
H A Dmulti.py366 on_node_down=None, argument
385 self.on_node_down = on_node_down
408 for node in self.getpids(on_down=self.on_node_down):
434 on_down = on_down if on_down is not None else self.on_node_down
/dports/databases/p5-Net-Async-CassandraCQL/Net-Async-CassandraCQL-0.11/examples/
H A Dcassandra-watch37 on_node_down => sub {
/dports/devel/py-celery/celery-4.4.7/celery/bin/
H A Dmulti.py390 on_node_down=self.on_node_down,
429 def on_node_down(self, node): member in MultiTool
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Drabbit_alarm.erl24 …, get_alarms/0, get_alarms/1, get_local_alarms/0, get_local_alarms/1, on_node_up/1, on_node_down/1,
157 -spec on_node_down(node()) -> 'ok'.
158 on_node_down(Node) -> gen_event:notify(?SERVER, {node_down, Node}). function
H A Drabbit_node_monitor.erl782 ok = rabbit_networking:on_node_down(Node),
783 ok = rabbit_amqqueue:on_node_down(Node),
784 ok = rabbit_alarm:on_node_down(Node),
785 ok = rabbit_mnesia:on_node_down(Node),
H A Drabbit_networking.erl24 stop_tcp_listener/1, on_node_down/1, active_listeners/0,
394 -spec on_node_down(node()) -> 'ok'.
396 on_node_down(Node) -> function
H A Drabbit_mnesia.erl39 on_node_down/1,
762 -spec on_node_down(node()) -> 'ok'.
764 on_node_down(_Node) -> function
H A Drabbit_amqqueue.erl35 -export([on_node_up/1, on_node_down/1]).
1918 -spec on_node_down(node()) -> 'ok'.
1920 on_node_down(Node) -> function
H A Drabbit_vhost.erl35 rabbit_amqqueue:on_node_down(node()),
/dports/databases/p5-Net-Async-CassandraCQL/Net-Async-CassandraCQL-0.11/t/
H A D24clustering-events.t51 on_node_down => sub { ( undef, $nodeid ) = @_; },
/dports/devel/py-celery/celery-4.4.7/t/unit/bin/
H A Dtest_multi.py230 assert c.on_node_down == m.on_node_down
263 self.t.on_node_down(Mock())
/dports/devel/py-celery/celery-4.4.7/t/unit/apps/
H A Dtest_multi.py336 on_node_down=Mock(name='on_node_down'),
/dports/databases/p5-Net-Async-CassandraCQL/Net-Async-CassandraCQL-0.11/lib/Net/Async/
H A DCassandraCQL.pm593 $self->maybe_invoke_event( on_node_down => $nodeid );
/dports/databases/p5-Net-Async-CassandraCQL/Net-Async-CassandraCQL-0.11/
H A DREADME48 on_node_down $nodeid