Namespace list
- Namespace faabric
faabric
faabric::batch_scheduler
faabric::batch_scheduler::InFlightPair
faabric::batch_scheduler::InFlightReqs
faabric::batch_scheduler::Host
faabric::batch_scheduler::HostMap
faabric::batch_scheduler::DecisionType
faabric::batch_scheduler::SchedulingTopologyHint
faabric::batch_scheduler::MigrationStrategy
faabric::batch_scheduler::getBatchScheduler()
faabric::batch_scheduler::resetBatchScheduler()
faabric::batch_scheduler::resetBatchScheduler()
faabric::batch_scheduler::getSchedulingDecisionCache()
faabric::batch_scheduler::getHostFreqCount()
faabric::batch_scheduler::minimiseNumOfMigrations()
faabric::batch_scheduler::deepCopyHostMap()
faabric::batch_scheduler::filterHosts()
faabric::batch_scheduler::filterHosts()
faabric::batch_scheduler::strToTopologyHint
faabric::batch_scheduler::topologyHintToStr
faabric::batch_scheduler::batchScheduler
faabric::batch_scheduler::BatchScheduler
faabric::batch_scheduler::BinPackScheduler
faabric::batch_scheduler::CachedDecision
faabric::batch_scheduler::CompactScheduler
faabric::batch_scheduler::DecisionCache
faabric::batch_scheduler::HostState
faabric::batch_scheduler::SchedulingDecision
faabric::batch_scheduler::SchedulingDecision::SchedulingDecision()
faabric::batch_scheduler::SchedulingDecision::operator==()
faabric::batch_scheduler::SchedulingDecision::isSingleHost()
faabric::batch_scheduler::SchedulingDecision::addMessage()
faabric::batch_scheduler::SchedulingDecision::addMessage()
faabric::batch_scheduler::SchedulingDecision::addMessage()
faabric::batch_scheduler::SchedulingDecision::addMessageInPosition()
faabric::batch_scheduler::SchedulingDecision::removeMessage()
faabric::batch_scheduler::SchedulingDecision::uniqueHosts()
faabric::batch_scheduler::SchedulingDecision::print()
faabric::batch_scheduler::SchedulingDecision::appId
faabric::batch_scheduler::SchedulingDecision::groupId
faabric::batch_scheduler::SchedulingDecision::nFunctions
faabric::batch_scheduler::SchedulingDecision::hosts
faabric::batch_scheduler::SchedulingDecision::messageIds
faabric::batch_scheduler::SchedulingDecision::appIdxs
faabric::batch_scheduler::SchedulingDecision::groupIdxs
faabric::batch_scheduler::SchedulingDecision::mpiPorts
faabric::batch_scheduler::SchedulingDecision::returnHost
faabric::batch_scheduler::SchedulingDecision::fromPointToPointMappings()
faabric::batch_scheduler::SpotScheduler
faabric::endpoint
faabric::endpoint::header
faabric::endpoint::EndpointMode
faabric::endpoint::FaabricEndpoint
faabric::endpoint::FaabricEndpoint::FaabricEndpoint()
faabric::endpoint::FaabricEndpoint::FaabricEndpoint()
faabric::endpoint::FaabricEndpoint::FaabricEndpoint()
faabric::endpoint::FaabricEndpoint::FaabricEndpoint()
faabric::endpoint::FaabricEndpoint::operator=()
faabric::endpoint::FaabricEndpoint::operator=()
faabric::endpoint::FaabricEndpoint::~FaabricEndpoint()
faabric::endpoint::FaabricEndpoint::start()
faabric::endpoint::FaabricEndpoint::stop()
faabric::endpoint::FaabricEndpointHandler
faabric::endpoint::HttpRequestContext
faabric::endpoint::HttpRequestHandler
faabric::endpoint::detail
faabric::executor
faabric::executor::setExecutorFactory()
faabric::executor::getExecutorFactory()
faabric::executor::context
faabric::executor::_factory
faabric::executor::ChainedCallException
faabric::executor::Executor
faabric::executor::Executor::Executor()
faabric::executor::Executor::~Executor()
faabric::executor::Executor::executeTasks()
faabric::executor::Executor::shutdown()
faabric::executor::Executor::reset()
faabric::executor::Executor::executeTask()
faabric::executor::Executor::tryClaim()
faabric::executor::Executor::claim()
faabric::executor::Executor::releaseClaim()
faabric::executor::Executor::getMainThreadSnapshot()
faabric::executor::Executor::getMillisSinceLastExec()
faabric::executor::Executor::getMemoryView()
faabric::executor::Executor::restore()
faabric::executor::Executor::getBoundMessage()
faabric::executor::Executor::isExecuting()
faabric::executor::Executor::isShutdown()
faabric::executor::Executor::addChainedMessage()
faabric::executor::Executor::getChainedMessage()
faabric::executor::Executor::getChainedMessageIds()
faabric::executor::Executor::mergeDirtyRegions()
faabric::executor::Executor::setThreadResult()
faabric::executor::Executor::setMemorySize()
faabric::executor::Executor::id
faabric::executor::ExecutorContext
faabric::executor::ExecutorContext::ExecutorContext()
faabric::executor::ExecutorContext::getExecutor()
faabric::executor::ExecutorContext::getBatchRequest()
faabric::executor::ExecutorContext::getMsg()
faabric::executor::ExecutorContext::getMsgIdx()
faabric::executor::ExecutorContext::isSet()
faabric::executor::ExecutorContext::set()
faabric::executor::ExecutorContext::unset()
faabric::executor::ExecutorContext::get()
faabric::executor::ExecutorContextException
faabric::executor::ExecutorFactory
faabric::executor::ExecutorTask
faabric::executor::ExecutorTask::ExecutorTask()
faabric::executor::ExecutorTask::ExecutorTask()
faabric::executor::ExecutorTask::ExecutorTask()
faabric::executor::ExecutorTask::operator=()
faabric::executor::ExecutorTask::ExecutorTask()
faabric::executor::ExecutorTask::operator=()
faabric::executor::ExecutorTask::req
faabric::executor::ExecutorTask::messageIndex
faabric::mpi
faabric::mpi::InMemoryMpiQueue
faabric::mpi::MpiMessageType
faabric::mpi::MpiMessageType::NORMAL
faabric::mpi::MpiMessageType::BARRIER_JOIN
faabric::mpi::MpiMessageType::BARRIER_DONE
faabric::mpi::MpiMessageType::SCATTER
faabric::mpi::MpiMessageType::GATHER
faabric::mpi::MpiMessageType::ALLGATHER
faabric::mpi::MpiMessageType::REDUCE
faabric::mpi::MpiMessageType::SCAN
faabric::mpi::MpiMessageType::ALLREDUCE
faabric::mpi::MpiMessageType::ALLTOALL
faabric::mpi::MpiMessageType::ALLTOALL_PACKED
faabric::mpi::MpiMessageType::SENDRECV
faabric::mpi::MpiMessageType::BROADCAST
faabric::mpi::MpiMessageType::UNACKED_MPI_MESSAGE
faabric::mpi::MpiMessageType::HANDSHAKE
faabric::mpi::payloadSize()
faabric::mpi::msgSize()
faabric::mpi::serializeMpiMsg()
faabric::mpi::parseMpiMsg()
faabric::mpi::getMpiMockedMessages()
faabric::mpi::getMpiWorldRegistry()
faabric::mpi::getAsyncRequestId()
faabric::mpi::getRanksFromRequestId()
faabric::mpi::checkSendRecvMatch()
faabric::mpi::mockMutex
faabric::mpi::mpiMockedMessages
faabric::mpi::rankState
faabric::mpi::iSendMagic
faabric::mpi::iRecvMagic
faabric::mpi::MpiContext
faabric::mpi::MpiMessage
faabric::mpi::MpiMessage::id
faabric::mpi::MpiMessage::worldId
faabric::mpi::MpiMessage::sendRank
faabric::mpi::MpiMessage::recvRank
faabric::mpi::MpiMessage::typeSize
faabric::mpi::MpiMessage::count
faabric::mpi::MpiMessage::requestId
faabric::mpi::MpiMessage::messageType
faabric::mpi::MpiMessage::buffer
faabric::mpi::MpiRankState
faabric::mpi::MpiRankState::reset()
faabric::mpi::MpiRankState::msgCount
faabric::mpi::MpiRankState::msg
faabric::mpi::MpiRankState::unackedMessageBuffers
faabric::mpi::MpiRankState::pinnedCpu
faabric::mpi::MpiRankState::sendSockets
faabric::mpi::MpiRankState::recvSocket
faabric::mpi::MpiRankState::recvConnPool
faabric::mpi::MpiWorld
faabric::mpi::MpiWorld::MpiWorld()
faabric::mpi::MpiWorld::create()
faabric::mpi::MpiWorld::broadcastHostsToRanks()
faabric::mpi::MpiWorld::initialiseFromMsg()
faabric::mpi::MpiWorld::initialiseRankFromMsg()
faabric::mpi::MpiWorld::getHostForRank()
faabric::mpi::MpiWorld::getUser()
faabric::mpi::MpiWorld::getFunction()
faabric::mpi::MpiWorld::getId()
faabric::mpi::MpiWorld::getSize()
faabric::mpi::MpiWorld::destroy()
faabric::mpi::MpiWorld::getCartesianRank()
faabric::mpi::MpiWorld::getRankFromCoords()
faabric::mpi::MpiWorld::shiftCartesianCoords()
faabric::mpi::MpiWorld::send()
faabric::mpi::MpiWorld::isend()
faabric::mpi::MpiWorld::broadcast()
faabric::mpi::MpiWorld::recv()
faabric::mpi::MpiWorld::irecv()
faabric::mpi::MpiWorld::awaitAsyncRequest()
faabric::mpi::MpiWorld::sendRecv()
faabric::mpi::MpiWorld::scatter()
faabric::mpi::MpiWorld::gather()
faabric::mpi::MpiWorld::allGather()
faabric::mpi::MpiWorld::reduce()
faabric::mpi::MpiWorld::allReduce()
faabric::mpi::MpiWorld::op_reduce()
faabric::mpi::MpiWorld::scan()
faabric::mpi::MpiWorld::allToAll()
faabric::mpi::MpiWorld::probe()
faabric::mpi::MpiWorld::barrier()
faabric::mpi::MpiWorld::getLocalQueue()
faabric::mpi::MpiWorld::getLocalQueueSize()
faabric::mpi::MpiWorld::overrideHost()
faabric::mpi::MpiWorld::getWTime()
faabric::mpi::MpiWorld::prepareMigration()
faabric::mpi::MpiWorldRegistry
faabric::mpi::MpiWorldRegistry::MpiWorldRegistry()
faabric::mpi::MpiWorldRegistry::createWorld()
faabric::mpi::MpiWorldRegistry::getOrInitialiseWorld()
faabric::mpi::MpiWorldRegistry::getWorld()
faabric::mpi::MpiWorldRegistry::worldExists()
faabric::mpi::MpiWorldRegistry::clearWorld()
faabric::mpi::MpiWorldRegistry::clear()
faabric::planner
faabric::planner::MessageResultPromise
faabric::planner::MessageResultPromisePtr
faabric::planner::header
faabric::planner::FlushType
faabric::planner::PlannerCalls
faabric::planner::PlannerCalls::NoPlanerCall
faabric::planner::PlannerCalls::Ping
faabric::planner::PlannerCalls::GetAvailableHosts
faabric::planner::PlannerCalls::RegisterHost
faabric::planner::PlannerCalls::RemoveHost
faabric::planner::PlannerCalls::SetMessageResult
faabric::planner::PlannerCalls::GetMessageResult
faabric::planner::PlannerCalls::GetBatchResults
faabric::planner::PlannerCalls::GetSchedulingDecision
faabric::planner::PlannerCalls::GetNumMigrations
faabric::planner::PlannerCalls::CallBatch
faabric::planner::PlannerCalls::PreloadSchedulingDecision
faabric::planner::getPlanner()
faabric::planner::getPlannerClient()
faabric::planner::availableOpenMpSlots()
faabric::planner::claimHostSlots()
faabric::planner::releaseHostSlots()
faabric::planner::claimHostMpiPort()
faabric::planner::releaseHostMpiPort()
faabric::planner::printHostState()
faabric::planner::convertToBatchSchedHostMap()
faabric::planner::KeepAliveThread
faabric::planner::Planner
faabric::planner::Planner::Planner()
faabric::planner::Planner::getConfig()
faabric::planner::Planner::printConfig()
faabric::planner::Planner::getPolicy()
faabric::planner::Planner::setPolicy()
faabric::planner::Planner::reset()
faabric::planner::Planner::flush()
faabric::planner::Planner::getAvailableHosts()
faabric::planner::Planner::registerHost()
faabric::planner::Planner::removeHost()
faabric::planner::Planner::setMessageResult()
faabric::planner::Planner::getMessageResult()
faabric::planner::Planner::preloadSchedulingDecision()
faabric::planner::Planner::getPreloadedSchedulingDecision()
faabric::planner::Planner::getBatchResults()
faabric::planner::Planner::getSchedulingDecision()
faabric::planner::Planner::getInFlightReqs()
faabric::planner::Planner::getNumMigrations()
faabric::planner::Planner::getNextEvictedHostIps()
faabric::planner::Planner::getEvictedReqs()
faabric::planner::Planner::callBatch()
faabric::planner::Planner::setNextEvictedVm()
faabric::planner::PlannerCache
faabric::planner::PlannerClient
faabric::planner::PlannerClient::PlannerClient()
faabric::planner::PlannerClient::PlannerClient()
faabric::planner::PlannerClient::ping()
faabric::planner::PlannerClient::clearCache()
faabric::planner::PlannerClient::getAvailableHosts()
faabric::planner::PlannerClient::registerHost()
faabric::planner::PlannerClient::removeHost()
faabric::planner::PlannerClient::setMessageResult()
faabric::planner::PlannerClient::setMessageResultLocally()
faabric::planner::PlannerClient::getMessageResult()
faabric::planner::PlannerClient::getMessageResult()
faabric::planner::PlannerClient::getBatchResults()
faabric::planner::PlannerClient::callFunctions()
faabric::planner::PlannerClient::getSchedulingDecision()
faabric::planner::PlannerClient::getNumMigrations()
faabric::planner::PlannerClient::preloadSchedulingDecision()
faabric::planner::PlannerEndpointHandler
faabric::planner::PlannerServer
faabric::planner::PlannerState
faabric::planner::PlannerState::policy
faabric::planner::PlannerState::hostMap
faabric::planner::PlannerState::appResults
faabric::planner::PlannerState::appResultWaiters
faabric::planner::PlannerState::inFlightReqs
faabric::planner::PlannerState::preloadedSchedulingDecisions
faabric::planner::PlannerState::numMigrations
faabric::planner::PlannerState::evictedRequests
faabric::planner::PlannerState::nextEvictedHostIps
faabric::redis
faabric::redis::UniqueRedisReply
faabric::redis::RedisRole
faabric::redis::wrapReply()
faabric::redis::safeRedisCommand()
faabric::redis::getLongFromReply()
faabric::redis::getBytesFromReply()
faabric::redis::getBytesFromReply()
faabric::redis::extractScriptResult()
faabric::redis::extractStringSetFromReply()
faabric::redis::Redis
faabric::redis::Redis::~Redis()
faabric::redis::Redis::ping()
faabric::redis::Redis::get()
faabric::redis::Redis::strlen()
faabric::redis::Redis::get()
faabric::redis::Redis::set()
faabric::redis::Redis::set()
faabric::redis::Redis::del()
faabric::redis::Redis::getCounter()
faabric::redis::Redis::incr()
faabric::redis::Redis::decr()
faabric::redis::Redis::incrByLong()
faabric::redis::Redis::decrByLong()
faabric::redis::Redis::setRange()
faabric::redis::Redis::setRangePipeline()
faabric::redis::Redis::flushPipeline()
faabric::redis::Redis::getRange()
faabric::redis::Redis::sadd()
faabric::redis::Redis::srem()
faabric::redis::Redis::scard()
faabric::redis::Redis::sismember()
faabric::redis::Redis::srandmember()
faabric::redis::Redis::smembers()
faabric::redis::Redis::sdiff()
faabric::redis::Redis::sinter()
faabric::redis::Redis::lpushLong()
faabric::redis::Redis::rpushLong()
faabric::redis::Redis::flushAll()
faabric::redis::Redis::listLength()
faabric::redis::Redis::getTtl()
faabric::redis::Redis::expire()
faabric::redis::Redis::refresh()
faabric::redis::Redis::acquireLock()
faabric::redis::Redis::releaseLock()
faabric::redis::Redis::delIfEq()
faabric::redis::Redis::setnxex()
faabric::redis::Redis::getLong()
faabric::redis::Redis::setLong()
faabric::redis::Redis::enqueue()
faabric::redis::Redis::enqueueBytes()
faabric::redis::Redis::enqueueBytes()
faabric::redis::Redis::dequeue()
faabric::redis::Redis::dequeueBytes()
faabric::redis::Redis::dequeueBytes()
faabric::redis::Redis::dequeueMultiple()
faabric::redis::Redis::publishSchedulerResult()
faabric::redis::Redis::getQueue()
faabric::redis::Redis::getState()
faabric::redis::RedisInstance
faabric::redis::RedisNoResponseException
faabric::runner
faabric::runner::FaabricMain
faabric::runner::FaabricMain::FaabricMain()
faabric::runner::FaabricMain::startBackground()
faabric::runner::FaabricMain::startRunner()
faabric::runner::FaabricMain::startFunctionCallServer()
faabric::runner::FaabricMain::startStateServer()
faabric::runner::FaabricMain::startSnapshotServer()
faabric::runner::FaabricMain::startPointToPointServer()
faabric::runner::FaabricMain::shutdown()
faabric::scheduler
faabric::scheduler::InMemoryMessageQueue
faabric::scheduler::InMemoryMessageQueuePair
faabric::scheduler::FunctionCalls
faabric::scheduler::getFunctionCalls()
faabric::scheduler::getFlushCalls()
faabric::scheduler::getBatchRequests()
faabric::scheduler::getMessageResults()
faabric::scheduler::clearMockRequests()
faabric::scheduler::getFunctionCallClient()
faabric::scheduler::clearFunctionCallClients()
faabric::scheduler::getScheduler()
faabric::scheduler::getChainedKey()
faabric::scheduler::mockMutex
faabric::scheduler::functionCalls
faabric::scheduler::flushCalls
faabric::scheduler::batchMessages
faabric::scheduler::messageResults
faabric::scheduler::functionCallClients
faabric::scheduler::FunctionCallClient
faabric::scheduler::FunctionCallServer
faabric::scheduler::Scheduler
faabric::scheduler::Scheduler::Scheduler()
faabric::scheduler::Scheduler::~Scheduler()
faabric::scheduler::Scheduler::executeBatch()
faabric::scheduler::Scheduler::reset()
faabric::scheduler::Scheduler::resetThreadLocalCache()
faabric::scheduler::Scheduler::shutdown()
faabric::scheduler::Scheduler::isShutdown()
faabric::scheduler::Scheduler::broadcastSnapshotDelete()
faabric::scheduler::Scheduler::reapStaleExecutors()
faabric::scheduler::Scheduler::getFunctionExecutorCount()
faabric::scheduler::Scheduler::setThreadResultLocally()
faabric::scheduler::Scheduler::awaitThreadResults()
faabric::scheduler::Scheduler::getCachedMessageCount()
faabric::scheduler::Scheduler::getThisHost()
faabric::scheduler::Scheduler::addHostToGlobalSet()
faabric::scheduler::Scheduler::addHostToGlobalSet()
faabric::scheduler::Scheduler::removeHostFromGlobalSet()
faabric::scheduler::Scheduler::setThisHostResources()
faabric::scheduler::Scheduler::getRecordedMessages()
faabric::scheduler::Scheduler::clearRecordedMessages()
faabric::scheduler::Scheduler::checkForMigrationOpportunities()
faabric::scheduler::SchedulerReaperThread
faabric::snapshot
faabric::snapshot::SnapshotCalls
faabric::snapshot::getSnapshotPushes()
faabric::snapshot::getSnapshotDiffPushes()
faabric::snapshot::getSnapshotDeletes()
faabric::snapshot::getThreadResults()
faabric::snapshot::clearMockSnapshotRequests()
faabric::snapshot::getSnapshotClient()
faabric::snapshot::clearSnapshotClients()
faabric::snapshot::getSnapshotRegistry()
faabric::snapshot::mockMutex
faabric::snapshot::snapshotPushes
faabric::snapshot::snapshotDiffPushes
faabric::snapshot::snapshotDeletes
faabric::snapshot::threadResults
faabric::snapshot::snapshotClients
faabric::snapshot::MockThreadResult
faabric::snapshot::SnapshotClient
faabric::snapshot::SnapshotRegistry
faabric::snapshot::SnapshotRegistry::SnapshotRegistry()
faabric::snapshot::SnapshotRegistry::getSnapshot()
faabric::snapshot::SnapshotRegistry::snapshotExists()
faabric::snapshot::SnapshotRegistry::registerSnapshot()
faabric::snapshot::SnapshotRegistry::deleteSnapshot()
faabric::snapshot::SnapshotRegistry::getSnapshotCount()
faabric::snapshot::SnapshotRegistry::clear()
faabric::snapshot::SnapshotServer
faabric::state
faabric::state::InMemoryStateKeyStatus
faabric::state::StateCalls
faabric::state::getInMemoryStateRegistry()
faabric::state::getGlobalState()
faabric::state::getMasterKey()
faabric::state::AppendedInMemoryState
faabric::state::InMemoryStateKeyValue
faabric::state::InMemoryStateKeyValue::InMemoryStateKeyValue()
faabric::state::InMemoryStateKeyValue::InMemoryStateKeyValue()
faabric::state::InMemoryStateKeyValue::isMaster()
faabric::state::InMemoryStateKeyValue::getAppendedValue()
faabric::state::InMemoryStateKeyValue::getStateSizeFromRemote()
faabric::state::InMemoryStateKeyValue::deleteFromRemote()
faabric::state::InMemoryStateKeyValue::clearAll()
faabric::state::InMemoryStateRegistry
faabric::state::RedisStateKeyValue
faabric::state::State
faabric::state::State::State()
faabric::state::State::getStateSize()
faabric::state::State::getKV()
faabric::state::State::getKV()
faabric::state::State::forceClearAll()
faabric::state::State::deleteKV()
faabric::state::State::deleteKVLocally()
faabric::state::State::getKVCount()
faabric::state::State::getThisIP()
faabric::state::StateChunk
faabric::state::StateClient
faabric::state::StateClient::StateClient()
faabric::state::StateClient::pushChunks()
faabric::state::StateClient::pullChunks()
faabric::state::StateClient::append()
faabric::state::StateClient::pullAppended()
faabric::state::StateClient::clearAppended()
faabric::state::StateClient::stateSize()
faabric::state::StateClient::deleteState()
faabric::state::StateClient::lock()
faabric::state::StateClient::unlock()
faabric::state::StateClient::user
faabric::state::StateClient::key
faabric::state::StateKeyValue
faabric::state::StateKeyValue::StateKeyValue()
faabric::state::StateKeyValue::StateKeyValue()
faabric::state::StateKeyValue::get()
faabric::state::StateKeyValue::get()
faabric::state::StateKeyValue::getChunk()
faabric::state::StateKeyValue::getChunk()
faabric::state::StateKeyValue::getAllChunks()
faabric::state::StateKeyValue::set()
faabric::state::StateKeyValue::setChunk()
faabric::state::StateKeyValue::append()
faabric::state::StateKeyValue::getAppended()
faabric::state::StateKeyValue::clearAppended()
faabric::state::StateKeyValue::mapSharedMemory()
faabric::state::StateKeyValue::unmapSharedMemory()
faabric::state::StateKeyValue::pull()
faabric::state::StateKeyValue::pushPartial()
faabric::state::StateKeyValue::pushPartialMask()
faabric::state::StateKeyValue::lockRead()
faabric::state::StateKeyValue::unlockRead()
faabric::state::StateKeyValue::lockWrite()
faabric::state::StateKeyValue::unlockWrite()
faabric::state::StateKeyValue::flagDirty()
faabric::state::StateKeyValue::flagChunkDirty()
faabric::state::StateKeyValue::size()
faabric::state::StateKeyValue::getSharedMemorySize()
faabric::state::StateKeyValue::pushFull()
faabric::state::StateKeyValue::user
faabric::state::StateKeyValue::key
faabric::state::StateKeyValue::waitOnRedisRemoteLock()
faabric::state::StateKeyValueException
faabric::state::StateServer
faabric::transport
faabric::transport::MessageResponseCode
faabric::transport::MessageEndpointConnectType
faabric::transport::SocketType
faabric::transport::PointToPointCall
faabric::transport::PointToPointCall::MAPPING
faabric::transport::PointToPointCall::MESSAGE
faabric::transport::PointToPointCall::LOCK_GROUP
faabric::transport::PointToPointCall::LOCK_GROUP_RECURSIVE
faabric::transport::PointToPointCall::UNLOCK_GROUP
faabric::transport::PointToPointCall::UNLOCK_GROUP_RECURSIVE
faabric::transport::getPointToPointBroker()
faabric::transport::getSentMappings()
faabric::transport::getSentPointToPointMessages()
faabric::transport::getSentLockMessages()
faabric::transport::clearSentMessages()
faabric::transport::getClient()
faabric::transport::getPointToPointKey()
faabric::transport::getPointToPointKey()
faabric::transport::getEndpointPtrs()
faabric::transport::MessageResponseCodeText
faabric::transport::groups
faabric::transport::endpoints
faabric::transport::threadEndpoints
faabric::transport::clients
faabric::transport::currentGroupId
faabric::transport::sentMsgCount
faabric::transport::recvMsgCount
faabric::transport::outOfOrderMsgs
faabric::transport::mockMutex
faabric::transport::sentMappings
faabric::transport::sentMessages
faabric::transport::sentLockMessages
faabric::transport::AsyncDirectRecvEndpoint
faabric::transport::AsyncDirectSendEndpoint
faabric::transport::AsyncFanMessageEndpoint
faabric::transport::AsyncInternalRecvMessageEndpoint
faabric::transport::AsyncInternalSendMessageEndpoint
faabric::transport::AsyncRecvMessageEndpoint
faabric::transport::AsyncSendMessageEndpoint
faabric::transport::FanMessageEndpoint
faabric::transport::Message
faabric::transport::Message::Message()
faabric::transport::Message::Message()
faabric::transport::Message::Message()
faabric::transport::Message::~Message()
faabric::transport::Message::Message()
faabric::transport::Message::operator=()
faabric::transport::Message::Message()
faabric::transport::Message::operator=()
faabric::transport::Message::getResponseCode()
faabric::transport::Message::allData()
faabric::transport::Message::allData()
faabric::transport::Message::data()
faabric::transport::Message::data()
faabric::transport::Message::udata()
faabric::transport::Message::udata()
faabric::transport::Message::dataCopy()
faabric::transport::Message::getMessageCode()
faabric::transport::Message::getDeclaredDataSize()
faabric::transport::Message::getSequenceNum()
faabric::transport::MessageContext
faabric::transport::MessageContext::MessageContext()
faabric::transport::MessageContext::MessageContext()
faabric::transport::MessageContext::MessageContext()
faabric::transport::MessageContext::operator=()
faabric::transport::MessageContext::MessageContext()
faabric::transport::MessageContext::operator=()
faabric::transport::MessageContext::~MessageContext()
faabric::transport::MessageContext::context
faabric::transport::MessageEndpoint
faabric::transport::MessageEndpoint::MessageEndpoint()
faabric::transport::MessageEndpoint::MessageEndpoint()
faabric::transport::MessageEndpoint::operator=()
faabric::transport::MessageEndpoint::MessageEndpoint()
faabric::transport::MessageEndpoint::~MessageEndpoint()
faabric::transport::MessageEndpoint::getAddress()
faabric::transport::MessageEndpointClient
faabric::transport::MessageEndpointServer
faabric::transport::MessageEndpointServer::MessageEndpointServer()
faabric::transport::MessageEndpointServer::start()
faabric::transport::MessageEndpointServer::stop()
faabric::transport::MessageEndpointServer::onWorkerStop()
faabric::transport::MessageEndpointServer::setRequestLatch()
faabric::transport::MessageEndpointServer::awaitRequestLatch()
faabric::transport::MessageEndpointServer::getNThreads()
faabric::transport::MessageEndpointServerHandler
faabric::transport::MessageTimeoutException
faabric::transport::PointToPointBroker
faabric::transport::PointToPointBroker::PointToPointBroker()
faabric::transport::PointToPointBroker::getHostForReceiver()
faabric::transport::PointToPointBroker::getMpiPortForReceiver()
faabric::transport::PointToPointBroker::setUpLocalMappingsFromSchedulingDecision()
faabric::transport::PointToPointBroker::setAndSendMappingsFromSchedulingDecision()
faabric::transport::PointToPointBroker::sendMappingsFromSchedulingDecision()
faabric::transport::PointToPointBroker::waitForMappingsOnThisHost()
faabric::transport::PointToPointBroker::getIdxsRegisteredForGroup()
faabric::transport::PointToPointBroker::getHostsRegisteredForGroup()
faabric::transport::PointToPointBroker::updateHostForIdx()
faabric::transport::PointToPointBroker::sendMessage()
faabric::transport::PointToPointBroker::sendMessage()
faabric::transport::PointToPointBroker::recvMessage()
faabric::transport::PointToPointBroker::clearGroup()
faabric::transport::PointToPointBroker::clear()
faabric::transport::PointToPointBroker::resetThreadLocalCache()
faabric::transport::PointToPointBroker::postMigrationHook()
faabric::transport::PointToPointClient
faabric::transport::PointToPointGroup
faabric::transport::PointToPointGroup::PointToPointGroup()
faabric::transport::PointToPointGroup::lock()
faabric::transport::PointToPointGroup::unlock()
faabric::transport::PointToPointGroup::getLockOwner()
faabric::transport::PointToPointGroup::localLock()
faabric::transport::PointToPointGroup::localUnlock()
faabric::transport::PointToPointGroup::localTryLock()
faabric::transport::PointToPointGroup::barrier()
faabric::transport::PointToPointGroup::notify()
faabric::transport::PointToPointGroup::getNotifyCount()
faabric::transport::PointToPointGroup::getGroup()
faabric::transport::PointToPointGroup::getOrAwaitGroup()
faabric::transport::PointToPointGroup::groupExists()
faabric::transport::PointToPointGroup::addGroup()
faabric::transport::PointToPointGroup::addGroupIfNotExists()
faabric::transport::PointToPointGroup::clearGroup()
faabric::transport::PointToPointGroup::clear()
faabric::transport::PointToPointServer
faabric::transport::RecvMessageEndpoint
faabric::transport::SyncFanMessageEndpoint
faabric::transport::SyncRecvMessageEndpoint
faabric::transport::SyncSendMessageEndpoint
faabric::transport::tcp
faabric::transport::tcp::setReuseAddr()
faabric::transport::tcp::setNoDelay()
faabric::transport::tcp::setQuickAck()
faabric::transport::tcp::setNonBlocking()
faabric::transport::tcp::setBlocking()
faabric::transport::tcp::isNonBlocking()
faabric::transport::tcp::setBusyPolling()
faabric::transport::tcp::setRecvTimeoutMs()
faabric::transport::tcp::setSendTimeoutMs()
faabric::transport::tcp::setRecvBufferSize()
faabric::transport::tcp::setSendBufferSize()
faabric::transport::tcp::SocketTimeoutMs
faabric::transport::tcp::SocketBufferSizeBytes
faabric::transport::tcp::Address
faabric::transport::tcp::RecvSocket
faabric::transport::tcp::SendSocket
faabric::transport::tcp::Socket
faabric::util
faabric::util::BeastHttpRequest
faabric::util::BeastHttpResponse
faabric::util::TimePoint
faabric::util::UniqueLock
faabric::util::FullLock
faabric::util::SharedLock
faabric::util::MemoryRegion
faabric::util::DeltaCommand
faabric::util::SnapshotDataType
faabric::util::SnapshotMergeOperation
faabric::util::SnapshotMergeOperation::Bytewise
faabric::util::SnapshotMergeOperation::Sum
faabric::util::SnapshotMergeOperation::Product
faabric::util::SnapshotMergeOperation::Subtract
faabric::util::SnapshotMergeOperation::Max
faabric::util::SnapshotMergeOperation::Min
faabric::util::SnapshotMergeOperation::Ignore
faabric::util::SnapshotMergeOperation::XOR
faabric::util::batchExecFactory()
faabric::util::batchExecFactory()
faabric::util::isBatchExecRequestValid()
faabric::util::updateBatchExecAppId()
faabric::util::updateBatchExecGroupId()
faabric::util::batchExecStatusFactory()
faabric::util::batchExecStatusFactory()
faabric::util::getNumFinishedMessagesInBatch()
faabric::util::stringToBytes()
faabric::util::bytesToInt()
faabric::util::bytesToString()
faabric::util::formatByteArrayToIntString()
faabric::util::trimTrailingZeros()
faabric::util::safeCopyToBuffer()
faabric::util::safeCopyToBuffer()
faabric::util::byteArrayToHexString()
faabric::util::hexStringToByteArray()
faabric::util::intToHexString()
faabric::util::unalignedRead()
faabric::util::unalignedWrite()
faabric::util::appendBytesOf()
faabric::util::readBytesOf()
faabric::util::valueToBytes()
faabric::util::getGlobalClock()
faabric::util::compareArrays()
faabric::util::getSystemConfig()
faabric::util::setUpCrashHandler()
faabric::util::handleCrash()
faabric::util::serializeDelta()
faabric::util::applyDelta()
faabric::util::getDirtyTracker()
faabric::util::resetDirtyTracker()
faabric::util::getEnvVar()
faabric::util::setEnvVar()
faabric::util::unsetEnvVar()
faabric::util::getUsableCores()
faabric::util::getFunctionExecGraphNode()
faabric::util::getFunctionExecGraph()
faabric::util::logChainedFunction()
faabric::util::getChainedFunctions()
faabric::util::countExecGraphNodes()
faabric::util::getExecGraphHosts()
faabric::util::getMpiRankHostsFromExecGraph()
faabric::util::getMigratedMpiRankHostsFromExecGraph()
faabric::util::execNodeToJson()
faabric::util::execGraphToJson()
faabric::util::addDetail()
faabric::util::incrementCounter()
faabric::util::readFileToString()
faabric::util::readFileToBytes()
faabric::util::writeBytesToFile()
faabric::util::isWasm()
faabric::util::funcToString()
faabric::util::funcToString()
faabric::util::setMessageId()
faabric::util::buildAsyncResponse()
faabric::util::messageFactoryShared()
faabric::util::messageFactory()
faabric::util::resultKeyFromMessageId()
faabric::util::statusKeyFromMessageId()
faabric::util::messageToBytes()
faabric::util::getArgvForMessage()
faabric::util::getMainThreadSnapshotKey()
faabric::util::generateGid()
faabric::util::pinThreadToFreeCpu()
faabric::util::messageToJson()
faabric::util::jsonToMessage()
faabric::util::initLogging()
faabric::util::malloc()
faabric::util::free()
faabric::util::realloc()
faabric::util::mergeManyDirtyPages()
faabric::util::mergeDirtyPages()
faabric::util::isPageAligned()
faabric::util::getRequiredHostPages()
faabric::util::getRequiredHostPagesRoundDown()
faabric::util::alignOffsetDown()
faabric::util::getPageAlignedChunk()
faabric::util::allocatePrivateMemory()
faabric::util::allocateSharedMemory()
faabric::util::allocateVirtualMemory()
faabric::util::claimVirtualMemory()
faabric::util::mapMemoryPrivate()
faabric::util::mapMemoryShared()
faabric::util::resizeFd()
faabric::util::writeToFd()
faabric::util::createFd()
faabric::util::appendDataToFd()
faabric::util::getIPFromHostname()
faabric::util::getPrimaryIPForThisHost()
faabric::util::ptpMappingsFromSchedulingDecision()
faabric::util::randomString()
faabric::util::randomStringFromSet()
faabric::util::diffArrayRegions()
faabric::util::calculateDiffValue()
faabric::util::applyDiffValue()
faabric::util::snapshotDataTypeStr()
faabric::util::snapshotMergeOpStr()
faabric::util::keyForUser()
faabric::util::maskDouble()
faabric::util::isAllWhitespace()
faabric::util::startsWith()
faabric::util::endsWith()
faabric::util::contains()
faabric::util::removeSubstr()
faabric::util::stringIsInt()
faabric::util::vectorToString()
faabric::util::setTestMode()
faabric::util::setMockMode()
faabric::util::isTestMode()
faabric::util::isMockMode()
faabric::util::startTimer()
faabric::util::getTimeDiffNanos()
faabric::util::getTimeDiffMicros()
faabric::util::getTimeDiffMillis()
faabric::util::logEndTimer()
faabric::util::startGlobalTimer()
faabric::util::printTimerTotals()
faabric::util::timespecToNanos()
faabric::util::nanosToTimespec()
faabric::util::pageAlignAddress()
faabric::util::countExecGraphNode()
faabric::util::getExecGraphHostsForNode()
faabric::util::getMpiRankHostsFromExecGraphNode()
faabric::util::writeDataCallback()
faabric::util::getNextFreeCpu()
faabric::util::doPinThreadToCpu()
faabric::util::doAlloc()
faabric::util::mapMemory()
faabric::util::DELTA_PROTOCOL_VERSION
faabric::util::DELTA_ZSTD_COMPRESS_LEVEL
faabric::util::NO_CPU_IDX
faabric::util::GHA_CPU_IDX
faabric::util::HOST_PAGE_SIZE
faabric::util::tracking
faabric::util::globalTracking
faabric::util::tracker
faabric::util::uffd
faabric::util::uffdWriteProtect
faabric::util::uffdSigbus
faabric::util::closeFd
faabric::util::eventThread
faabric::util::freeCpus
faabric::util::ipMap
faabric::util::hostnameMx
faabric::util::testMode
faabric::util::mockMode
faabric::util::AlignedChunk
faabric::util::AlignedChunk::originalOffset
faabric::util::AlignedChunk::originalLength
faabric::util::AlignedChunk::nBytesOffset
faabric::util::AlignedChunk::nBytesLength
faabric::util::AlignedChunk::nPagesOffset
faabric::util::AlignedChunk::nPagesLength
faabric::util::AlignedChunk::offsetRemainder
faabric::util::Barrier
faabric::util::ChainedCallFailedException
faabric::util::Clock
faabric::util::ConcurrentMap
faabric::util::ConcurrentMap::key_type
faabric::util::ConcurrentMap::mapped_type
faabric::util::ConcurrentMap::size_type
faabric::util::ConcurrentMap::difference_type
faabric::util::ConcurrentMap::ConcurrentMap()
faabric::util::ConcurrentMap::ConcurrentMap()
faabric::util::ConcurrentMap::ConcurrentMap()
faabric::util::ConcurrentMap::operator=()
faabric::util::ConcurrentMap::ConcurrentMap()
faabric::util::ConcurrentMap::operator=()
faabric::util::ConcurrentMap::swap()
faabric::util::ConcurrentMap::isEmpty()
faabric::util::ConcurrentMap::size()
faabric::util::ConcurrentMap::capacity()
faabric::util::ConcurrentMap::reserve()
faabric::util::ConcurrentMap::rehash()
faabric::util::ConcurrentMap::clear()
faabric::util::ConcurrentMap::erase()
faabric::util::ConcurrentMap::insert()
faabric::util::ConcurrentMap::insertOrAssign()
faabric::util::ConcurrentMap::tryEmplace()
faabric::util::ConcurrentMap::tryEmplaceShared()
faabric::util::ConcurrentMap::inspect()
faabric::util::ConcurrentMap::get()
faabric::util::ConcurrentMap::eraseIf()
faabric::util::DeltaSettings
faabric::util::DirtyTracker
faabric::util::DirtyTracker::DirtyTracker()
faabric::util::DirtyTracker::clearAll()
faabric::util::DirtyTracker::getType()
faabric::util::DirtyTracker::startTracking()
faabric::util::DirtyTracker::stopTracking()
faabric::util::DirtyTracker::getDirtyPages()
faabric::util::DirtyTracker::startThreadLocalTracking()
faabric::util::DirtyTracker::stopThreadLocalTracking()
faabric::util::DirtyTracker::getThreadLocalDirtyPages()
faabric::util::DirtyTracker::getBothDirtyPages()
faabric::util::DirtyTrackingRecord
faabric::util::DirtyTrackingRecord::DirtyTrackingRecord()
faabric::util::DirtyTrackingRecord::trackRegion()
faabric::util::DirtyTrackingRecord::markPage()
faabric::util::DirtyTrackingRecord::isInitialised()
faabric::util::DirtyTrackingRecord::getNPages()
faabric::util::DirtyTrackingRecord::getDirtyFlags()
faabric::util::DirtyTrackingRecord::reset()
faabric::util::ExecGraph
faabric::util::ExecGraphNode
faabric::util::ExecGraphNodeNotFoundException
faabric::util::FaabricCpuSet
faabric::util::FaabricException
faabric::util::FixedCapacityQueue
faabric::util::FixedCapacityQueue::FixedCapacityQueue()
faabric::util::FixedCapacityQueue::FixedCapacityQueue()
faabric::util::FixedCapacityQueue::enqueue()
faabric::util::FixedCapacityQueue::dequeueIfPresent()
faabric::util::FixedCapacityQueue::dequeue()
faabric::util::FixedCapacityQueue::peek()
faabric::util::FixedCapacityQueue::drain()
faabric::util::FixedCapacityQueue::size()
faabric::util::FixedCapacityQueue::reset()
faabric::util::FlagWaiter
faabric::util::FreeCpus
faabric::util::FunctionFrozenException
faabric::util::FunctionMigratedException
faabric::util::JsonSerialisationException
faabric::util::Latch
faabric::util::NoneDirtyTracker
faabric::util::NoneDirtyTracker::NoneDirtyTracker()
faabric::util::NoneDirtyTracker::clearAll()
faabric::util::NoneDirtyTracker::getType()
faabric::util::NoneDirtyTracker::startTracking()
faabric::util::NoneDirtyTracker::stopTracking()
faabric::util::NoneDirtyTracker::getDirtyPages()
faabric::util::NoneDirtyTracker::startThreadLocalTracking()
faabric::util::NoneDirtyTracker::stopThreadLocalTracking()
faabric::util::NoneDirtyTracker::getThreadLocalDirtyPages()
faabric::util::NoneDirtyTracker::getBothDirtyPages()
faabric::util::PeriodicBackgroundThread
faabric::util::Queue
faabric::util::QueueTimeoutException
faabric::util::SegfaultDirtyTracker
faabric::util::SegfaultDirtyTracker::SegfaultDirtyTracker()
faabric::util::SegfaultDirtyTracker::clearAll()
faabric::util::SegfaultDirtyTracker::getType()
faabric::util::SegfaultDirtyTracker::startTracking()
faabric::util::SegfaultDirtyTracker::stopTracking()
faabric::util::SegfaultDirtyTracker::getDirtyPages()
faabric::util::SegfaultDirtyTracker::startThreadLocalTracking()
faabric::util::SegfaultDirtyTracker::stopThreadLocalTracking()
faabric::util::SegfaultDirtyTracker::getThreadLocalDirtyPages()
faabric::util::SegfaultDirtyTracker::getBothDirtyPages()
faabric::util::SegfaultDirtyTracker::handler()
faabric::util::SnapshotData
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::SnapshotData()
faabric::util::SnapshotData::operator=()
faabric::util::SnapshotData::~SnapshotData()
faabric::util::SnapshotData::copyInData()
faabric::util::SnapshotData::getDataPtr()
faabric::util::SnapshotData::getDataCopy()
faabric::util::SnapshotData::getDataCopy()
faabric::util::SnapshotData::mapToMemory()
faabric::util::SnapshotData::addMergeRegion()
faabric::util::SnapshotData::fillGapsWithBytewiseRegions()
faabric::util::SnapshotData::clearMergeRegions()
faabric::util::SnapshotData::getMergeRegions()
faabric::util::SnapshotData::getQueuedDiffsCount()
faabric::util::SnapshotData::applyDiffs()
faabric::util::SnapshotData::applyDiff()
faabric::util::SnapshotData::queueDiffs()
faabric::util::SnapshotData::writeQueuedDiffs()
faabric::util::SnapshotData::getSize()
faabric::util::SnapshotData::getMaxSize()
faabric::util::SnapshotData::getTrackedChanges()
faabric::util::SnapshotData::clearTrackedChanges()
faabric::util::SnapshotData::diffWithDirtyRegions()
faabric::util::SnapshotDiff
faabric::util::SnapshotMergeRegion
faabric::util::SnapshotMergeRegion::SnapshotMergeRegion()
faabric::util::SnapshotMergeRegion::SnapshotMergeRegion()
faabric::util::SnapshotMergeRegion::addDiffs()
faabric::util::SnapshotMergeRegion::operator<()
faabric::util::SnapshotMergeRegion::operator==()
faabric::util::SnapshotMergeRegion::offset
faabric::util::SnapshotMergeRegion::length
faabric::util::SnapshotMergeRegion::dataType
faabric::util::SnapshotMergeRegion::operation
faabric::util::SoftPTEDirtyTracker
faabric::util::SoftPTEDirtyTracker::SoftPTEDirtyTracker()
faabric::util::SoftPTEDirtyTracker::~SoftPTEDirtyTracker()
faabric::util::SoftPTEDirtyTracker::clearAll()
faabric::util::SoftPTEDirtyTracker::getType()
faabric::util::SoftPTEDirtyTracker::startTracking()
faabric::util::SoftPTEDirtyTracker::stopTracking()
faabric::util::SoftPTEDirtyTracker::getDirtyPages()
faabric::util::SoftPTEDirtyTracker::startThreadLocalTracking()
faabric::util::SoftPTEDirtyTracker::stopThreadLocalTracking()
faabric::util::SoftPTEDirtyTracker::getThreadLocalDirtyPages()
faabric::util::SoftPTEDirtyTracker::getBothDirtyPages()
faabric::util::SpinLockQueue
faabric::util::SystemConfig
faabric::util::SystemConfig::SystemConfig()
faabric::util::SystemConfig::print()
faabric::util::SystemConfig::reset()
faabric::util::SystemConfig::serialisation
faabric::util::SystemConfig::logLevel
faabric::util::SystemConfig::logFile
faabric::util::SystemConfig::stateMode
faabric::util::SystemConfig::deltaSnapshotEncoding
faabric::util::SystemConfig::redisStateHost
faabric::util::SystemConfig::redisQueueHost
faabric::util::SystemConfig::redisPort
faabric::util::SystemConfig::overrideCpuCount
faabric::util::SystemConfig::overrideFreeCpuStart
faabric::util::SystemConfig::batchSchedulerMode
faabric::util::SystemConfig::globalMessageTimeout
faabric::util::SystemConfig::boundTimeout
faabric::util::SystemConfig::reaperIntervalSeconds
faabric::util::SystemConfig::defaultMpiWorldSize
faabric::util::SystemConfig::endpointInterface
faabric::util::SystemConfig::endpointHost
faabric::util::SystemConfig::endpointPort
faabric::util::SystemConfig::endpointNumThreads
faabric::util::SystemConfig::functionServerThreads
faabric::util::SystemConfig::stateServerThreads
faabric::util::SystemConfig::snapshotServerThreads
faabric::util::SystemConfig::pointToPointServerThreads
faabric::util::SystemConfig::dirtyTrackingMode
faabric::util::SystemConfig::diffingMode
faabric::util::SystemConfig::plannerHost
faabric::util::SystemConfig::plannerPort
faabric::util::ThreadSafeDirtyTrackingRecord
faabric::util::ThreadSafeDirtyTrackingRecord::ThreadSafeDirtyTrackingRecord()
faabric::util::ThreadSafeDirtyTrackingRecord::trackRegion()
faabric::util::ThreadSafeDirtyTrackingRecord::markPage()
faabric::util::ThreadSafeDirtyTrackingRecord::getDirtyFlags()
faabric::util::ThreadSafeDirtyTrackingRecord::isInitialised()
faabric::util::ThreadSafeDirtyTrackingRecord::getNPages()
faabric::util::ThreadSafeDirtyTrackingRecord::reset()
faabric::util::TokenPool
faabric::util::UffdDirtyTracker
faabric::util::UffdDirtyTracker::UffdDirtyTracker()
faabric::util::UffdDirtyTracker::~UffdDirtyTracker()
faabric::util::UffdDirtyTracker::clearAll()
faabric::util::UffdDirtyTracker::getType()
faabric::util::UffdDirtyTracker::startTracking()
faabric::util::UffdDirtyTracker::stopTracking()
faabric::util::UffdDirtyTracker::getDirtyPages()
faabric::util::UffdDirtyTracker::startThreadLocalTracking()
faabric::util::UffdDirtyTracker::stopThreadLocalTracking()
faabric::util::UffdDirtyTracker::getThreadLocalDirtyPages()
faabric::util::UffdDirtyTracker::getBothDirtyPages()
faabric::util::UffdDirtyTracker::sigbusHandler()
faabric::util::detail
- Namespace faabric::batch_scheduler
batch_scheduler
batch_scheduler::InFlightPair
batch_scheduler::InFlightReqs
batch_scheduler::Host
batch_scheduler::HostMap
batch_scheduler::DecisionType
batch_scheduler::SchedulingTopologyHint
batch_scheduler::MigrationStrategy
batch_scheduler::getBatchScheduler()
batch_scheduler::resetBatchScheduler()
batch_scheduler::resetBatchScheduler()
batch_scheduler::getSchedulingDecisionCache()
batch_scheduler::getHostFreqCount()
batch_scheduler::minimiseNumOfMigrations()
batch_scheduler::deepCopyHostMap()
batch_scheduler::filterHosts()
batch_scheduler::filterHosts()
batch_scheduler::strToTopologyHint
batch_scheduler::topologyHintToStr
batch_scheduler::batchScheduler
batch_scheduler::BatchScheduler
batch_scheduler::BinPackScheduler
batch_scheduler::CachedDecision
batch_scheduler::CompactScheduler
batch_scheduler::DecisionCache
batch_scheduler::HostState
batch_scheduler::SchedulingDecision
batch_scheduler::SchedulingDecision::SchedulingDecision()
batch_scheduler::SchedulingDecision::operator==()
batch_scheduler::SchedulingDecision::isSingleHost()
batch_scheduler::SchedulingDecision::addMessage()
batch_scheduler::SchedulingDecision::addMessage()
batch_scheduler::SchedulingDecision::addMessage()
batch_scheduler::SchedulingDecision::addMessageInPosition()
batch_scheduler::SchedulingDecision::removeMessage()
batch_scheduler::SchedulingDecision::uniqueHosts()
batch_scheduler::SchedulingDecision::print()
batch_scheduler::SchedulingDecision::appId
batch_scheduler::SchedulingDecision::groupId
batch_scheduler::SchedulingDecision::nFunctions
batch_scheduler::SchedulingDecision::hosts
batch_scheduler::SchedulingDecision::messageIds
batch_scheduler::SchedulingDecision::appIdxs
batch_scheduler::SchedulingDecision::groupIdxs
batch_scheduler::SchedulingDecision::mpiPorts
batch_scheduler::SchedulingDecision::returnHost
batch_scheduler::SchedulingDecision::fromPointToPointMappings()
batch_scheduler::SpotScheduler
- Namespace faabric::endpoint
endpoint
endpoint::header
endpoint::EndpointMode
endpoint::FaabricEndpoint
endpoint::FaabricEndpoint::FaabricEndpoint()
endpoint::FaabricEndpoint::FaabricEndpoint()
endpoint::FaabricEndpoint::FaabricEndpoint()
endpoint::FaabricEndpoint::FaabricEndpoint()
endpoint::FaabricEndpoint::operator=()
endpoint::FaabricEndpoint::operator=()
endpoint::FaabricEndpoint::~FaabricEndpoint()
endpoint::FaabricEndpoint::start()
endpoint::FaabricEndpoint::stop()
endpoint::FaabricEndpointHandler
endpoint::HttpRequestContext
endpoint::HttpRequestHandler
endpoint::detail
- Namespace faabric::endpoint::@99
- Namespace faabric::endpoint::detail
- Namespace faabric::executor
executor
executor::setExecutorFactory()
executor::getExecutorFactory()
executor::context
executor::_factory
executor::ChainedCallException
executor::Executor
executor::Executor::Executor()
executor::Executor::~Executor()
executor::Executor::executeTasks()
executor::Executor::shutdown()
executor::Executor::reset()
executor::Executor::executeTask()
executor::Executor::tryClaim()
executor::Executor::claim()
executor::Executor::releaseClaim()
executor::Executor::getMainThreadSnapshot()
executor::Executor::getMillisSinceLastExec()
executor::Executor::getMemoryView()
executor::Executor::restore()
executor::Executor::getBoundMessage()
executor::Executor::isExecuting()
executor::Executor::isShutdown()
executor::Executor::addChainedMessage()
executor::Executor::getChainedMessage()
executor::Executor::getChainedMessageIds()
executor::Executor::mergeDirtyRegions()
executor::Executor::setThreadResult()
executor::Executor::setMemorySize()
executor::Executor::id
executor::ExecutorContext
executor::ExecutorContext::ExecutorContext()
executor::ExecutorContext::getExecutor()
executor::ExecutorContext::getBatchRequest()
executor::ExecutorContext::getMsg()
executor::ExecutorContext::getMsgIdx()
executor::ExecutorContext::isSet()
executor::ExecutorContext::set()
executor::ExecutorContext::unset()
executor::ExecutorContext::get()
executor::ExecutorContextException
executor::ExecutorFactory
executor::ExecutorTask
- Namespace faabric::mpi
mpi
mpi::InMemoryMpiQueue
mpi::MpiMessageType
mpi::MpiMessageType::NORMAL
mpi::MpiMessageType::BARRIER_JOIN
mpi::MpiMessageType::BARRIER_DONE
mpi::MpiMessageType::SCATTER
mpi::MpiMessageType::GATHER
mpi::MpiMessageType::ALLGATHER
mpi::MpiMessageType::REDUCE
mpi::MpiMessageType::SCAN
mpi::MpiMessageType::ALLREDUCE
mpi::MpiMessageType::ALLTOALL
mpi::MpiMessageType::ALLTOALL_PACKED
mpi::MpiMessageType::SENDRECV
mpi::MpiMessageType::BROADCAST
mpi::MpiMessageType::UNACKED_MPI_MESSAGE
mpi::MpiMessageType::HANDSHAKE
mpi::payloadSize()
mpi::msgSize()
mpi::serializeMpiMsg()
mpi::parseMpiMsg()
mpi::getMpiMockedMessages()
mpi::getMpiWorldRegistry()
mpi::getAsyncRequestId()
mpi::getRanksFromRequestId()
mpi::checkSendRecvMatch()
mpi::mockMutex
mpi::mpiMockedMessages
mpi::rankState
mpi::iSendMagic
mpi::iRecvMagic
mpi::MpiContext
mpi::MpiMessage
mpi::MpiRankState
mpi::MpiWorld
mpi::MpiWorld::MpiWorld()
mpi::MpiWorld::create()
mpi::MpiWorld::broadcastHostsToRanks()
mpi::MpiWorld::initialiseFromMsg()
mpi::MpiWorld::initialiseRankFromMsg()
mpi::MpiWorld::getHostForRank()
mpi::MpiWorld::getUser()
mpi::MpiWorld::getFunction()
mpi::MpiWorld::getId()
mpi::MpiWorld::getSize()
mpi::MpiWorld::destroy()
mpi::MpiWorld::getCartesianRank()
mpi::MpiWorld::getRankFromCoords()
mpi::MpiWorld::shiftCartesianCoords()
mpi::MpiWorld::send()
mpi::MpiWorld::isend()
mpi::MpiWorld::broadcast()
mpi::MpiWorld::recv()
mpi::MpiWorld::irecv()
mpi::MpiWorld::awaitAsyncRequest()
mpi::MpiWorld::sendRecv()
mpi::MpiWorld::scatter()
mpi::MpiWorld::gather()
mpi::MpiWorld::allGather()
mpi::MpiWorld::reduce()
mpi::MpiWorld::allReduce()
mpi::MpiWorld::op_reduce()
mpi::MpiWorld::scan()
mpi::MpiWorld::allToAll()
mpi::MpiWorld::probe()
mpi::MpiWorld::barrier()
mpi::MpiWorld::getLocalQueue()
mpi::MpiWorld::getLocalQueueSize()
mpi::MpiWorld::overrideHost()
mpi::MpiWorld::getWTime()
mpi::MpiWorld::prepareMigration()
mpi::MpiWorldRegistry
- Namespace faabric::planner
planner
planner::MessageResultPromise
planner::MessageResultPromisePtr
planner::header
planner::FlushType
planner::PlannerCalls
planner::PlannerCalls::NoPlanerCall
planner::PlannerCalls::Ping
planner::PlannerCalls::GetAvailableHosts
planner::PlannerCalls::RegisterHost
planner::PlannerCalls::RemoveHost
planner::PlannerCalls::SetMessageResult
planner::PlannerCalls::GetMessageResult
planner::PlannerCalls::GetBatchResults
planner::PlannerCalls::GetSchedulingDecision
planner::PlannerCalls::GetNumMigrations
planner::PlannerCalls::CallBatch
planner::PlannerCalls::PreloadSchedulingDecision
planner::getPlanner()
planner::getPlannerClient()
planner::availableOpenMpSlots()
planner::claimHostSlots()
planner::releaseHostSlots()
planner::claimHostMpiPort()
planner::releaseHostMpiPort()
planner::printHostState()
planner::convertToBatchSchedHostMap()
planner::KeepAliveThread
planner::Planner
planner::Planner::Planner()
planner::Planner::getConfig()
planner::Planner::printConfig()
planner::Planner::getPolicy()
planner::Planner::setPolicy()
planner::Planner::reset()
planner::Planner::flush()
planner::Planner::getAvailableHosts()
planner::Planner::registerHost()
planner::Planner::removeHost()
planner::Planner::setMessageResult()
planner::Planner::getMessageResult()
planner::Planner::preloadSchedulingDecision()
planner::Planner::getPreloadedSchedulingDecision()
planner::Planner::getBatchResults()
planner::Planner::getSchedulingDecision()
planner::Planner::getInFlightReqs()
planner::Planner::getNumMigrations()
planner::Planner::getNextEvictedHostIps()
planner::Planner::getEvictedReqs()
planner::Planner::callBatch()
planner::Planner::setNextEvictedVm()
planner::PlannerCache
planner::PlannerClient
planner::PlannerClient::PlannerClient()
planner::PlannerClient::PlannerClient()
planner::PlannerClient::ping()
planner::PlannerClient::clearCache()
planner::PlannerClient::getAvailableHosts()
planner::PlannerClient::registerHost()
planner::PlannerClient::removeHost()
planner::PlannerClient::setMessageResult()
planner::PlannerClient::setMessageResultLocally()
planner::PlannerClient::getMessageResult()
planner::PlannerClient::getMessageResult()
planner::PlannerClient::getBatchResults()
planner::PlannerClient::callFunctions()
planner::PlannerClient::getSchedulingDecision()
planner::PlannerClient::getNumMigrations()
planner::PlannerClient::preloadSchedulingDecision()
planner::PlannerEndpointHandler
planner::PlannerServer
planner::PlannerState
planner::PlannerState::policy
planner::PlannerState::hostMap
planner::PlannerState::appResults
planner::PlannerState::appResultWaiters
planner::PlannerState::inFlightReqs
planner::PlannerState::preloadedSchedulingDecisions
planner::PlannerState::numMigrations
planner::PlannerState::evictedRequests
planner::PlannerState::nextEvictedHostIps
- Namespace faabric::redis
redis
redis::UniqueRedisReply
redis::RedisRole
redis::wrapReply()
redis::safeRedisCommand()
redis::getLongFromReply()
redis::getBytesFromReply()
redis::getBytesFromReply()
redis::extractScriptResult()
redis::extractStringSetFromReply()
redis::Redis
redis::Redis::~Redis()
redis::Redis::ping()
redis::Redis::get()
redis::Redis::strlen()
redis::Redis::get()
redis::Redis::set()
redis::Redis::set()
redis::Redis::del()
redis::Redis::getCounter()
redis::Redis::incr()
redis::Redis::decr()
redis::Redis::incrByLong()
redis::Redis::decrByLong()
redis::Redis::setRange()
redis::Redis::setRangePipeline()
redis::Redis::flushPipeline()
redis::Redis::getRange()
redis::Redis::sadd()
redis::Redis::srem()
redis::Redis::scard()
redis::Redis::sismember()
redis::Redis::srandmember()
redis::Redis::smembers()
redis::Redis::sdiff()
redis::Redis::sinter()
redis::Redis::lpushLong()
redis::Redis::rpushLong()
redis::Redis::flushAll()
redis::Redis::listLength()
redis::Redis::getTtl()
redis::Redis::expire()
redis::Redis::refresh()
redis::Redis::acquireLock()
redis::Redis::releaseLock()
redis::Redis::delIfEq()
redis::Redis::setnxex()
redis::Redis::getLong()
redis::Redis::setLong()
redis::Redis::enqueue()
redis::Redis::enqueueBytes()
redis::Redis::enqueueBytes()
redis::Redis::dequeue()
redis::Redis::dequeueBytes()
redis::Redis::dequeueBytes()
redis::Redis::dequeueMultiple()
redis::Redis::publishSchedulerResult()
redis::Redis::getQueue()
redis::Redis::getState()
redis::RedisInstance
redis::RedisNoResponseException
- Namespace faabric::runner
runner
runner::FaabricMain
runner::FaabricMain::FaabricMain()
runner::FaabricMain::startBackground()
runner::FaabricMain::startRunner()
runner::FaabricMain::startFunctionCallServer()
runner::FaabricMain::startStateServer()
runner::FaabricMain::startSnapshotServer()
runner::FaabricMain::startPointToPointServer()
runner::FaabricMain::shutdown()
- Namespace faabric::scheduler
scheduler
scheduler::InMemoryMessageQueue
scheduler::InMemoryMessageQueuePair
scheduler::FunctionCalls
scheduler::getFunctionCalls()
scheduler::getFlushCalls()
scheduler::getBatchRequests()
scheduler::getMessageResults()
scheduler::clearMockRequests()
scheduler::getFunctionCallClient()
scheduler::clearFunctionCallClients()
scheduler::getScheduler()
scheduler::getChainedKey()
scheduler::mockMutex
scheduler::functionCalls
scheduler::flushCalls
scheduler::batchMessages
scheduler::messageResults
scheduler::functionCallClients
scheduler::FunctionCallClient
scheduler::FunctionCallServer
scheduler::Scheduler
scheduler::Scheduler::Scheduler()
scheduler::Scheduler::~Scheduler()
scheduler::Scheduler::executeBatch()
scheduler::Scheduler::reset()
scheduler::Scheduler::resetThreadLocalCache()
scheduler::Scheduler::shutdown()
scheduler::Scheduler::isShutdown()
scheduler::Scheduler::broadcastSnapshotDelete()
scheduler::Scheduler::reapStaleExecutors()
scheduler::Scheduler::getFunctionExecutorCount()
scheduler::Scheduler::setThreadResultLocally()
scheduler::Scheduler::awaitThreadResults()
scheduler::Scheduler::getCachedMessageCount()
scheduler::Scheduler::getThisHost()
scheduler::Scheduler::addHostToGlobalSet()
scheduler::Scheduler::addHostToGlobalSet()
scheduler::Scheduler::removeHostFromGlobalSet()
scheduler::Scheduler::setThisHostResources()
scheduler::Scheduler::getRecordedMessages()
scheduler::Scheduler::clearRecordedMessages()
scheduler::Scheduler::checkForMigrationOpportunities()
scheduler::SchedulerReaperThread
- Namespace faabric::snapshot
snapshot
snapshot::SnapshotCalls
snapshot::getSnapshotPushes()
snapshot::getSnapshotDiffPushes()
snapshot::getSnapshotDeletes()
snapshot::getThreadResults()
snapshot::clearMockSnapshotRequests()
snapshot::getSnapshotClient()
snapshot::clearSnapshotClients()
snapshot::getSnapshotRegistry()
snapshot::mockMutex
snapshot::snapshotPushes
snapshot::snapshotDiffPushes
snapshot::snapshotDeletes
snapshot::threadResults
snapshot::snapshotClients
snapshot::MockThreadResult
snapshot::SnapshotClient
snapshot::SnapshotRegistry
snapshot::SnapshotRegistry::SnapshotRegistry()
snapshot::SnapshotRegistry::getSnapshot()
snapshot::SnapshotRegistry::snapshotExists()
snapshot::SnapshotRegistry::registerSnapshot()
snapshot::SnapshotRegistry::deleteSnapshot()
snapshot::SnapshotRegistry::getSnapshotCount()
snapshot::SnapshotRegistry::clear()
snapshot::SnapshotServer
- Namespace faabric::state
state
state::InMemoryStateKeyStatus
state::StateCalls
state::getInMemoryStateRegistry()
state::getGlobalState()
state::getMasterKey()
state::AppendedInMemoryState
state::InMemoryStateKeyValue
state::InMemoryStateKeyValue::InMemoryStateKeyValue()
state::InMemoryStateKeyValue::InMemoryStateKeyValue()
state::InMemoryStateKeyValue::isMaster()
state::InMemoryStateKeyValue::getAppendedValue()
state::InMemoryStateKeyValue::getStateSizeFromRemote()
state::InMemoryStateKeyValue::deleteFromRemote()
state::InMemoryStateKeyValue::clearAll()
state::InMemoryStateRegistry
state::RedisStateKeyValue
state::State
state::StateChunk
state::StateClient
state::StateClient::StateClient()
state::StateClient::pushChunks()
state::StateClient::pullChunks()
state::StateClient::append()
state::StateClient::pullAppended()
state::StateClient::clearAppended()
state::StateClient::stateSize()
state::StateClient::deleteState()
state::StateClient::lock()
state::StateClient::unlock()
state::StateClient::user
state::StateClient::key
state::StateKeyValue
state::StateKeyValue::StateKeyValue()
state::StateKeyValue::StateKeyValue()
state::StateKeyValue::get()
state::StateKeyValue::get()
state::StateKeyValue::getChunk()
state::StateKeyValue::getChunk()
state::StateKeyValue::getAllChunks()
state::StateKeyValue::set()
state::StateKeyValue::setChunk()
state::StateKeyValue::append()
state::StateKeyValue::getAppended()
state::StateKeyValue::clearAppended()
state::StateKeyValue::mapSharedMemory()
state::StateKeyValue::unmapSharedMemory()
state::StateKeyValue::pull()
state::StateKeyValue::pushPartial()
state::StateKeyValue::pushPartialMask()
state::StateKeyValue::lockRead()
state::StateKeyValue::unlockRead()
state::StateKeyValue::lockWrite()
state::StateKeyValue::unlockWrite()
state::StateKeyValue::flagDirty()
state::StateKeyValue::flagChunkDirty()
state::StateKeyValue::size()
state::StateKeyValue::getSharedMemorySize()
state::StateKeyValue::pushFull()
state::StateKeyValue::user
state::StateKeyValue::key
state::StateKeyValue::waitOnRedisRemoteLock()
state::StateKeyValueException
state::StateServer
- Namespace faabric::transport
transport
transport::MessageResponseCode
transport::MessageEndpointConnectType
transport::SocketType
transport::PointToPointCall
transport::getPointToPointBroker()
transport::getSentMappings()
transport::getSentPointToPointMessages()
transport::getSentLockMessages()
transport::clearSentMessages()
transport::getClient()
transport::getPointToPointKey()
transport::getPointToPointKey()
transport::getEndpointPtrs()
transport::MessageResponseCodeText
transport::groups
transport::endpoints
transport::threadEndpoints
transport::clients
transport::currentGroupId
transport::sentMsgCount
transport::recvMsgCount
transport::outOfOrderMsgs
transport::mockMutex
transport::sentMappings
transport::sentMessages
transport::sentLockMessages
transport::AsyncDirectRecvEndpoint
transport::AsyncDirectSendEndpoint
transport::AsyncFanMessageEndpoint
transport::AsyncInternalRecvMessageEndpoint
transport::AsyncInternalSendMessageEndpoint
transport::AsyncRecvMessageEndpoint
transport::AsyncSendMessageEndpoint
transport::FanMessageEndpoint
transport::Message
transport::Message::Message()
transport::Message::Message()
transport::Message::Message()
transport::Message::~Message()
transport::Message::Message()
transport::Message::operator=()
transport::Message::Message()
transport::Message::operator=()
transport::Message::getResponseCode()
transport::Message::allData()
transport::Message::allData()
transport::Message::data()
transport::Message::data()
transport::Message::udata()
transport::Message::udata()
transport::Message::dataCopy()
transport::Message::getMessageCode()
transport::Message::getDeclaredDataSize()
transport::Message::getSequenceNum()
transport::MessageContext
transport::MessageContext::MessageContext()
transport::MessageContext::MessageContext()
transport::MessageContext::MessageContext()
transport::MessageContext::operator=()
transport::MessageContext::MessageContext()
transport::MessageContext::operator=()
transport::MessageContext::~MessageContext()
transport::MessageContext::context
transport::MessageEndpoint
transport::MessageEndpointClient
transport::MessageEndpointServer
transport::MessageEndpointServer::MessageEndpointServer()
transport::MessageEndpointServer::start()
transport::MessageEndpointServer::stop()
transport::MessageEndpointServer::onWorkerStop()
transport::MessageEndpointServer::setRequestLatch()
transport::MessageEndpointServer::awaitRequestLatch()
transport::MessageEndpointServer::getNThreads()
transport::MessageEndpointServerHandler
transport::MessageTimeoutException
transport::PointToPointBroker
transport::PointToPointBroker::PointToPointBroker()
transport::PointToPointBroker::getHostForReceiver()
transport::PointToPointBroker::getMpiPortForReceiver()
transport::PointToPointBroker::setUpLocalMappingsFromSchedulingDecision()
transport::PointToPointBroker::setAndSendMappingsFromSchedulingDecision()
transport::PointToPointBroker::sendMappingsFromSchedulingDecision()
transport::PointToPointBroker::waitForMappingsOnThisHost()
transport::PointToPointBroker::getIdxsRegisteredForGroup()
transport::PointToPointBroker::getHostsRegisteredForGroup()
transport::PointToPointBroker::updateHostForIdx()
transport::PointToPointBroker::sendMessage()
transport::PointToPointBroker::sendMessage()
transport::PointToPointBroker::recvMessage()
transport::PointToPointBroker::clearGroup()
transport::PointToPointBroker::clear()
transport::PointToPointBroker::resetThreadLocalCache()
transport::PointToPointBroker::postMigrationHook()
transport::PointToPointClient
transport::PointToPointGroup
transport::PointToPointGroup::PointToPointGroup()
transport::PointToPointGroup::lock()
transport::PointToPointGroup::unlock()
transport::PointToPointGroup::getLockOwner()
transport::PointToPointGroup::localLock()
transport::PointToPointGroup::localUnlock()
transport::PointToPointGroup::localTryLock()
transport::PointToPointGroup::barrier()
transport::PointToPointGroup::notify()
transport::PointToPointGroup::getNotifyCount()
transport::PointToPointGroup::getGroup()
transport::PointToPointGroup::getOrAwaitGroup()
transport::PointToPointGroup::groupExists()
transport::PointToPointGroup::addGroup()
transport::PointToPointGroup::addGroupIfNotExists()
transport::PointToPointGroup::clearGroup()
transport::PointToPointGroup::clear()
transport::PointToPointServer
transport::RecvMessageEndpoint
transport::SyncFanMessageEndpoint
transport::SyncRecvMessageEndpoint
transport::SyncSendMessageEndpoint
transport::tcp
transport::tcp::setReuseAddr()
transport::tcp::setNoDelay()
transport::tcp::setQuickAck()
transport::tcp::setNonBlocking()
transport::tcp::setBlocking()
transport::tcp::isNonBlocking()
transport::tcp::setBusyPolling()
transport::tcp::setRecvTimeoutMs()
transport::tcp::setSendTimeoutMs()
transport::tcp::setRecvBufferSize()
transport::tcp::setSendBufferSize()
transport::tcp::SocketTimeoutMs
transport::tcp::SocketBufferSizeBytes
transport::tcp::Address
transport::tcp::RecvSocket
transport::tcp::SendSocket
transport::tcp::Socket
- Namespace faabric::transport::tcp
tcp
tcp::setReuseAddr()
tcp::setNoDelay()
tcp::setQuickAck()
tcp::setNonBlocking()
tcp::setBlocking()
tcp::isNonBlocking()
tcp::setBusyPolling()
tcp::setRecvTimeoutMs()
tcp::setSendTimeoutMs()
tcp::setRecvBufferSize()
tcp::setSendBufferSize()
tcp::SocketTimeoutMs
tcp::SocketBufferSizeBytes
tcp::Address
tcp::RecvSocket
tcp::SendSocket
tcp::Socket
- Namespace faabric::util
util
util::BeastHttpRequest
util::BeastHttpResponse
util::TimePoint
util::UniqueLock
util::FullLock
util::SharedLock
util::MemoryRegion
util::DeltaCommand
util::SnapshotDataType
util::SnapshotMergeOperation
util::batchExecFactory()
util::batchExecFactory()
util::isBatchExecRequestValid()
util::updateBatchExecAppId()
util::updateBatchExecGroupId()
util::batchExecStatusFactory()
util::batchExecStatusFactory()
util::getNumFinishedMessagesInBatch()
util::stringToBytes()
util::bytesToInt()
util::bytesToString()
util::formatByteArrayToIntString()
util::trimTrailingZeros()
util::safeCopyToBuffer()
util::safeCopyToBuffer()
util::byteArrayToHexString()
util::hexStringToByteArray()
util::intToHexString()
util::unalignedRead()
util::unalignedWrite()
util::appendBytesOf()
util::readBytesOf()
util::valueToBytes()
util::getGlobalClock()
util::compareArrays()
util::getSystemConfig()
util::setUpCrashHandler()
util::handleCrash()
util::serializeDelta()
util::applyDelta()
util::getDirtyTracker()
util::resetDirtyTracker()
util::getEnvVar()
util::setEnvVar()
util::unsetEnvVar()
util::getUsableCores()
util::getFunctionExecGraphNode()
util::getFunctionExecGraph()
util::logChainedFunction()
util::getChainedFunctions()
util::countExecGraphNodes()
util::getExecGraphHosts()
util::getMpiRankHostsFromExecGraph()
util::getMigratedMpiRankHostsFromExecGraph()
util::execNodeToJson()
util::execGraphToJson()
util::addDetail()
util::incrementCounter()
util::readFileToString()
util::readFileToBytes()
util::writeBytesToFile()
util::isWasm()
util::funcToString()
util::funcToString()
util::setMessageId()
util::buildAsyncResponse()
util::messageFactoryShared()
util::messageFactory()
util::resultKeyFromMessageId()
util::statusKeyFromMessageId()
util::messageToBytes()
util::getArgvForMessage()
util::getMainThreadSnapshotKey()
util::generateGid()
util::pinThreadToFreeCpu()
util::messageToJson()
util::jsonToMessage()
util::initLogging()
util::malloc()
util::free()
util::realloc()
util::mergeManyDirtyPages()
util::mergeDirtyPages()
util::isPageAligned()
util::getRequiredHostPages()
util::getRequiredHostPagesRoundDown()
util::alignOffsetDown()
util::getPageAlignedChunk()
util::allocatePrivateMemory()
util::allocateSharedMemory()
util::allocateVirtualMemory()
util::claimVirtualMemory()
util::mapMemoryPrivate()
util::mapMemoryShared()
util::resizeFd()
util::writeToFd()
util::createFd()
util::appendDataToFd()
util::getIPFromHostname()
util::getPrimaryIPForThisHost()
util::ptpMappingsFromSchedulingDecision()
util::randomString()
util::randomStringFromSet()
util::diffArrayRegions()
util::calculateDiffValue()
util::applyDiffValue()
util::snapshotDataTypeStr()
util::snapshotMergeOpStr()
util::keyForUser()
util::maskDouble()
util::isAllWhitespace()
util::startsWith()
util::endsWith()
util::contains()
util::removeSubstr()
util::stringIsInt()
util::vectorToString()
util::setTestMode()
util::setMockMode()
util::isTestMode()
util::isMockMode()
util::startTimer()
util::getTimeDiffNanos()
util::getTimeDiffMicros()
util::getTimeDiffMillis()
util::logEndTimer()
util::startGlobalTimer()
util::printTimerTotals()
util::timespecToNanos()
util::nanosToTimespec()
util::pageAlignAddress()
util::countExecGraphNode()
util::getExecGraphHostsForNode()
util::getMpiRankHostsFromExecGraphNode()
util::writeDataCallback()
util::getNextFreeCpu()
util::doPinThreadToCpu()
util::doAlloc()
util::mapMemory()
util::DELTA_PROTOCOL_VERSION
util::DELTA_ZSTD_COMPRESS_LEVEL
util::NO_CPU_IDX
util::GHA_CPU_IDX
util::HOST_PAGE_SIZE
util::tracking
util::globalTracking
util::tracker
util::uffd
util::uffdWriteProtect
util::uffdSigbus
util::closeFd
util::eventThread
util::freeCpus
util::ipMap
util::hostnameMx
util::testMode
util::mockMode
util::AlignedChunk
util::Barrier
util::ChainedCallFailedException
util::Clock
util::ConcurrentMap
util::ConcurrentMap::key_type
util::ConcurrentMap::mapped_type
util::ConcurrentMap::size_type
util::ConcurrentMap::difference_type
util::ConcurrentMap::ConcurrentMap()
util::ConcurrentMap::ConcurrentMap()
util::ConcurrentMap::ConcurrentMap()
util::ConcurrentMap::operator=()
util::ConcurrentMap::ConcurrentMap()
util::ConcurrentMap::operator=()
util::ConcurrentMap::swap()
util::ConcurrentMap::isEmpty()
util::ConcurrentMap::size()
util::ConcurrentMap::capacity()
util::ConcurrentMap::reserve()
util::ConcurrentMap::rehash()
util::ConcurrentMap::clear()
util::ConcurrentMap::erase()
util::ConcurrentMap::insert()
util::ConcurrentMap::insertOrAssign()
util::ConcurrentMap::tryEmplace()
util::ConcurrentMap::tryEmplaceShared()
util::ConcurrentMap::inspect()
util::ConcurrentMap::get()
util::ConcurrentMap::eraseIf()
util::DeltaSettings
util::DirtyTracker
util::DirtyTracker::DirtyTracker()
util::DirtyTracker::clearAll()
util::DirtyTracker::getType()
util::DirtyTracker::startTracking()
util::DirtyTracker::stopTracking()
util::DirtyTracker::getDirtyPages()
util::DirtyTracker::startThreadLocalTracking()
util::DirtyTracker::stopThreadLocalTracking()
util::DirtyTracker::getThreadLocalDirtyPages()
util::DirtyTracker::getBothDirtyPages()
util::DirtyTrackingRecord
util::ExecGraph
util::ExecGraphNode
util::ExecGraphNodeNotFoundException
util::FaabricCpuSet
util::FaabricException
util::FixedCapacityQueue
util::FixedCapacityQueue::FixedCapacityQueue()
util::FixedCapacityQueue::FixedCapacityQueue()
util::FixedCapacityQueue::enqueue()
util::FixedCapacityQueue::dequeueIfPresent()
util::FixedCapacityQueue::dequeue()
util::FixedCapacityQueue::peek()
util::FixedCapacityQueue::drain()
util::FixedCapacityQueue::size()
util::FixedCapacityQueue::reset()
util::FlagWaiter
util::FreeCpus
util::FunctionFrozenException
util::FunctionMigratedException
util::JsonSerialisationException
util::Latch
util::NoneDirtyTracker
util::NoneDirtyTracker::NoneDirtyTracker()
util::NoneDirtyTracker::clearAll()
util::NoneDirtyTracker::getType()
util::NoneDirtyTracker::startTracking()
util::NoneDirtyTracker::stopTracking()
util::NoneDirtyTracker::getDirtyPages()
util::NoneDirtyTracker::startThreadLocalTracking()
util::NoneDirtyTracker::stopThreadLocalTracking()
util::NoneDirtyTracker::getThreadLocalDirtyPages()
util::NoneDirtyTracker::getBothDirtyPages()
util::PeriodicBackgroundThread
util::Queue
util::QueueTimeoutException
util::SegfaultDirtyTracker
util::SegfaultDirtyTracker::SegfaultDirtyTracker()
util::SegfaultDirtyTracker::clearAll()
util::SegfaultDirtyTracker::getType()
util::SegfaultDirtyTracker::startTracking()
util::SegfaultDirtyTracker::stopTracking()
util::SegfaultDirtyTracker::getDirtyPages()
util::SegfaultDirtyTracker::startThreadLocalTracking()
util::SegfaultDirtyTracker::stopThreadLocalTracking()
util::SegfaultDirtyTracker::getThreadLocalDirtyPages()
util::SegfaultDirtyTracker::getBothDirtyPages()
util::SegfaultDirtyTracker::handler()
util::SnapshotData
util::SnapshotData::SnapshotData()
util::SnapshotData::SnapshotData()
util::SnapshotData::SnapshotData()
util::SnapshotData::SnapshotData()
util::SnapshotData::SnapshotData()
util::SnapshotData::SnapshotData()
util::SnapshotData::operator=()
util::SnapshotData::~SnapshotData()
util::SnapshotData::copyInData()
util::SnapshotData::getDataPtr()
util::SnapshotData::getDataCopy()
util::SnapshotData::getDataCopy()
util::SnapshotData::mapToMemory()
util::SnapshotData::addMergeRegion()
util::SnapshotData::fillGapsWithBytewiseRegions()
util::SnapshotData::clearMergeRegions()
util::SnapshotData::getMergeRegions()
util::SnapshotData::getQueuedDiffsCount()
util::SnapshotData::applyDiffs()
util::SnapshotData::applyDiff()
util::SnapshotData::queueDiffs()
util::SnapshotData::writeQueuedDiffs()
util::SnapshotData::getSize()
util::SnapshotData::getMaxSize()
util::SnapshotData::getTrackedChanges()
util::SnapshotData::clearTrackedChanges()
util::SnapshotData::diffWithDirtyRegions()
util::SnapshotDiff
util::SnapshotMergeRegion
util::SnapshotMergeRegion::SnapshotMergeRegion()
util::SnapshotMergeRegion::SnapshotMergeRegion()
util::SnapshotMergeRegion::addDiffs()
util::SnapshotMergeRegion::operator<()
util::SnapshotMergeRegion::operator==()
util::SnapshotMergeRegion::offset
util::SnapshotMergeRegion::length
util::SnapshotMergeRegion::dataType
util::SnapshotMergeRegion::operation
util::SoftPTEDirtyTracker
util::SoftPTEDirtyTracker::SoftPTEDirtyTracker()
util::SoftPTEDirtyTracker::~SoftPTEDirtyTracker()
util::SoftPTEDirtyTracker::clearAll()
util::SoftPTEDirtyTracker::getType()
util::SoftPTEDirtyTracker::startTracking()
util::SoftPTEDirtyTracker::stopTracking()
util::SoftPTEDirtyTracker::getDirtyPages()
util::SoftPTEDirtyTracker::startThreadLocalTracking()
util::SoftPTEDirtyTracker::stopThreadLocalTracking()
util::SoftPTEDirtyTracker::getThreadLocalDirtyPages()
util::SoftPTEDirtyTracker::getBothDirtyPages()
util::SpinLockQueue
util::SystemConfig
util::SystemConfig::SystemConfig()
util::SystemConfig::print()
util::SystemConfig::reset()
util::SystemConfig::serialisation
util::SystemConfig::logLevel
util::SystemConfig::logFile
util::SystemConfig::stateMode
util::SystemConfig::deltaSnapshotEncoding
util::SystemConfig::redisStateHost
util::SystemConfig::redisQueueHost
util::SystemConfig::redisPort
util::SystemConfig::overrideCpuCount
util::SystemConfig::overrideFreeCpuStart
util::SystemConfig::batchSchedulerMode
util::SystemConfig::globalMessageTimeout
util::SystemConfig::boundTimeout
util::SystemConfig::reaperIntervalSeconds
util::SystemConfig::defaultMpiWorldSize
util::SystemConfig::endpointInterface
util::SystemConfig::endpointHost
util::SystemConfig::endpointPort
util::SystemConfig::endpointNumThreads
util::SystemConfig::functionServerThreads
util::SystemConfig::stateServerThreads
util::SystemConfig::snapshotServerThreads
util::SystemConfig::pointToPointServerThreads
util::SystemConfig::dirtyTrackingMode
util::SystemConfig::diffingMode
util::SystemConfig::plannerHost
util::SystemConfig::plannerPort
util::ThreadSafeDirtyTrackingRecord
util::ThreadSafeDirtyTrackingRecord::ThreadSafeDirtyTrackingRecord()
util::ThreadSafeDirtyTrackingRecord::trackRegion()
util::ThreadSafeDirtyTrackingRecord::markPage()
util::ThreadSafeDirtyTrackingRecord::getDirtyFlags()
util::ThreadSafeDirtyTrackingRecord::isInitialised()
util::ThreadSafeDirtyTrackingRecord::getNPages()
util::ThreadSafeDirtyTrackingRecord::reset()
util::TokenPool
util::UffdDirtyTracker
util::UffdDirtyTracker::UffdDirtyTracker()
util::UffdDirtyTracker::~UffdDirtyTracker()
util::UffdDirtyTracker::clearAll()
util::UffdDirtyTracker::getType()
util::UffdDirtyTracker::startTracking()
util::UffdDirtyTracker::stopTracking()
util::UffdDirtyTracker::getDirtyPages()
util::UffdDirtyTracker::startThreadLocalTracking()
util::UffdDirtyTracker::stopThreadLocalTracking()
util::UffdDirtyTracker::getThreadLocalDirtyPages()
util::UffdDirtyTracker::getBothDirtyPages()
util::UffdDirtyTracker::sigbusHandler()
util::detail
- Namespace faabric::util::detail