archive/nntpchan
Archived
1
0
Fork 0
Code Activity

make it work

Browse Source
This commit is contained in:
Jeff Becker
2017-09-20 12:45:24 -04:00
parent 693b399f10
commit 3097cea3a4
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -68,7 +68,7 @@ type nntpConnection struct {
// ARTICLE <message-id> // ARTICLE <message-id>
article chan string article chan string
// map of message-id -> stream state // map of message-id -> stream state
pending map[string]syncEvent pending map[string]*syncEvent
// lock for accessing self.pending map // lock for accessing self.pending map
pending_access sync.Mutex pending_access sync.Mutex
@@ -122,7 +122,7 @@ func createNNTPConnection(addr string) *nntpConnection {
return &nntpConnection{ return &nntpConnection{
hostname: host, hostname: host,
article: make(chan string, 1024), article: make(chan string, 1024),
pending: make(map[string]syncEvent), pending: make(map[string]*syncEvent),
} }
} }
@@ -297,6 +297,7 @@ func (self *nntpConnection) handleStreamEvent(ev nntpStreamEvent, daemon *NNTPDa
} }
} else if cmd == "CHECK" { } else if cmd == "CHECK" {
conn.PrintfLine("%s", ev) conn.PrintfLine("%s", ev)
self.pending[msgid].state = "pending"
} else { } else {
log.Println("invalid stream command", ev) log.Println("invalid stream command", ev)
} }
@@ -330,7 +331,7 @@ func (self *nntpConnection) messageSetPendingState(msgid, state string, sz int64
s.state = state s.state = state
self.pending[msgid] = s self.pending[msgid] = s
} else { } else {
self.pending[msgid] = syncEvent{msgid: msgid, sz: sz, state: state} self.pending[msgid] = &syncEvent{msgid: msgid, sz: sz, state: state}
} }
self.pending_access.Unlock() self.pending_access.Unlock()
} }