commit b0037422e6f976e4793f3a6b14e7a9df5d973fbf
author Matt Jeanneret <mj3580@att.com> Sat Mar 23 14:36:51 2019 -0400
committer Matt Jeanneret <mj3580@att.com> Thu Apr 04 14:03:46 2019 -0400
tree 2fae58f9efe54f228b0712d6fd56b8534db3b642
parent ed4b76047e036508b084d48a22a6cbb811ab27d2

VOL-1489: Call update incremental flows properly

Fix a presumed typo in update_flows incremental vs bulk

Change-Id: I8d3283a444d07890271b2aced2219baae788019d

rw_core/core/adapter_proxy.go

diff --git a/rw_core/core/adapter_proxy.go b/rw_core/core/adapter_proxy.go
index 49f56e5..4ed1a71 100644
--- a/rw_core/core/adapter_proxy.go
+++ b/rw_core/core/adapter_proxy.go
@@ -443,7 +443,7 @@
 func (ap *AdapterProxy) UpdateFlowsIncremental(device *voltha.Device, flowChanges *openflow_13.FlowChanges, groupChanges *openflow_13.FlowGroupChanges) error {
 	log.Debugw("UpdateFlowsIncremental", log.Fields{"deviceId": device.Id})
 	toTopic := ap.getAdapterTopic(device.Adapter)
-	rpc := "update_flows_bulk"
+	rpc := "update_flows_incrementally"
 	args := make([]*kafka.KVArg, 3)
 	args[0] = &kafka.KVArg{
 		Key:   "device",