Commit14941de

authored and

committed

Add check that hearbeats are sent

1 parent308dc9b commit14941deCopy full SHA for 14941de

File tree

+10

-6

lines changed

+10

-6

lines changed

Lines changed: 10 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -102,11 +102,12 @@ typedef struct`
`102`	`102`	`MtmArbiterMessage*data;`
`103`	`103`	`}MtmBuffer;`
`104`	`104`
`105`		`-staticint*sockets;`
`106`		`-staticintgateway;`
`107`		`-staticboolsend_heartbeat;`
`108`		`-staticTimeoutIdheartbeat_timer;`
`109`		`-staticintbusy_socket;`
	`105`	`+staticint*sockets;`
	`106`	`+staticintgateway;`
	`107`	`+staticboolsend_heartbeat;`
	`108`	`+statictimestamp_tlast_sent_hearbeat;`
	`109`	`+staticTimeoutIdheartbeat_timer;`
	`110`	`+staticintbusy_socket;`
`110`	`111`
`111`	`112`	`staticvoidMtmTransSender(Datumarg);`
`112`	`113`	`staticvoidMtmTransReceiver(Datumarg);`
`@@ -326,6 +327,8 @@ static void MtmSetSocketOptions(int sd)`
`326`	`327`
`327`	`328`	`staticvoidMtmScheduleHeartbeat()`
`328`	`329`	`{`
	`330`	`+Assert(!last_sent_hearbeat\|\|last_sent_hearbeat+MSEC_TO_USEC(MtmHeartbeatRecvTimeout) >=MtmGetSystemTime());`
	`331`	`+enable_timeout_after(heartbeat_timer,MtmHeartbeatSendTimeout);`
`329`	`332`	`send_heartbeat= true;`
`330`	`333`	`PGSemaphoreUnlock(&Mtm->votingSemaphore);`
`331`	`334`	`}`
`@@ -338,7 +341,8 @@ static void MtmSendHeartbeat()`
`338`	`341`	`msg.disabledNodeMask=Mtm->disabledNodeMask;`
`339`	`342`	`msg.oldestSnapshot=Mtm->nodes[MtmNodeId-1].oldestSnapshot;`
`340`	`343`	`msg.node=MtmNodeId;`
`341`		`-`
	`344`	`+last_sent_hearbeat=MtmGetSystemTime();`
	`345`	`+`
`342`	`346`	`for (i=0;i<Mtm->nAllNodes;i++)`
`343`	`347`	`{`
`344`	`348`	`if (sockets[i] >=0&&sockets[i]!=busy_socket&& !BIT_CHECK(Mtm->disabledNodeMask\|Mtm->reconnectMask,i))`

Comments

(0)