(helper *clients.TestClient, k8sh *utils.K8sHelper, s *suite.Suite, settings *installer.TestCephSettings, filesystemName string, activeCount int)
| 522 | } |
| 523 | |
| 524 | func createFilesystem(helper *clients.TestClient, k8sh *utils.K8sHelper, s *suite.Suite, settings *installer.TestCephSettings, filesystemName string, activeCount int) { |
| 525 | logger.Infof("Create file System") |
| 526 | fscErr := helper.FSClient.Create(filesystemName, settings.Namespace, activeCount) |
| 527 | require.Nil(s.T(), fscErr) |
| 528 | var err error |
| 529 | |
| 530 | var filesystemList []cephclient.CephFilesystem |
| 531 | for i := 1; i <= 10; i++ { |
| 532 | filesystemList, err = helper.FSClient.List(settings.Namespace) |
| 533 | if err != nil { |
| 534 | logger.Errorf("failed to list fs. trying again. %v", err) |
| 535 | continue |
| 536 | } |
| 537 | logger.Debugf("filesystemList is %+v", filesystemList) |
| 538 | if len(filesystemList) == 1 { |
| 539 | logger.Infof("File system %s created", filesystemList[0].Name) |
| 540 | break |
| 541 | } |
| 542 | logger.Infof("Waiting for file system %s to be created", filesystemName) |
| 543 | time.Sleep(time.Second * 5) |
| 544 | } |
| 545 | logger.Debugf("filesystemList is %+v", filesystemList) |
| 546 | require.Equal(s.T(), 1, len(filesystemList), "There should be one shared file system present") |
| 547 | } |
| 548 | |
| 549 | func fileTestDataCleanUp(helper *clients.TestClient, k8sh *utils.K8sHelper, s *suite.Suite, podName string, namespace string, filesystemName string) { |
| 550 | logger.Infof("Cleaning up file system") |
no test coverage detected