(conn *net.UDPConn)
| 98 | } |
| 99 | |
| 100 | func RecvFromServerMulti(conn *net.UDPConn) (*bytes.Buffer, error) { |
| 101 | ret := bytes.NewBuffer(make([]byte, 0)) |
| 102 | for { |
| 103 | data, err := RecvFromServer(conn) |
| 104 | if err != nil { |
| 105 | return ret, err |
| 106 | } |
| 107 | if data.Len() < MAX_PAYLOAD_LEN { |
| 108 | if ret.Len() == 0 { |
| 109 | return data, err |
| 110 | } else { |
| 111 | ret.Write(data.Bytes()) |
| 112 | return ret, err |
| 113 | } |
| 114 | } |
| 115 | ret.Write(data.Bytes()) |
| 116 | } |
| 117 | return ret, nil |
| 118 | } |
| 119 | |
| 120 | func CommmandGetResult(mid ModuleId, operate int, arg string) (string, error) { |
| 121 | _, result, err := SendToServer(mid, ModuleOperate(operate), bytes.NewBuffer([]byte(arg))) |
no test coverage detected