archive/nntpchan
Archived
1
0
Fork 0
Code Activity

try fix

Browse Source
This commit is contained in:
Jeff Becker
2017-10-31 12:03:15 -04:00
parent f11f67190c
commit 882da39b87
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
contrib/backends/srndv2/src/srnd/nntp.go
View File

@@ -1546,8 +1546,8 @@ func (self *nntpConnection) requestArticle(daemon *NNTPDaemon, conn *textproto.C
func (self *nntpConnection) startReader(daemon *NNTPDaemon, conn *textproto.Conn) { func (self *nntpConnection) startReader(daemon *NNTPDaemon, conn *textproto.Conn) {
log.Println(self.name, "run reader mode") log.Println(self.name, "run reader mode")
for { var err error
var err error for err == nil {
select { select {
case chnl := <-self.die: case chnl := <-self.die:
// we were asked to die // we were asked to die
@@ -1563,7 +1563,6 @@ func (self *nntpConnection) startReader(daemon *NNTPDaemon, conn *textproto.Conn
self.messageSetProcessed(msgid) self.messageSetProcessed(msgid)
if err != nil { if err != nil {
log.Println(self.name, "error while in reader mode:", err) log.Println(self.name, "error while in reader mode:", err)
break
} }
} }
} }