Skip to content

Commit e6eee59

Browse files
committed
Fixed typo in README and tweaked receiver logging. Final commit before thesis hand-in.
1 parent 7af37c0 commit e6eee59

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ Evaluation scripts to benchmark pluto's response time performance against the de
138138

139139
## Acknowledgments
140140

141-
I would like to thank my thesis supervisor [Tim Jungnickel](https://github.com/TimJuni) for coming up with this project's idea, providing feedback and ideas on current progress, and evaluation help. Furthermore, [Matthias Loibl](https://github.com/MetalMatze) routinely reviewed Go code I committed to pluto and thus helped to improve code quality and readibility. Thank you!
141+
I would like to thank my thesis supervisor [Tim Jungnickel](https://github.com/TimJuni) for coming up with this project's idea, providing feedback and ideas on current progress, and evaluation help. Furthermore, [Matthias Loibl](https://github.com/MetalMatze) routinely reviewed Go code I committed to pluto and thus helped to improve code quality and readability. Thank you!
142142

143143

144144
## License

comm/receiver.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -349,7 +349,7 @@ func (recv *Receiver) AcceptIncMsgs() error {
349349
func (recv *Receiver) TriggerMsgApplier() {
350350

351351
// Specify duration to wait between triggers.
352-
triggerD := 2 * time.Second
352+
triggerD := 5 * time.Second
353353

354354
// Create a timer that waits for one second
355355
// to elapse and then fires.
@@ -598,7 +598,7 @@ func (recv *Receiver) ApplyStoredMsgs() {
598598
// Wait for done signal from node.
599599
<-recv.doneCRDTUpdChan
600600
} else {
601-
log.Printf("[comm.ApplyStoredMsgs] %s: message was a duplicate, already seen.", recv.name)
601+
log.Printf("[comm.ApplyStoredMsgs] %s: message was a duplicate, already seen.\n", recv.name)
602602
}
603603

604604
for node, value := range msg.VClock {
@@ -651,7 +651,7 @@ func (recv *Receiver) ApplyStoredMsgs() {
651651
}
652652
} else {
653653

654-
log.Printf("[comm.ApplyStoredMsgs] Message was out of order. Next.")
654+
log.Printf("[comm.ApplyStoredMsgs] Message was out of order. Next.\n")
655655

656656
// Set position of head to byte after just read message,
657657
// effectively delaying execution of that message.

0 commit comments

Comments
 (0)