service ping

Gopkg.toml

@@ -1,6 +1,6 @@
 # Gopkg.toml example
 #
-# Refer to https://github.com/golang/dep/blob/master/docs/Gopkg.toml.md
+# Refer to https://golang.github.io/dep/docs/Gopkg.toml.html
 # for detailed Gopkg.toml documentation.
 #
 # required = ["github.com/user/thing/cmd/thing"]
@@ -59,12 +59,24 @@
 
 [[constraint]]
   name = "github.com/google/gopacket"
-  version = "1.1.14"
+  version = "1.1.15"
+
+[[constraint]]
+  branch = "master"
+  name = "github.com/grandcat/zeroconf"
+
+[[constraint]]
+  branch = "master"
+  name = "github.com/huin/goupnp"
 
 [[constraint]]
   name = "github.com/k-sone/snmpgo"
   version = "3.2.0"
 
+[[constraint]]
+  name = "github.com/satori/go.uuid"
+  version = "1.2.0"
+
 [[constraint]]
   name = "github.com/valyala/fasthttp"
   version = "20180529.0.0"
@@ -73,14 +85,10 @@
   name = "go.uber.org/zap"
   version = "1.9.1"
 
+[[constraint]]
+  branch = "master"
+  name = "golang.org/x/sync"
+
 [prune]
   go-tests = true
   unused-packages = true
-
-[[constraint]]
-  branch = "master"
-  name = "github.com/grandcat/zeroconf"
-
-[[constraint]]
-  branch = "master"
-  name = "github.com/huin/goupnp"

__test/test.go

@@ -2,6 +2,7 @@ package __test
 
 import (
 	"fmt"
+	"strings"
 
 	omd "git.loafle.net/overflow/model/discovery"
 	omm "git.loafle.net/overflow/model/meta"
@@ -43,6 +44,7 @@ const (
 )
 
 func Zone() *omd.Zone {
+	strings.Builder
 	return omd.NewZone(
 		ZONE_IFACE,
 		ZONE_MAC,

ping/service/service.go

@@ -46,14 +46,16 @@ func processPing(service *omd.Service, pingOption ounp.Option, _pingFunc pingFun
 
 	for indexR := 0; indexR < pingOption.GetCount(); indexR++ {
 		summary.SendCount = summary.SendCount + 1
+		if 0 < indexR {
+			// select {
+			// case <-time.After(time.Duration(pingOption.GetInterval()) * time.Second):
+			// }
+			time.Sleep(time.Duration(pingOption.GetInterval()) * time.Second)
+		}
+
 		startTime := time.Now()
 
 		_res = &ounp.PingResponse{}
-		if 0 < indexR {
-			select {
-			case <-time.After(time.Duration(pingOption.GetDeadline()) * time.Second):
-			}
-		}
 
 		ttl, err := _pingFunc(service, pingOption)
 		elapsedTime := float64(time.Since(startTime).Nanoseconds()) / float64(1E6)

server/server.go

@@ -39,6 +39,8 @@ func New() *ossw.Server {
 	sh.Name = "Probe"
 	sh.Services = services
 	sh.PubSub = _pubsub
+	sh.ReadBufferSize = 8192
+	sh.WriteBufferSize = 8192
 
 	sh.RegisterServlet("/scanner", ss)