Merge pull request #455 from GoogleCloudPlatform/enable-streaming-writes

add integration test for gcsfuse v2.9.0

Author: tyuchn

test/e2e/testsuites/gcsfuse_integration.go

@@ -37,19 +37,20 @@ import (
 const (
 	gcsfuseIntegrationTestsBasePath = "gcsfuse/tools/integration_tests"
 
-	testNameOperations           = "operations"
-	testNameReadonly             = "readonly"
-	testNameRenameDirLimit       = "rename_dir_limit"
-	testNameImplicitDir          = "implicit_dir"
-	testNameExplicitDir          = "explicit_dir"
-	testNameReadLargeFiles       = "read_large_files"
-	testNameWriteLargeFiles      = "write_large_files"
-	testNameGzip                 = "gzip"
-	testNameLocalFile            = "local_file"
-	testNameListLargeDir         = "list_large_dir"
-	testNameManagedFolders       = "managed_folders"
-	testNameConcurrentOperations = "concurrent_operations"
-	testNameKernelListCache      = "kernel_list_cache"
+	testNameOperations            = "operations"
+	testNameReadonly              = "readonly"
+	testNameRenameDirLimit        = "rename_dir_limit"
+	testNameImplicitDir           = "implicit_dir"
+	testNameExplicitDir           = "explicit_dir"
+	testNameReadLargeFiles        = "read_large_files"
+	testNameWriteLargeFiles       = "write_large_files"
+	testNameGzip                  = "gzip"
+	testNameLocalFile             = "local_file"
+	testNameListLargeDir          = "list_large_dir"
+	testNameManagedFolders        = "managed_folders"
+	testNameConcurrentOperations  = "concurrent_operations"
+	testNameKernelListCache       = "kernel_list_cache"
+	testNameEnableStreamingWrites = "enable_streaming_writes"
 
 	testNamePrefixSucceed = "should succeed in "
 
@@ -147,6 +148,11 @@ func (t *gcsFuseCSIGCSFuseIntegrationTestSuite) DefineTests(driver storageframew
 			e2eskipper.Skipf("skip gcsfuse integration HNS tests on gcsfuse version %v", v.String())
 		}
 
+		// GCSFuse flag enable-streaming-writes is supported after v2.9.0.
+		if !v.AtLeast(version.MustParseSemantic("v2.9.0")) && testName == testNameEnableStreamingWrites {
+			e2eskipper.Skipf("skip gcsfuse integration test %v for gcsfuse version %v", testNameEnableStreamingWrites, v.String())
+		}
+
 		// tests are added or modified after v2.3.1 release and before v2.4.0 release
 		if !v.AtLeast(version.MustParseSemantic("v2.4.0")) && (testName == testNameListLargeDir || testName == testNameConcurrentOperations || testName == testNameKernelListCache || testName == testNameLocalFile) {
 			return "v2.4.0"
@@ -586,4 +592,11 @@ func (t *gcsFuseCSIGCSFuseIntegrationTestSuite) DefineTests(driver storageframew
 
 		gcsfuseIntegrationTest(testNameManagedFolders+":TestEnableEmptyManagedFoldersTrue", false, "implicit-dirs=true")
 	})
+
+	ginkgo.It(testNamePrefixSucceed+testNameEnableStreamingWrites+testNameSuffix(1), func() {
+		init()
+		defer cleanup()
+
+		gcsfuseIntegrationTest(testNameEnableStreamingWrites, false, "enable-streaming-writes=true")
+	})
 }