Add clock sync capability to syncbase server.
1) Adds a syncservice in clock package that deals with
clock data response from peer
2) Clock sync logic to vsync package with makes
rpc call to peer right before initiating getDeltas
3) Deamon to service to run clockservice and
ntpservice in the background
4) Unit tests for syncservice
Change-Id: I6434fb940a2b8c0360d6b71c213b0b0d5220960f
diff --git a/services/syncbase/server/watchable/transaction.go b/services/syncbase/server/watchable/transaction.go
index 3178cb7..b4556c3 100644
--- a/services/syncbase/server/watchable/transaction.go
+++ b/services/syncbase/server/watchable/transaction.go
@@ -140,7 +140,7 @@
return verror.New(verror.ErrInternal, nil, "seq maxed out")
}
// Write LogEntry records.
- timestamp := tx.st.clock.Now(nil).UnixNano()
+ timestamp := tx.st.clock.Now().UnixNano()
seq := tx.st.seq
for i, op := range tx.ops {
key := logEntryKey(seq)
@@ -177,7 +177,7 @@
// GetStoreTime returns the current time from the given transaction store.
func GetStoreTime(ctx *context.T, tx store.Transaction) time.Time {
wtx := tx.(*transaction)
- return wtx.st.clock.Now(ctx)
+ return wtx.st.clock.Now()
}
// AddSyncGroupOp injects a SyncGroup operation notification in the log entries
