Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 392 for defer (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/mvn/MavenOptions.java

         */
        @Nonnull
        Optional<Boolean> failFast();
    
        /**
         * Indicates whether Maven should run all builds but defer error reporting to the end.
         *
         * @return an {@link Optional} containing true if error reporting should be deferred to the end, false if not, or empty if not specified
         */
        @Nonnull
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jun 11 13:14:09 UTC 2025
    - 8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top