|
|
@ -70,13 +70,13 @@ event_route[kazoo:consumer-event-nodes-advertise] |
|
|
{ |
|
|
{ |
|
|
$var(count) = $shtinc(nodes=>$(kzE{kz.json,Node})::count); |
|
|
$var(count) = $shtinc(nodes=>$(kzE{kz.json,Node})::count); |
|
|
if($var(count) == 0) { |
|
|
if($var(count) == 0) { |
|
|
xlog("L_WARNING", "$(kzE{kz.json,Msg-ID})|nodes|hearbeat for reconnected node $(kzE{kz.json,Node})\n"); |
|
|
|
|
|
|
|
|
xlog("L_WARNING", "$(kzE{kz.json,Msg-ID})|nodes|heartbeat for reconnected node $(kzE{kz.json,Node})\n"); |
|
|
$var(count) = $shtinc(nodes=>$(kzE{kz.json,Node})::count); |
|
|
$var(count) = $shtinc(nodes=>$(kzE{kz.json,Node})::count); |
|
|
} else { |
|
|
} else { |
|
|
if($var(count) == 1) { |
|
|
if($var(count) == 1) { |
|
|
xlog("L_WARNING", "$(kzE{kz.json,Msg-ID})|nodes|hearbeat from new node $(kzE{kz.json,Node})\n"); |
|
|
|
|
|
|
|
|
xlog("L_WARNING", "$(kzE{kz.json,Msg-ID})|nodes|heartbeat from new node $(kzE{kz.json,Node})\n"); |
|
|
} else { |
|
|
} else { |
|
|
xlog("L_DEBUG", "$(kzE{kz.json,Msg-ID})|nodes|hearbeat from existing node $(kzE{kz.json,Node})\n"); |
|
|
|
|
|
|
|
|
xlog("L_DEBUG", "$(kzE{kz.json,Msg-ID})|nodes|heartbeat from existing node $(kzE{kz.json,Node})\n"); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
mq_add("node_heartbeat", "$(kzE{kz.json,Node})", "$kzE"); |
|
|
mq_add("node_heartbeat", "$(kzE{kz.json,Node})", "$kzE"); |
|
|
@ -92,7 +92,7 @@ event_route[htable:expired:nodes] |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
xlog("L_WARNING", "htable|nodes|hearbeat expired for node $shtrecord(key)\n"); |
|
|
|
|
|
|
|
|
xlog("L_WARNING", "htable|nodes|heartbeat expired for node $shtrecord(key)\n"); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
route[NODE_TRACK_ROUTE] |
|
|
route[NODE_TRACK_ROUTE] |
|
|
@ -112,7 +112,7 @@ route[NODE_HEARTBEAT_ROUTE] |
|
|
while(mq_fetch("node_heartbeat") == 1 && $var(runloop) < MAX_WHILE_LOOPS) { |
|
|
while(mq_fetch("node_heartbeat") == 1 && $var(runloop) < MAX_WHILE_LOOPS) { |
|
|
$var(Node) = $mqk(node_heartbeat); |
|
|
$var(Node) = $mqk(node_heartbeat); |
|
|
$var(Payload) = $mqv(node_heartbeat); |
|
|
$var(Payload) = $mqv(node_heartbeat); |
|
|
xlog("L_DEBUG", "$(var(Payload){kz.json,Msg-ID})|nodes|processing hearbeat for node $var(Node)\n"); |
|
|
|
|
|
|
|
|
xlog("L_DEBUG", "$(var(Payload){kz.json,Msg-ID})|nodes|processing heartbeat for node $var(Node)\n"); |
|
|
|
|
|
|
|
|
route(CHECK_MEDIA_SERVERS); |
|
|
route(CHECK_MEDIA_SERVERS); |
|
|
|
|
|
|
|
|
@ -187,7 +187,7 @@ route[MEDIA_SERVER_UP] |
|
|
|
|
|
|
|
|
route[MEDIA_SERVER_DOWN] |
|
|
route[MEDIA_SERVER_DOWN] |
|
|
{ |
|
|
{ |
|
|
xlog("L_WARNING", "htable|media|hearbeat expired for media server $var(MediaUrl) in zone $var(Zone)\n"); |
|
|
|
|
|
|
|
|
xlog("L_WARNING", "htable|media|heartbeat expired for media server $var(MediaUrl) in zone $var(Zone)\n"); |
|
|
|
|
|
|
|
|
#!ifdef PRESENCE_ROLE |
|
|
#!ifdef PRESENCE_ROLE |
|
|
route(RESET_PUBLISHER); |
|
|
route(RESET_PUBLISHER); |
|
|
|