Iwasaki Yudai eaf7d631ad mvcc: restore unsynced watchers ...

In case syncWatchersLoop() starts before Restore() is called,
watchers already added by that moment are moved to s.synced by the loop.
However, there is a broken logic that moves watchers from s.synced
to s.uncyned without setting keyWatchers of the watcherGroup.
Eventually syncWatchers() fails to pickup those watchers from s.unsynced
and no events are sent to the watchers, because newWatcherBatch() called
in the function uses wg.watcherSetByKey() internally that requires
a proper keyWatchers value.

2018-02-06 11:34:46 -08:00

..

backend

mvcc: check null before set FillPercent not to panic

2018-01-08 13:08:03 -08:00

mvccpb

*: regenerate protobuf, grpc-gateway

2017-12-07 21:31:13 -08:00

doc.go

mvcc: update LICENSE header

2016-05-12 20:50:33 -07:00

index_test.go

mvcc: add tests for Keep

2017-07-31 17:59:42 -07:00

index.go

mvcc: move 'keyi' define before holding locks

2017-10-05 10:06:28 -07:00

key_index_test.go

mvcc: add tests for Keep

2017-07-31 17:59:42 -07:00

key_index.go

mvcc: clean-up godoc in key_index.go

2017-12-18 13:20:00 -08:00

kv_test.go

mvcc: test keys gauge is reloaded correctly on restore

2017-08-10 09:21:39 -07:00

kv_view.go

mvcc: txns and r/w views

2017-03-08 20:52:59 -08:00

kv.go

mvcc: add HashByRev to kv.go

2017-07-25 17:00:46 -07:00

kvstore_bench_test.go

mvcc: add range benchmark for fetching 100 keys

2017-08-31 13:23:23 -07:00

kvstore_compaction_test.go

mvcc: fix gofmt issues from Go tip

2016-10-20 16:32:47 -07:00

kvstore_compaction.go

mvcc: Add metric for count of db key revisions compacted.

2017-07-20 10:07:56 -07:00

kvstore_test.go

mvcc: fetch revisions with current revision, not 0, in HashByRev

2017-12-18 12:17:06 -08:00

kvstore_txn.go

mvcc: Revisions() method for index to avoid key allocation

2017-08-21 11:30:02 -07:00

kvstore.go

mvcc: fetch revisions with current revision, not 0, in HashByRev

2017-12-18 12:17:06 -08:00

metrics_txn.go

mvcc: count range/put/del operations for txns

2017-06-07 16:53:50 -07:00

metrics.go

mvcc: Add metric for count of db key revisions compacted.

2017-07-20 10:07:56 -07:00

revision_test.go

mvcc: update LICENSE header

2016-05-12 20:50:33 -07:00

revision.go

mvcc: update LICENSE header

2016-05-12 20:50:33 -07:00

util.go

mvcc: use capnslog

2016-05-20 22:31:22 -07:00

watchable_store_bench_test.go

mvcc: txns and r/w views

2017-03-08 20:52:59 -08:00

watchable_store_test.go

mvcc: restore unsynced watchers

2018-02-06 11:34:46 -08:00

watchable_store_txn.go

mvcc: txns and r/w views

2017-03-08 20:52:59 -08:00

watchable_store.go

mvcc: restore unsynced watchers

2018-02-06 11:34:46 -08:00

watcher_bench_test.go

mvcc: update LICENSE header

2016-05-12 20:50:33 -07:00

watcher_group.go

*: support checking that an interval tree's keys cover an entire interval

2017-04-03 15:38:07 -07:00

watcher_test.go

mvcc: return -1 for wrong watcher range key >= end

2016-11-08 17:02:28 -08:00

watcher.go

mvcc: only remove watch cancel after cancel completes

2017-08-28 17:06:33 -07:00