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/common/defines.go b/internal/pkg/common/defines.go
index 2c597c1..23a16dd 100755
--- a/internal/pkg/common/defines.go
+++ b/internal/pkg/common/defines.go
@@ -314,6 +314,7 @@
CookieSlice []uint64 `json:"cookie_slice"`
VlanRuleParams UniVlanRuleParams `json:"vlan_rule_params"`
Meter *voltha.OfpMeterConfig `json:"flow_meter"`
+ RespChan *chan error `json:"-"`
}
///////////////////////////////////////////////////////////
diff --git a/internal/pkg/common/interfaces.go b/internal/pkg/common/interfaces.go
index a15bf35..ef5e004 100755
--- a/internal/pkg/common/interfaces.go
+++ b/internal/pkg/common/interfaces.go
@@ -76,6 +76,8 @@
GetAlarmManagerIsRunning(context.Context) bool
StartAlarmManager(context.Context)
+ GetFlowMonitoringIsRunning(uniID uint8) bool
+
CheckAuditStartCondition(context.Context, UsedOmciConfigFsms) bool
RemoveOnuUpgradeFsm(context.Context, *voltha.ImageState)
@@ -112,6 +114,8 @@
SendOMCIRequest(context.Context, string, *ic.OmciMessage) error
CreatePortInCore(context.Context, *voltha.Port) error
+
+ PerOnuFlowHandlerRoutine(uniID uint8)
}
// IonuDeviceEntry interface to onuDeviceEntry