| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/ |
| H A D | TestMultiVersionConcurrencyControlBasic.java | 34 MultiVersionConcurrencyControl mvcc = new MultiVersionConcurrencyControl(); in testSimpleMvccOps() local
35 long readPoint = mvcc.getReadPoint(); in testSimpleMvccOps()
36 MultiVersionConcurrencyControl.WriteEntry writeEntry = mvcc.begin(); in testSimpleMvccOps()
37 mvcc.completeAndWait(writeEntry); in testSimpleMvccOps()
38 assertEquals(readPoint + 1, mvcc.getReadPoint()); in testSimpleMvccOps()
39 writeEntry = mvcc.begin(); in testSimpleMvccOps()
41 mvcc.complete(writeEntry); in testSimpleMvccOps()
42 assertEquals(readPoint + 2, mvcc.getWritePoint()); in testSimpleMvccOps()
|
| H A D | TestMultiVersionConcurrencyControl.java | 36 final MultiVersionConcurrencyControl mvcc; field in TestMultiVersionConcurrencyControl.Writer
39 Writer(AtomicBoolean finished, MultiVersionConcurrencyControl mvcc, AtomicBoolean status) { in Writer() argument
41 this.mvcc = mvcc; in Writer()
52 mvcc.begin(); in run()
63 mvcc.completeAndWait(e); in run()
77 final MultiVersionConcurrencyControl mvcc = new MultiVersionConcurrencyControl(); in testParallelism() local
86 long prev = mvcc.getReadPoint(); in testParallelism()
88 long newPrev = mvcc.getReadPoint(); in testParallelism()
109 writers[i] = new Thread(new Writer(finished, mvcc, statuses[i])); in testParallelism()
|
| H A D | TestDefaultMemStore.java | 251 mvcc.begin(); in testMemstoreConcurrentControl()
260 mvcc.completeAndWait(w); in testMemstoreConcurrentControl()
265 w = mvcc.begin(); in testMemstoreConcurrentControl()
273 mvcc.completeAndWait(w); in testMemstoreConcurrentControl()
295 mvcc.begin(); in testMemstoreEditsVisibilityWithSameKey()
304 mvcc.completeAndWait(w); in testMemstoreEditsVisibilityWithSameKey()
311 w = mvcc.begin(); in testMemstoreEditsVisibilityWithSameKey()
347 mvcc.begin(); in testMemstoreDeletesVisibilityWithSameKey()
363 w = mvcc.begin(); in testMemstoreDeletesVisibilityWithSameKey()
403 this.mvcc = mvcc; in ReadOwnWritesTester()
[all …]
|
| /dports/devel/etcd31/etcd-3.1.20/etcdserver/api/v3rpc/ |
| H A D | watch.go | 35 watchable mvcc.WatchableKV
85 watchable mvcc.WatchableKV
88 watchStream mvcc.WatchStream
96 progress map[mvcc.WatchID]bool
97 prevKV map[mvcc.WatchID]bool
118 progress: make(map[mvcc.WatchID]bool),
119 prevKV: make(map[mvcc.WatchID]bool),
219 delete(sws.prevKV, mvcc.WatchID(id))
234 ids := make(map[mvcc.WatchID]struct{})
295 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/ |
| H A D | WALUtil.java | 60 final CompactionDescriptor c, MultiVersionConcurrencyControl mvcc) in writeCompactionMarker() argument
62 long trx = writeMarker(wal, htd, hri, WALEdit.createCompaction(hri, c), mvcc, true); in writeCompactionMarker()
73 final FlushDescriptor f, boolean sync, MultiVersionConcurrencyControl mvcc) in writeFlushMarker() argument
75 long trx = writeMarker(wal, htd, hri, WALEdit.createFlushWALEdit(hri, f), mvcc, sync); in writeFlushMarker()
86 final RegionEventDescriptor r, final MultiVersionConcurrencyControl mvcc) in writeRegionEventMarker() argument
88 long trx = writeMarker(wal, htd, hri, WALEdit.createRegionEventWALEdit(hri, r), mvcc, true); in writeRegionEventMarker()
107 final MultiVersionConcurrencyControl mvcc) in writeBulkLoadMarkerAndSync() argument
109 long trx = writeMarker(wal, htd, hri, WALEdit.createBulkLoadEvent(hri, desc), mvcc, true); in writeBulkLoadMarkerAndSync()
117 final WALEdit edit, final MultiVersionConcurrencyControl mvcc, final boolean sync) in writeMarker() argument
121 new HLogKey(hri.getEncodedNameAsBytes(), hri.getTable(), System.currentTimeMillis(), mvcc); in writeMarker()
[all …]
|
| H A D | HLogKey.java | 81 final MultiVersionConcurrencyControl mvcc) { in HLogKey() argument
82 super(encodedRegionName, tablename, now, mvcc); in HLogKey()
106 MultiVersionConcurrencyControl mvcc) { in HLogKey() argument
107 super(encodedRegionName, tablename, logSeqNum, now, clusterIds, nonceGroup, nonce, mvcc); in HLogKey()
129 final MultiVersionConcurrencyControl mvcc) { in HLogKey() argument
130 super(encodedRegionName, tablename, now, clusterIds, nonceGroup, nonce, mvcc); in HLogKey()
146 long nonceGroup, long nonce, MultiVersionConcurrencyControl mvcc) { in HLogKey() argument
147 super(encodedRegionName, tablename, logSeqNum, nonceGroup, nonce, mvcc); in HLogKey()
|
| H A D | ReplayHLogKey.java | 37 MultiVersionConcurrencyControl mvcc) { in ReplayHLogKey() argument
38 super(encodedRegionName, tablename, now, clusterIds, nonceGroup, nonce, mvcc); in ReplayHLogKey()
43 MultiVersionConcurrencyControl mvcc) { in ReplayHLogKey() argument
44 super(encodedRegionName, tablename, logSeqNum, now, clusterIds, nonceGroup, nonce, mvcc); in ReplayHLogKey()
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 38 watchable mvcc.WatchableKV
95 watchable mvcc.WatchableKV
98 watchStream mvcc.WatchStream
106 progress map[mvcc.WatchID]bool
107 prevKV map[mvcc.WatchID]bool
109 fragment map[mvcc.WatchID]bool
135 progress: make(map[mvcc.WatchID]bool),
136 prevKV: make(map[mvcc.WatchID]bool),
305 ids := make(map[mvcc.WatchID]struct{})
368 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/etcdserver/api/v3rpc/ |
| H A D | watch.go | 38 watchable mvcc.WatchableKV
95 watchable mvcc.WatchableKV
98 watchStream mvcc.WatchStream
106 progress map[mvcc.WatchID]bool
107 prevKV map[mvcc.WatchID]bool
109 fragment map[mvcc.WatchID]bool
135 progress: make(map[mvcc.WatchID]bool),
136 prevKV: make(map[mvcc.WatchID]bool),
306 ids := make(map[mvcc.WatchID]struct{})
369 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 38 watchable mvcc.WatchableKV
95 watchable mvcc.WatchableKV
98 watchStream mvcc.WatchStream
106 progress map[mvcc.WatchID]bool
107 prevKV map[mvcc.WatchID]bool
109 fragment map[mvcc.WatchID]bool
135 progress: make(map[mvcc.WatchID]bool),
136 prevKV: make(map[mvcc.WatchID]bool),
305 ids := make(map[mvcc.WatchID]struct{})
368 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 35 watchable mvcc.WatchableKV
88 watchable mvcc.WatchableKV
91 watchStream mvcc.WatchStream
99 progress map[mvcc.WatchID]bool
100 prevKV map[mvcc.WatchID]bool
123 progress: make(map[mvcc.WatchID]bool),
124 prevKV: make(map[mvcc.WatchID]bool),
266 delete(sws.prevKV, mvcc.WatchID(id))
281 ids := make(map[mvcc.WatchID]struct{})
344 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/devel/etcd32/etcd-3.2.32/etcdserver/api/v3rpc/ |
| H A D | watch.go | 36 watchable mvcc.WatchableKV
89 watchable mvcc.WatchableKV
92 watchStream mvcc.WatchStream
100 progress map[mvcc.WatchID]bool
101 prevKV map[mvcc.WatchID]bool
124 progress: make(map[mvcc.WatchID]bool),
125 prevKV: make(map[mvcc.WatchID]bool),
267 delete(sws.prevKV, mvcc.WatchID(id))
282 ids := make(map[mvcc.WatchID]struct{})
343 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/coreos/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 35 watchable mvcc.WatchableKV
88 watchable mvcc.WatchableKV
91 watchStream mvcc.WatchStream
99 progress map[mvcc.WatchID]bool
100 prevKV map[mvcc.WatchID]bool
123 progress: make(map[mvcc.WatchID]bool),
124 prevKV: make(map[mvcc.WatchID]bool),
266 delete(sws.prevKV, mvcc.WatchID(id))
281 ids := make(map[mvcc.WatchID]struct{})
344 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 43 watchable mvcc.WatchableKV
116 watchable mvcc.WatchableKV
120 watchStream mvcc.WatchStream
127 progress map[mvcc.WatchID]bool
129 prevKV map[mvcc.WatchID]bool
131 fragment map[mvcc.WatchID]bool
158 progress: make(map[mvcc.WatchID]bool),
159 prevKV: make(map[mvcc.WatchID]bool),
160 fragment: make(map[mvcc.WatchID]bool),
397 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
128 watchable mvcc.WatchableKV
132 watchStream mvcc.WatchStream
139 progress map[mvcc.WatchID]bool
141 prevKV map[mvcc.WatchID]bool
143 fragment map[mvcc.WatchID]bool
170 progress: make(map[mvcc.WatchID]bool),
171 prevKV: make(map[mvcc.WatchID]bool),
172 fragment: make(map[mvcc.WatchID]bool),
419 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
129 watchable mvcc.WatchableKV
133 watchStream mvcc.WatchStream
140 progress map[mvcc.WatchID]bool
142 prevKV map[mvcc.WatchID]bool
144 fragment map[mvcc.WatchID]bool
171 progress: make(map[mvcc.WatchID]bool),
172 prevKV: make(map[mvcc.WatchID]bool),
173 fragment: make(map[mvcc.WatchID]bool),
418 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
128 watchable mvcc.WatchableKV
132 watchStream mvcc.WatchStream
139 progress map[mvcc.WatchID]bool
141 prevKV map[mvcc.WatchID]bool
143 fragment map[mvcc.WatchID]bool
170 progress: make(map[mvcc.WatchID]bool),
171 prevKV: make(map[mvcc.WatchID]bool),
172 fragment: make(map[mvcc.WatchID]bool),
419 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/www/minio-client/etcd-3.5.0/server/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
128 watchable mvcc.WatchableKV
132 watchStream mvcc.WatchStream
139 progress map[mvcc.WatchID]bool
141 prevKV map[mvcc.WatchID]bool
143 fragment map[mvcc.WatchID]bool
170 progress: make(map[mvcc.WatchID]bool),
171 prevKV: make(map[mvcc.WatchID]bool),
172 fragment: make(map[mvcc.WatchID]bool),
419 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/devel/etcd34/etcd-3.4.18/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
129 watchable mvcc.WatchableKV
133 watchStream mvcc.WatchStream
140 progress map[mvcc.WatchID]bool
142 prevKV map[mvcc.WatchID]bool
144 fragment map[mvcc.WatchID]bool
171 progress: make(map[mvcc.WatchID]bool),
172 prevKV: make(map[mvcc.WatchID]bool),
173 fragment: make(map[mvcc.WatchID]bool),
428 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/etcdserver/api/v3rpc/ |
| H A D | watch.go | 45 watchable mvcc.WatchableKV
129 watchable mvcc.WatchableKV
133 watchStream mvcc.WatchStream
140 progress map[mvcc.WatchID]bool
142 prevKV map[mvcc.WatchID]bool
144 fragment map[mvcc.WatchID]bool
171 progress: make(map[mvcc.WatchID]bool),
172 prevKV: make(map[mvcc.WatchID]bool),
173 fragment: make(map[mvcc.WatchID]bool),
428 mvcc.ReportEventReceived(len(evs))
[all …]
|
| /dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/ |
| H A D | WALKey.java | 84 return mvcc; in getMvcc()
101 MultiVersionConcurrencyControl mvcc = getMvcc(); in getWriteEntry()
103 if (mvcc != null) { in getWriteEntry()
105 mvcc.complete(this.writeEntry); in getWriteEntry()
197 private MultiVersionConcurrencyControl mvcc; field in WALKey
238 MultiVersionConcurrencyControl mvcc) { in WALKey() argument
246 mvcc); in WALKey()
269 MultiVersionConcurrencyControl mvcc) { in WALKey() argument
310 final MultiVersionConcurrencyControl mvcc) { in WALKey() argument
318 mvcc); in WALKey()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/mysql-test/suite/tokudb/t/ |
| H A D | disabled.def | 1 mvcc-19: tokutek
2 mvcc-20: tokutek
3 mvcc-27: tokutek
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/mysql-test/suite/tokudb/t/ |
| H A D | disabled.def | 1 mvcc-19: tokutek
2 mvcc-20: tokutek
3 mvcc-27: tokutek
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/mysql-test/suite/tokudb/t/ |
| H A D | disabled.def | 1 mvcc-19: tokutek
2 mvcc-20: tokutek
3 mvcc-27: tokutek
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/tokudb/mysql-test/tokudb/t/ |
| H A D | disabled.def | 1 mvcc-19: tokutek
2 mvcc-20: tokutek
3 mvcc-27: tokutek
|