github/ping
1
0
Fork 0
mirror of https://github.com/go-ping/ping.git synced 2025-04-30 19:53:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added ICMP Packet ID to distinguish ICMP replies in multithreading environment (#15)

Browse Source
This commit is contained in:
webfrank 2018-08-29 19:21:50 +02:00 committed by Cameron Sparr
parent 5740bb1ff1
commit d046b24518
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
ping.go
View File

@ -90,7 +90,10 @@ func NewPinger(addr string) (*Pinger, error) {
Interval: time.Second, Interval: time.Second,
Timeout: time.Second * 100000, Timeout: time.Second * 100000,
Count: -1, Count: -1,
id: rand.Intn(0xffff),
network: "udp",
ipv4: ipv4,
size: timeSliceLength,
network: "udp", network: "udp",
ipv4: ipv4, ipv4: ipv4,
Size: timeSliceLength, Size: timeSliceLength,
@ -140,9 +143,10 @@ type Pinger struct {
ipaddr *net.IPAddr ipaddr *net.IPAddr
addr string addr string
ipv4 bool ipv4 bool
source string source string
size int
id int
sequence int sequence int
network string network string
} }
@ -430,6 +434,12 @@ func (p *Pinger) processPacket(recv *packet) error {
return nil return nil
} }
// Check if reply from same ID
body := m.Body.(*icmp.Echo)
if body.ID != p.id {
return nil
}
outPkt := &Packet{ outPkt := &Packet{
Nbytes: recv.nbytes, Nbytes: recv.nbytes,
IPAddr: p.ipaddr, IPAddr: p.ipaddr,
@ -475,7 +485,7 @@ func (p *Pinger) sendICMP(conn *icmp.PacketConn) error {
bytes, err := (&icmp.Message{ bytes, err := (&icmp.Message{
Type: typ, Code: 0, Type: typ, Code: 0,
Body: &icmp.Echo{ Body: &icmp.Echo{
ID: rand.Intn(65535), ID: p.id,
Seq: p.sequence, Seq: p.sequence,
Data: t, Data: t,
}, },