Home
last modified time | relevance | path

Searched refs:tLogs (Results 1 – 15 of 15) sorted by relevance

/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A DDBCoreState.h40 std::vector< UID > tLogs; member
70 std::vector<CoreTLogSet> tLogs; member
77 return tLogs == rhs.tLogs && logRouterTags == rhs.logRouterTags && epochEnd == rhs.epochEnd;
86 tLogs.push_back(CoreTLogSet()); in serialize()
87 …serializer(ar, tLogs[0].tLogs, tLogs[0].tLogWriteAntiQuorum, tLogs[0].tLogReplicationFactor, tLogs… in serialize()
94 std::vector<CoreTLogSet> tLogs; member
104 for(auto& it : tLogs) { in getPriorCommittedLogServers()
105 for(auto& log : it.tLogs) { in getPriorCommittedLogServers()
111 for(auto& log : it.tLogs) { in getPriorCommittedLogServers()
136 tLogs.push_back(CoreTLogSet()); in serialize()
[all …]
H A DLogSystemConfig.h85 …tLogs[j].id() != rhs.tLogs[j].id() || tLogs[j].present() != rhs.tLogs[j].present() || ( tLogs[j].p…
106 if( tLogs[i].id() != r.tLogs[i].id() ) { in isEqualIds()
141 if(tLogs.size() != r.tLogs.size()) { in isEqualIds()
145 if(!tLogs[i].isEqualIds(r.tLogs[i])) { in isEqualIds()
177 if(tLogs[i].isLocal) { in allLocalLogs()
178 for( int j = 0; j < tLogs[i].tLogs.size(); j++ ) { in allLocalLogs()
179 if( tLogs[i].tLogs[j].present() ) { in allLocalLogs()
180 results.push_back(tLogs[i].tLogs[j].interf()); in allLocalLogs()
191 for( int j = 0; j < tLogs[i].tLogs.size(); j++ ) { in allPresentLogs()
192 if( tLogs[i].tLogs[j].present() ) { in allPresentLogs()
[all …]
H A DTagPartitionedLogSystem.actor.cpp129 logSystem->tLogs.reserve(lsConf.tLogs.size()); in fromLogSystemConfig()
201 logSystem->tLogs.resize( lsConf.oldTLogs[0].tLogs.size()); in fromOldLogSystemConfig()
656 …tLogs[bestSet]->startVersion, end, true, tLogs[bestSet]->tLogLocalities, tLogs[bestSet]->tLogPolic… in peekLocal()
1406 oldData.tLogs.resize(old.tLogs.size()); in epochEnd()
1585 for(auto& tLogs : self->tLogs) { in recruitOldLogRouters() local
1602 for(auto& tLogs : self->tLogs) { in recruitOldLogRouters() local
1636 for(auto& tLogs : old.tLogs) { in recruitOldLogRouters() local
1651 for(auto& tLogs : old.tLogs) { in recruitOldLogRouters() local
1687 for(auto& tLogs : self->tLogs) { in recruitOldLogRouters() local
1709 for(auto& tLogs : old.tLogs) { in recruitOldLogRouters() local
[all …]
H A DStatus.actor.cpp621 for(log = tLogs.begin(); log != tLogs.end(); ++log) { in processStatusFetcher()
1548 for(int i = 0; i < it.tLogs.size(); i++) { in oldTlogFetcher()
1550 for(auto& log : it.tLogs[i].tLogs) { in oldTlogFetcher()
1563 …maxFaultTolerance = std::max(maxFaultTolerance, it.tLogs[i].tLogReplicationFactor - 1 - it.tLogs[i… in oldTlogFetcher()
1564 if(it.tLogs[i].isLocal && it.tLogs[i].locality == tagLocalitySatellite) { in oldTlogFetcher()
1567 …sat_log_fault_tolerance = it.tLogs[i].tLogReplicationFactor - 1 - it.tLogs[i].tLogWriteAntiQuorum … in oldTlogFetcher()
1569 else if(it.tLogs[i].isLocal) { in oldTlogFetcher()
1571 log_write_anti_quorum = it.tLogs[i].tLogWriteAntiQuorum; in oldTlogFetcher()
1572 …log_fault_tolerance = it.tLogs[i].tLogReplicationFactor - 1 - it.tLogs[i].tLogWriteAntiQuorum - fa… in oldTlogFetcher()
1930 state vector<std::pair<TLogInterface, EventMap>> tLogs; in clusterGetStatus() local
[all …]
H A Dmasterserver.actor.cpp324 …std::transform(recr.tLogs.begin(), recr.tLogs.end(), std::back_inserter(exclusionWorkerIds), [](co… in newTLogServers()
326 …ration, remoteDcId, recr.tLogs.size() * std::max<int>(1, self->configuration.desiredLogRouterCount… in newTLogServers()
424 for(auto& logSet : self->logSystem->getLogSystemConfig().tLogs) { in updateLogsValue()
425 for(auto& log : logSet.tLogs) { in updateLogsValue()
477 …f->cstate.myDBState.recoveryCount).detail("Logs", describe(logSystem->getLogSystemConfig().tLogs)); in updateRegistration()
549 } else if (!self->cstate.prevDBState.tLogs.size()) { in recruitEverything()
596 .detail("TLogs", recruits.tLogs.size()) in recruitEverything()
683 self->safeLocality = oldLogSystem->getLogSystemConfig().tLogs[0].locality; in readTransactionSystemState()
1137 …ASSERT( newState.tLogs[0].tLogWriteAntiQuorum == self->configuration.tLogWriteAntiQuorum && newSta… in trackTlogRecovery()
1139 …state bool allLogs = newState.tLogs.size() == self->configuration.expectedLogSets(self->primaryDcI… in trackTlogRecovery()
[all …]
H A DClusterRecruitmentInterface.h86 vector<WorkerInterface> tLogs; member
99 …serializer(ar, tLogs, satelliteTLogs, proxies, resolvers, storageServers, oldLogRouters, dcId, sat… in serialize()
H A DOldTLogServer_4_6.actor.cpp1060 for(auto& log : inf.logSystemConfig.tLogs) { in rejoinMasters()
1061 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1069 for(auto& log : old.tLogs) { in rejoinMasters()
1070 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1080 ….detail("LogSysConf", describe(inf.logSystemConfig.tLogs)).detail("PriorLogs", describe(inf.priorC… in rejoinMasters()
H A DOldTLogServer_6_0.actor.cpp1321 for(auto& log : inf.logSystemConfig.tLogs) { in rejoinMasters()
1322 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1330 for(auto& log : old.tLogs) { in rejoinMasters()
1331 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1341 ….detail("LogSysConf", describe(inf.logSystemConfig.tLogs)).detail("PriorLogs", describe(inf.priorC… in rejoinMasters()
1431 for(auto& logs : self->dbInfo->get().logSystemConfig.tLogs) { in serveTLogInterface()
1432 if( std::count( logs.tLogs.begin(), logs.tLogs.end(), logData->logId ) ) { in serveTLogInterface()
H A DClusterController.actor.cpp660 result.tLogs.push_back(tlogs[i].interf); in findWorkersForConfiguration()
766 result.tLogs.push_back(tlogs[i].interf); in findWorkersForConfiguration()
834 ….detail("DesiredLogs", req.configuration.getDesiredLogs()).detail("ActualLogs", result.tLogs.size(… in findWorkersForConfiguration()
924 for( auto& logSet : dbi.logSystemConfig.tLogs ) {
925 for( auto& it : logSet.tLogs ) {
1019 for(auto& logSet : dbi.logSystemConfig.tLogs) {
1114 for (const auto& tlogset : dbInfo.logSystemConfig.tLogs) {
1115 for (const auto& tlog: tlogset.tLogs) {
2378 for(auto& logSet : self->db.serverInfo->get().logSystemConfig.tLogs) {
2380 for(auto& tLog : logSet.tLogs) {
[all …]
H A DLogRouter.actor.cpp420 for(auto& log : db->get().logSystemConfig.tLogs) { in checkRemoved()
429 for(auto& log : old.tLogs) { in checkRemoved()
H A DTLogServer.actor.cpp1681 for(auto& log : inf.logSystemConfig.tLogs) { in rejoinMasters()
1682 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1690 for(auto& log : old.tLogs) { in rejoinMasters()
1691 if( std::count( log.tLogs.begin(), log.tLogs.end(), tli.id() ) ) { in rejoinMasters()
1701 ….detail("LogSysConf", describe(inf.logSystemConfig.tLogs)).detail("PriorLogs", describe(inf.priorC… in rejoinMasters()
1791 for(auto& logs : self->dbInfo->get().logSystemConfig.tLogs) { in serveTLogInterface()
1792 if( std::count( logs.tLogs.begin(), logs.tLogs.end(), logData->logId ) ) { in serveTLogInterface()
H A DLogSystem.h714 for(auto& log : logSystem->getLogSystemConfig().tLogs) { in LogPushData()
716 for(int i = 0; i < log.tLogs.size(); i++) { in LogPushData()
H A DMasterProxyServer.actor.cpp1359 for(auto& logSet : db->get().logSystemConfig.tLogs) { in monitorRemoteCommitted()
1361 remoteLogs = logSet.tLogs; in monitorRemoteCommitted()
1362 for(auto& tLog : logSet.tLogs) { in monitorRemoteCommitted()
/dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/receiver/hostmetricsreceiver/
H A Dfactory_test.go52 …tLogs, err := factory.CreateLogsReceiver(context.Background(), creationSet, cfg, consumertest.NewN…
54 assert.Nil(t, tLogs)
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/
H A DConsistencyCheck.actor.cpp1355 for (auto &tlogSet : db.logSystemConfig.tLogs) { in checkUsingDesiredClasses()