- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 392 for defer (0.03 sec)
-
cmd/batch-rotate.go
lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID, Versioned: versioned, VersionSuspended: versionSuspended, NoLock: true, }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 14.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
} return } } // DetectTestLeak - snapshots the currently running goroutines and returns a // function to be run at the end of tests to see whether any // goroutines leaked. // Usage: `defer DetectTestLeak(t)()` in beginning line of benchmarks or unit tests. func DetectTestLeak(t TestErrHandler) func() { initialStackSnapShot := NewLeakDetect() return func() { initialStackSnapShot.DetectLeak(t) } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.2K bytes - Viewed (0) -
docs/sts/web-identity.go
if err != nil { return d, err } clnt := http.Client{ Transport: http.DefaultTransport, } resp, err := clnt.Do(req) if err != nil { return d, err } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return d, fmt.Errorf("unexpected error returned by %s : status(%s)", ustr, resp.Status) } dec := json.NewDecoder(resp.Body) if err = dec.Decode(&d); err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 19 09:13:33 UTC 2023 - 7.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/transport/Transport.java
* return which would render the timeout effectively useless. */ doConnect(); } catch (final Exception ex) { ex0 = ex; // Defer to below where we're locked return; } finally { synchronized (run_thread) { if (run_thread != thread) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.3K bytes - Viewed (0) -
src/bytes/buffer_test.go
// Confirm that when Reader panics, the empty buffer remains empty var buf2 Buffer defer func() { recover() check(t, "TestReadFromPanicReader (2)", &buf2, "") }() buf2.ReadFrom(panicReader{panic: true}) } func TestReadFromNegativeReader(t *testing.T) { var b Buffer defer func() { switch err := recover().(type) { case nil: t.Fatal("bytes.Buffer.ReadFrom didn't panic")
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon May 19 16:13:04 UTC 2025 - 18.6K bytes - Viewed (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 8K bytes - Viewed (0) -
cmd/generic-handlers_test.go
{URL: &url.URL{}, Header: http.Header{xhttp.AmzServerSideEncryptionCopyCustomerAlgorithm: []string{""}}, IsTLS: false, ShouldFail: true}, // 4 } func TestSSETLSHandler(t *testing.T) { defer func(isSSL bool) { globalIsTLS = isSSL }(globalIsTLS) // reset globalIsTLS after test var okHandler http.HandlerFunc = func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusOK) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.2K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
XL xl `json:"xl"` } func getMountMap() (map[string]string, error) { result := make(map[string]string) mountInfo, err := os.Open("/proc/self/mountinfo") if err != nil { return nil, err } defer mountInfo.Close() scanner := bufio.NewScanner(mountInfo) for scanner.Scan() { s := strings.Split(scanner.Text(), " ") if len(s) != 11 { return nil, errors.New("unsupported /proc/self/mountinfo format") }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/server-main.go
}() go func() { if globalEnableSyncBoot { defer bootstrapTrace("unfreezeServices", unfreezeServices) t := time.AfterFunc(5*time.Minute, func() { warnings = append(warnings, color.YellowBold("- Initializing the config subsystem is taking longer than 5 minutes. Please remove 'MINIO_SYNC_BOOT=on' to not freeze the APIs")) }) defer t.Stop() } // Initialize data scanner.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
guava/src/com/google/common/cache/CacheLoader.java
* * <p>This method should be overridden when bulk retrieval is significantly more efficient than * many individual lookups. Note that {@link LoadingCache#getAll} will defer to individual calls * to {@link LoadingCache#get} if this method is not overridden. * * @param keys the unique, non-null keys whose values should be loaded
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 9.5K bytes - Viewed (0)