- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 392 for defer (0.01 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
docs/erasure/storage-class/README.md
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 5.9K bytes - Viewed (0) -
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)