Change rfatable bgworker start parameters

Author: knizhnik

contrib/mmts/tests2/test_recovery.py

@@ -27,10 +27,19 @@ def test_0_0_0(self):
 
         time.sleep(10)
         subprocess.check_call(['blockade','partition','node3'])
+        print('### blockade node3 ###')
 
         self.clients.set_acc_to_tx(10000)
         self.clients.start()
 
+        for i in range(10):
+            time.sleep(3)
+            self.clients.print_agg()
+            print("\n")
+
+        subprocess.check_call(['blockade','join'])
+        print('### deblockade node3 ###')
+
         for i in range(1000):
             time.sleep(3)
             self.clients.print_agg()

contrib/raftable/worker.c

@@ -488,7 +488,7 @@ void worker_register(WorkerConfig *cfg)
 	BackgroundWorker worker = {};
 	strcpy(worker.bgw_name, "raftable worker");
 	worker.bgw_flags = BGWORKER_SHMEM_ACCESS;
-	worker.bgw_start_time = BgWorkerStart_PostmasterStart;
+	worker.bgw_start_time = BgWorkerStart_ConsistentState;/*BgWorkerStart_PostmasterStart;*/
 	worker.bgw_restart_time = 1;
 	worker.bgw_main = worker_main;
 	worker.bgw_main_arg = PointerGetDatum(cfg);