Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for parallelReader (0.16 sec)

  1. cmd/erasure-decode.go

    func (p *parallelReader) Done() {
    	if p.stashBuffer != nil {
    		globalBytePoolCap.Load().Put(p.stashBuffer)
    		p.stashBuffer = nil
    	}
    }
    
    // preferReaders can mark readers as preferred.
    // These will be chosen before others.
    func (p *parallelReader) preferReaders(prefer []bool) {
    	if len(prefer) != len(p.orgReaders) {
    		return
    	}
    	// Copy so we don't change our input.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex_test.go

    	}
    }
    
    // Test cases below are copied 1 to 1 from sync/rwmutex_test.go (adapted to use DRWMutex)
    
    // Borrowed from rwmutex_test.go
    func parallelReader(ctx context.Context, m *DRWMutex, clocked, cunlock, cdone chan bool) {
    	if m.GetRLock(ctx, nil, id, source, Options{Timeout: time.Second}) {
    		clocked <- true
    		<-cunlock
    		m.RUnlock(context.Background())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  3. internal/lsync/lrwmutex_test.go

    	}
    }
    
    // Test cases below are copied 1 to 1 from sync/rwmutex_test.go (adapted to use LRWMutex)
    
    // Borrowed from rwmutex_test.go
    func parallelReader(ctx context.Context, m *LRWMutex, clocked, cunlock, cdone chan bool) {
    	if m.GetRLock(ctx, "", "", time.Second) {
    		clocked <- true
    		<-cunlock
    		m.RUnlock()
    		cdone <- true
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top