X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fnngpush.go;h=0d9634eab06c3848389507dc7e7f0ac0412a2a9c;hb=87c46ef443a44730cfdcab1ba00b25f60825e037;hp=7ba43c552f29db6bc25cdd16845aeb1d4f588471;hpb=2bff80d0fa41b3e2b89b9fb32431558a9cb35170;p=ric-plt%2Frtmgr.git

diff --git a/pkg/sbi/nngpush.go b/pkg/sbi/nngpush.go
index 7ba43c5..0d9634e 100644
--- a/pkg/sbi/nngpush.go
+++ b/pkg/sbi/nngpush.go
@@ -50,7 +50,7 @@ var rmrcallid = 1
 var rmrdynamiccallid = 201
 var addendpointct = 1
 var count int
-var conn sync.Mutex
+var Conn sync.Mutex
 
 type RmrPush struct {
 	Sbi
@@ -169,9 +169,9 @@ func (c *RmrPush) send_sync(ep *rtmgr.Endpoint, policies *[]string, call_id int)
 		xapp.Logger.Error("Invoked  send_data to try again due to return value : %v", ret)
 	}
 
-	conn.Lock()
+	Conn.Lock()
 	rtmgr.RMRConnStatus[ep.Uuid] = ret
-	conn.Unlock()
+	Conn.Unlock()
 	// Handling per connection .. may be updating global map
 
 	//channel <- EPStatus{ep.Uuid, ret}