Home
last modified time | relevance | path

Searched refs:errorOr (Results 1 – 13 of 13) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/
H A DLoadBalance.actor.h150 model->addActor.send(success(errorOr(reply))); in addLaggingRequest()
326 …when(ErrorOr<Optional<REPLY_TYPE(Request)>> result = wait( firstRequest.isValid() ? errorOr(firstR…
341 when(ErrorOr<Optional<REPLY_TYPE(Request)>> result = wait( errorOr(secondRequest) )) {
369 when(ErrorOr<Optional<REPLY_TYPE(Request)>> result = wait( errorOr(firstRequest) )) {
H A DAsyncFileNonDurable.actor.h640 wait(success(errorOr(allModifications))); in onSync()
647 wait(success(errorOr(self->file->sync()))); in onSync()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/
H A DUnreadable.actor.cpp359 …ErrorOr<Standalone<RangeResultRef>> value = wait(errorOr(tr.getRange(range, CLIENT_KNOBS->TOO_MANY… in _start()
393 …ErrorOr<Standalone<RangeResultRef>> value = wait(errorOr(tr.getRange(begin, end, limit, snapshot, … in _start()
436 ErrorOr<Optional<Value>> value = wait(errorOr(tr.get(key, snapshot))); in _start()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A DStatus.actor.cpp89 …ErrorOr<TraceEventFields> eventTrace = wait( errorOr(timeoutError(worker.eventLogRequest.getReply… in latestEventOnWorker()
108 …eventTraces.push_back(errorOr(timeoutError(workers[c].interf.eventLogRequest.getReply(req), 2.0))); in latestEventOnWorkers()
920 ErrorOr<double> grv = wait(errorOr(grvProbe)); in doReadProbe()
941 ErrorOr<double> grv = wait(errorOr(grvProbe)); in doCommitProbe()
967 when(ErrorOr<double> result = wait(errorOr(probe))) { in doProbe()
1974 …tor<std::pair<StorageServerInterface, EventMap>>>> storageServerFuture = errorOr(getStorageServers… in clusterGetStatus()
1975 …state Future<ErrorOr<vector<std::pair<TLogInterface, EventMap>>>> tLogFuture = errorOr(getTLogsAnd… in clusterGetStatus()
1976 …state Future<ErrorOr<vector<std::pair<MasterProxyInterface, EventMap>>>> proxyFuture = errorOr(get… in clusterGetStatus()
H A Dworker.actor.cpp117 state Future<ErrorOr<Void>> storeError = actor.isReady() ? Never() : errorOr( store->getError() ); in handleIOErrors()
119 when (state ErrorOr<Void> e = wait( errorOr(actor) )) { in handleIOErrors()
479 ErrorOr<Void> e = wait( errorOr( prevStorageServer) ); in storageServerRollbackRebooter()
1220 …state ErrorOr<Reference<IAsyncFile>> lockFile = wait(errorOr(IAsyncFileSystem::filesystem(g_networ… in createAndLockProcessIdFile()
H A DKeyValueStoreSQLite.actor.cpp1197 …ErrorOr<Reference<IAsyncFile>> dbFile = waitForAndGet( errorOr( IAsyncFileSystem::filesystem()->op… in checkAllPageChecksums()
1198 …ErrorOr<Reference<IAsyncFile>> walFile = waitForAndGet( errorOr( IAsyncFileSystem::filesystem()->o… in checkAllPageChecksums()
1283 …ErrorOr<Reference<IAsyncFile>> dbFile = waitForAndGet( errorOr( IAsyncFileSystem::filesystem()->op… in open()
1284 …ErrorOr<Reference<IAsyncFile>> walFile = waitForAndGet( errorOr( IAsyncFileSystem::filesystem()->o… in open()
H A DDiskQueue.actor.cpp478 wait(success(errorOr(self->lastCommit))); in shutdown()
H A DOldTLogServer_4_6.actor.cpp1296 removed.push_back(errorOr(logData->removed)); in restorePersistentState()
H A DClusterController.actor.cpp2076 …state ErrorOr<StatusReply> result = wait(errorOr(clusterGetStatus(self->db.serverInfo, self->cx, w…
2612 state Future<ErrorOr<Void>> error = errorOr( actorCollection( self.addActor.getFuture() ) );
H A DOldTLogServer_6_0.actor.cpp1798 removed.push_back(errorOr(logData->removed)); in restorePersistentState()
H A DTLogServer.actor.cpp2165 removed.push_back(errorOr(logData->removed)); in restorePersistentState()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/flow/
H A Dgenericactors.actor.h104 ErrorOr<T> errorOr( T t ) { in errorOr() function
109 Future<ErrorOr<T>> errorOr( Future<T> f ) { in errorOr() function
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbclient/
H A DFileBackupAgent.actor.cpp1882 state Future<Void> sendEOS = map(errorOr(waitForAll(rc)), [=](ErrorOr<Void> const &result) { in _execute()