fix: Add mutex to configurator dump (#1804)

Signed-off-by: Ondrej Fabry <[email protected]>

plugins/configurator/configurator.go

@@ -41,6 +41,10 @@ import (
 	"go.ligato.io/vpp-agent/v3/proto/ligato/vpp"
 )
 
+const (
+	waitDoneCheckPendingPeriod = time.Millisecond * 10
+)
+
 // configuratorServer implements DataSyncer service.
 type configuratorServer struct {
 	pb.UnimplementedConfiguratorServiceServer
@@ -75,8 +79,6 @@ func (svc *configuratorServer) Get(context.Context, *pb.GetRequest) (*pb.GetResp
 	return &pb.GetResponse{Config: config}, nil
 }
 
-const waitDoneCheckPendingPeriod = time.Millisecond * 10
-
 // Update adds configuration data present in data request to the VPP/Linux
 func (svc *configuratorServer) Update(ctx context.Context, req *pb.UpdateRequest) (*pb.UpdateResponse, error) {
 	ctx, task := trace.NewTask(ctx, "grpc.Update")

plugins/configurator/dump.go

@@ -17,6 +17,7 @@ package configurator
 import (
 	"context"
 	"errors"
+	"sync"
 
 	"go.ligato.io/cn-infra/v2/logging"
 
@@ -48,16 +49,18 @@ import (
 type dumpService struct {
 	log logging.Logger
 
+	mux sync.Mutex
+
 	// VPP Handlers
 	ifHandler    ifvppcalls.InterfaceVppRead
 	l2Handler    l2vppcalls.L2VppAPI
 	l3Handler    l3vppcalls.L3VppAPI
 	ipsecHandler ipsecvppcalls.IPSecVPPRead
 	// plugins
-	aclHandler  aclvppcalls.ACLVppRead
-	abfHandler  abfvppcalls.ABFVppRead
-	natHandler  natvppcalls.NatVppRead
-	puntHandler vppcalls.PuntVPPRead
+	aclHandler       aclvppcalls.ACLVppRead
+	abfHandler       abfvppcalls.ABFVppRead
+	natHandler       natvppcalls.NatVppRead
+	puntHandler      vppcalls.PuntVPPRead
 	wireguardHandler wireguardvppcalls.WgVppRead
 
 	// Linux handlers
@@ -69,6 +72,9 @@ type dumpService struct {
 func (svc *dumpService) Dump(ctx context.Context, req *rpc.DumpRequest) (*rpc.DumpResponse, error) {
 	defer trackOperation("Dump")()
 
+	svc.mux.Lock()
+	defer svc.mux.Unlock()
+
 	svc.log.Debugf("Received Dump request..")
 
 	dump := newConfig()