Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 392 for defer (0.01 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/graph/ForwardingGraph.java

     */
    abstract class ForwardingGraph<N> extends AbstractGraph<N> {
    
      abstract BaseGraph<N> delegate();
    
      @Override
      public Set<N> nodes() {
        return delegate().nodes();
      }
    
      /**
       * Defer to {@link AbstractGraph#edges()} (based on {@link #successors(Object)}) for full edges()
       * implementation.
       */
      @Override
      protected long edgeCount() {
        return delegate().edges().size();
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. cmd/lock-rest-client_test.go

    	}
    	endpointLocal, err := NewEndpoint("http://localhost:9012")
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	endpointLocal.IsLocal = true
    
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    	err = initGlobalLockGrid(ctx, []PoolEndpoints{{Endpoints: Endpoints{endpoint, endpointLocal}}})
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	lkClient := newlockRESTClient(endpoint)
    	if lkClient.IsOnline() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2K bytes
    - Viewed (0)
  4. 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 Sep 07 09:35:13 UTC 2025
    - Last Modified: Tue Aug 26 06:24:29 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  5. cmd/bucket-versioning-handler.go

    )
    
    // PutBucketVersioningHandler - PUT Bucket Versioning.
    // ----------
    func (api objectAPIHandlers) PutBucketVersioningHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketVersioning")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    
    	objectAPI := api.ObjectAPI()
    	if objectAPI == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5K bytes
    - Viewed (0)
  6. cmd/globals.go

    )
    
    var globalAuthPluginMutex sync.Mutex
    
    func newGlobalAuthNPluginFn() *idplugin.AuthNPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (1)
  7. misc/go_android_exec/main.go

    	lockPath := filepath.Join(os.TempDir(), "go_android_exec-adb-lock")
    	lock, err := os.OpenFile(lockPath, os.O_CREATE|os.O_RDWR, 0666)
    	if err != nil {
    		return 0, err
    	}
    	defer lock.Close()
    	if err := syscall.Flock(int(lock.Fd()), syscall.LOCK_EX); err != nil {
    		return 0, err
    	}
    
    	// In case we're booting a device or emulator alongside all.bash, wait for
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  8. docs/debugging/s3-verify/main.go

    	wg.Add(2)
    	go func() {
    		defer wg.Done()
    		srcSize, err := io.Copy(srcSha256, sobj)
    		if err != nil {
    			fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err)
    			sourceFailed = true
    		} else if srcSize != srcCtnt.Size {
    			fmt.Printf("unreadable on source - size differs upon read: %s\n", srcCtnt.Key)
    			sourceFailed = true
    		}
    	}()
    	go func() {
    		defer wg.Done()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  9. docs/erasure/storage-class/README.md

    s3Client, err := minio.New("localhost:9000", "YOUR-ACCESSKEYID", "YOUR-SECRETACCESSKEY", true)
    if err != nil {
     log.Fatalln(err)
    }
    
    object, err := os.Open("my-testfile")
    if err != nil {
     log.Fatalln(err)
    }
    defer object.Close()
    objectStat, err := object.Stat()
    if err != nil {
     log.Fatalln(err)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  10. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Feb 27 18:43:32 UTC 2025
    - 9.7K bytes
    - Viewed (0)
Back to top