From e639ade004584a19b93101bdf6692aa48b1200d0 Mon Sep 17 00:00:00 2001
From: noah <noah@theschricks.com>
Date: Tue, 8 Feb 2022 18:02:32 -0600
Subject: [PATCH] Adjusting syncing and buffering

---
 src/ag_gen/ag_gen.cpp | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/ag_gen/ag_gen.cpp b/src/ag_gen/ag_gen.cpp
index 4041873..3654b98 100755
--- a/src/ag_gen/ag_gen.cpp
+++ b/src/ag_gen/ag_gen.cpp
@@ -1281,11 +1281,6 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
         }
 
         if (world.rank() > 1){
-            //Start Fresh each iteration
-	        localFrontier.clear();
-            std::vector<Factbase>().swap(instance.factbases);       
-            std::vector<Edge>().swap(instance.edges);
-            std::vector<FactbaseItems>().swap(instance.factbase_items);
 
             //Check for finished signal
             if(world.iprobe(0, 99)){
@@ -1295,6 +1290,12 @@ AGGenInstance &AGGen::sg_generate(bool batch_process, int batch_num, int numThrd
 
             //We get a new state and need to do work
             if (world.iprobe(0, 1)){
+                //Start Fresh each iteration
+                localFrontier.clear();
+                std::vector<Factbase>().swap(instance.factbases);       
+                std::vector<Edge>().swap(instance.edges);
+                std::vector<FactbaseItems>().swap(instance.factbase_items);
+                
                 NetworkState current_state;
                 world.recv(0, 1, current_state);
                 state_count = 0;