diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-03-06 14:25:05 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-03-06 14:26:27 -0800 |
| commit | 8363be85486e97053cdac45e9d0a692fe76af02e (patch) | |
| tree | 725aa268909b2c288fa0944c50460961ee608f88 /weed | |
| parent | 38fc200e564e1086742c3ef908b7793be942356a (diff) | |
| download | seaweedfs-8363be85486e97053cdac45e9d0a692fe76af02e.tar.xz seaweedfs-8363be85486e97053cdac45e9d0a692fe76af02e.zip | |
trim out trailing return character
Diffstat (limited to 'weed')
| -rw-r--r-- | weed/server/volume_server_tcp_handlers_write.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/server/volume_server_tcp_handlers_write.go b/weed/server/volume_server_tcp_handlers_write.go index 7c2f1a77f..a009611da 100644 --- a/weed/server/volume_server_tcp_handlers_write.go +++ b/weed/server/volume_server_tcp_handlers_write.go @@ -6,6 +6,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/storage/needle" "github.com/chrislusf/seaweedfs/weed/util" + "io" "net" "strings" ) @@ -21,9 +22,12 @@ func (vs *VolumeServer) HandleTcpConnection(c net.Conn) { for { cmd, err := bufReader.ReadString('\n') if err != nil { - glog.Errorf("read command from %s: %v", c.RemoteAddr().String(), err) + if err != io.EOF { + glog.Errorf("read command from %s: %v", c.RemoteAddr().String(), err) + } return } + cmd = cmd[:len(cmd)-1] switch cmd[0] { case '+': fileId := cmd[1:] |