VOL-4125: Respond with success/failure to flow insertion according the
operation result in adapter
VOL-4323: Support serialization of flow messages (execute a flow to
completion before picking up another flow)
Change-Id: I934fc68b103042971109923491a3f27aaf885328
diff --git a/internal/pkg/config/config.go b/internal/pkg/config/config.go
index aff1de3..98c7eac 100644
--- a/internal/pkg/config/config.go
+++ b/internal/pkg/config/config.go
@@ -71,6 +71,7 @@
GrpcAddress string
CoreEndpoint string
RPCTimeout time.Duration
+ MaxConcurrentFlowsPerUni int
}
// ParseCommandArguments parses the arguments when running read-write adaptercore service
@@ -270,6 +271,10 @@
"max_retry_delay",
10*time.Second,
"The maximum number of milliseconds to delay before a connection retry attempt")
+ fs.IntVar(&(so.MaxConcurrentFlowsPerUni),
+ "max_concurrent_flows_per_uni",
+ 16,
+ "The max number of concurrent flows (add/remove) that can be queued per UNI")
_ = fs.Parse(args)
containerName := getContainerInfo()