22package driver
33
44import (
5- // "os"
5+ "os"
66 "strconv"
77 "sync"
88 "testing"
@@ -13,12 +13,12 @@ import (
1313
1414 "github.com/container-storage-interface/spec/lib/go/csi"
1515 "github.com/hpe-storage/common-host-libs/chapi"
16- // log "github.com/hpe-storage/common-host-libs/logger"
16+ log "github.com/hpe-storage/common-host-libs/logger"
1717 "github.com/hpe-storage/common-host-libs/storageprovider"
1818 "github.com/hpe-storage/common-host-libs/storageprovider/fake"
1919 "github.com/hpe-storage/csi-driver/pkg/flavor"
2020 "github.com/hpe-storage/csi-driver/pkg/flavor/vanilla"
21- // "github.com/kubernetes-csi/csi-test/pkg/sanity"
21+ "github.com/kubernetes-csi/csi-test/pkg/sanity"
2222)
2323
2424const (
@@ -28,40 +28,39 @@ const (
2828 testCount int = 500
2929)
3030
31- /*
32- func TestPluginSuite(t *testing.T) {
33- endpoint := "unix://" + testsocket
34- if err := os.Remove(testsocket); err != nil && !os.IsNotExist(err) {
35- t.Fatalf("failed to remove unix domain socket file %s, error: %s", testsocket, err)
36- }
37-
38- log.InitLogging("csi-test.log", &log.LogParams{Level: "trace"}, false)
39-
40- // driver := realDriver(t, endpoint)
41- // secretsFile := "csi-secrets.yaml"
42- driver := fakeDriver(endpoint)
43- secretsFile := "fake-csi-secrets.yaml"
44- driver.grpc = NewNonBlockingGRPCServer()
45- // start node, controller and identity servers on same endpoint for tests
46- go driver.grpc.Start(driver.endpoint, driver, driver, driver)
47- defer driver.Stop(true)
48-
49- stagingPath := "./csi-mnt"
50- targetPath := "./csi-mnt-stage"
51- os.RemoveAll(stagingPath)
52- os.RemoveAll(targetPath)
53-
54- config := &sanity.Config{
55- StagingPath: stagingPath,
56- TargetPath: targetPath,
57- Address: endpoint,
58- SecretsFile: secretsFile,
59- CreateTargetDir: createTarget,
60- }
61-
62- sanity.Test(t, config)
31+ func TestPluginSuite (t * testing.T ) {
32+ endpoint := "unix://" + testsocket
33+ if err := os .Remove (testsocket ); err != nil && ! os .IsNotExist (err ) {
34+ t .Fatalf ("failed to remove unix domain socket file %s, error: %s" , testsocket , err )
6335 }
64- */
36+
37+ log .InitLogging ("csi-test.log" , & log.LogParams {Level : "trace" }, false )
38+
39+ //driver := realDriver(t, endpoint)
40+ //secretsFile := "csi-secrets.yaml"
41+ driver := fakeDriver (endpoint )
42+ secretsFile := "fake-csi-secrets.yaml"
43+ driver .grpc = NewNonBlockingGRPCServer ()
44+ // start node, controller and identity servers on same endpoint for tests
45+ go driver .grpc .Start (driver .endpoint , driver , driver , driver )
46+ defer driver .Stop (true )
47+
48+ stagingPath := "./csi-mnt"
49+ targetPath := "./csi-mnt-stage"
50+ os .RemoveAll (stagingPath )
51+ os .RemoveAll (targetPath )
52+
53+ config := & sanity.Config {
54+ StagingPath : stagingPath ,
55+ TargetPath : targetPath ,
56+ Address : endpoint ,
57+ SecretsFile : secretsFile ,
58+ CreateTargetDir : createTarget ,
59+ }
60+
61+ sanity .Test (t , config )
62+ }
63+
6564func createTarget (_ string ) (string , error ) {
6665 return "./csi-mnt-stage" , nil
6766}
0 commit comments