commit 035231e82ce1ce37bcfe6683b772e5b5faff1260
author Jordan Halterman <jordan@onlab.us> Tue Jul 18 08:39:07 2017 -0700
committer Ray Milkey <ray@opennetworking.org> Thu Jul 20 19:04:15 2017 +0000
tree 68e44e9da4741aa6fd9f4152cb321aaffba8b4d3
parent 3548bb24db0fe0f87f4b88caa67c25ac47910bd9

Upgrade to Atomix 2.0.0-raft-beta1

Change-Id: I9f3345eb0107ee0079fec8980542678ee9d6f01f

core/store/primitives/src/test/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorServiceTest.java

diff --git a/core/store/primitives/src/test/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorServiceTest.java b/core/store/primitives/src/test/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorServiceTest.java
index d3b6343..f640a81 100644
--- a/core/store/primitives/src/test/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorServiceTest.java
+++ b/core/store/primitives/src/test/java/org/onosproject/store/primitives/resources/impl/AtomixLeaderElectorServiceTest.java
@@ -15,9 +15,11 @@
  */
 package org.onosproject.store.primitives.resources.impl;
 
+import java.util.concurrent.ScheduledExecutorService;
+
 import io.atomix.protocols.raft.ReadConsistency;
 import io.atomix.protocols.raft.cluster.MemberId;
-import io.atomix.protocols.raft.impl.RaftServerContext;
+import io.atomix.protocols.raft.impl.RaftContext;
 import io.atomix.protocols.raft.protocol.RaftServerProtocol;
 import io.atomix.protocols.raft.service.ServiceId;
 import io.atomix.protocols.raft.service.ServiceType;
@@ -64,7 +66,7 @@
         expect(context.serviceId()).andReturn(ServiceId.from(1)).anyTimes();
         expect(context.executor()).andReturn(mock(ThreadContext.class)).anyTimes();
 
-        RaftServerContext server = mock(RaftServerContext.class);
+        RaftContext server = mock(RaftContext.class);
         expect(server.getProtocol()).andReturn(mock(RaftServerProtocol.class));
 
         replay(context, server);
@@ -85,7 +87,8 @@
                         ReadConsistency.LINEARIZABLE,
                         5000,
                         context,
-                        server),
+                        server,
+                        mock(ScheduledExecutorService.class)),
                 System.currentTimeMillis()));
 
         try (SnapshotWriter writer = snapshot.openWriter()) {