Skip to content

Commit 6eed814

Browse files
committed
remove gzip
1 parent bedd749 commit 6eed814

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

v2/fileio.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
package v2
1717

1818
import (
19-
"compress/gzip"
19+
"bufio"
2020
_ "encoding/gob" // make sure gob is available
2121
"encoding/json"
2222
"errors"
@@ -40,11 +40,10 @@ func (f *Filter) ReadFrom(r io.Reader) (n int64, err error) {
4040
// ReadFrom Reader r into a lossless-compressed Bloom filter f
4141
func ReadFrom(r io.Reader) (f *Filter, n int64, err error) {
4242
f = new(Filter)
43-
rawR, err := gzip.NewReader(r)
43+
rawR := bufio.NewReaderSize(r, 1*1024*1024)
4444
if err != nil {
4545
return nil, -1, err
4646
}
47-
defer rawR.Close()
4847
n, err = f.UnmarshalFromReader(rawR)
4948
if err != nil {
5049
return nil, -1, err
@@ -66,11 +65,11 @@ func ReadFile(filename string) (f *Filter, n int64, err error) {
6665

6766
// WriteTo a Writer w from lossless-compressed Bloom Filter f
6867
func (f *Filter) WriteTo(w io.Writer) (n int64, err error) {
69-
rawW := gzip.NewWriter(w)
70-
defer rawW.Close()
71-
68+
rawW := bufio.NewWriterSize(w, 1*1024*1024)
7269
intN, _, err := f.MarshallToWriter(rawW)
73-
//intN, _, err := f.MarshallToWriter(w)
70+
if err := rawW.Flush(); err != nil {
71+
return 0, err
72+
}
7473
n = int64(intN)
7574
return n, err
7675
}

0 commit comments

Comments
 (0)