From 44d7587940f842a343a64d9107601591bdfb1027 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michael=20Mur=C3=A9?= Date: Sun, 8 Nov 2020 17:53:11 +0100 Subject: [PATCH] lamport: match wikipedia algorithm --- util/lamport/clock_testing.go | 2 +- util/lamport/mem_clock.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/util/lamport/clock_testing.go b/util/lamport/clock_testing.go index fc59afb2..4bf6d2bf 100644 --- a/util/lamport/clock_testing.go +++ b/util/lamport/clock_testing.go @@ -11,7 +11,7 @@ func testClock(t *testing.T, c Clock) { val, err := c.Increment() assert.NoError(t, err) - assert.Equal(t, Time(1), val) + assert.Equal(t, Time(2), val) assert.Equal(t, Time(2), c.Time()) err = c.Witness(41) diff --git a/util/lamport/mem_clock.go b/util/lamport/mem_clock.go index ce6f2d4d..f113b501 100644 --- a/util/lamport/mem_clock.go +++ b/util/lamport/mem_clock.go @@ -62,7 +62,7 @@ func (mc *MemClock) Time() Time { // Increment is used to return the value of the lamport clock and increment it afterwards func (mc *MemClock) Increment() (Time, error) { - return Time(atomic.AddUint64(&mc.counter, 1) - 1), nil + return Time(atomic.AddUint64(&mc.counter, 1)), nil } // Witness is called to update our local clock if necessary after