2020-06-23 19:02:54 +03:00
|
|
|
package lamport
|
|
|
|
|
|
|
|
import (
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"io/ioutil"
|
|
|
|
"os"
|
2020-12-05 05:08:54 +03:00
|
|
|
|
|
|
|
"github.com/go-git/go-billy/v5"
|
|
|
|
"github.com/go-git/go-billy/v5/util"
|
2020-06-23 19:02:54 +03:00
|
|
|
)
|
|
|
|
|
|
|
|
var ErrClockNotExist = errors.New("clock doesn't exist")
|
|
|
|
|
|
|
|
type PersistedClock struct {
|
|
|
|
*MemClock
|
2020-12-05 05:08:54 +03:00
|
|
|
root billy.Filesystem
|
2020-06-23 19:02:54 +03:00
|
|
|
filePath string
|
|
|
|
}
|
|
|
|
|
|
|
|
// NewPersistedClock create a new persisted Lamport clock
|
2020-12-05 05:08:54 +03:00
|
|
|
func NewPersistedClock(root billy.Filesystem, filePath string) (*PersistedClock, error) {
|
2020-06-23 19:02:54 +03:00
|
|
|
clock := &PersistedClock{
|
|
|
|
MemClock: NewMemClock(),
|
2020-12-05 05:08:54 +03:00
|
|
|
root: root,
|
2020-06-23 19:02:54 +03:00
|
|
|
filePath: filePath,
|
|
|
|
}
|
|
|
|
|
2020-12-05 05:08:54 +03:00
|
|
|
err := clock.Write()
|
2020-06-23 19:02:54 +03:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return clock, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// LoadPersistedClock load a persisted Lamport clock from a file
|
2020-12-05 05:08:54 +03:00
|
|
|
func LoadPersistedClock(root billy.Filesystem, filePath string) (*PersistedClock, error) {
|
2020-06-23 19:02:54 +03:00
|
|
|
clock := &PersistedClock{
|
2020-12-05 05:08:54 +03:00
|
|
|
root: root,
|
2020-06-23 19:02:54 +03:00
|
|
|
filePath: filePath,
|
|
|
|
}
|
|
|
|
|
|
|
|
err := clock.read()
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return clock, nil
|
|
|
|
}
|
|
|
|
|
|
|
|
// Increment is used to return the value of the lamport clock and increment it afterwards
|
|
|
|
func (pc *PersistedClock) Increment() (Time, error) {
|
|
|
|
time, err := pc.MemClock.Increment()
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
return time, pc.Write()
|
|
|
|
}
|
|
|
|
|
|
|
|
// Witness is called to update our local clock if necessary after
|
|
|
|
// witnessing a clock value received from another process
|
|
|
|
func (pc *PersistedClock) Witness(time Time) error {
|
|
|
|
// TODO: rework so that we write only when the clock was actually updated
|
|
|
|
err := pc.MemClock.Witness(time)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
return pc.Write()
|
|
|
|
}
|
|
|
|
|
|
|
|
func (pc *PersistedClock) read() error {
|
2020-12-05 05:08:54 +03:00
|
|
|
f, err := pc.root.Open(pc.filePath)
|
2020-06-23 19:02:54 +03:00
|
|
|
if os.IsNotExist(err) {
|
|
|
|
return ErrClockNotExist
|
|
|
|
}
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2020-12-05 05:08:54 +03:00
|
|
|
defer f.Close()
|
|
|
|
|
|
|
|
content, err := ioutil.ReadAll(f)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2020-06-23 19:02:54 +03:00
|
|
|
|
|
|
|
var value uint64
|
|
|
|
n, err := fmt.Sscanf(string(content), "%d", &value)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
if n != 1 {
|
|
|
|
return fmt.Errorf("could not read the clock")
|
|
|
|
}
|
|
|
|
|
|
|
|
pc.MemClock = NewMemClockWithTime(value)
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (pc *PersistedClock) Write() error {
|
|
|
|
data := []byte(fmt.Sprintf("%d", pc.counter))
|
2020-12-05 05:08:54 +03:00
|
|
|
return util.WriteFile(pc.root, pc.filePath, data, 0644)
|
2020-06-23 19:02:54 +03:00
|
|
|
}
|