CEF/ergo
1
0
Fork 0
forked from External/ergo
Code Pull requests Activity

Implement mode [+-]i.

Browse source
This commit is contained in:
Jeremy Latt 2012-04-17 20:24:26 -07:00
parent 8f0bd1b07a
commit 99364e8b5f
7 changed files with 94 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/irc/net.go
View file

@ -16,12 +16,13 @@ func readTrimmedLine(reader *bufio.Reader) (string, error) {
func StringReadChan(conn net.Conn) <-chan string {
ch := make(chan string)
reader := bufio.NewReader(conn)
addr := conn.RemoteAddr()
go func() {
for {
line, err := readTrimmedLine(reader)
if (line != "") {
ch <- line
log.Printf("%s -> %s", conn.RemoteAddr(), line)
log.Printf("%s -> %s", addr, line)
}
if err != nil {
break
@ -35,13 +36,14 @@ func StringReadChan(conn net.Conn) <-chan string {
func StringWriteChan(conn net.Conn) chan<- string {
ch := make(chan string)
writer := bufio.NewWriter(conn)
addr := conn.RemoteAddr()
go func() {
for str := range ch {
if _, err := writer.WriteString(str + "\r\n"); err != nil {
break
}
writer.Flush()
log.Printf("%s <- %s", conn.RemoteAddr(), str)
log.Printf("%s <- %s", addr, str)
}
close(ch)
}()