Skip to content

Commit 8d38c56

Browse files
committed
(#301) Fix runaway CPU usage after 'test' cmd
1 parent 974700e commit 8d38c56

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

jobberrunner/testjob/test_job_server.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package testjob
33
import (
44
"context"
55
"fmt"
6-
"io"
76
"io/ioutil"
87
"net"
98
"os"
@@ -107,6 +106,7 @@ func (self *TestJobServer) serve(job *jobfile.Job, listener net.Listener, sockDi
107106
// wait for subproc to finish
108107
result = <-thread.ResultChan()
109108
}
109+
common.Logger.Println("test thread done")
110110

111111
// report result
112112
conn.Write([]byte("\n\n"))
@@ -139,7 +139,7 @@ func callWhenConnClosed(conn net.Conn, cb func()) {
139139
var buf [1]byte
140140
for {
141141
_, err := conn.Read(buf[:])
142-
if err == io.EOF {
142+
if err != nil {
143143
cb()
144144
return
145145
}

0 commit comments

Comments
 (0)