Home
last modified time | relevance | path

Searched refs:logSystem (Results 1 – 17 of 17) sorted by relevance

/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-core/include/aws/core/utils/logging/
H A DLogMacros.h46 if ( logSystem ) \
55 if ( logSystem && logSystem->GetLogLevel() >= level ) \
64 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Fatal ) \
73 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Error ) \
82 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Warn ) \
91 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Info ) \
100 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Debug ) \
109 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Trace ) \
118 if ( logSystem && logSystem->GetLogLevel() >= level ) \
151 if ( logSystem && logSystem->GetLogLevel() >= Aws::Utils::Logging::LogLevel::Warn ) \
[all …]
H A DAWSLogging.h24 … AWS_CORE_API void InitializeAWSLogging(const std::shared_ptr<LogSystemInterface>& logSystem);
41 AWS_CORE_API void PushLogger(const std::shared_ptr<LogSystemInterface> &logSystem);
/dports/devel/qca/qca-2.3.4/unittest/logger/
H A Dloggerunittest.cpp121 QCA::Logger *logSystem = QCA::logger(); in basicSetup() local
125 logSystem->setLevel(QCA::Logger::Debug); in basicSetup()
130 logSystem->registerLogDevice(nullLogger); in basicSetup()
141 QCA::Logger *logSystem = QCA::logger(); in logText1() local
146 logSystem->registerLogDevice(lastlogger); in logText1()
184 QCA::Logger *logSystem = QCA::logger(); in logText2() local
218 QCA::Logger *logSystem = QCA::logger(); in logBlob() local
223 logSystem->logBinaryMessage(test); in logBlob()
230 logSystem->logBinaryMessage(test); in logBlob()
244 logSystem->logBinaryMessage(test); in logBlob()
[all …]
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/
H A DTagPartitionedLogSystem.actor.cpp192 return logSystem; in fromLogSystemConfig()
204 logSystem->tLogs[i] = logSet; in fromOldLogSystemConfig()
257 logSystem->stopped = true; in fromOldLogSystemConfig()
259 return logSystem; in fromOldLogSystemConfig()
1269 logSystem->recoverAt = 0; in epochEnd()
1271 logSystem->stopped = true; in epochEnd()
1553 logSystem->stopped = true; in epochEnd()
1900 logSystem->tLogs[1]->updateLocalitySet(logSystem->tLogs[1]->tLogLocalities); in newEpoch()
2080 logSystem->remoteRecovery = logSystem->recoveryComplete; in newEpoch()
2081 logSystem->remoteRecoveryComplete = logSystem->recoveryComplete; in newEpoch()
[all …]
H A DLogSystemDiskQueueAdapter.actor.cpp31 if (self->recoveryLoc == self->logSystem->getEnd()) { in readNext()
33 ….detail("Bytes", bytes).detail("Loc", self->recoveryLoc).detail("End", self->logSystem->getEnd()); in readNext()
34 self->logSystem.clear(); in readNext()
45 …self->cursor = self->logSystem->peekSpecial( UID(), self->recoveryLoc, self->tag, self->peekLocali… in readNext()
51 self->cursor = self->logSystem->peek( UID(), self->recoveryLoc, self->tag, true ); in readNext()
54 …self->cursor = self->logSystem->peekSpecial( UID(), self->recoveryLoc, self->tag, self->peekLocali… in readNext()
57 …self->cursor = self->logSystem->peekSpecial( UID(), self->recoveryLoc, self->tag, self->peekLocali… in readNext()
63 ….detail("Bytes", bytes).detail("Loc", self->recoveryLoc).detail("End", self->logSystem->getEnd()); in readNext()
171 LogSystemDiskQueueAdapter* openDiskQueueAdapter( Reference<ILogSystem> logSystem, Tag tag, Referenc… in openDiskQueueAdapter() argument
172 return new LogSystemDiskQueueAdapter( logSystem, tag, peekLocality ); in openDiskQueueAdapter()
H A DLogSystemDiskQueueAdapter.h55 …ference<ILogSystem> logSystem, Tag tag, Reference<AsyncVar<PeekSpecialInfo>> peekLocality, bool re… in logSystem() argument
58 …cursor = logSystem->peekSpecial( UID(), 1, tag, peekLocality ? peekLocality->get().primaryLocality… in logSystem()
103 Reference<ILogSystem> logSystem; variable
117 LogSystemDiskQueueAdapter* openDiskQueueAdapter( Reference<ILogSystem> logSystem, Tag tag, Referenc…
H A DLogSystem.h713 explicit LogPushData(Reference<ILogSystem> logSystem) : logSystem(logSystem), subsequence(1) { in LogPushData()
714 for(auto& log : logSystem->getLogSystemConfig().tLogs) { in LogPushData()
731 if(logSystem->hasRemoteLogs()) {
732 prev_tags.push_back( logSystem->getRandomRouterTag() );
738 logSystem->getPushLocations( prev_tags, msg_locations );
753 if(logSystem->hasRemoteLogs()) { in addTypedMessage()
754 prev_tags.push_back( logSystem->getRandomRouterTag() ); in addTypedMessage()
760 logSystem->getPushLocations( prev_tags, msg_locations ); in addTypedMessage()
781 Reference<ILogSystem> logSystem;
H A DLogRouter.actor.cpp77 Reference<AsyncVar<Reference<ILogSystem>>> logSystem; member
106 …itializeLogRouterRequest req) : dbgid(dbgid), routerTag(req.routerTag), logSystem(new AsyncVar<Ref… in LogRouterData()
217 if( self->logSystem->get() ) in pullAsyncData()
218 r = self->logSystem->get()->peekLogRouter( self->dbgid, tagAt, self->routerTag ); in pullAsyncData()
221 dbInfoChange = self->logSystem->onChange(); in pullAsyncData()
380 if(self->logSystem->get() && self->allowPops) { in logRouterPop()
381 self->logSystem->get()->pop(self->poppedVersion, self->routerTag); in logRouterPop()
404 …logRouterData.logSystem->set(ILogSystem::fromServerDBInfo( logRouterData.dbgid, db->get(), true )); in logRouterCore()
H A Dmasterserver.actor.cpp180 Reference< ILogSystem > logSystem; member
329 self->logSystem = Reference<ILogSystem>(); in newTLogServers()
331 self->logSystem = newLogSystem; in newTLogServers()
334 self->logSystem = Reference<ILogSystem>(); in newTLogServers()
336 self->logSystem = newLogSystem; in newTLogServers()
424 for(auto& logSet : self->logSystem->getLogSystemConfig().tLogs) { in updateLogsValue()
441 tr.set(logsKey, self->logSystem->getLogsValue()); in updateLogsValue()
1134 self->logSystem->toCoreState( newState ); in trackTlogRecovery()
1142 self->logSystem->coreStateWritten(newState); in trackTlogRecovery()
1351 self->addActor.send( self->logSystem->onError() ); in masterCore()
[all …]
H A DOldTLogServer_6_0.actor.cpp411 Reference<AsyncVar<Reference<ILogSystem>>> logSystem; member
1141 logData->logSystem->get()->pop(ver, logData->remoteTag, knownCommittedVersion, logData->locality); in doQueueCommit()
1439 logData->logSystem->set(ILogSystem::fromServerDBInfo( self->dbgid, self->dbInfo->get() )); in serveTLogInterface()
1446 logData->removed = logData->removed && logData->logSystem->get()->endEpoch(); in serveTLogInterface()
1449 logData->logSystem->set(Reference<ILogSystem>()); in serveTLogInterface()
1517 if( logData->logSystem->get() ) { in pullAsyncData()
1522 dbInfoChange = logData->logSystem->onChange(); in pullAsyncData()
1928 logSystem->set(Reference<ILogSystem>()); in updateLogSystem()
1954 if(!it.second->isPrimary && it.second->logSystem->get()) { in tLogStart()
1955 it.second->removed = it.second->removed && it.second->logSystem->get()->endEpoch(); in tLogStart()
[all …]
H A DApplyMetadataMutation.h48 …teStore, LogPushData* toCommit, bool *confChange, Reference<ILogSystem> logSystem = Reference<ILog…
309 if (logSystem && popVersion) {
314 logSystem->pop( popVersion, decodeServerTagValue(kv.value) );
337 if (logSystem && popVersion) {
342 logSystem->pop( popVersion, tag );
H A DMasterProxyServer.actor.cpp194 Reference<ILogSystem> logSystem; member
416 state LogPushData toCommit(self->logSystem); in commitBatch()
903 …Future<Version> loggingComplete = self->logSystem->push( prevVersion, commitVersion, self->committ… in commitBatch()
935 self->logSystem->pop(msg.popTo, txsTag); in commitBatch()
1033 wait(commitData->logSystem->confirmEpochLive(debugID)); in getLiveCommittedVersion()
1399 self->logSystem->pop(self->txsPopVersions.front().second, txsTag, 0, tagLocalityRemoteLog); in monitorRemoteCommitted()
1455 commitData.logSystem = ILogSystem::fromServerDBInfo(proxy.id(), db->get(), false, addActor); in masterProxyServerCore()
1456 …commitData.logAdapter = new LogSystemDiskQueueAdapter(commitData.logSystem, txsTag, Reference<Asyn… in masterProxyServerCore()
1482 commitData.logSystem = ILogSystem::fromServerDBInfo(proxy.id(), db->get(), false, addActor); in masterProxyServerCore()
1484 commitData.logSystem->pop(it.second, it.first); in masterProxyServerCore()
[all …]
H A DTLogServer.actor.cpp468 Reference<AsyncVar<Reference<ILogSystem>>> logSystem; member
1500 logData->logSystem->get()->pop(ver, logData->remoteTag, knownCommittedVersion, logData->locality); in doQueueCommit()
1799 logData->logSystem->set(ILogSystem::fromServerDBInfo( self->dbgid, self->dbInfo->get() )); in serveTLogInterface()
1806 logData->removed = logData->removed && logData->logSystem->get()->endEpoch(); in serveTLogInterface()
1809 logData->logSystem->set(Reference<ILogSystem>()); in serveTLogInterface()
1881 if( logData->logSystem->get() ) { in pullAsyncData()
1886 dbInfoChange = logData->logSystem->onChange(); in pullAsyncData()
2314 logSystem->set(Reference<ILogSystem>()); in updateLogSystem()
2340 if(!it.second->isPrimary && it.second->logSystem->get()) { in tLogStart()
2341 it.second->removed = it.second->removed && it.second->logSystem->get()->endEpoch(); in tLogStart()
[all …]
H A Dstorageserver.actor.cpp316 if(logSystem) { in popVersion()
330 logSystem->pop( v, hist->back().second ); in popVersion()
334 logSystem->pop( v, hist->back().second ); in popVersion()
336 logSystem->pop( v, tag ); in popVersion()
390 Reference<ILogSystem> logSystem; member
3376 TEST( self->logSystem ); // shardServer dbInfo changed in storageServerCore()
3379 self->logSystem = ILogSystem::fromServerDBInfo( self->thisServerID, self->db->get() ); in storageServerCore()
3380 if (self->logSystem) { in storageServerCore()
3384 …self->logCursor = self->logSystem->peekSingle( self->thisServerID, self->version.get() + 1, self->… in storageServerCore()
3452 if (!self->logSystem) in storageServerCore()
/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-core/source/utils/logging/
H A DAWSLogging.cpp25 void InitializeAWSLogging(const std::shared_ptr<LogSystemInterface> &logSystem) { in InitializeAWSLogging() argument
26 AWSLogSystem = logSystem; in InitializeAWSLogging()
37 void PushLogger(const std::shared_ptr<LogSystemInterface> &logSystem) in PushLogger() argument
40 AWSLogSystem = logSystem; in PushLogger()
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/internal/imageresizer/
H A Dimage_resizer.go78 logSystem = "imageresizer" const
405 "subsystem": logSystem,
408 logSystem + ".status": outcome.status,
409 logSystem + ".target_width": targetWidth,
410 logSystem + ".content_type": contentType,
411 logSystem + ".original_filesize": outcome.originalFileSize,
/dports/net-mgmt/librenms/librenms-21.5.1/mibs/chatsworth/
H A DCPI-UNITY-MIB7384 logSystem OBJECT-TYPE