@Test @SuppressWarnings("unchecked") public void activation_not_sent_if_deferred_activation_is_disabled_in_state_bundle() { var f = StateActivationFixture.withTwoPhaseDisabled(); var cf = f.cf; f.ackStateBundleFromBothDistributors(); assertEquals(f.stateBundle, f.broadcaster.getLastClusterStateBundleConverged()); clusterNodeInfos(cf.cluster(), Node.ofDistributor(0), Node.ofDistributor(1)).forEach(nodeInfo -> { verify(f.mockCommunicator, times(0)).activateClusterStateVersion(eq(123), eq(nodeInfo), any()); }); }
public ClusterStateBundle getLastClusterStateBundleConverged() { return lastClusterStateBundleConverged; }
SystemStateBroadcaster { public ClusterStateBundle getLastClusterStateBundleConverged() { return lastClusterStateBundleConverged; } }
SystemStateBroadcaster { public ClusterStateBundle getLastClusterStateBundleConverged() { return lastClusterStateBundleConverged; } SystemStateBroadcaster(Timer timer, Object monitor); }
SystemStateBroadcaster { public ClusterStateBundle getLastClusterStateBundleConverged() { return lastClusterStateBundleConverged; } SystemStateBroadcaster(Timer timer, Object monitor); void handleNewClusterStates(ClusterStateBundle state); ClusterState getClusterState(); boolean hasBroadcastedClusterStateBundle(); void resetBroadcastedClusterStateBundle(); ClusterStateBundle getClusterStateBundle(); ClusterStateBundle getLastClusterStateBundleConverged(); boolean processResponses(); boolean broadcastNewStateBundleIfRequired(DatabaseHandler.Context dbContext, Communicator communicator); boolean broadcastStateActivationsIfRequired(DatabaseHandler.Context dbContext, Communicator communicator); int lastClusterStateVersionInSync(); }
SystemStateBroadcaster { public ClusterStateBundle getLastClusterStateBundleConverged() { return lastClusterStateBundleConverged; } SystemStateBroadcaster(Timer timer, Object monitor); void handleNewClusterStates(ClusterStateBundle state); ClusterState getClusterState(); boolean hasBroadcastedClusterStateBundle(); void resetBroadcastedClusterStateBundle(); ClusterStateBundle getClusterStateBundle(); ClusterStateBundle getLastClusterStateBundleConverged(); boolean processResponses(); boolean broadcastNewStateBundleIfRequired(DatabaseHandler.Context dbContext, Communicator communicator); boolean broadcastStateActivationsIfRequired(DatabaseHandler.Context dbContext, Communicator communicator); int lastClusterStateVersionInSync(); static Logger log; }