Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 1,043 for channel (2.58 sec)

  1. internal/grid/grid_test.go

    			close(nowBlocking)
    			// Block until test is done.
    			<-stopBlocking
    			return nil
    		})
    	}()
    
    	<-nowBlocking
    	// Wait for the receiver channel to fill.
    	for len(st.responses) != cap(st.responses) {
    		time.Sleep(time.Millisecond)
    	}
    	cancel()
    	<-serverCanceled
    	local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) {
    		if !closed {
    			t.Error("expected outgoing closed")
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  2. RELEASE.md

    ### Bug Fixes and Other Changes
    
    * <SIMILAR TO ABOVE SECTION, BUT FOR OTHER IMPORTANT CHANGES / BUG FIXES>
    * <IF A CHANGE CLOSES A GITHUB ISSUE, IT SHOULD BE DOCUMENTED HERE>
    * <NOTES SHOULD BE GROUPED PER AREA>
    
    ## Keras
    
    <INSERT SMALL BLURB ABOUT RELEASE FOCUS AREA AND POTENTIAL TOOLCHAIN CHANGES>
    
    ### Breaking Changes
    
    * <DOCUMENT BREAKING CHANGES HERE>
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Oct 22 14:33:53 UTC 2024
    - 735.3K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    	rng := rand.New(rand.NewSource(time.Now().UTC().UnixNano()))
    	var d net.Dialer
    	var retry int
    	for retry < len(hosts) {
    		ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond)
    
    		host = hosts[rng.Intn(len(hosts))]
    		conn, err := d.DialContext(ctx, "tcp", host)
    		cancel()
    		if err != nil {
    			retry++
    			continue
    		}
    		conn.Close()
    		break
    	}
    
    	return host
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    // scanDataFolder will scanner the basepath+cache.Info.Name and return an updated cache.
    // The returned cache will always be valid, but may not be updated from the existing.
    // Before each operation sleepDuration is called which can be used to temporarily halt the scanner.
    // If the supplied context is canceled the function will return at the first chance.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    	}
    
    	// Start profiling on remote servers.
    	for _, profiler := range profiles {
    		// Limit start time to max 10s.
    		ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    		globalNotificationSys.StartProfiling(ctx, profiler)
    		// StartProfiling blocks, so we can cancel now.
    		cancel()
    
    		// Start profiling locally as well.
    		prof, err := startProfiler(profiler)
    		if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.14.md

        - [Other notable changes](#other-notable-changes)
    - [v1.14.9](#v1149)
      - [Downloads for v1.14.9](#downloads-for-v1149)
        - [Client Binaries](#client-binaries-1)
        - [Server Binaries](#server-binaries-1)
        - [Node Binaries](#node-binaries-1)
      - [Changelog since v1.14.8](#changelog-since-v1148)
        - [Other notable changes](#other-notable-changes-1)
    - [v1.14.8](#v1148)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Mon Jun 14 22:06:39 UTC 2021
    - 271.5K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.32.md

      - [Changes by Kind](#changes-by-kind)
        - [API Change](#api-change)
        - [Feature](#feature)
        - [Documentation](#documentation)
        - [Bug or Regression](#bug-or-regression)
        - [Other (Cleanup or Flake)](#other-cleanup-or-flake)
      - [Dependencies](#dependencies)
        - [Added](#added)
        - [Changed](#changed)
        - [Removed](#removed)
    - [v1.32.0-alpha.2](#v1320-alpha2)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.29.md

        - [Container Images](#container-images-2)
      - [Changelog since v1.29.7](#changelog-since-v1297)
      - [Changes by Kind](#changes-by-kind-2)
        - [API Change](#api-change)
        - [Bug or Regression](#bug-or-regression-2)
      - [Dependencies](#dependencies-2)
        - [Added](#added-2)
        - [Changed](#changed-2)
        - [Removed](#removed-2)
    - [v1.29.7](#v1297)
      - [Downloads for v1.29.7](#downloads-for-v1297)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:37:31 UTC 2024
    - 375.1K bytes
    - Viewed (1)
  9. cmd/erasure-object.go

    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    				done <- false
    				continue
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    
    	ctx, cancel := context.WithCancel(ctx)
    	defer cancel()
    
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	var results []dataUsageCache
    	var firstErr error
    
    	allBuckets, err := z.ListBuckets(ctx, BucketOptions{})
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top