@Test public void testUpdateReplicaSessionManager() { String storage1 = "fakehost:6000"; String storage2 = "fakehost:6001"; int[] oldPartitions1 = {}; int[] oldPartitions2 = {0}; int[] newPartitions1 = {1}; int[] newPartitions2 = {0, 1}; Map<String, int[]> oldReplicas = new HashMap<>(); oldReplicas.put(storage1, oldPartitions1); oldReplicas.put(storage2, oldPartitions2); ReplicaAssignments oldAssignments = new ReplicaAssignments(oldReplicas); Map<String, int[]> newReplicas = new HashMap<>(); newReplicas.put(storage1, newPartitions1); newReplicas.put(storage2, newPartitions2); ReplicaAssignments newAssignments = new ReplicaAssignments(newReplicas); NodeData<ReplicaAssignments> nodeData = new NodeData<>(newAssignments, Mockito.mock(Stat.class)); ConnectionConfig config = Mockito.mock(ConnectionConfig.class); ReplicaSessionManager manager = new ReplicaSessionManager(oldAssignments, config); Assert.assertEquals(1, manager.getReplicaIds().size()); Assert.assertEquals(1, manager.getConnectionFactories().size()); manager.updateReplicaSessionManager(nodeData); Assert.assertEquals(3, manager.getReplicaIds().size()); Assert.assertEquals(2, manager.getConnectionFactories().size()); }
public void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData) { synchronized (this) { close(); replicaIds = createReplicaIds(nodeData.value); connectionFactories = createConnectionFactories(); } }
ReplicaSessionManager { public void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData) { synchronized (this) { close(); replicaIds = createReplicaIds(nodeData.value); connectionFactories = createConnectionFactories(); } } }
ReplicaSessionManager { public void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData) { synchronized (this) { close(); replicaIds = createReplicaIds(nodeData.value); connectionFactories = createConnectionFactories(); } } ReplicaSessionManager(ReplicaAssignments assignments, ConnectionConfig config); }
ReplicaSessionManager { public void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData) { synchronized (this) { close(); replicaIds = createReplicaIds(nodeData.value); connectionFactories = createConnectionFactories(); } } ReplicaSessionManager(ReplicaAssignments assignments, ConnectionConfig config); void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData); void close(); Set<ReplicaId> getReplicaIds(); Map<String, ReplicaConnectionFactory> getConnectionFactories(); ConnectionConfig getConnectionConfig(); }
ReplicaSessionManager { public void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData) { synchronized (this) { close(); replicaIds = createReplicaIds(nodeData.value); connectionFactories = createConnectionFactories(); } } ReplicaSessionManager(ReplicaAssignments assignments, ConnectionConfig config); void updateReplicaSessionManager(NodeData<ReplicaAssignments> nodeData); void close(); Set<ReplicaId> getReplicaIds(); Map<String, ReplicaConnectionFactory> getConnectionFactories(); ConnectionConfig getConnectionConfig();  }