홍길동 / onos

Go to a project
Toggle navigation Toggle navigation pinning
Brian O'Connor
8fc739af 1 parent bcfeadb2

Disabling anti-entropy messages to stabilize performance of intent store 

Change-Id: Ic66c6d710e6bc4bc82496c38a5b9955e58f72e73
Inline Side-by-side
Showing 1 changed file with 4 additions and 4 deletions
...@@ -46,7 +46,6 @@ import java.util.concurrent.CopyOnWriteArraySet; ...@@ -46,7 +46,6 @@ import java.util.concurrent.CopyOnWriteArraySet;
46 import java.util.concurrent.ExecutorService; 46 import java.util.concurrent.ExecutorService;
47 import java.util.concurrent.Executors; 47 import java.util.concurrent.Executors;
48 import java.util.concurrent.ScheduledExecutorService; 48 import java.util.concurrent.ScheduledExecutorService;
49 -import java.util.concurrent.TimeUnit;
50 import java.util.stream.Collectors; 49 import java.util.stream.Collectors;
51 50
52 import static com.google.common.base.Preconditions.checkNotNull; 51 import static com.google.common.base.Preconditions.checkNotNull;
...@@ -154,9 +153,10 @@ public class EventuallyConsistentMapImpl<K, V> ...@@ -154,9 +153,10 @@ public class EventuallyConsistentMapImpl<K, V>
154 groupedThreads("onos/ecm", mapName + "-bg-%d"))); 153 groupedThreads("onos/ecm", mapName + "-bg-%d")));
155 154
156 // start anti-entropy thread 155 // start anti-entropy thread
157 - backgroundExecutor.scheduleAtFixedRate(new SendAdvertisementTask(), 156 + //FIXME need to re-enable
158 - initialDelaySec, periodSec, 157 +// backgroundExecutor.scheduleAtFixedRate(new SendAdvertisementTask(),
159 - TimeUnit.SECONDS); 158 +// initialDelaySec, periodSec,
159 +// TimeUnit.SECONDS);
160 160
161 updateMessageSubject = new MessageSubject("ecm-" + mapName + "-update"); 161 updateMessageSubject = new MessageSubject("ecm-" + mapName + "-update");
162 clusterCommunicator.addSubscriber(updateMessageSubject, 162 clusterCommunicator.addSubscriber(updateMessageSubject,
......