| commit | 5e92bbf3aba6904ad3be84a4051b54f155853018 | [log] [tgz] |
|---|---|---|
| author | pierventre <pier@opennetworking.org> | Tue Jul 13 18:03:22 2021 +0200 |
| committer | Pier Luigi Ventre <pier@opennetworking.org> | Mon Aug 02 18:30:55 2021 +0000 |
| tree | 8048519e9e2fcdbf84fab3d233c90de51b8979a3 | |
| parent | c4ab355b9e067ea0b84695651d2d89685f1bf616 [diff] [blame] |
[SDFAB-338] Revisit DistributedFabricUpfStore in fabric.p4 Remove the global far id consistent map and uses consistent hashing for the allocation of the farId. Stores the reverse lookup (far -> ruleId) into an EC consistent map and purges its entries on the far removal Change-Id: Ia401d081c9dcb28329fab4424b1fcd3d8e8ad916
diff --git a/pipelines/fabric/impl/src/main/java/org/onosproject/pipelines/fabric/impl/behaviour/upf/FabricUpfProgrammable.java b/pipelines/fabric/impl/src/main/java/org/onosproject/pipelines/fabric/impl/behaviour/upf/FabricUpfProgrammable.java index 3735238..401b5db 100644 --- a/pipelines/fabric/impl/src/main/java/org/onosproject/pipelines/fabric/impl/behaviour/upf/FabricUpfProgrammable.java +++ b/pipelines/fabric/impl/src/main/java/org/onosproject/pipelines/fabric/impl/behaviour/upf/FabricUpfProgrammable.java
@@ -554,7 +554,7 @@ log.info("Removing {}", far.toString()); PiCriterion match = PiCriterion.builder() - .matchExact(HDR_FAR_ID, fabricUpfStore.globalFarIdOf(far.sessionId(), far.farId())) + .matchExact(HDR_FAR_ID, fabricUpfStore.removeGlobalFarId(far.sessionId(), far.farId())) .build(); removeEntry(match, FABRIC_INGRESS_SPGW_FARS, false);