Fix bug which set zero all resources in a wrong way.

Added debug mode in test environment.
liqotech · Jul 29, 2021 · 01ecc61 · 01ecc61
1 parent 7bc8200
commit 01ecc61
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 3 deletions.
diff --git a/internal/resource-request-operator/broadcaster.go b/internal/resource-request-operator/broadcaster.go
@@ -286,7 +286,7 @@ func (b *Broadcaster) writePodResources(clusterID string, newResources corev1.Re
 	if clusterID == "" {
 		return
 	}
-	if errorsmanagement.Must(checkSign(newResources)) {
+	if !errorsmanagement.Must(checkSign(newResources)) {
 		setZero(&newResources)
 	}
 	b.podMutex.Lock()

diff --git a/internal/resource-request-operator/suite_test.go b/internal/resource-request-operator/suite_test.go
@@ -21,6 +21,7 @@ import (
 	discoveryv1alpha1 "github.com/liqotech/liqo/apis/discovery/v1alpha1"
 	sharingv1alpha1 "github.com/liqotech/liqo/apis/sharing/v1alpha1"
 	"github.com/liqotech/liqo/pkg/clusterid"
+	errorsmanagement "github.com/liqotech/liqo/pkg/utils/errorsManagement"
 )
 
 var (
@@ -70,6 +71,7 @@ func createCluster() {
 		MetricsBindAddress: "0", // this avoids port binding collision
 	})
 	Expect(err).ToNot(HaveOccurred())
+	errorsmanagement.SetDebug(true)
 	clientset = kubernetes.NewForConfigOrDie(k8sManager.GetConfig())
 	homeClusterID = clusterid.NewStaticClusterID("test-cluster").GetClusterID()
 	updater := OfferUpdater{}

diff --git a/pkg/liqonet/ipam/ipam.pb.go b/pkg/liqonet/ipam/ipam.pb.go
diff --git a/pkg/liqonet/ipam/ipam_grpc.pb.go b/pkg/liqonet/ipam/ipam_grpc.pb.go