/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
H A D | DBCoreState.h | 40 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 D | LogSystemConfig.h | 85 …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 D | TagPartitionedLogSystem.actor.cpp | 129 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 D | Status.actor.cpp | 621 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 D | masterserver.actor.cpp | 324 …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 D | ClusterRecruitmentInterface.h | 86 vector<WorkerInterface> tLogs; member 99 …serializer(ar, tLogs, satelliteTLogs, proxies, resolvers, storageServers, oldLogRouters, dcId, sat… in serialize()
|
H A D | OldTLogServer_4_6.actor.cpp | 1060 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 D | OldTLogServer_6_0.actor.cpp | 1321 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 D | ClusterController.actor.cpp | 660 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 D | LogRouter.actor.cpp | 420 for(auto& log : db->get().logSystemConfig.tLogs) { in checkRemoved() 429 for(auto& log : old.tLogs) { in checkRemoved()
|
H A D | TLogServer.actor.cpp | 1681 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 D | LogSystem.h | 714 for(auto& log : logSystem->getLogSystemConfig().tLogs) { in LogPushData() 716 for(int i = 0; i < log.tLogs.size(); i++) { in LogPushData()
|
H A D | MasterProxyServer.actor.cpp | 1359 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 D | factory_test.go | 52 …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 D | ConsistencyCheck.actor.cpp | 1355 for (auto &tlogSet : db.logSystemConfig.tLogs) { in checkUsingDesiredClasses()
|