Commit6fae8cd

committed

add mtm.poll_node function

1 parentc9e0dd8 commit6fae8cdCopy full SHA for 6fae8cd

File tree

+29

-2

lines changed

+29

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -1,2 +1,2 @@`
`1`		`-rm -rf /home/knizhnik/postgres_cluster/contrib/mmts/tmp_check/log`
	`1`	`+rm -rf /home/knizhnik/postgres_cluster/contrib/mmts/tmp_check`
`2`	`2`	`TESTDIR='/home/knizhnik/postgres_cluster/contrib/mmts' PATH="/home/knizhnik/postgres_cluster/tmp_install/home/knizhnik/postgres_cluster/dist/bin:$PATH" LD_LIBRARY_PATH="/home/knizhnik/postgres_cluster/tmp_install/home/knizhnik/postgres_cluster/dist/lib:$LD_LIBRARY_PATH" PGPORT='65432' PG_REGRESS='/home/knizhnik/postgres_cluster/contrib/mmts/../../src/test/regress/pg_regress' prove -I ../../src/test/perl/ --verbose t/001_basic_recovery.pl`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -44,6 +44,10 @@ CREATE FUNCTION mtm.dump_lock_graph() RETURNS text`
`44`	`44`	`AS'MODULE_PATHNAME','mtm_dump_lock_graph'`
`45`	`45`	`LANGUAGE C;`
`46`	`46`
	`47`	`+CREATEFUNCTIONmtm.poll_node(nodeIdinteger, noWaitboolean default FALSE) RETURNSboolean`
	`48`	`+AS'MODULE_PATHNAME','mtm_poll_node'`
	`49`	`+LANGUAGE C;`
	`50`	`+`
`47`	`51`	`CREATETABLEIF NOT EXISTSmtm.ddl_log (issuedtimestamp with time zonenot null, querytext);`
`48`	`52`
`49`	`53`	`CREATETABLEIF NOT EXISTSmtm.local_tables(rel_schematext, rel_nametext,primary key(rel_schema, rel_name));`

Lines changed: 22 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -103,6 +103,7 @@ PG_MODULE_MAGIC;`
`103`	`103`	`PG_FUNCTION_INFO_V1(mtm_start_replication);`
`104`	`104`	`PG_FUNCTION_INFO_V1(mtm_stop_replication);`
`105`	`105`	`PG_FUNCTION_INFO_V1(mtm_drop_node);`
	`106`	`+PG_FUNCTION_INFO_V1(mtm_poll_node);`
`106`	`107`	`PG_FUNCTION_INFO_V1(mtm_recover_node);`
`107`	`108`	`PG_FUNCTION_INFO_V1(mtm_get_snapshot);`
`108`	`109`	`PG_FUNCTION_INFO_V1(mtm_get_nodes_state);`
`@@ -2069,6 +2070,27 @@ mtm_drop_node(PG_FUNCTION_ARGS)`
`2069`	`2070`	`PG_RETURN_VOID();`
`2070`	`2071`	`}`
`2071`	`2072`
	`2073`	`+Datum`
	`2074`	`+mtm_poll_node(PG_FUNCTION_ARGS)`
	`2075`	`+{`
	`2076`	`+intnodeId=PG_GETARG_INT32(0);`
	`2077`	`+boolnowait=PG_GETARG_BOOL(1);`
	`2078`	`+boolonline= true;`
	`2079`	`+while (BIT_CHECK(Mtm->disabledNodeMask,nodeId-1)) {`
	`2080`	`+if (nowait) {`
	`2081`	`+online= false;`
	`2082`	`+break;`
	`2083`	`+}else {`
	`2084`	`+MtmSleep(STATUS_POLL_DELAY);`
	`2085`	`+}`
	`2086`	`+}`
	`2087`	`+if (!nowait) {`
	`2088`	`+/* Just wait some time until logical repication channels will be reestablished */`
	`2089`	`+MtmSleep(MtmNodeDisableDelay);`
	`2090`	`+}`
	`2091`	`+PG_RETURN_BOOL(online);`
	`2092`	`+}`
	`2093`	`+`
`2072`	`2094`	`Datum`
`2073`	`2095`	`mtm_recover_node(PG_FUNCTION_ARGS)`
`2074`	`2096`	`{`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,8 @@`
`60`	`60`	`diag("starting node 2");`
`61`	`61`	`$cluster->{nodes}->[2]->start;`
`62`	`62`	`diag("sleeping 10");`
`63`		`-sleep(10);# XXX: here we can poll`
	`63`	`+#sleep(10); # XXX: here we can poll`
	`64`	`+$cluster->psql(0,'postgres',"select mtm.poll_node(3);");`
`64`	`65`	`diag("inserting 3");`
`65`	`66`	`$cluster->psql(0,'postgres',"insert into t values(3, 30);");`
`66`	`67`	`diag("selecting");`

Comments

(0)