mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-01-18 22:43:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

trim out trailing return character

Browse Source
This commit is contained in:
Chris Lu 2021-03-06 14:25:05 -08:00
parent 38fc200e56
commit 8363be8548
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
weed/server/volume_server_tcp_handlers_write.go
View File

@ -6,6 +6,7 @@ import (
"github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/storage/needle" "github.com/chrislusf/seaweedfs/weed/storage/needle"
"github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/util"
"io"
"net" "net"
"strings" "strings"
) )
@ -21,9 +22,12 @@ func (vs *VolumeServer) HandleTcpConnection(c net.Conn) {
for { for {
cmd, err := bufReader.ReadString('\n') cmd, err := bufReader.ReadString('\n')
if err != nil { 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 return
} }
cmd = cmd[:len(cmd)-1]
switch cmd[0] { switch cmd[0] {
case '+': case '+':
fileId := cmd[1:] fileId := cmd[1:]