Commit 39d7ba59 authored by Sushant Mahajan's avatar Sushant Mahajan

exposed method to commit log entry

parent c77ec532
......@@ -93,6 +93,10 @@ func NewLogEntry(id Lsn, data []byte, committed bool, conn net.Conn) *LogEntryDa
return entry
}
func SetCommitted(logEntry *LogEntryData, committed bool) {
logEntry.committed = committed
}
//goroutine that monitors channel to check if the majority of servers have replied
func monitorAckChannel(rft *Raft, ack_ch <-chan int, log_entry LogEntry, majCh chan bool) {
acks_received := 0
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment