Searched refs:throwErrorOr (Results 1 – 4 of 4) sorted by relevance
1614 …auto reply = transformErrors( throwErrorOr( workers[nextRouter].logRouter.getReplyUnlessFailedFor(… in recruitOldLogRouters()1663 …auto reply = transformErrors( throwErrorOr( workers[nextRouter].logRouter.getReplyUnlessFailedFor(… in recruitOldLogRouters()1779 …logRouterInitializationReplies.push_back( transformErrors( throwErrorOr( remoteWorkers.logRouters[… in newRemoteEpoch()1824 …remoteTLogInitializationReplies.push_back( transformErrors( throwErrorOr( remoteWorkers.remoteTLog… in newRemoteEpoch()1841 …recoveryComplete.push_back( transformErrors( throwErrorOr( logSet->logServers[i]->get().interf().r… in newRemoteEpoch()2006 …initializationReplies.push_back( transformErrors( throwErrorOr( recr.tLogs[i].tLog.getReplyUnlessF… in newEpoch()2043 …satelliteInitializationReplies.push_back( transformErrors( throwErrorOr( recr.satelliteTLogs[i].tL… in newEpoch()2052 …recoveryComplete.push_back( transformErrors( throwErrorOr( logSystem->tLogs[1]->logServers[i]->get… in newEpoch()2067 …recoveryComplete.push_back( transformErrors( throwErrorOr( logSystem->tLogs[0]->logServers[i]->get… in newEpoch()
275 …initializationReplies.push_back( transformErrors( throwErrorOr( recr.proxies[i].masterProxy.getRep… in newProxies()293 …initializationReplies.push_back( transformErrors( throwErrorOr( recr.resolvers[i].resolver.getRepl… in newResolvers()
119 Future<T> throwErrorOr( Future<ErrorOr<T>> f ) { in throwErrorOr() function
2585 …reply = proxies.size() ? throwErrorOr ( brokenPromiseToMaybeDelivered ( proxies[0].commit.tryGetRe… in tryCommit()