Commitc53a67c

authored and

committed

Establish connection with database in arbiter

1 parent4b3a499 commitc53a67cCopy full SHA for c53a67c

File tree

+13

-0

lines changed

+13

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -668,6 +668,13 @@ static void MtmTransSender(Datum arg)`
`668`	`668`	`sigfillset(&sset);`
`669`	`669`	`sigprocmask(SIG_UNBLOCK,&sset,NULL);`
`670`	`670`
	`671`	`+/* We're now ready to receive signals */`
	`672`	`+BackgroundWorkerUnblockSignals();`
	`673`	`+`
	`674`	`+/* Connect to a database */`
	`675`	`+BackgroundWorkerInitializeConnection(MtmDatabaseName,NULL);`
	`676`	`+`
	`677`	`+`
`671`	`678`	`heartbeat_timer=RegisterTimeout(USER_TIMEOUT,MtmScheduleHeartbeat);`
`672`	`679`	`enable_timeout_after(heartbeat_timer,MtmHeartbeatSendTimeout);`
`673`	`680`
`@@ -755,6 +762,12 @@ static void MtmTransReceiver(Datum arg)`
`755`	`762`	`sigfillset(&sset);`
`756`	`763`	`sigprocmask(SIG_UNBLOCK,&sset,NULL);`
`757`	`764`
	`765`	`+/* We're now ready to receive signals */`
	`766`	`+BackgroundWorkerUnblockSignals();`
	`767`	`+`
	`768`	`+/* Connect to a database */`
	`769`	`+BackgroundWorkerInitializeConnection(MtmDatabaseName,NULL);`
	`770`	`+`
`758`	`771`	`MtmAcceptIncomingConnections();`
`759`	`772`
`760`	`773`	`for (i=0;i<nNodes;i++) {`

Comments

(0)