Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for startBlock (0.1 sec)

  1. cmd/erasure-decode.go

    		reader.preferReaders(prefer)
    	}
    	defer reader.Done()
    
    	startBlock := offset / e.blockSize
    	endBlock := (offset + length) / e.blockSize
    
    	var bytesWritten int64
    	var bufs [][]byte
    	for block := startBlock; block <= endBlock; block++ {
    		var blockOffset, blockLength int64
    		switch {
    		case startBlock == endBlock:
    			blockOffset = offset % e.blockSize
    			blockLength = length
    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/event/targetlist.go

    	failedEvents int64
    }
    
    func (list *TargetList) getStatsByTargetID(id TargetID) (stat targetStat) {
    	list.statLock.RLock()
    	defer list.statLock.RUnlock()
    
    	return list.targetStats[id]
    }
    
    func (list *TargetList) incCurrentSendCalls(id TargetID) {
    	list.statLock.Lock()
    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    		stats = targetStat{}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. src/test/java/jcifs/tests/ConcurrencyTest.java

                this.file = smbFile;
            }
    
    
            public void waitForStart () throws InterruptedException {
                synchronized ( this.startedLock ) {
                    while ( !this.started ) {
                        this.startedLock.wait();
                    }
                }
            }
    
    
            public void shutdown () {
                this.shutdown = true;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
Back to top