luhuaei
/
zabbix-bench
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

some fixes for close socket

This commit is contained in:
Dmitry Vasilyev 2016-11-21 19:48:39 +03:00
parent 78ca6ac173
commit de9fb4a0a6
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
generate-template-clients.sh
View File

@ -3,7 +3,7 @@
TEMPLATE_NAME="zabbix-bench"
GROUP_NAME="Linux servers"
CLIENT_PREFIX="client"
CLIENTS=40000
CLIENTS=2000
echo "<?xml version=\"1.0\" encoding=\"UTF-8\"?>
<zabbix_export>

5
src/main.go
View File

@ -14,13 +14,12 @@ import (
)
var (
argClientCount = flag.Int("client", 200, "number of concurrent clients")
argClientCount = flag.Int("client", 2000, "number of concurrent clients")
argThreadCount = flag.Int("threads", runtime.NumCPU()*4, "number of threads")
argClinetName = flag.String("client-format", "client-%d", "format of client name")
argPacketSize = flag.Int("packet-size", 400, "count of metric in packet")
argMetricName = flag.String("metric-format", "metric-%d", "format of metric name in packet")
argPacketDelay = flag.Duration("packet-delay", 100*time.Millisecond, "delay of send packet")
argSendTimeout = flag.Duration("packet-send-timeout", 10*time.Millisecond, "packet send timeout")
argPacketDelay = flag.Duration("packet-delay", 60*time.Second, "delay of send packet")
argZabbix = flag.String("zabbix", "127.0.0.1:10051", "address of zabbix server")
argMaxMetrics = flag.Int("max-metrics", 0, "max number of metrics each client sends")
argMaxDuration = flag.Duration("max-duration", 0, "max duration of benchmark test")

2
src/zabbix/sender.go
View File

@ -64,6 +64,6 @@ func (s *Sender) Send(packet *Packet) error {
fmt.Fprintf(os.Stderr, "Read zabbix response error: %s\n", err.Error())
}
return nil
return conn.Close()
}