continue to fix bugs

Author: smallnest

2setup.sh

@@ -0,0 +1,17 @@
+#!/bin/bash
+## 这个脚本使用Docker在不同的网络命名空间产生多个client实例.
+## 这样才能避免source port的限制，在一台机器上才能创建百万的连接.
+##
+## 用法: ./connect <connections> <number of clients> <server ip>
+## Server IP 通常是 Docker gateway IP address, 缺省是 172.17.0.1
+
+CONNECTIONS=$1
+REPLICAS=$2
+IP=$3
+#go build --tags "static netgo" -o client client.go
+
+for (( c=0; c<${REPLICAS}; c++ ))
+do
+    docker run -v $(pwd)/client:/client --name 1mclient_$c -d alpine /client \
+    -conn=${CONNECTIONS} -ip=${IP}
+done

4_epoll_client/client.go

@@ -16,7 +16,7 @@ import (
 var (
 	ip          = flag.String("ip", "127.0.0.1", "server IP")
 	connections = flag.Int("conn", 1, "number of tcp connections")
-	startMetric = flag.String("sm", time.Now().Format("2006-01-02T15:04:05"), "start time point of all clients")
+	startMetric = flag.String("sm", time.Now().Format("2006-01-02T15:04:05 -0700"), "start time point of all clients")
 )
 
 var (
@@ -31,7 +31,7 @@ func main() {
 	setLimit()
 
 	go func() {
-		startPoint, err := time.Parse("2006-01-02T15:04:05", *startMetric)
+		startPoint, err := time.Parse("2006-01-02T15:04:05 -0700", *startMetric)
 		if err != nil {
 			panic(err)
 		}

5_multiple_client/client.go

@@ -17,7 +17,7 @@ var (
 	ip          = flag.String("ip", "127.0.0.1", "server IP")
 	connections = flag.Int("conn", 1, "number of total tcp connections")
 	c           = flag.Int("c", 100, "currency count")
-	startMetric = flag.String("sm", time.Now().Format("2006-01-02T15:04:05"), "start time point of all clients")
+	startMetric = flag.String("sm", time.Now().Format("2006-01-02T15:04:05 -0700"), "start time point of all clients")
 )
 
 var (
@@ -30,7 +30,7 @@ func main() {
 
 	setLimit()
 	go func() {
-		startPoint, _ := time.Parse("2006-01-02T15:04:05", *startMetric)
+		startPoint, _ := time.Parse("2006-01-02T15:04:05 -0700", *startMetric)
 		time.Sleep(startPoint.Sub(time.Now()))
 
 		metrics.Log(metrics.DefaultRegistry, 5*time.Second, log.New(os.Stderr, "metrics: ", log.Lmicroseconds))

report.sh

@@ -2,6 +2,8 @@
 
 REPLICAS=$1
 
+rm -f metrics.log 
+
 for (( c=0; c<${REPLICAS}; c++ ))
 do
     docker logs 1mclient_$c|egrep "mean|stddev"|tail -3 >> metrics.log

setup.sh

@@ -10,9 +10,9 @@ REPLICAS=$2
 IP=$3
 #go build --tags "static netgo" -o client client.go
 
-DATE=`date -d "+5 minutes" +"%FT%T"`
+DATE=`date -d "+2 minutes" +"%FT%T %z"`
 for (( c=0; c<${REPLICAS}; c++ ))
 do
-    docker run -v $(pwd)/client:/client --name 1mclient_$c -d frolvlad/alpine-glibc /client \
-    -conn=${CONNECTIONS} -ip=${IP} -sm ${DATE}
+    docker run -v $(pwd)/client:/client --name 1mclient_$c -d alpine /client \
+    -conn=${CONNECTIONS} -ip=${IP} -sm "${DATE}"
 done

setupm.sh

@@ -10,10 +10,10 @@ REPLICAS=$2
 IP=$3
 CONCURRENCY=$4
 
-DATE=`date -d "+5 minutes" +"%FT%T"`
+DATE=`date -d "+2 minutes" +"%FT%T %z"`
 
 for (( c=0; c<${REPLICAS}; c++ ))
 do
-    docker run -v $(pwd)/mclient:/client --name 1mclient_$c -d frolvlad/alpine-glibc /client \
-    -conn=${CONNECTIONS} -ip=${IP} -c=${CONCURRENCY} -sm ${DATE}
+    docker run -v $(pwd)/mclient:/client --name 1mclient_$c -d alpine /client \
+    -conn=${CONNECTIONS} -ip=${IP} -c=${CONCURRENCY} -sm "${DATE}"
 done