small bug fix
This commit is contained in:
11
clamd.go
11
clamd.go
@@ -28,6 +28,7 @@ package clamd
|
|||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"log"
|
||||||
"io"
|
"io"
|
||||||
"strings"
|
"strings"
|
||||||
)
|
)
|
||||||
@@ -243,15 +244,15 @@ func (c *Clamd) ScanStream(r io.Reader) (chan string, error) {
|
|||||||
buf := make([]byte, CHUNK_SIZE)
|
buf := make([]byte, CHUNK_SIZE)
|
||||||
|
|
||||||
nr, err := r.Read(buf)
|
nr, err := r.Read(buf)
|
||||||
|
if nr > 0 {
|
||||||
|
log.Printf("Error %v, %v, %v", buf[0:nr], nr, err)
|
||||||
|
conn.sendChunk(buf[0:nr])
|
||||||
|
}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
if nr == 0 {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
|
|
||||||
conn.sendChunk(buf[:nr])
|
|
||||||
}
|
}
|
||||||
|
|
||||||
err = conn.sendEOF()
|
err = conn.sendEOF()
|
||||||
|
|||||||
2
conn.go
2
conn.go
@@ -86,9 +86,7 @@ func (c *CLAMDConn) readResponse() (chan string, sync.WaitGroup, error) {
|
|||||||
|
|
||||||
// var dataArrays []string
|
// var dataArrays []string
|
||||||
go func() {
|
go func() {
|
||||||
fmt.Println("Start")
|
|
||||||
defer func() {
|
defer func() {
|
||||||
fmt.Println("Cleaning up")
|
|
||||||
close(ch)
|
close(ch)
|
||||||
wg.Done()
|
wg.Done()
|
||||||
}()
|
}()
|
||||||
|
|||||||
Reference in New Issue
Block a user