- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for startBlock (0.1 sec)
-
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) -
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) -
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)