- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for RemoveAll (0.66 sec)
-
cmd/signature-v4_test.go
func TestDoesPresignedSignatureMatch(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) } // sha256 hash of "payload" payloadSHA256 := "239f59ed55e737c77147cf55ad0c1b030b6d7ee748a7426952f9b852d5a935e5"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 10.4K bytes - Viewed (1) -
cmd/format-erasure_test.go
func TestFixFormatV3(t *testing.T) { erasureDirs, err := getRandomDisks(8) if err != nil { t.Fatal(err) } for _, erasureDir := range erasureDirs { defer os.RemoveAll(erasureDir) } endpoints := mustGetNewEndpoints(0, 8, erasureDirs...) storageDisks, errs := initStorageDisksWithErrors(endpoints, storageOpts{cleanUp: false, healthCheck: false}) for _, err := range errs {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
) func TestCheckValid(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, objLayer); err != nil { t.Fatalf("unable initialize config file, %s", err) } initAllSubsystems(ctx) initConfigSubsystem(ctx, objLayer)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0) -
cmd/xl-storage.go
return errs } func (s *xlStorage) cleanupTrashImmediateCallers(ctx context.Context) { for { select { case <-ctx.Done(): return case entry := <-s.immediatePurge: removeAll(entry) } } } const almostFilledPercent = 0.05 func (s *xlStorage) diskAlmostFilled() bool { info, err := s.diskInfoCache.Get() if err != nil { return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/test-utils_test.go
func (testServer TestServer) Stop() { testServer.cancel() testServer.Server.Close() testServer.Obj.Shutdown(context.Background()) os.RemoveAll(testServer.Root) for _, ep := range testServer.Disks { for _, disk := range ep.Endpoints { os.RemoveAll(disk.Path) } } } // Truncate request to simulate unexpected EOF for a request signed using streaming signature v4.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/site-replication.go
siteNames := rreq.SiteNames updatedPeers := make(map[string]madmin.PeerInfo) for _, pi := range info.Sites { updatedPeers[pi.DeploymentID] = pi peerMap[pi.Name] = pi if rreq.RemoveAll { siteNames = append(siteNames, pi.Name) } } for _, s := range siteNames { pinfo, ok := peerMap[s] if !ok { return st, errSRConfigMissingError(errMissingSRConfig) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
cmd/server-startup-msg_test.go
func TestPrintServerCommonMessage(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir) if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatal(err) } apiEndpoints := []string{"http://127.0.0.1:9000"} printServerCommonMsg(apiEndpoints) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 4K bytes - Viewed (0) -
cmd/os-readdir_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 7.5K bytes - Viewed (0) -
internal/store/queuestore_test.go
if oErr := queueStore.Open(); oErr != nil { return nil, oErr } return queueStore, nil } // Tear down queue store. func tearDownQueueStore() error { return os.RemoveAll(queueDir) } // TestQueueStorePut - tests for store.Put func TestQueueStorePut(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil { t.Fatal("Failed to tear down store ", err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
func TestLockRpcServerRemoveEntry(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() testPath, locker, _ := createLockTestServer(ctx, t) defer os.RemoveAll(testPath) lockRequesterInfo1 := lockRequesterInfo{ Owner: "owner", Writer: true, UID: "0123-4567", Timestamp: UTCNow(), TimeLastRefresh: UTCNow(), }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 23 17:26:21 GMT 2023 - 3.1K bytes - Viewed (0)