Commit57f620d

committed

Copy dtmhost string on call to TuneToDtm.

1 parentda45ca5 commit57f620dCopy full SHA for 57f620d

File tree

+16

-7

lines changed

+16

-7

lines changed

Lines changed: 16 additions & 7 deletions

Original file line number	Diff line number	Diff line change
`@@ -231,11 +231,15 @@ static bool dtm_query(DTMConn dtm, char cmd, int argc, ...)`
`231`	`231`	`return true;`
`232`	`232`	`}`
`233`	`233`
`234`		`-staticchar*dtmhost="127.0.0.1";`
`235`		`-staticintdtmport=5431;`
	`234`	`+staticchar*dtmhost=NULL;`
	`235`	`+staticintdtmport=0;`
`236`	`236`
`237`	`237`	`voidTuneToDtm(char*host,intport) {`
`238`		`-dtmhost=host;`
	`238`	`+if (dtmhost) {`
	`239`	`+free(dtmhost);`
	`240`	`+dtmhost=NULL;`
	`241`	`+}`
	`242`	`+dtmhost=strdup(host);`
`239`	`243`	`dtmport=port;`
`240`	`244`	`}`
`241`	`245`
`@@ -244,10 +248,15 @@ static DTMConn GetConnection()`
`244`	`248`	`staticDTMConndtm=NULL;`
`245`	`249`	`if (dtm==NULL)`
`246`	`250`	`{`
`247`		`-dtm=DtmConnect(dtmhost,dtmport);`
`248`		`-if (dtm==NULL) {`
`249`		`-elog(ERROR,"Failed to connect to DTMD");`
`250`		`- }`
	`251`	`+if (dtmhost) {`
	`252`	`+dtm=DtmConnect(dtmhost,dtmport);`
	`253`	`+if (dtm==NULL)`
	`254`	`+{`
	`255`	`+elog(ERROR,"Failed to connect to DTMD %s:%d",dtmhost,dtmport);`
	`256`	`+}`
	`257`	`+}else {`
	`258`	`+elog(ERROR,"DTMD address not specified");`
	`259`	`+}`
`251`	`260`	`}`
`252`	`261`	`returndtm;`
`253`	`262`	`}`

Comments

(0)