Skip to content

Commit

Permalink
fix hearbeat to heartbeat
Browse files Browse the repository at this point in the history
  • Loading branch information
jamesaimonetti authored and lazedo committed Apr 11, 2018
1 parent fb4e942 commit 72c9386
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions kamailio/nodes-role.cfg
Original file line number Diff line number Diff line change
Expand Up @@ -70,13 +70,13 @@ event_route[kazoo:consumer-event-nodes-advertise]
{
$var(count) = $shtinc(nodes=>$(kzE{kz.json,Node})::count);
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);
} else {
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 {
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");
Expand All @@ -92,7 +92,7 @@ event_route[htable:expired:nodes]
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]
Expand All @@ -112,7 +112,7 @@ route[NODE_HEARTBEAT_ROUTE]
while(mq_fetch("node_heartbeat") == 1 && $var(runloop) < MAX_WHILE_LOOPS) {
$var(Node) = $mqk(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);

Expand Down Expand Up @@ -187,7 +187,7 @@ route[MEDIA_SERVER_UP]

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
route(RESET_PUBLISHER);
Expand Down

0 comments on commit 72c9386

Please sign in to comment.