Commit b37af2a2 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ae843e08
......@@ -200,16 +200,12 @@ func (db *DB) watcher(watchq <-chan CommitEvent) { // XXX err ?
}
// forget older δtail entries
//fmt.Println()
//fmt.Printf("%s\n", db.δtail.Head().Time().Time)
//fmt.Printf("%s\n", db.δtail.Head().Time().Add(-db.tδkeep))
tcut := db.δtail.Head().Time().Add(-db.tδkeep)
δcut := TidFromTime(tcut)
fmt.Printf("db: watcher: δtail: = (%s, %s]\n", db.δtail.Tail(), db.δtail.Head())
fmt.Printf("db: watcher: forget <= %s\n", δcut)
//fmt.Printf("db: watcher: δtail: = (%s, %s]\n", db.δtail.Tail(), db.δtail.Head())
//fmt.Printf("db: watcher: forget <= %s\n", δcut)
db.δtail.ForgetPast(δcut)
fmt.Printf("db: watcher: δtail: -> (%s, %s]\n", db.δtail.Tail(), db.δtail.Head())
//fmt.Printf("db: watcher: δtail: -> (%s, %s]\n", db.δtail.Tail(), db.δtail.Head())
db.mu.Unlock()
......
......@@ -348,9 +348,6 @@ func TestPersistentDB(t *testing.T) {
// obj2 data should be new
xobj1, err = conn1.Get(ctx1, 101); X(err)
xobj2, err = conn1.Get(ctx1, 102); X(err)
println("\nAAA")
println(obj1)
println(xobj1.(*MyObject))
assert.Exactly(obj1, xobj1) // XXX is
assert.Exactly(obj2, xobj2) // XXX is
err = obj1.PActivate(ctx1); X(err)
......
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