- buf_net = make([]byte, BUF_SIZE)
- _, err := client.conn.Read(buf_net)
+ if prev == BufSize {
+ log.Println(client, "buffer size exceeded, kicking him")
+ sink <- ClientEvent{client, EventDel, ""}
+ client.conn.Close()
+ break
+ }
+ n, err = client.conn.Read(buf[prev:])