b612/starnet
1
0
Fork 0
Code Issues Pull Requests Projects Releases 13 Wiki Activity

update go mod and improve icmp result

Browse Source
This commit is contained in:
兔子 2023-02-11 17:15:01 +08:00
parent b92288bbc9
commit be3df9703e
3 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
curl.go
View File

@ -22,6 +22,7 @@ const (
HEADER_FORM_URLENCODE = `application/x-www-form-urlencoded` HEADER_FORM_URLENCODE = `application/x-www-form-urlencoded`
HEADER_FORM_DATA = `multipart/form-data` HEADER_FORM_DATA = `multipart/form-data`
HEADER_JSON = `application/json` HEADER_JSON = `application/json`
HEADER_PLAIN = `text/plain`
) )
type RequestFile struct { type RequestFile struct {

13
ping.go
View File

@ -33,6 +33,7 @@ func getICMP(seq uint16) ICMP {
func sendICMPRequest(icmp ICMP, destAddr *net.IPAddr, timeout time.Duration) (PingResult, error) { func sendICMPRequest(icmp ICMP, destAddr *net.IPAddr, timeout time.Duration) (PingResult, error) {
var res PingResult var res PingResult
res.RemoteIP = destAddr.String()
conn, err := net.DialIP("ip:icmp", nil, destAddr) conn, err := net.DialIP("ip:icmp", nil, destAddr)
if err != nil { if err != nil {
return res, err return res, err
@ -84,6 +85,7 @@ func checkSum(data []byte) uint16 {
type PingResult struct { type PingResult struct {
Duration time.Duration Duration time.Duration
RecvCount int RecvCount int
RemoteIP string
} }
func Ping(ip string, seq int, timeout time.Duration) (PingResult, error) { func Ping(ip string, seq int, timeout time.Duration) (PingResult, error) {
@ -95,3 +97,14 @@ func Ping(ip string, seq int, timeout time.Duration) (PingResult, error) {
icmp := getICMP(uint16(seq)) icmp := getICMP(uint16(seq))
return sendICMPRequest(icmp, ipAddr, timeout) return sendICMPRequest(icmp, ipAddr, timeout)
} }
func IsIpPingable(ip string, timeout time.Duration, retryLimit int) bool {
for i := 0; i < retryLimit; i++ {
_, err := Ping(ip, 29, timeout)
if err != nil {
continue
}
return true
}
return false
}

6
ping_test.go
View File

@ -7,5 +7,9 @@ import (
) )
func Test_Ping(t *testing.T) { func Test_Ping(t *testing.T) {
fmt.Println(Ping("baidu.com", 0, time.Second*2)) fmt.Println(Ping("baidu.com", 29, time.Second*2))
fmt.Println(Ping("www.b612.me", 29, time.Second*2))
fmt.Println(IsIpPingable("baidu.com", time.Second*2, 3))
fmt.Println(IsIpPingable("www.b612.me", time.Second*2, 3))
} }