Added filtering for incorrect slo boosting logs

Author: chrisThePattyEater

pkg/gce-cloud-provider/compute/gce.go

@@ -21,6 +21,7 @@ import (
 	"net/http"
 	"net/url"
 	"os"
+	"regexp"
 	"runtime"
 	"sync"
 	"time"
@@ -77,6 +78,11 @@ const (
 	gcpTagsRequestTokenBucketSize = 8
 )
 
+var (
+	ssAlreadyExistsRegex = regexp.MustCompile("The resource [^']+ already exists")
+	gcpViolationRegex    = regexp.MustCompile("violates constraint constraints/gcp.")
+)
+
 // ResourceType indicates the type of a compute resource.
 type ResourceType string
 
@@ -441,3 +447,13 @@ func IsGCENotFoundError(err error) bool {
 func IsGCEInvalidError(err error) bool {
 	return IsGCEError(err, "invalid")
 }
+
+// IsSnapshotAlreadyExistsError checks if the error is a snapshot already exists error.
+func IsSnapshotAlreadyExistsError(err error) bool {
+	return ssAlreadyExistsRegex.MatchString(err.Error())
+}
+
+// IsGCPOrgViolationError checks if the error is a GCP organization policy violation error.
+func IsGCPOrgViolationError(err error) bool {
+	return gcpViolationRegex.MatchString(err.Error())
+}

pkg/gce-cloud-provider/compute/gce_test.go

@@ -101,6 +101,60 @@ func TestIsGCEError(t *testing.T) {
 	}
 }
 
+func TestErrorIsGCPViolationRegex(t *testing.T) {
+	testCases := []struct {
+		name           string
+		inputErr       error
+		expectedResult bool
+	}{
+		{
+			name:           "is gcp org violation error",
+			inputErr:       errors.New("Your api request violates constraint constraints/gcp.resourceLocations"),
+			expectedResult: true,
+		},
+		{
+			name:           "is not gcp org violation error",
+			inputErr:       errors.New("Some incorrect error message"),
+			expectedResult: false,
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Logf("Running test: %v", tc.name)
+		result := IsGCPOrgViolationError(tc.inputErr)
+		if tc.expectedResult != result {
+			t.Fatalf("Got '%t', expected '%t'", result, tc.expectedResult)
+		}
+	}
+}
+
+func TestErrorIsSnapshotExistsError(t *testing.T) {
+	testCases := []struct {
+		name           string
+		inputErr       error
+		expectedResult bool
+	}{
+		{
+			name:           "is ss error",
+			inputErr:       errors.New("The resource projects/dcme-pre-opt-mdp-rmp-00/global/snapshots/snapshot-3c208602-d815-40ae-a61e-3259e3bd29ca already exists, alreadyExists"),
+			expectedResult: true,
+		},
+		{
+			name:           "is not ss already exists error",
+			inputErr:       errors.New("Some incorrect error message"),
+			expectedResult: false,
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Logf("Running test: %v", tc.name)
+		result := IsSnapshotAlreadyExistsError(tc.inputErr)
+		if tc.expectedResult != result {
+			t.Fatalf("Got '%t', expected '%t'", result, tc.expectedResult)
+		}
+	}
+}
+
 func TestGetComputeVersion(t *testing.T) {
 	testCases := []struct {
 		name               string

pkg/gce-pd-csi-driver/controller.go

@@ -1668,6 +1668,16 @@ func (gceCS *GCEControllerServer) createPDSnapshot(ctx context.Context, project
 			if gce.IsGCEError(err, "notFound") {
 				return nil, status.Errorf(codes.NotFound, "Could not find volume with ID %v: %v", volKey.String(), err.Error())
 			}
+
+			// Identified as incorrect error handling
+			if gce.IsSnapshotAlreadyExistsError(err) {
+				return nil, status.Errorf(codes.AlreadyExists, "Snapshot already exists: %v", err.Error())
+			}
+
+			// Identified as incorrect error handling
+			if gce.IsGCPOrgViolationError(err) {
+				return nil, status.Errorf(codes.FailedPrecondition, "Violates GCP org policy: %v", err.Error())
+			}
 			return nil, common.LoggedError("Failed to create snapshot: ", err)
 		}
 	}