mirror of
https://github.com/fumiama/water.git
synced 2026-06-27 15:30:24 +08:00
more logging in ipv4_test
This commit is contained in:
@@ -15,8 +15,9 @@ func startRead(ch chan<- []byte, ifce *Interface) {
|
|||||||
go func() {
|
go func() {
|
||||||
for {
|
for {
|
||||||
buffer := make([]byte, BUFFERSIZE)
|
buffer := make([]byte, BUFFERSIZE)
|
||||||
_, err := ifce.Read(buffer)
|
n, err := ifce.Read(buffer)
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
buffer = buffer[:n:n]
|
||||||
ch <- buffer
|
ch <- buffer
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -73,6 +74,7 @@ readFrame:
|
|||||||
if waterutil.IPv4Protocol(packet) != waterutil.ICMP {
|
if waterutil.IPv4Protocol(packet) != waterutil.ICMP {
|
||||||
continue readFrame
|
continue readFrame
|
||||||
}
|
}
|
||||||
|
t.Logf("received broadcast frame: %#v\n", buffer)
|
||||||
break readFrame
|
break readFrame
|
||||||
case <-timeout:
|
case <-timeout:
|
||||||
t.Fatal("Waiting for broadcast packet timeout")
|
t.Fatal("Waiting for broadcast packet timeout")
|
||||||
|
|||||||
Reference in New Issue
Block a user