mirrors/onos
1
0
Fork 0
mirror of https://github.com/opennetworkinglab/onos.git synced 2025-11-08 12:12:01 +01:00
Code Issues Projects Releases Wiki Activity

Refactor: extract the same procedures

Browse Source 
Change-Id: If28960f4e9fddc3276091fd04e2b624e6168dc5c
This commit is contained in:
Sho SHIMIZU 2016-02-15 13:56:34 -08:00 committed by Gerrit Code Review
parent d4712e2aac
commit 171a9380a2
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
core/store/dist/src/main/java/org/onosproject/store/newresource/impl/ConsistentResourceStore.java vendored
View File

@ -268,21 +268,18 @@ public class ConsistentResourceStore extends AbstractStore<ResourceEvent, Resour
tx.getTransactionalMap(CONTINUOUS_CONSUMER_MAP, SERIALIZER); tx.getTransactionalMap(CONTINUOUS_CONSUMER_MAP, SERIALIZER);
for (Resource resource: resources) { for (Resource resource: resources) {
if (resource instanceof DiscreteResource) { // if the resource is not registered, then abort
if (!lookup(childTxMap, resource.id()).isPresent()) {
return abortTransaction(tx);
}
ResourceConsumer oldValue = discreteConsumerTxMap.put(((DiscreteResource) resource).id(), consumer);
if (oldValue != null) {
return abortTransaction(tx);
}
} else if (resource instanceof ContinuousResource) {
Optional<Resource> lookedUp = lookup(childTxMap, resource.id()); Optional<Resource> lookedUp = lookup(childTxMap, resource.id());
if (!lookedUp.isPresent()) { if (!lookedUp.isPresent()) {
return abortTransaction(tx); return abortTransaction(tx);
} }
if (resource instanceof DiscreteResource) {
ResourceConsumer oldValue = discreteConsumerTxMap.put(((DiscreteResource) resource).id(), consumer);
if (oldValue != null) {
return abortTransaction(tx);
}
} else if (resource instanceof ContinuousResource) {
// Down cast: this must be safe as ContinuousResource is associated with ContinuousResourceId // Down cast: this must be safe as ContinuousResource is associated with ContinuousResourceId
ContinuousResource continuous = (ContinuousResource) lookedUp.get(); ContinuousResource continuous = (ContinuousResource) lookedUp.get();
ContinuousResourceAllocation allocations = continuousConsumerTxMap.get(continuous.id()); ContinuousResourceAllocation allocations = continuousConsumerTxMap.get(continuous.id());