123456789101112131415161718192021222324 |
- package main
- import (
- "log"
- "net"
- "time"
- )
- type ID uint64
- func Drain(conn net.Conn, drain int) {
- conn.SetReadDeadline(time.Now().Add(time.Second * time.Duration(drain)))
- var buff []byte = make([]byte, 32)
- var n int
- var err error
- n, err = conn.Read(buff)
- if n > 0 {
- log.Printf("Drained %d bytes [%#v].\n", n, buff[:n])
- }
- if err != nil {
- log.Println("Drain:", err)
- }
- conn.SetReadDeadline(time.Time{})
- }
|