(conn net.Conn, version int)
| 126 | } |
| 127 | |
| 128 | func WriteUDPHeader(conn net.Conn, version int) error { |
| 129 | if version < Version3 { |
| 130 | return errors.New("unsupport UDP version") |
| 131 | } |
| 132 | |
| 133 | // version, command, clientID length |
| 134 | _, err := conn.Write([]byte{Version, CommandUDP, 0x00}) |
| 135 | return err |
| 136 | } |
| 137 | |
| 138 | func writeZeroChunk(conn net.Conn) error { |
| 139 | if _, err := conn.Write(endSignal); err != nil { |
no test coverage detected