Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 78 for go_routine (0.14 sec)

  1. internal/rest/client.go

    		sleep := min(unit*time.Duration(1<<attempt), maxSleep)
    		sleep -= time.Duration(r.Float64() * float64(sleep-unit))
    		return sleep
    	}
    }
    
    func (c *Client) runHealthCheck() bool {
    	// Start goroutine that will attempt to reconnect.
    	// If server is already trying to reconnect this will have no effect.
    	if c.HealthCheckFn != nil && atomic.CompareAndSwapInt32(&c.connected, online, offline) {
    		go func() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. internal/ringbuffer/ring_buffer.go

    )
    
    // RingBuffer is a circular buffer that implement io.ReaderWriter interface.
    // It operates like a buffered pipe, where data written to a RingBuffer
    // and can be read back from another goroutine.
    // It is safe to concurrently read and write RingBuffer.
    type RingBuffer struct {
    	buf       []byte
    	size      int
    	r         int // next position to read
    	w         int // next position to write
    	isFull    bool
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  3. internal/dsync/drwmutex_test.go

    	}
    	// Wait for all parallel RLock()s to succeed.
    	for range numReaders {
    		<-clocked
    	}
    	for range numReaders {
    		cunlock <- true
    	}
    	// Wait for the goroutines to finish.
    	for range numReaders {
    		<-cdone
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func TestParallelReaders(t *testing.T) {
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(-1))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  4. cmd/data-scanner_test.go

    		LockEnabled: true,
    	}
    
    	expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) {
    		defer wg.Done()
    		// signal the calling goroutine that the worker is ready tor receive tasks
    		close(readyCh)
    		var expired []ObjectToDelete
    		for t := range taskCh {
    			switch v := t.(type) {
    			case noncurrentVersionsTask:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  5. internal/s3select/json/preader.go

    const jsonSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    // If an error is returned no goroutines have been started and r.err will have been set.
    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() []byte {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. cmd/admin-handlers_test.go

    	}
    
    	result := &serviceResult{}
    	if err := json.Unmarshal(resp, result); err != nil {
    		t.Error(err)
    	}
    	_ = result
    
    	// Wait until testServiceSignalReceiver() called in a goroutine quits.
    	wg.Wait()
    }
    
    // Test for service restart management REST API.
    func TestServiceRestartHandler(t *testing.T) {
    	testServicesCmdHandler(restartCmd, t)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  7. internal/lsync/lrwmutex_test.go

    	}
    	// Wait for all parallel RLock()s to succeed.
    	for range numReaders {
    		<-clocked
    	}
    	for range numReaders {
    		cunlock <- true
    	}
    	// Wait for the goroutines to finish.
    	for range numReaders {
    		<-cdone
    	}
    }
    
    // Borrowed from rwmutex_test.go
    func TestParallelReaders(t *testing.T) {
    	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(-1))
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  8. cmd/sftp-server-driver.go

    }
    
    func (f *sftpDriver) Filewrite(r *sftp.Request) (w io.WriterAt, err error) {
    	stopFn := globalSftpMetrics.log(r, f.AccessKey())
    	defer func() {
    		if err != nil {
    			// If there is an error, we never started the goroutine.
    			stopFn(0, err)
    		}
    	}()
    
    	flags := r.Pflags()
    	if !flags.Write {
    		// sanity check
    		return nil, os.ErrInvalid
    	}
    
    	bucket, object := path2BucketObject(r.Filepath)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  9. docs/de/docs/_llm-test.md

    * der `APIRouter`
    * die `requirements.txt`
    * das Bearer-Token
    * der Breaking Change
    * der Bug
    * der Button
    * das Callable
    * der Code
    * der Commit
    * der Contextmanager
    * die Coroutine
    * die Datenbanksession
    * die Festplatte
    * die Domain
    * die Engine
    * das Fake-X
    * die HTTP-GET-Methode
    * das Item
    * die Bibliothek
    * der Lifespan
    * der Lock
    * die Middleware
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 07:17:04 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  10. cmd/batch-expire.go

    				cancelCause(err)
    				xioutil.SafeClose(results)
    				return
    			}
    			for result := range prefixResultCh {
    				results <- result
    			}
    		}
    		xioutil.SafeClose(results)
    	}()
    
    	// Goroutine to periodically save batch-expire job's in-memory state
    	saverQuitCh := make(chan struct{})
    	go func() {
    		saveTicker := time.NewTicker(10 * time.Second)
    		defer saveTicker.Stop()
    		quit := false
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Apr 22 11:16:32 UTC 2025
    - 23K bytes
    - Viewed (0)
Back to top