[Groonga-commit] pgroonga/pgroonga at e351d46 [master] Support logical replication

Back to archive index

Kouhei Sutou null+****@clear*****
Tue Jul 18 23:08:11 JST 2017


Kouhei Sutou	2017-07-18 23:08:11 +0900 (Tue, 18 Jul 2017)

  New Revision: e351d466027d9509c6868a6e2e42ec4015066659
  https://github.com/pgroonga/pgroonga/commit/e351d466027d9509c6868a6e2e42ec4015066659

  Message:
    Support logical replication

  Modified files:
    src/pgrn-compatible.h
    src/pgroonga.c

  Modified: src/pgrn-compatible.h (+1 -0)
===================================================================
--- src/pgrn-compatible.h    2017-07-18 22:46:11 +0900 (1f46eed)
+++ src/pgrn-compatible.h    2017-07-18 23:08:11 +0900 (5a72d12)
@@ -157,4 +157,5 @@
 #	define PGRN_INDEX_AM_ROUTINE_HAVE_AM_ESTIMATE_PARALLEL_SCAN
 #	define PGRN_INDEX_AM_ROUTINE_HAVE_AM_INIT_PARALLEL_SCAN
 #	define PGRN_INDEX_AM_ROUTINE_HAVE_AM_PARALLEL_RESCAN
+#	define PGRN_SUPPORT_LOGICAL_REPLICATION
 #endif

  Modified: src/pgroonga.c (+4 -1)
===================================================================
--- src/pgroonga.c    2017-07-18 22:46:11 +0900 (4c9e83c)
+++ src/pgroonga.c    2017-07-18 23:08:11 +0900 (fb6e81f)
@@ -40,6 +40,9 @@
 #include <optimizer/clauses.h>
 #include <optimizer/cost.h>
 #include <postmaster/bgworker.h>
+#ifdef PGRN_SUPPORT_LOGICAL_REPLICATION
+#	include <replication/worker_internal.h>
+#endif
 #include <storage/bufmgr.h>
 #include <storage/ipc.h>
 #include <utils/array.h>
@@ -437,7 +440,7 @@ PGrnInitializePrefixRKSequentialSearchData(void)
 void
 _PG_init(void)
 {
-	if (MyBgworkerEntry)
+	if (MyBgworkerEntry && !MyLogicalRepWorker)
 		return;
 
 	if (PGrnInitialized)
-------------- next part --------------
HTML����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index