xsync grpc optimizations

loxinet/dpbroker.go

@@ -429,7 +429,6 @@ type DpH struct {
 	ToFinCh  chan int
 	DpHooks  DpHookInterface
 	SyncMtx  sync.RWMutex
-	MapMtx   sync.RWMutex
 	Peers    []DpPeer
 	RPC      *XSync
 	Remotes  []XSync
@@ -597,10 +596,10 @@ func callGRPC(client XSyncClient, rpcCallStr string, args interface{}, reply *in
 
 	if err != nil {
 		*reply = -1
-		tk.LogIt(tk.LogInfo, "XSync %s reply - %v[NOK]\n", rpcCallStr, err.Error())
+		tk.LogIt(tk.LogError, "XSync %s reply - %v[NOK]\n", rpcCallStr, err.Error())
 	} else if xreply != nil {
 		*reply = int(xreply.Response)
-		tk.LogIt(tk.LogInfo, "XSync %s peer reply - %d\n", rpcCallStr, *reply)
+		tk.LogIt(tk.LogDebug, "XSync %s peer reply - %d\n", rpcCallStr, *reply)
 	}
 	return err
 }

loxinet/dpebpf_linux.go

@@ -187,11 +187,8 @@ func dpEbpfTicker() {
 			// Age any entries related to Conntrack
 			/* No need to fetch all stats in this fashion */
 			//C.llb_collect_map_stats(C.int(C.LL_DP_CT_STATS_MAP))
-			mh.dp.MapMtx.Lock()
 			/* Per entry stats will be fetched in C.ll_ct_map_ent_has_aged */
 			C.llb_age_map_entries(C.LL_DP_CT_MAP)
-			mh.dp.MapMtx.Unlock()
-
 			C.llb_age_map_entries(C.LL_DP_FCV4_MAP)
 
 			// This means around 10s from start

loxinet/xsync_server.go

@@ -40,9 +40,6 @@ func (xs *XSync) DpWorkOnBlockCtAdd(blockCtis []DpCtInfo, ret *int) error {
 
 	*ret = 0
 
-	mh.dp.MapMtx.Lock()
-	defer mh.dp.MapMtx.Unlock()
-
 	for _, cti := range blockCtis {
 
 		tk.LogIt(tk.LogDebug, "RPC - Block CT Add %s\n", cti.Key())
@@ -63,9 +60,6 @@ func (xs *XSync) DpWorkOnBlockCtDelete(blockCtis []DpCtInfo, ret *int) error {
 
 	*ret = 0
 
-	mh.dp.MapMtx.Lock()
-	defer mh.dp.MapMtx.Unlock()
-
 	for _, cti := range blockCtis {
 
 		tk.LogIt(tk.LogDebug, "RPC - Block CT Del %s\n", cti.Key())