Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 640 for defer (0.05 sec)

  1. cmd/os-readdir_test.go

    		t.Fatalf("expected = %s, got: %s", errFileNotFound, err)
    	}
    
    	file := path.Join(os.TempDir(), "issue")
    	if err := os.WriteFile(file, []byte(""), 0o644); err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(file)
    
    	// Check if file is given.
    	if _, err := readDir(path.Join(file, "mydir")); err != errFileNotFound {
    		t.Fatalf("expected = %s, got: %s", errFileNotFound, err)
    	}
    
    	// Only valid for linux.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 7.5K bytes
    - Viewed (0)
  2. cmd/sftp-server_test.go

    	}
    }
    
    func (s *TestSuiteIAM) SFTPInvalidServiceAccountPassword(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
    	defer cancel()
    
    	accessKey, secretKey := mustGenerateCredentials(c)
    	err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    		c.Fatalf("Unable to set user: %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:25 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. cmd/signals.go

    	// Custom exit function
    	exit := func(success bool) {
    		if globalLoggerOutput != nil {
    			globalLoggerOutput.Close()
    		}
    
    		// If global profiler is set stop before we exit.
    		globalProfilerMu.Lock()
    		defer globalProfilerMu.Unlock()
    		for _, p := range globalProfiler {
    			p.Stop()
    		}
    
    		if success {
    			os.Exit(0)
    		}
    
    		os.Exit(1)
    	}
    
    	stopProcess := func() bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. cmd/kms-handlers_test.go

    	asRoot bool
    
    	// Wanted in response.
    	wantStatusCode int
    	wantKeyNames   []string
    	wantResp       []string
    }
    
    func TestKMSHandlersCreateKey(t *testing.T) {
    	adminTestBed, tearDown := setupKMSTest(t, true)
    	defer tearDown()
    
    	tests := []kmsTestCase{
    		// Create key test
    		{
    			name:   "create key as user with no policy want forbidden",
    			method: http.MethodPost,
    			path:   kmsKeyCreatePath,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/netns_linux_test.go

    	}
    	// the inode for netns is proc dynamic, so it needs to be higher than
    	// #define PROC_DYNAMIC_FIRST 0xF0000000U
    
    	if ns.Inode() < 0xF0000000 {
    		t.Fatalf("unexpected inode: %v", ns.Inode())
    	}
    	defer ns.Close()
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 976 bytes
    - Viewed (0)
  6. cmd/data-usage-cache.go

    	}
    
    	buf := bytebufferpool.Get()
    	defer func() {
    		<-maxConcurrentScannerSaves
    		buf.Reset()
    		bytebufferpool.Put(buf)
    	}()
    
    	if err := d.serializeTo(buf); err != nil {
    		return err
    	}
    
    	save := func(name string, timeout time.Duration) error {
    		// Abandon if more than a minute, so we don't hold up scanner.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  7. cmd/handler-utils_test.go

    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(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)
    	}
    
    	// Corrupted XML
    	malformedReq := &http.Request{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  8. cmd/data-scanner_test.go

    )
    
    func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) {
    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    	globalBucketMetadataSys = NewBucketMetadataSys()
    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. finisher_api.go

    	tx = db.getInstance()
    	if tx.Statement.Model == nil {
    		tx.Statement.Model = tx.Statement.Dest
    		defer func() {
    			tx.Statement.Model = nil
    		}()
    	}
    
    	if selectClause, ok := db.Statement.Clauses["SELECT"]; ok {
    		defer func() {
    			tx.Statement.Clauses["SELECT"] = selectClause
    		}()
    	} else {
    		defer delete(tx.Statement.Clauses, "SELECT")
    	}
    
    	if len(tx.Statement.Selects) == 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
  10. cmd/bucket-listobjects-handlers.go

    // of the versions of objects in a bucket.
    func (api objectAPIHandlers) listObjectVersionsHandler(w http.ResponseWriter, r *http.Request, metadata bool) {
    	ctx := newContext(r, w, "ListObjectVersions")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top