|
@@ -105,11 +105,11 @@ func (c *ChunkReadAt) Close() error {
|
|
|
|
|
|
func (c *ChunkReadAt) ReadAt(p []byte, offset int64) (n int, err error) {
|
|
|
|
|
|
+ c.readerPattern.MonitorReadAt(offset, len(p))
|
|
|
+
|
|
|
c.readerLock.Lock()
|
|
|
defer c.readerLock.Unlock()
|
|
|
|
|
|
- c.readerPattern.MonitorReadAt(offset, len(p))
|
|
|
-
|
|
|
|
|
|
return c.doReadAt(p, offset)
|
|
|
}
|