diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-02-14 22:24:38 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-02-14 22:24:38 -0800 |
| commit | c7ac94ea9a3bc2842ce41c1fcad6fc23781c1296 (patch) | |
| tree | a311bf1155c110610519186113889f8943407193 /weed/command/volume.go | |
| parent | be415f4e3c5ddb96577ae5e0fd86e612f6122078 (diff) | |
| download | seaweedfs-c7ac94ea9a3bc2842ce41c1fcad6fc23781c1296.tar.xz seaweedfs-c7ac94ea9a3bc2842ce41c1fcad6fc23781c1296.zip | |
skip EOF message
now tcp
Concurrency Level: 16
Time taken for tests: 22.963 seconds
Complete requests: 1048576
Failed requests: 0
Total transferred: 1106755384 bytes
Requests per second: 45663.49 [#/sec]
Transfer rate: 47067.47 [Kbytes/sec]
vs normal
Concurrency Level: 16
Time taken for tests: 22.286 seconds
Complete requests: 1048576
Failed requests: 0
Total transferred: 1106754345 bytes
Requests per second: 47050.30 [#/sec]
Transfer rate: 48496.88 [Kbytes/sec]
Diffstat (limited to 'weed/command/volume.go')
| -rw-r--r-- | weed/command/volume.go | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/weed/command/volume.go b/weed/command/volume.go index 8caa8d92f..c48896b18 100644 --- a/weed/command/volume.go +++ b/weed/command/volume.go @@ -261,18 +261,15 @@ func (v VolumeServerOptions) startTcpServer(vs *weed_server.VolumeServer) { for { c, err := tcpL.Accept() - if err!= nil { + if err != nil { glog.V(0).Infof("accept tcp connection: %v", err) continue } go func() { - for { - if err := vs.HandleTcpConnection(c); err != nil { - glog.V(0).Infof("handle tcp remote %s: %v", c.RemoteAddr(), err) - return - } + if err := vs.HandleTcpConnection(c); err != nil { + glog.V(0).Infof("handle tcp remote %s: %v", c.RemoteAddr(), err) + return } - }() } } |