Committed by
Gerrit Code Review
Deprecate MastershipService::getDevicesOf method
Change-Id: I79ac1cbd7765229d39a5e2c614c98f17760f52a1
Showing
2 changed files
with
4 additions
and
1 deletions
... | @@ -124,7 +124,9 @@ public interface MastershipService | ... | @@ -124,7 +124,9 @@ public interface MastershipService |
124 | * | 124 | * |
125 | * @param nodeId the ID of the controller | 125 | * @param nodeId the ID of the controller |
126 | * @return a set of device IDs | 126 | * @return a set of device IDs |
127 | + * @deprecated 1.6.0 Goldeneye release. | ||
127 | */ | 128 | */ |
129 | + @Deprecated | ||
128 | Set<DeviceId> getDevicesOf(NodeId nodeId); | 130 | Set<DeviceId> getDevicesOf(NodeId nodeId); |
129 | 131 | ||
130 | } | 132 | } | ... | ... |
... | @@ -843,8 +843,9 @@ public class DistributedFlowRuleStore | ... | @@ -843,8 +843,9 @@ public class DistributedFlowRuleStore |
843 | } | 843 | } |
844 | try { | 844 | try { |
845 | // determine the set of devices that we need to backup during this run. | 845 | // determine the set of devices that we need to backup during this run. |
846 | - Set<DeviceId> devicesToBackup = mastershipService.getDevicesOf(local) | 846 | + Set<DeviceId> devicesToBackup = flowEntries.keySet() |
847 | .stream() | 847 | .stream() |
848 | + .filter(mastershipService::isLocalMaster) | ||
848 | .filter(deviceId -> { | 849 | .filter(deviceId -> { |
849 | Long lastBackupTime = lastBackupTimes.get(deviceId); | 850 | Long lastBackupTime = lastBackupTimes.get(deviceId); |
850 | Long lastUpdateTime = lastUpdateTimes.get(deviceId); | 851 | Long lastUpdateTime = lastUpdateTimes.get(deviceId); | ... | ... |
-
Please register or login to post a comment