| commit | a46458bd7a8f4a24f9192aef0173bb61fef9128a | [log] [tgz] |
|---|---|---|
| author | khenaidoo <knursimu@ciena.com> | Wed Dec 15 16:50:44 2021 -0500 |
| committer | khenaidoo <knursimu@ciena.com> | Mon Feb 14 13:51:42 2022 -0500 |
| tree | 3d3ea090c317f6d335cb99b2522149f73608a963 | |
| parent | 58d1c06da6c6cb9122106de59a9382f0c1431898 [diff] [blame] |
[VOL-4442] grpc streaming connection monitoring Change-Id: I6b26a29c74be8833e7262eb59d266e6cce66f0c3
diff --git a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/flows/flow_utils.go b/vendor/github.com/opencord/voltha-lib-go/v7/pkg/flows/flow_utils.go index 41b615a..1e50a63 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/flows/flow_utils.go +++ b/vendor/github.com/opencord/voltha-lib-go/v7/pkg/flows/flow_utils.go
@@ -1378,6 +1378,12 @@ return filteredDR } +func (dr *DeviceRules) RemoveRule(deviceId string) { + dr.rulesLock.RLock() + defer dr.rulesLock.RUnlock() + delete(dr.Rules, deviceId) +} + func (dr *DeviceRules) AddFlow(deviceId string, flow *ofp.OfpFlowStats) { dr.rulesLock.Lock() defer dr.rulesLock.Unlock()