Skip to content

Commit 60ed180

Browse files
committed
remove failing test as its test file is unavailable (too large).
1 parent feb996b commit 60ed180

1 file changed

Lines changed: 3 additions & 46 deletions

File tree

reader_test.go

Lines changed: 3 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -390,12 +390,12 @@ func TestReader_DirectModeStaleData(t *testing.T) {
390390
// The frame ends with: [end mark: 00 00 00 00].
391391
// Insert a zero-length uncompressed block (0x80000000) before the end mark.
392392
raw := compressed.Bytes()
393-
endMark := raw[len(raw)-4:] // last 4 bytes = end mark
394-
prefix := raw[:len(raw)-4] // everything before end mark
393+
endMark := raw[len(raw)-4:] // last 4 bytes = end mark
394+
prefix := raw[:len(raw)-4] // everything before end mark
395395
var frame bytes.Buffer
396396
frame.Write(prefix)
397397
frame.Write([]byte{0x00, 0x00, 0x00, 0x80}) // zero-length uncompressed block
398-
frame.Write(endMark) // end mark
398+
frame.Write(endMark) // end mark
399399

400400
// Read with a large buffer to force the direct path (buf >= block size)
401401
// and concurrency=1. The zero-length block triggers the bn==0 fallback
@@ -423,46 +423,3 @@ func TestReader_DirectModeStaleData(t *testing.T) {
423423
result.Len(), result.Bytes(), len(payload), payload)
424424
}
425425
}
426-
427-
func TestReader_BufferIssue(t *testing.T) {
428-
for _, opts := range [][]lz4.Option{
429-
nil,
430-
_o(lz4.ConcurrencyOption(2)),
431-
} {
432-
label := fmt.Sprintf("%v", opts)
433-
t.Run(label, func(t *testing.T) {
434-
pr, pw := io.Pipe()
435-
go func(w *io.PipeWriter) {
436-
defer w.Close()
437-
file, err := os.Open("testdata/bundle.00001.part00000.lz4")
438-
if err != nil {
439-
w.CloseWithError(err)
440-
return
441-
}
442-
defer file.Close()
443-
io.Copy(w, file)
444-
}(pw)
445-
data := make([]byte, 1024*1024*4)
446-
lz4Reader := lz4.NewReader(pr)
447-
if err := lz4Reader.Apply(opts...); err != nil {
448-
t.Fatal(err)
449-
}
450-
var total int
451-
for {
452-
n, readErr := lz4Reader.Read(data)
453-
if n > 0 {
454-
total += n
455-
}
456-
if readErr == io.EOF {
457-
break
458-
}
459-
if readErr != nil {
460-
t.Fatal(readErr)
461-
}
462-
}
463-
if total != 128*1024*1024 {
464-
t.Fatalf("incorrect number of bytes: got %d, want %d", total, 128*1024*1024)
465-
}
466-
})
467-
}
468-
}

0 commit comments

Comments
 (0)