Commite2424b9

authored and

committed

Create fake portal

1 parentf2afd06 commite2424b9Copy full SHA for e2424b9

File tree

+15

-5

lines changed

+15

-5

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -20,12 +20,13 @@ static void BgwPoolMainLoop(BgwPool* pool)`
`20`	`20`	`{`
`21`	`21`	`intsize;`
`22`	`22`	`void*work;`
	`23`	`+staticPortalDatafakePortal;`
`23`	`24`
`24`	`25`	`MtmIsLogicalReceiver= true;`
`25`	`26`
`26`	`27`	`BackgroundWorkerUnblockSignals();`
`27`	`28`	`BackgroundWorkerInitializeConnection(pool->dbname,pool->dbuser);`
`28`		`-ActivePortal=CreatePortal("", true, true);`
	`29`	`+ActivePortal=&fakePortal;`
`29`	`30`	`ActivePortal->status=PORTAL_ACTIVE;`
`30`	`31`	`ActivePortal->sourceText="";`
`31`	`32`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -288,6 +288,7 @@ extern int MtmReplicationNodeId;`
`288`	`288`	`externintMtmNodes;`
`289`	`289`	`externintMtmArbiterPort;`
`290`	`290`	`externchar*MtmDatabaseName;`
	`291`	`+externchar*MtmDatabaseUser;`
`291`	`292`	`externintMtmConnectTimeout;`
`292`	`293`	`externintMtmReconnectTimeout;`
`293`	`294`	`externintMtmRaftPollDelay;`

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -371,7 +371,8 @@ process_remote_transactional_message(StringInfo s)`
`371`	`371`	`}`
`372`	`372`
`373`	`373`	`MTM_LOG1("%d: Executing utility statement %s",MyProcPid,stmt);`
`374`		`-SPI_connect();`
	`374`	`+SPI_connect();`
	`375`	`+ActivePortal->sourceText=stmt;`
`375`	`376`	`rc=SPI_execute(stmt, false,0);`
`376`	`377`	`SPI_finish();`
`377`	`378`	`if (rc<0)`
`@@ -971,8 +972,8 @@ void MtmExecutor(void* work, size_t size)`
`971`	`972`	`StringInfoDatas;`
`972`	`973`	`Relationrel=NULL;`
`973`	`974`	`intspill_file=-1;`
`974`		`-intsave_cursor;`
`975`		`-intsave_len;`
	`975`	`+intsave_cursor=0;`
	`976`	`+intsave_len=0;`
`976`	`977`	`s.data=work;`
`977`	`978`	`s.len=size;`
`978`	`979`	`s.maxlen=-1;`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -35,6 +35,8 @@`
`35`	`35`	`#include"utils/memutils.h"`
`36`	`36`	`#include"executor/spi.h"`
`37`	`37`	`#include"replication/origin.h"`
	`38`	`+#include"utils/portal.h"`
	`39`	`+#include"tcop/pquery.h"`
`38`	`40`
`39`	`41`	`#include"multimaster.h"`
`40`	`42`	`#include"spill.h"`
`@@ -218,6 +220,8 @@ pglogical_receiver_main(Datum main_arg)`
`218`	`220`	`StringInfoDataspill_info;`
`219`	`221`	`char*slotName;`
`220`	`222`	`char*connString=psprintf("replication=database %s",Mtm->nodes[nodeId-1].con.connStr);`
	`223`	`+staticPortalDatafakePortal;`
	`224`	`+`
`221`	`225`	`slotName=psprintf(MULTIMASTER_SLOT_PATTERN,MtmNodeId);`
`222`	`226`
`223`	`227`	`MtmIsLogicalReceiver= true;`
`@@ -239,7 +243,10 @@ pglogical_receiver_main(Datum main_arg)`
`239`	`243`	`BackgroundWorkerUnblockSignals();`
`240`	`244`
`241`	`245`	`/* Connect to a database */`
`242`		`-BackgroundWorkerInitializeConnection(MtmDatabaseName,NULL);`
	`246`	`+BackgroundWorkerInitializeConnection(MtmDatabaseName,MtmDatabaseUser);`
	`247`	`+ActivePortal=&fakePortal;`
	`248`	`+ActivePortal->status=PORTAL_ACTIVE;`
	`249`	`+ActivePortal->sourceText="";`
`243`	`250`
`244`	`251`	`/* This is main loop of logical replication.`
`245`	`252`	`* In case of errors we will try to reestablish connection.`

Comments

(0)