@@ -20,7 +20,6 @@ import (
20
20
"github.com/rfjakob/gocryptfs/v2/internal/contentenc"
21
21
"github.com/rfjakob/gocryptfs/v2/internal/inomap"
22
22
"github.com/rfjakob/gocryptfs/v2/internal/openfiletable"
23
- "github.com/rfjakob/gocryptfs/v2/internal/serialize_reads"
24
23
"github.com/rfjakob/gocryptfs/v2/internal/stupidgcm"
25
24
"github.com/rfjakob/gocryptfs/v2/internal/syscallcompat"
26
25
"github.com/rfjakob/gocryptfs/v2/internal/tlog"
@@ -252,13 +251,7 @@ func (f *File) Read(ctx context.Context, buf []byte, off int64) (resultData fuse
252
251
defer f .fileTableEntry .ContentLock .RUnlock ()
253
252
254
253
tlog .Debug .Printf ("ino%d: FUSE Read: offset=%d length=%d" , f .qIno .Ino , off , len (buf ))
255
- if f .rootNode .args .SerializeReads {
256
- serialize_reads .Wait (off , len (buf ))
257
- }
258
254
out , errno := f .doRead (buf [:0 ], uint64 (off ), uint64 (len (buf )))
259
- if f .rootNode .args .SerializeReads {
260
- serialize_reads .Done ()
261
- }
262
255
if errno != 0 {
263
256
return nil , errno
264
257
}
@@ -389,6 +382,7 @@ func (f *File) Write(ctx context.Context, data []byte, off int64) (uint32, sysca
389
382
// But if the write directly follows an earlier write, it cannot create a
390
383
// hole, and we can save one Stat() call.
391
384
if ! f .isConsecutiveWrite (off ) {
385
+ fmt .Printf ("isConsecutiveWrite=false, off=%d\n " , off )
392
386
errno := f .writePadHole (off )
393
387
if errno != 0 {
394
388
return 0 , errno
0 commit comments