WIP test-client: implementing sendUDP
This commit is contained in:
parent
66662bd26e
commit
024e4cba4f
@ -83,7 +83,30 @@ func sendTCP() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func sendUDP() {
|
func sendUDP() {
|
||||||
//TODO: implement this part
|
var (
|
||||||
|
addr *net.UDPAddr
|
||||||
|
conn *net.UDPConn
|
||||||
|
err error
|
||||||
|
buf, b []byte
|
||||||
|
)
|
||||||
|
|
||||||
|
if addr, err = net.ResolveUDPAddr("udp", viper.GetString("server")); err != nil {
|
||||||
|
log.Fatal().Err(err).Str("server", viper.GetString("server")).Msg("udp resolve address")
|
||||||
|
}
|
||||||
|
|
||||||
|
if conn, err = net.DialUDP("udp", nil, addr); err != nil {
|
||||||
|
log.Fatal().Err(err).Str("server", viper.GetString("server")).Msg("dial server udp")
|
||||||
|
}
|
||||||
|
|
||||||
|
buf = make([]byte, 4096)
|
||||||
|
for {
|
||||||
|
sb := slicewriter.NewSliceWriter(buf)
|
||||||
|
if _, err = fmt.Fprintf(sb, "client %s | %v | %s", viper.GetString("name"), time.Now(), viper.GetString("message")); err != nil {
|
||||||
|
log.Fatal().Err(err).Msg("Failed to build client message")
|
||||||
|
}
|
||||||
|
b = sb.Bytes()
|
||||||
|
}
|
||||||
|
//TODO: complete the implementation of sendUDP
|
||||||
}
|
}
|
||||||
|
|
||||||
func parseFlags() {
|
func parseFlags() {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user