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

Remove debug statements.

pull/2111/head
Ben Johnson 2015-03-29 15:31:01 -06:00
parent 55768e6973
commit 189aaa0d82
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
raft/log.go
View File

@ -40,7 +40,7 @@ const logEntryHeaderSize = 8 + 8 + 8 // sz+index+term
// WaitInterval represents the amount of time between checks to the applied index.
// This is used by clients wanting to wait until a given index is processed.
const WaitInterval = 100 * time.Millisecond
const WaitInterval = 1 * time.Millisecond
// State represents whether the log is a follower, candidate, or leader.
type State int
@ -1227,7 +1227,6 @@ func (l *Log) Wait(idx uint64) error {
for {
l.mu.Lock()
state, index := l.state, l.FSM.Index()
l.tracef("WAIT> I=%d, Aⁱ=%d, Cⁱ=%d, LLⁱ=%d", idx, index, l.commitIndex, l.lastLogIndex)
l.mu.Unlock()
if state == Stopped {
@ -1701,11 +1700,6 @@ func (l *Log) writeTo(writer *logWriter, id, term, index uint64) error {
}
flushWriter(w)
// // Write snapshot index at the end and flush.
// if err := binary.Write(w, binary.BigEndian, snapshotIndex); err != nil {
// return fmt.Errorf("write snapshot index: %s", err)
// }
// Write entries since the snapshot occurred and begin tailing writer.
if err := l.advanceWriter(writer); err != nil {
return err