Close opened files
This commit is contained in:
parent
63186e34b3
commit
0416e0aa9c
4
group.go
4
group.go
|
@ -444,6 +444,7 @@ func (g *Group) readGroupInfo() GroupInfo {
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
|
defer dir.Close()
|
||||||
fiz, err := dir.Readdir(0)
|
fiz, err := dir.Readdir(0)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
|
@ -598,6 +599,9 @@ func (gr *GroupReader) openFile(index int) error {
|
||||||
curReader := bufio.NewReader(curFile)
|
curReader := bufio.NewReader(curFile)
|
||||||
|
|
||||||
// Update gr.cur*
|
// Update gr.cur*
|
||||||
|
if gr.curFile != nil {
|
||||||
|
gr.curFile.Close() // TODO return error?
|
||||||
|
}
|
||||||
gr.curIndex = index
|
gr.curIndex = index
|
||||||
gr.curFile = curFile
|
gr.curFile = curFile
|
||||||
gr.curReader = curReader
|
gr.curReader = curReader
|
||||||
|
|
Loading…
Reference in New Issue