New P4RuntimeClient implementation that supports batching and error reporting
The new client API supports batching and provides detailed response for
write requests (e.g. if entity already exists when inserting), which was
not possible with the old one.
This patch includes:
- New more efficient implementation of P4RuntimeClient (no more locking,
use native gRPC executor, use stub deadlines)
- Ported all codecs to new AbstractCodec-based implementation (needed to
implement codec cache in the future)
- Uses batching in P4RuntimeFlowRuleProgrammable and
P4RuntimeGroupActionProgrammable
- Minor changes to PI framework runtime classes
Change-Id: I3fac42057bb4e1389d761006a32600c786598683
diff --git a/drivers/p4runtime/src/main/java/org/onosproject/drivers/p4runtime/mirror/DistributedP4RuntimeMeterMirror.java b/drivers/p4runtime/src/main/java/org/onosproject/drivers/p4runtime/mirror/DistributedP4RuntimeMeterMirror.java
index bf36274..581c83a 100644
--- a/drivers/p4runtime/src/main/java/org/onosproject/drivers/p4runtime/mirror/DistributedP4RuntimeMeterMirror.java
+++ b/drivers/p4runtime/src/main/java/org/onosproject/drivers/p4runtime/mirror/DistributedP4RuntimeMeterMirror.java
@@ -16,10 +16,9 @@
package org.onosproject.drivers.p4runtime.mirror;
-import org.onlab.util.KryoNamespace;
+import org.onosproject.net.pi.runtime.PiEntityType;
import org.onosproject.net.pi.runtime.PiMeterCellConfig;
-import org.onosproject.net.pi.runtime.PiMeterHandle;
-import org.onosproject.store.serializers.KryoNamespaces;
+import org.onosproject.net.pi.runtime.PiMeterCellHandle;
import org.osgi.service.component.annotations.Component;
/**
@@ -28,21 +27,10 @@
@Component(immediate = true, service = P4RuntimeMeterMirror.class)
public final class DistributedP4RuntimeMeterMirror
extends AbstractDistributedP4RuntimeMirror
- <PiMeterHandle, PiMeterCellConfig>
+ <PiMeterCellHandle, PiMeterCellConfig>
implements P4RuntimeMeterMirror {
- private static final String DIST_MAP_NAME = "onos-p4runtime-meter-mirror";
-
- @Override
- String mapName() {
- return DIST_MAP_NAME;
+ public DistributedP4RuntimeMeterMirror() {
+ super(PiEntityType.METER_CELL_CONFIG);
}
-
- @Override
- KryoNamespace storeSerializer() {
- return KryoNamespace.newBuilder()
- .register(KryoNamespaces.API)
- .register(TimedEntry.class)
- .build();
- }
-}
\ No newline at end of file
+}