Home
last modified time | relevance | path

Searched refs:RangeResultRef (Results 1 – 25 of 79) sorted by relevance

1234

/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/
H A DRyowCorrectness.actor.cpp154 …void pushKVPair(std::vector<Standalone<RangeResultRef>> &results, Key const& key, Optional<Value> … in pushKVPair()
155 Standalone<RangeResultRef> result; in pushKVPair()
165 std::vector<Standalone<RangeResultRef>> applySequenceToStore(std::vector<Operation> sequence) { in applySequenceToStore()
166 std::vector<Standalone<RangeResultRef>> results; in applySequenceToStore()
234 state std::vector<Standalone<RangeResultRef>> results; in applySequenceToDatabase()
251 Standalone<RangeResultRef> result = wait(transaction->getRange(range, op.limit, op.reverse)); in applySequenceToDatabase()
253 results.push_back((RangeResultRef)result); in applySequenceToDatabase()
256 …Standalone<RangeResultRef> result = wait(transaction->getRange(op.beginSelector, op.endSelector, o… in applySequenceToDatabase()
258 results.push_back((RangeResultRef)result); in applySequenceToDatabase()
291 …bool compareResults(std::vector<Standalone<RangeResultRef>> dbResults, std::vector<Standalone<Rang… in compareResults()
[all …]
H A DLockDatabase.actor.cpp58 …ACTOR static Future<Standalone<RangeResultRef>> lockAndSave( Database cx, LockDatabaseWorkload* se… in lockAndSave()
63 state Standalone<RangeResultRef> data = wait( tr.getRange(normalKeys, 50000) ); in lockAndSave()
73 …kAndCheck( Database cx, LockDatabaseWorkload* self, UID lockID, Standalone<RangeResultRef> data ) { in unlockAndCheck()
83 state Standalone<RangeResultRef> data2 = wait( tr.getRange(normalKeys, 50000) ); in unlockAndCheck()
121 state Standalone<RangeResultRef> data = wait(lockAndSave(cx, self, lockID)); in lockWorker()
H A DApiWorkload.h55 …virtual Future<Standalone<RangeResultRef>> getRange(KeyRangeRef &keys, int limit, bool reverse) = …
58 …virtual Future<Standalone<RangeResultRef>> getRange(KeySelectorRef &begin, KeySelectorRef &end, in…
115 Future<Standalone<RangeResultRef>> getRange(KeyRangeRef &keys, int limit, bool reverse) { in getRange()
120 …Future<Standalone<RangeResultRef>> getRange(KeySelectorRef &begin, KeySelectorRef &end, int limit,… in getRange()
193 Future<Standalone<RangeResultRef>> getRange(KeyRangeRef &keys, int limit, bool reverse) { in getRange()
198 …Future<Standalone<RangeResultRef>> getRange(KeySelectorRef &begin, KeySelectorRef &end, int limit,… in getRange()
H A DConflictRange.actor.cpp90 state Standalone<RangeResultRef> originalResults; in conflictRangeClient()
159 …Standalone<RangeResultRef> res = wait( tr1.getRange(KeySelectorRef(StringRef(myKeyA),onEqualA,offs… in conflictRangeClient()
217 …Standalone<RangeResultRef> res = wait( trRYOW.getRange(KeySelectorRef(StringRef(myKeyA),onEqualA,o… in conflictRangeClient()
221 …Standalone<RangeResultRef> res = wait( tr3.getRange(KeySelectorRef(StringRef(myKeyA),onEqualA,offs… in conflictRangeClient()
238 …Standalone<RangeResultRef> res = wait( tr4.getRange(KeySelectorRef(StringRef(myKeyA),onEqualA,offs… in conflictRangeClient()
282 …Standalone<RangeResultRef> res = wait( tr4.getRange( KeyRangeRef( StringRef( format( "%010d", 0 ) … in conflictRangeClient()
293 …Standalone<RangeResultRef> res = wait( tr4.getRange(KeySelectorRef(StringRef(myKeyA),onEqualA,offs… in conflictRangeClient()
H A DRYWPerformance.actor.cpp122 std::vector<Future<Standalone<RangeResultRef>>> gets; in fillCache()
128 std::vector<Future<Standalone<RangeResultRef>>> gets; in fillCache()
137 std::vector<Future<Standalone<RangeResultRef>>> gets; in fillCache()
146 std::vector<Future<Standalone<RangeResultRef>>> gets; in fillCache()
155 std::vector<Future<Standalone<RangeResultRef>>> gets; in fillCache()
H A DSerializability.actor.cpp234 std::vector<Future<Standalone<RangeResultRef>>>* getRangeFutures, in runTransaction()
309 ACTOR static Future<Standalone<RangeResultRef>> getDatabaseContents( Database cx, int nodes ) { in getDatabaseContents()
312 Standalone<RangeResultRef> result = wait( tr.getRange(normalKeys, nodes+1) ); in getDatabaseContents()
335 state std::vector<std::vector<Future<Standalone<RangeResultRef>>>> getRangeFutures; in _start()
342 getRangeFutures.push_back(std::vector<Future<Standalone<RangeResultRef>>>()); in _start()
382 state Standalone<RangeResultRef> result1 = wait( getDatabaseContents(cx, self->nodes) ); in _start()
394 Standalone<RangeResultRef> result2 = wait( getDatabaseContents(cx, self->nodes) ); in _start()
H A DAtomicOps.actor.cpp168 state Standalone<RangeResultRef> log; in _check()
173 …Standalone<RangeResultRef> log_ = wait( tr.getRange(KeyRangeRef(begin, strinc(begin)), CLIENT_KNOB… in _check()
186 …Standalone<RangeResultRef> ops = wait( tr.getRange(KeyRangeRef(begin, strinc(begin)), CLIENT_KNOBS… in _check()
H A DMemoryKeyValueStore.cpp83 Standalone<RangeResultRef> MemoryKeyValueStore::getRange(KeyRangeRef range, int limit, bool reverse… in getRange()
84 Standalone<RangeResultRef> results; in getRange()
H A DBackgroundSelectors.actor.cpp96 state Standalone<RangeResultRef> rangeResult; in backgroundSelectorWorker()
157 …Standalone<RangeResultRef> rangeResult_ = wait( tr.getRange( randomizedSelector(endKey, true, endD… in backgroundSelectorWorker()
165 …Standalone<RangeResultRef> rangeResult_ = wait( tr.getRange( randomizedSelector(startKey, true, st… in backgroundSelectorWorker()
H A DBulkSetup.actor.h171 state Future<Standalone<RangeResultRef>> countFuture = tr.getRange(keyPrefix, 1000000000); in trackInsertionCount()
172 state Future<Standalone<RangeResultRef>> bytesFuture = tr.getRange(bytesPrefix, 1000000000); in trackInsertionCount()
175 Standalone<RangeResultRef> counts = countFuture.get(); in trackInsertionCount()
176 Standalone<RangeResultRef> bytes = bytesFuture.get(); in trackInsertionCount()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbclient/
H A DKeyRangeMap.actor.cpp38 Standalone<RangeResultRef> krmDecodeRanges( in krmDecodeRanges()
41 Standalone<RangeResultRef> kv ) in krmDecodeRanges()
52 Standalone<RangeResultRef> result; in krmDecodeRanges()
74 ACTOR Future<Standalone<RangeResultRef>> krmGetRanges( Transaction* tr, Key mapPrefix, KeyRange key… in krmGetRanges()
80 …Standalone<RangeResultRef> kv = wait( tr->getRange( lastLessOrEqual(withPrefix.begin), firstGreate… in krmGetRanges()
85 ACTOR Future<Standalone<RangeResultRef>> krmGetRanges( Reference<ReadYourWritesTransaction> tr, Key… in krmGetRanges()
91 …Standalone<RangeResultRef> kv = wait( tr->getRange( lastLessOrEqual(withPrefix.begin), firstGreate… in krmGetRanges()
112 …Standalone<RangeResultRef> old = wait(tr->getRange(lastLessOrEqual(withPrefix.end), firstGreaterTh… in krmSetRange()
132 …Standalone<RangeResultRef> old = wait(tr->getRange(lastLessOrEqual(withPrefix.end), firstGreaterTh… in krmSetRange()
159 state vector<Future<Standalone<RangeResultRef>>> keys; in krmSetRangeCoalescing()
H A DReadYourWrites.actor.cpp70 typedef Standalone<RangeResultRef> Result;
176 …return Standalone<RangeResultRef>(RangeResultRef( VectorRef<KeyValueRef>(&_v[0], i+1), false ), _v… in readThrough()
481 return RangeResultRef(false, false); in getRangeValue()
497 return RangeResultRef(false, false); in getRangeValue()
521 return RangeResultRef(false, false); in getRangeValue()
754 return RangeResultRef(false, false); in getRangeValueBack()
894 RangeResultRef reversed; in getRangeValueBack()
1175 Standalone<RangeResultRef> result; in getWorkerInterfaces()
1273 return Standalone<RangeResultRef>(); in getRange()
1291 return Standalone<RangeResultRef>(); in getRange()
[all …]
H A DIClientApi.h43 …virtual ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySe…
44 …virtual ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySe…
45 …virtual ThreadFuture<Standalone<RangeResultRef>> getRange(const KeyRangeRef& keys, int limit, bool…
46 …virtual ThreadFuture<Standalone<RangeResultRef>> getRange( const KeyRangeRef& keys, GetRangeLimits…
H A DThreadSafeTransaction.h64 …ThreadFuture< Standalone<RangeResultRef> > getRange( const KeySelectorRef& begin, const KeySelecto…
65 …ThreadFuture< Standalone<RangeResultRef> > getRange( const KeySelectorRef& begin, const KeySelecto…
66 …ThreadFuture< Standalone<RangeResultRef> > getRange( const KeyRangeRef& keys, int limit, bool snap…
69 …ThreadFuture< Standalone<RangeResultRef> > getRange( const KeyRangeRef& keys, GetRangeLimits limit…
H A DReadYourWrites.h75 …Future< Standalone<RangeResultRef> > getRange( const KeySelector& begin, const KeySelector& end, i…
76 …Future< Standalone<RangeResultRef> > getRange( KeySelector begin, KeySelector end, GetRangeLimits …
77 …Future< Standalone<RangeResultRef> > getRange( const KeyRange& keys, int limit, bool snapshot = fa…
81 …Future< Standalone<RangeResultRef> > getRange( const KeyRange& keys, GetRangeLimits limits, bool s…
H A DMultiVersionTransaction.h125 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySelectorRe…
126 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySelectorRe…
127 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeyRangeRef& keys, int limit, bool snapsho…
128 …ThreadFuture<Standalone<RangeResultRef>> getRange( const KeyRangeRef& keys, GetRangeLimits limits,…
221 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySelectorRe…
222 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeySelectorRef& begin, const KeySelectorRe…
223 …ThreadFuture<Standalone<RangeResultRef>> getRange(const KeyRangeRef& keys, int limit, bool snapsho…
224 …ThreadFuture<Standalone<RangeResultRef>> getRange( const KeyRangeRef& keys, GetRangeLimits limits,…
H A DNativeAPI.actor.h234 …Future< Standalone<RangeResultRef> > getRange( const KeySelector& begin, const KeySelector& end, i…
235 …Future< Standalone<RangeResultRef> > getRange( const KeySelector& begin, const KeySelector& end, G…
236 …Future< Standalone<RangeResultRef> > getRange( const KeyRange& keys, int limit, bool snapshot = fa…
240 …Future< Standalone<RangeResultRef> > getRange( const KeyRange& keys, GetRangeLimits limits, bool s…
H A DThreadSafeTransaction.actor.cpp149 ThreadFuture< Standalone<RangeResultRef> > ThreadSafeTransaction::getRange( const KeySelectorRef& b… in getRange()
154 …return onMainThread( [tr, b, e, limit, snapshot, reverse]() -> Future< Standalone<RangeResultRef> … in getRange()
160 ThreadFuture< Standalone<RangeResultRef> > ThreadSafeTransaction::getRange( const KeySelectorRef& b… in getRange()
165 …return onMainThread( [tr, b, e, limits, snapshot, reverse]() -> Future< Standalone<RangeResultRef>… in getRange()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/bindings/flow/
H A Dfdb_flow.h68 virtual Future<FDBStandalone<RangeResultRef>> getRange(
72 virtual Future<FDBStandalone<RangeResultRef>> getRange(
77 virtual Future<FDBStandalone<RangeResultRef>> getRange(
84 virtual Future<FDBStandalone<RangeResultRef>> getRange(
H A DFDBLoanerTypes.h159 struct RangeResultRef : VectorRef<KeyValueRef> { struct
167 RangeResultRef() : more(false), readToBegin(false), readThroughEnd(false) {} in RangeResultRef() argument
168 …RangeResultRef( Arena& p, const RangeResultRef& toCopy ) : more( toCopy.more ), readToBegin( toCop… in RangeResultRef() argument
169 …RangeResultRef( const VectorRef<KeyValueRef>& value, bool more, Optional<KeyRef> readThrough = Opt…
170 …RangeResultRef( bool readToBegin, bool readThroughEnd ) : more(false), readToBegin(readToBegin), r… in RangeResultRef() argument
H A Dfdb_flow.actor.cpp68 …FDBStandalone<RangeResultRef> r = wait( tr->getRange( KeyRangeRef( LiteralStringRef("a"), LiteralS… in _test()
134 Future<FDBStandalone<RangeResultRef>> getRange(const KeySelector& begin, const KeySelector& end,
338 …Future<FDBStandalone<RangeResultRef>> TransactionImpl::getRange(const KeySelector& begin, const Ke… in getRange()
340 …return backToFuture< FDBStandalone<RangeResultRef> >( fdb_transaction_get_range( tr, begin.key.beg… in getRange()
347 …return FDBStandalone<RangeResultRef>( f, RangeResultRef( VectorRef<KeyValueRef>( (KeyValueRef*)kv,… in getRange()
H A DHighContentionAllocator.actor.cpp29 FDBStandalone<RangeResultRef> range = wait(tr->getRange(counters.range(), 1, true, true)); in _allocate()
72 …state Future<FDBStandalone<RangeResultRef>> latestCounter = tr->getRange(counters.range(), 1, true… in _allocate()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A Dpubsub.actor.cpp217 state Standalone<RangeResultRef> watchingInboxes = wait( (*tr).getRange( in updateFeedWatchers()
264 state Standalone<RangeResultRef> latestMessage = wait( tr.getRange( in _postMessage()
322 state Standalone<RangeResultRef> staleFeeds = wait( tr.getRange( in singlePassInboxCacheUpdate()
379 state Standalone<RangeResultRef> lastMessageRange = wait( (*tr).getRange( in getFeedLatestAtOrAfter()
416 state Standalone<RangeResultRef> feeds = wait( tr.getRange( in _listInboxMessages()
446 Standalone<RangeResultRef> dispatching = wait( tr.getRange( in _listInboxMessages()
488 state Standalone<RangeResultRef> messageIds = wait( tr.getRange( in _listFeedMessages()
H A DMoveKeys.actor.cpp161 ACTOR Future<vector<vector<UID>>> additionalSources(Standalone<RangeResultRef> shards, Transaction*… in additionalSources()
279 …state Standalone<RangeResultRef> old = wait( krmGetRanges( &tr, keyServersPrefix, currentKeys, SER… in startMoveKeys()
493 …state Standalone<RangeResultRef> keyServers = wait( krmGetRanges( &tr, keyServersPrefix, currentKe… in finishMoveKeys()
694 …state Future<Standalone<RangeResultRef>> fTagLocalities = tr.getRange( tagLocalityListKeys, CLIENT… in addStorageServer()
700 …state Future<Standalone<RangeResultRef>> fTags = tr.getRange( serverTagKeys, CLIENT_KNOBS->TOO_MAN… in addStorageServer()
701 …state Future<Standalone<RangeResultRef>> fHistoryTags = tr.getRange( serverTagHistoryKeys, CLIENT_… in addStorageServer()
783 …Standalone<RangeResultRef> keys = wait( krmGetRanges( tr, serverKeysPrefixFor(serverID), allKeys, … in canRemoveStorageServer()
817 …state Future<Standalone<RangeResultRef>> fTags = tr.getRange( serverTagKeys, CLIENT_KNOBS->TOO_MAN… in removeStorageServer()
818 …state Future<Standalone<RangeResultRef>> fHistoryTags = tr.getRange( serverTagHistoryKeys, CLIENT_… in removeStorageServer()
819 …state Future<Standalone<RangeResultRef>> fTagLocalities = tr.getRange( tagLocalityListKeys, CLIENT… in removeStorageServer()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/bindings/c/
H A Dfdb_c.cpp263 Standalone<RangeResultRef> rrr = TSAV(Standalone<RangeResultRef>, f)->get(); in fdb_future_get_keyvalue_array_impl()
274 Standalone<RangeResultRef> rrr = TSAV(Standalone<RangeResultRef>, f)->get(); in fdb_future_get_keyvalue_array_v13()
456 return TSAV_ERROR(Standalone<RangeResultRef>, exact_mode_without_limits); in fdb_transaction_get_range_impl()
475 return TSAV_ERROR(Standalone<RangeResultRef>, client_invalid_operation); in fdb_transaction_get_range_impl()
483 return TSAV_ERROR(Standalone<RangeResultRef>, client_invalid_operation); in fdb_transaction_get_range_impl()

1234