Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for coroutines (0.15 sec)

  1. cmd/bucket-replication.go

    	defer p.mrfMU.Unlock()
    
    	if !p.initialized() {
    		return errServerNotInitialized
    	}
    
    	mrfRec, err := p.loadMRF()
    	if err != nil {
    		return err
    	}
    
    	// queue replication heal in a goroutine to avoid holding up mrf save routine
    	go func() {
    		for vID, e := range mrfRec.Entries {
    			ctx, cancel := context.WithTimeout(p.ctx, time.Second) // Do not waste more than a second on this.
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. cmd/metrics-v2.go

    		Type:      counterMetric,
    	}
    }
    
    func getMinIOGORoutineCountMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: goRoutines,
    		Name:      total,
    		Help:      "Total number of go routines running",
    		Type:      gaugeMetric,
    	}
    }
    
    func getMinIOProcessStartTimeMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    	// Wait till all go routines finishes execution.
    	wg.Wait()
    	// Validate the upload ID by an attempt to list parts using it.
    	for _, uploadID := range testUploads.uploads {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
  4. src/cmd/cgo/internal/test/callback.go

    		}
    	}()
    	C.callPanic()
    }
    
    // Test that C code can return a value if it calls a Go function that
    // causes a stack copy.
    func testReturnAfterGrow(t *testing.T) {
    	// Use a new goroutine so that we get a small stack.
    	c := make(chan int)
    	go func() {
    		c <- int(C.returnAfterGrow())
    	}()
    	if got, want := <-c, 123456; got != want {
    		t.Errorf("got %d want %d", got, want)
    	}
    }
    
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri May 12 12:00:02 GMT 2023
    - 111.5K bytes
    - Viewed (0)
Back to top