Commitfe853ca

committed

Add DtmdHost and DtmdPort variables

1 parentd6d7bba commitfe853caCopy full SHA for fe853ca

File tree

+43

-3

lines changed

+43

-3

lines changed

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -24,6 +24,10 @@ typedef struct DTMConnData`
`24`	`24`
`25`	`25`	`typedefunsigned long longxid_t;`
`26`	`26`
	`27`	`+intDtmdPort;`
	`28`	`+char*DtmdHost;`
	`29`	`+`
	`30`	`+`
`27`	`31`	`// Returns true if the write was successful.`
`28`	`32`	`staticbooldtm_write_char(DTMConndtm,charc)`
`29`	`33`	`{`
`@@ -237,7 +241,7 @@ static DTMConn GetConnection()`
`237`	`241`	`if (dtm==NULL)`
`238`	`242`	`{`
`239`	`243`	`// FIXME: add API for setting the host and port for dtm connection`
`240`		`-dtm=DtmConnect("127.0.0.1",5431);`
	`244`	`+dtm=DtmConnect(DtmdHost,DtmdPort);`
`241`	`245`	`if (dtm==NULL) {`
`242`	`246`	`elog(ERROR,"Failed to connect to DTMD");`
`243`	`247`	`}`

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,9 @@`
`8`	`8`
`9`	`9`	`#defineINVALID_XID 0`
`10`	`10`
	`11`	`+externintDtmdPort;`
	`12`	`+externchar*DtmdHost;`
	`13`	`+`
`11`	`14`	`voidDtmInitSnapshot(Snapshotsnapshot);`
`12`	`15`
`13`	`16`	`// Starts a new global transaction. Returns the`

Lines changed: 27 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -713,6 +713,33 @@ _PG_init(void)`
`713`	`713`	`NULL`
`714`	`714`	`);`
`715`	`715`
	`716`	`+DefineCustomIntVariable(`
	`717`	`+"dtm.dtmd_port",`
	`718`	`+"DTMD port",`
	`719`	`+NULL,`
	`720`	`+&DtmdPort,`
	`721`	`+5431,`
	`722`	`+1,`
	`723`	`+INT_MAX,`
	`724`	`+PGC_BACKEND,`
	`725`	`+0,`
	`726`	`+NULL,`
	`727`	`+NULL,`
	`728`	`+NULL`
	`729`	`+);`
	`730`	`+`
	`731`	`+DefineCustomStringVariable(`
	`732`	`+"dtm.dtmd_host",`
	`733`	`+"DTMD host name",`
	`734`	`+NULL,`
	`735`	`+&DtmdHost,`
	`736`	`+"localhost",`
	`737`	`+PGC_BACKEND,`
	`738`	`+0,`
	`739`	`+NULL,`
	`740`	`+NULL,`
	`741`	`+NULL);`
	`742`	`+`
`716`	`743`	`/*`
`717`	`744`	`* Install hooks.`
`718`	`745`	`*/`

Lines changed: 8 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -1464,6 +1464,12 @@ HeapTupleIsSurelyDead(HeapTuple htup, TransactionId OldestXmin)`
`1464`	`1464`	`returnTransactionIdPrecedes(HeapTupleHeaderGetRawXmax(tuple),OldestXmin);`
`1465`	`1465`	`}`
`1466`	`1466`
	`1467`	`+bool`
	`1468`	`+XidInMVCCSnapshot(TransactionIdxid,Snapshotsnapshot)`
	`1469`	`+{`
	`1470`	`+returnTM->IsInSnapshot(xid,snapshot);`
	`1471`	`+}`
	`1472`	`+`
`1467`	`1473`	`/*`
`1468`	`1474`	`* XidInMVCCSnapshot`
`1469`	`1475`	`*Is the given XID still-in-progress according to the snapshot?`
`@@ -1474,8 +1480,8 @@ HeapTupleIsSurelyDead(HeapTuple htup, TransactionId OldestXmin)`
`1474`	`1480`	`* TransactionIdIsCurrentTransactionId first, except for known-committed`
`1475`	`1481`	`* XIDs which could not be ours anyway.`
`1476`	`1482`	`*/`
`1477`		`-staticbool`
`1478`		`-XidInMVCCSnapshot(TransactionIdxid,Snapshotsnapshot)`
	`1483`	`+bool`
	`1484`	`+PgXidInMVCCSnapshot(TransactionIdxid,Snapshotsnapshot)`
`1479`	`1485`	`{`
`1480`	`1486`	`uint32i;`
`1481`	`1487`

Comments

(0)