- bufNet = make([]byte, BufSize)
- _, err := client.conn.Read(bufNet)
+ 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:])