Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
net: add multicast UDP support for plan9
The new implementation adds listening support on a multicast address with plan9 network interfaces. Fixes #17218 Change-Id: I2c75515e72e120acb71610cd077fddfbf9cf4e29 Reviewed-on: https://go-review.googlesource.com/29964 Reviewed-by: Brad Fitzpatrick <bradfitz@golang.org> Run-TryBot: Brad Fitzpatrick <bradfitz@golang.org> TryBot-Result: Gobot Gobot <gobot@golang.org>
- Loading branch information
1 parent
a7c8466
commit e4820bc
Showing
3 changed files
with
107 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,69 @@ | ||
// Copyright 2016 The Go Authors. All rights reserved. | ||
// Use of this source code is governed by a BSD-style | ||
// license that can be found in the LICENSE file. | ||
|
||
package net | ||
|
||
import ( | ||
"internal/testenv" | ||
"runtime" | ||
"testing" | ||
) | ||
|
||
func TestListenMulticastUDP(t *testing.T) { | ||
testenv.MustHaveExternalNetwork(t) | ||
|
||
ifcs, err := Interfaces() | ||
if err != nil { | ||
t.Skip(err.Error()) | ||
} | ||
if len(ifcs) == 0 { | ||
t.Skip("no network interfaces found") | ||
} | ||
|
||
var mifc *Interface | ||
for _, ifc := range ifcs { | ||
if ifc.Flags&FlagUp|FlagMulticast != FlagUp|FlagMulticast { | ||
continue | ||
} | ||
mifc = &ifc | ||
break | ||
} | ||
|
||
if mifc == nil { | ||
t.Skipf("no multicast interfaces found") | ||
} | ||
|
||
c1, err := ListenMulticastUDP("udp4", mifc, &UDPAddr{IP: ParseIP("224.0.0.254")}) | ||
if err != nil { | ||
t.Fatalf("multicast not working on %s", runtime.GOOS) | ||
} | ||
c1addr := c1.LocalAddr().(*UDPAddr) | ||
if err != nil { | ||
t.Fatal(err) | ||
} | ||
defer c1.Close() | ||
|
||
c2, err := ListenUDP("udp4", &UDPAddr{IP: IPv4zero, Port: 0}) | ||
c2addr := c2.LocalAddr().(*UDPAddr) | ||
if err != nil { | ||
t.Fatal(err) | ||
} | ||
defer c2.Close() | ||
|
||
n, err := c2.WriteToUDP([]byte("data"), c1addr) | ||
if err != nil { | ||
t.Fatal(err) | ||
} | ||
if n != 4 { | ||
t.Fatalf("got %d; want 4", n) | ||
} | ||
|
||
n, err = c1.WriteToUDP([]byte("data"), c2addr) | ||
if err != nil { | ||
t.Fatal(err) | ||
} | ||
if n != 4 { | ||
t.Fatalf("got %d; want 4", n) | ||
} | ||
} |