sneak/go-ircevent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Kill channels for fater retry

Browse Source
This commit is contained in:
tj 2010-10-11 21:17:17 +02:00
parent fd854c475a
commit 1fe11ca937
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
irc.go
View File

@ -62,7 +62,7 @@ func writer(irc *IRCConnection) {
for !error { for !error {
b := []byte(<-irc.pwrite) b := []byte(<-irc.pwrite)
if b == nil || irc.socket == nil { if b == nil || irc.socket == nil {
return break
} }
_, err := irc.socket.Write(b) _, err := irc.socket.Write(b)
if err != nil { if err != nil {
@ -108,6 +108,8 @@ func (irc *IRCConnection) SendRaw(message string) {
} }
func (i *IRCConnection) Reconnect() os.Error { func (i *IRCConnection) Reconnect() os.Error {
close(i.pwrite)
close(i.pread)
<-i.syncreader <-i.syncreader
<-i.syncwriter <-i.syncwriter
for { for {