openstack
/
swift
Code Issues Proposed changes

go: replicator fix 

switch from r.Read(..) to io.ReadFull(r, ...) in the replicator to make sure we
read the full json document.

Change-Id: I37402a731eb17d1397589e4a90016eece75bd368
This commit is contained in:
Michael Barton 2015-08-31 18:56:55 +00:00
parent c1cd26b2db
commit 68904b118a
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
go/objectserver/repconn.go
View File

@ -5,6 +5,7 @@ import (
"encoding/binary"
"encoding/json"
"fmt"
"io"
"net"
"net/http"
"net/http/httputil"
@ -81,7 +82,7 @@ func (r *RepConn) RecvMessage(v interface{}) (err error) {
return
}
data := make([]byte, length)
if _, err = r.rw.Read(data); err != nil {
if _, err = io.ReadFull(r.rw, data); err != nil {
r.Close()
return
}
@ -110,7 +111,7 @@ func (r *RepConn) Flush() (err error) {
func (r *RepConn) Read(data []byte) (l int, err error) {
r.c.SetDeadline(time.Now().Add(repITimeout))
if l, err = r.rw.Read(data); err != nil {
if l, err = io.ReadFull(r.rw, data); err != nil {
r.Close()
}
return