@Test public void getMasterFor() { mgr.setRole(NID_LOCAL, DEV_MASTER, MASTER); mgr.setRole(NID_OTHER, DEV_OTHER, MASTER); assertEquals("wrong master:", NID_LOCAL, mgr.getMasterFor(DEV_MASTER)); assertEquals("wrong master:", NID_OTHER, mgr.getMasterFor(DEV_OTHER)); mgr.setRole(NID_LOCAL, DEV_OTHER, MASTER); assertEquals("wrong master:", NID_LOCAL, mgr.getMasterFor(DEV_OTHER)); }
@Override public NodeId getMasterFor(DeviceId deviceId) { checkPermission(CLUSTER_READ); checkNotNull(deviceId, DEVICE_ID_NULL); return store.getMaster(deviceId); }
MastershipManager extends AbstractListenerManager<MastershipEvent, MastershipListener> implements MastershipService, MastershipAdminService, MastershipTermService,
               MetricsHelper { @Override public NodeId getMasterFor(DeviceId deviceId) { checkPermission(CLUSTER_READ); checkNotNull(deviceId, DEVICE_ID_NULL); return store.getMaster(deviceId); } }
MastershipManager extends AbstractListenerManager<MastershipEvent, MastershipListener> implements MastershipService, MastershipAdminService, MastershipTermService,
               MetricsHelper { @Override public NodeId getMasterFor(DeviceId deviceId) { checkPermission(CLUSTER_READ); checkNotNull(deviceId, DEVICE_ID_NULL); return store.getMaster(deviceId); }  }
MastershipManager extends AbstractListenerManager<MastershipEvent, MastershipListener> implements MastershipService, MastershipAdminService, MastershipTermService,
               MetricsHelper { @Override public NodeId getMasterFor(DeviceId deviceId) { checkPermission(CLUSTER_READ); checkNotNull(deviceId, DEVICE_ID_NULL); return store.getMaster(deviceId); }  @Activate void activate(); @Deactivate void deactivate(); @Override CompletableFuture<Void> setRole(NodeId nodeId, DeviceId deviceId, MastershipRole role); @Override MastershipRole getLocalRole(DeviceId deviceId); @Override CompletableFuture<Void> relinquishMastership(DeviceId deviceId); @Override CompletableFuture<MastershipRole> requestRoleFor(DeviceId deviceId); @Override NodeId getMasterFor(DeviceId deviceId); @Override Set<DeviceId> getDevicesOf(NodeId nodeId); @Override RoleInfo getNodesFor(DeviceId deviceId); @Override MastershipTerm getMastershipTerm(DeviceId deviceId); @Override MetricsService metricsService(); @Override void balanceRoles(); }
MastershipManager extends AbstractListenerManager<MastershipEvent, MastershipListener> implements MastershipService, MastershipAdminService, MastershipTermService,
               MetricsHelper { @Override public NodeId getMasterFor(DeviceId deviceId) { checkPermission(CLUSTER_READ); checkNotNull(deviceId, DEVICE_ID_NULL); return store.getMaster(deviceId); }  @Activate void activate(); @Deactivate void deactivate(); @Override CompletableFuture<Void> setRole(NodeId nodeId, DeviceId deviceId, MastershipRole role); @Override MastershipRole getLocalRole(DeviceId deviceId); @Override CompletableFuture<Void> relinquishMastership(DeviceId deviceId); @Override CompletableFuture<MastershipRole> requestRoleFor(DeviceId deviceId); @Override NodeId getMasterFor(DeviceId deviceId); @Override Set<DeviceId> getDevicesOf(NodeId nodeId); @Override RoleInfo getNodesFor(DeviceId deviceId); @Override MastershipTerm getMastershipTerm(DeviceId deviceId); @Override MetricsService metricsService(); @Override void balanceRoles(); public boolean useRegionForBalanceRoles; }