Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix log_entry.go

pull/820/head
Xiang Li 2013-08-02 02:40:27 -07:00
parent 6ca0964179
commit 1bb97e31ad
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
log_entry.go
View File

@ -55,14 +55,13 @@ func (e *LogEntry) encode(w io.Writer) (int, error) {
e.log.pLogEntry.Term = proto.Uint64(e.Term) e.log.pLogEntry.Term = proto.Uint64(e.Term)
e.log.pLogEntry.CommandName = proto.String(e.CommandName) e.log.pLogEntry.CommandName = proto.String(e.CommandName)
e.log.pLogEntry.Command = e.Command e.log.pLogEntry.Command = e.Command
p, err := proto.Marshal(pb)
err := e.log.pBuffer.Marshal(e.log.pLogEntry) err := e.log.pBuffer.Marshal(e.log.pLogEntry)
if err != nil { if err != nil {
return -1, err return -1, err
} }
_, err = fmt.Fprintf(w, "%8x\n", len(e.log.pBuffer.Bytes())) if _, err = fmt.Fprintf(w, "%8x\n", len(e.log.pBuffer.Bytes())); err != nil {
if _, err = fmt.Fprintf(w, "%8x\n", len(p)); err != nil {
return -1, err return -1, err
} }