|
@ -51,7 +51,7 @@ func (pw *PageWriter) FlushData() error { |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
func (pw *PageWriter) ReadDirtyDataAt(data []byte, offset int64, tsNs int64) (maxStop int64) { |
|
|
func (pw *PageWriter) ReadDirtyDataAt(data []byte, offset int64, tsNs int64) (maxStop int64) { |
|
|
glog.V(4).Infof("ReadDirtyDataAt %v [%d, %d)", pw.fh.fh, offset, offset+int64(len(data))) |
|
|
|
|
|
|
|
|
glog.V(4).Infof("ReadDirtyDataAt %v [%d, %d)", pw.fh.inode, offset, offset+int64(len(data))) |
|
|
|
|
|
|
|
|
chunkIndex := offset / pw.chunkSize |
|
|
chunkIndex := offset / pw.chunkSize |
|
|
for i := chunkIndex; len(data) > 0; i++ { |
|
|
for i := chunkIndex; len(data) > 0; i++ { |
|
|