Class list
- Class faabric::batch_scheduler::BatchScheduler
- Class faabric::batch_scheduler::BinPackScheduler
- Class faabric::batch_scheduler::CachedDecision
- Class faabric::batch_scheduler::CompactScheduler
- Class faabric::batch_scheduler::DecisionCache
- Class faabric::batch_scheduler::SchedulingDecision
SchedulingDecision
SchedulingDecision::SchedulingDecision()
SchedulingDecision::operator==()
SchedulingDecision::isSingleHost()
SchedulingDecision::addMessage()
SchedulingDecision::addMessage()
SchedulingDecision::addMessage()
SchedulingDecision::addMessageInPosition()
SchedulingDecision::removeMessage()
SchedulingDecision::uniqueHosts()
SchedulingDecision::print()
SchedulingDecision::appId
SchedulingDecision::groupId
SchedulingDecision::nFunctions
SchedulingDecision::hosts
SchedulingDecision::messageIds
SchedulingDecision::appIdxs
SchedulingDecision::groupIdxs
SchedulingDecision::mpiPorts
SchedulingDecision::returnHost
SchedulingDecision::fromPointToPointMappings()
- Class faabric::batch_scheduler::SpotScheduler
- Class faabric::endpoint::FaabricEndpoint
- Class faabric::endpoint::FaabricEndpointHandler
- Class faabric::endpoint::HttpRequestHandler
- Class faabric::endpoint::detail::EndpointState
- Class faabric::executor::ChainedCallException
- Class faabric::executor::Executor
Executor
Executor::Executor()
Executor::~Executor()
Executor::executeTasks()
Executor::shutdown()
Executor::reset()
Executor::executeTask()
Executor::tryClaim()
Executor::claim()
Executor::releaseClaim()
Executor::getMainThreadSnapshot()
Executor::getMillisSinceLastExec()
Executor::getMemoryView()
Executor::restore()
Executor::getBoundMessage()
Executor::isExecuting()
Executor::isShutdown()
Executor::addChainedMessage()
Executor::getChainedMessage()
Executor::getChainedMessageIds()
Executor::mergeDirtyRegions()
Executor::setThreadResult()
Executor::setMemorySize()
Executor::id
- Class faabric::executor::ExecutorContext
- Class faabric::executor::ExecutorContextException
- Class faabric::executor::ExecutorFactory
- Class faabric::executor::ExecutorTask
- Class faabric::mpi::MpiContext
- Class faabric::mpi::MpiWorld
MpiWorld
MpiWorld::MpiWorld()
MpiWorld::create()
MpiWorld::broadcastHostsToRanks()
MpiWorld::initialiseFromMsg()
MpiWorld::initialiseRankFromMsg()
MpiWorld::getHostForRank()
MpiWorld::getUser()
MpiWorld::getFunction()
MpiWorld::getId()
MpiWorld::getSize()
MpiWorld::destroy()
MpiWorld::getCartesianRank()
MpiWorld::getRankFromCoords()
MpiWorld::shiftCartesianCoords()
MpiWorld::send()
MpiWorld::isend()
MpiWorld::broadcast()
MpiWorld::recv()
MpiWorld::irecv()
MpiWorld::awaitAsyncRequest()
MpiWorld::sendRecv()
MpiWorld::scatter()
MpiWorld::gather()
MpiWorld::allGather()
MpiWorld::reduce()
MpiWorld::allReduce()
MpiWorld::op_reduce()
MpiWorld::scan()
MpiWorld::allToAll()
MpiWorld::probe()
MpiWorld::barrier()
MpiWorld::getLocalQueue()
MpiWorld::getLocalQueueSize()
MpiWorld::overrideHost()
MpiWorld::getWTime()
MpiWorld::prepareMigration()
- Class faabric::mpi::MpiWorldRegistry
- Class faabric::planner::KeepAliveThread
- Class faabric::planner::Planner
Planner
Planner::Planner()
Planner::getConfig()
Planner::printConfig()
Planner::getPolicy()
Planner::setPolicy()
Planner::reset()
Planner::flush()
Planner::getAvailableHosts()
Planner::registerHost()
Planner::removeHost()
Planner::setMessageResult()
Planner::getMessageResult()
Planner::preloadSchedulingDecision()
Planner::getPreloadedSchedulingDecision()
Planner::getBatchResults()
Planner::getSchedulingDecision()
Planner::getInFlightReqs()
Planner::getNumMigrations()
Planner::getNextEvictedHostIps()
Planner::getEvictedReqs()
Planner::callBatch()
Planner::setNextEvictedVm()
- Class faabric::planner::PlannerClient
PlannerClient
PlannerClient::PlannerClient()
PlannerClient::PlannerClient()
PlannerClient::ping()
PlannerClient::clearCache()
PlannerClient::getAvailableHosts()
PlannerClient::registerHost()
PlannerClient::removeHost()
PlannerClient::setMessageResult()
PlannerClient::setMessageResultLocally()
PlannerClient::getMessageResult()
PlannerClient::getMessageResult()
PlannerClient::getBatchResults()
PlannerClient::callFunctions()
PlannerClient::getSchedulingDecision()
PlannerClient::getNumMigrations()
PlannerClient::preloadSchedulingDecision()
- Class faabric::planner::PlannerEndpointHandler
- Class faabric::planner::PlannerServer
- Class faabric::redis::Redis
Redis
Redis::~Redis()
Redis::ping()
Redis::get()
Redis::strlen()
Redis::get()
Redis::set()
Redis::set()
Redis::del()
Redis::getCounter()
Redis::incr()
Redis::decr()
Redis::incrByLong()
Redis::decrByLong()
Redis::setRange()
Redis::setRangePipeline()
Redis::flushPipeline()
Redis::getRange()
Redis::sadd()
Redis::srem()
Redis::scard()
Redis::sismember()
Redis::srandmember()
Redis::smembers()
Redis::sdiff()
Redis::sinter()
Redis::lpushLong()
Redis::rpushLong()
Redis::flushAll()
Redis::listLength()
Redis::getTtl()
Redis::expire()
Redis::refresh()
Redis::acquireLock()
Redis::releaseLock()
Redis::delIfEq()
Redis::setnxex()
Redis::getLong()
Redis::setLong()
Redis::enqueue()
Redis::enqueueBytes()
Redis::enqueueBytes()
Redis::dequeue()
Redis::dequeueBytes()
Redis::dequeueBytes()
Redis::dequeueMultiple()
Redis::publishSchedulerResult()
Redis::getQueue()
Redis::getState()
- Class faabric::redis::RedisInstance
- Class faabric::redis::RedisNoResponseException
- Class faabric::runner::FaabricMain
- Class faabric::scheduler::FunctionCallClient
- Class faabric::scheduler::FunctionCallServer
- Class faabric::scheduler::Scheduler
Scheduler
Scheduler::Scheduler()
Scheduler::~Scheduler()
Scheduler::executeBatch()
Scheduler::reset()
Scheduler::resetThreadLocalCache()
Scheduler::shutdown()
Scheduler::isShutdown()
Scheduler::broadcastSnapshotDelete()
Scheduler::reapStaleExecutors()
Scheduler::getFunctionExecutorCount()
Scheduler::setThreadResultLocally()
Scheduler::awaitThreadResults()
Scheduler::getCachedMessageCount()
Scheduler::getThisHost()
Scheduler::addHostToGlobalSet()
Scheduler::addHostToGlobalSet()
Scheduler::removeHostFromGlobalSet()
Scheduler::setThisHostResources()
Scheduler::getRecordedMessages()
Scheduler::clearRecordedMessages()
Scheduler::checkForMigrationOpportunities()
- Class faabric::scheduler::SchedulerReaperThread
- Class faabric::snapshot::SnapshotClient
- Class faabric::snapshot::SnapshotRegistry
- Class faabric::snapshot::SnapshotServer
- Class faabric::state::AppendedInMemoryState
- Class faabric::state::InMemoryStateKeyValue
- Class faabric::state::InMemoryStateRegistry
- Class faabric::state::RedisStateKeyValue
- Class faabric::state::State
- Class faabric::state::StateChunk
- Class faabric::state::StateClient
- Class faabric::state::StateKeyValue
StateKeyValue
StateKeyValue::StateKeyValue()
StateKeyValue::StateKeyValue()
StateKeyValue::get()
StateKeyValue::get()
StateKeyValue::getChunk()
StateKeyValue::getChunk()
StateKeyValue::getAllChunks()
StateKeyValue::set()
StateKeyValue::setChunk()
StateKeyValue::append()
StateKeyValue::getAppended()
StateKeyValue::clearAppended()
StateKeyValue::mapSharedMemory()
StateKeyValue::unmapSharedMemory()
StateKeyValue::pull()
StateKeyValue::pushPartial()
StateKeyValue::pushPartialMask()
StateKeyValue::lockRead()
StateKeyValue::unlockRead()
StateKeyValue::lockWrite()
StateKeyValue::unlockWrite()
StateKeyValue::flagDirty()
StateKeyValue::flagChunkDirty()
StateKeyValue::size()
StateKeyValue::getSharedMemorySize()
StateKeyValue::pushFull()
StateKeyValue::user
StateKeyValue::key
StateKeyValue::waitOnRedisRemoteLock()
- Class faabric::state::StateKeyValueException
- Class faabric::state::StateServer
- Class faabric::transport::AsyncDirectRecvEndpoint
- Class faabric::transport::AsyncDirectSendEndpoint
- Class faabric::transport::AsyncFanMessageEndpoint
- Class faabric::transport::AsyncInternalRecvMessageEndpoint
- Class faabric::transport::AsyncInternalSendMessageEndpoint
- Class faabric::transport::AsyncRecvMessageEndpoint
- Class faabric::transport::AsyncSendMessageEndpoint
- Class faabric::transport::FanMessageEndpoint
- Class faabric::transport::Message
Message
Message::Message()
Message::Message()
Message::Message()
Message::~Message()
Message::Message()
Message::operator=()
Message::Message()
Message::operator=()
Message::getResponseCode()
Message::allData()
Message::allData()
Message::data()
Message::data()
Message::udata()
Message::udata()
Message::dataCopy()
Message::getMessageCode()
Message::getDeclaredDataSize()
Message::getSequenceNum()
- Class faabric::transport::MessageContext
- Class faabric::transport::MessageEndpoint
- Class faabric::transport::MessageEndpointClient
- Class faabric::transport::MessageEndpointServer
- Class faabric::transport::MessageEndpointServerHandler
- Class faabric::transport::MessageTimeoutException
- Class faabric::transport::PointToPointBroker
PointToPointBroker
PointToPointBroker::PointToPointBroker()
PointToPointBroker::getHostForReceiver()
PointToPointBroker::getMpiPortForReceiver()
PointToPointBroker::setUpLocalMappingsFromSchedulingDecision()
PointToPointBroker::setAndSendMappingsFromSchedulingDecision()
PointToPointBroker::sendMappingsFromSchedulingDecision()
PointToPointBroker::waitForMappingsOnThisHost()
PointToPointBroker::getIdxsRegisteredForGroup()
PointToPointBroker::getHostsRegisteredForGroup()
PointToPointBroker::updateHostForIdx()
PointToPointBroker::sendMessage()
PointToPointBroker::sendMessage()
PointToPointBroker::recvMessage()
PointToPointBroker::clearGroup()
PointToPointBroker::clear()
PointToPointBroker::resetThreadLocalCache()
PointToPointBroker::postMigrationHook()
- Class faabric::transport::PointToPointClient
- Class faabric::transport::PointToPointGroup
PointToPointGroup
PointToPointGroup::PointToPointGroup()
PointToPointGroup::lock()
PointToPointGroup::unlock()
PointToPointGroup::getLockOwner()
PointToPointGroup::localLock()
PointToPointGroup::localUnlock()
PointToPointGroup::localTryLock()
PointToPointGroup::barrier()
PointToPointGroup::notify()
PointToPointGroup::getNotifyCount()
PointToPointGroup::getGroup()
PointToPointGroup::getOrAwaitGroup()
PointToPointGroup::groupExists()
PointToPointGroup::addGroup()
PointToPointGroup::addGroupIfNotExists()
PointToPointGroup::clearGroup()
PointToPointGroup::clear()
- Class faabric::transport::PointToPointServer
- Class faabric::transport::RecvMessageEndpoint
- Class faabric::transport::SyncFanMessageEndpoint
- Class faabric::transport::SyncRecvMessageEndpoint
- Class faabric::transport::SyncSendMessageEndpoint
- Class faabric::transport::tcp::Address
- Class faabric::transport::tcp::RecvSocket
- Class faabric::transport::tcp::SendSocket
- Class faabric::transport::tcp::Socket
- Class faabric::util::Barrier
- Class faabric::util::ChainedCallFailedException
- Class faabric::util::Clock
- Class faabric::util::ConcurrentMap
ConcurrentMap
ConcurrentMap::key_type
ConcurrentMap::mapped_type
ConcurrentMap::size_type
ConcurrentMap::difference_type
ConcurrentMap::ConcurrentMap()
ConcurrentMap::ConcurrentMap()
ConcurrentMap::ConcurrentMap()
ConcurrentMap::operator=()
ConcurrentMap::ConcurrentMap()
ConcurrentMap::operator=()
ConcurrentMap::swap()
ConcurrentMap::isEmpty()
ConcurrentMap::size()
ConcurrentMap::capacity()
ConcurrentMap::reserve()
ConcurrentMap::rehash()
ConcurrentMap::clear()
ConcurrentMap::erase()
ConcurrentMap::insert()
ConcurrentMap::insertOrAssign()
ConcurrentMap::tryEmplace()
ConcurrentMap::tryEmplaceShared()
ConcurrentMap::inspect()
ConcurrentMap::get()
ConcurrentMap::eraseIf()
- Class faabric::util::DirtyTracker
DirtyTracker
DirtyTracker::DirtyTracker()
DirtyTracker::clearAll()
DirtyTracker::getType()
DirtyTracker::startTracking()
DirtyTracker::stopTracking()
DirtyTracker::getDirtyPages()
DirtyTracker::startThreadLocalTracking()
DirtyTracker::stopThreadLocalTracking()
DirtyTracker::getThreadLocalDirtyPages()
DirtyTracker::getBothDirtyPages()
- Class faabric::util::DirtyTrackingRecord
- Class faabric::util::ExecGraphNodeNotFoundException
- Class faabric::util::FaabricCpuSet
- Class faabric::util::FaabricException
- Class faabric::util::FixedCapacityQueue
- Class faabric::util::FlagWaiter
- Class faabric::util::FreeCpus
- Class faabric::util::FunctionFrozenException
- Class faabric::util::FunctionMigratedException
- Class faabric::util::JsonSerialisationException
- Class faabric::util::Latch
- Class faabric::util::NoneDirtyTracker
NoneDirtyTracker
NoneDirtyTracker::NoneDirtyTracker()
NoneDirtyTracker::clearAll()
NoneDirtyTracker::getType()
NoneDirtyTracker::startTracking()
NoneDirtyTracker::stopTracking()
NoneDirtyTracker::getDirtyPages()
NoneDirtyTracker::startThreadLocalTracking()
NoneDirtyTracker::stopThreadLocalTracking()
NoneDirtyTracker::getThreadLocalDirtyPages()
NoneDirtyTracker::getBothDirtyPages()
- Class faabric::util::PeriodicBackgroundThread
- Class faabric::util::Queue
- Class faabric::util::QueueTimeoutException
- Class faabric::util::SegfaultDirtyTracker
SegfaultDirtyTracker
SegfaultDirtyTracker::SegfaultDirtyTracker()
SegfaultDirtyTracker::clearAll()
SegfaultDirtyTracker::getType()
SegfaultDirtyTracker::startTracking()
SegfaultDirtyTracker::stopTracking()
SegfaultDirtyTracker::getDirtyPages()
SegfaultDirtyTracker::startThreadLocalTracking()
SegfaultDirtyTracker::stopThreadLocalTracking()
SegfaultDirtyTracker::getThreadLocalDirtyPages()
SegfaultDirtyTracker::getBothDirtyPages()
SegfaultDirtyTracker::handler()
- Class faabric::util::SnapshotData
SnapshotData
SnapshotData::SnapshotData()
SnapshotData::SnapshotData()
SnapshotData::SnapshotData()
SnapshotData::SnapshotData()
SnapshotData::SnapshotData()
SnapshotData::SnapshotData()
SnapshotData::operator=()
SnapshotData::~SnapshotData()
SnapshotData::copyInData()
SnapshotData::getDataPtr()
SnapshotData::getDataCopy()
SnapshotData::getDataCopy()
SnapshotData::mapToMemory()
SnapshotData::addMergeRegion()
SnapshotData::fillGapsWithBytewiseRegions()
SnapshotData::clearMergeRegions()
SnapshotData::getMergeRegions()
SnapshotData::getQueuedDiffsCount()
SnapshotData::applyDiffs()
SnapshotData::applyDiff()
SnapshotData::queueDiffs()
SnapshotData::writeQueuedDiffs()
SnapshotData::getSize()
SnapshotData::getMaxSize()
SnapshotData::getTrackedChanges()
SnapshotData::clearTrackedChanges()
SnapshotData::diffWithDirtyRegions()
- Class faabric::util::SnapshotDiff
- Class faabric::util::SnapshotMergeRegion
SnapshotMergeRegion
SnapshotMergeRegion::SnapshotMergeRegion()
SnapshotMergeRegion::SnapshotMergeRegion()
SnapshotMergeRegion::addDiffs()
SnapshotMergeRegion::operator<()
SnapshotMergeRegion::operator==()
SnapshotMergeRegion::offset
SnapshotMergeRegion::length
SnapshotMergeRegion::dataType
SnapshotMergeRegion::operation
- Class faabric::util::SoftPTEDirtyTracker
SoftPTEDirtyTracker
SoftPTEDirtyTracker::SoftPTEDirtyTracker()
SoftPTEDirtyTracker::~SoftPTEDirtyTracker()
SoftPTEDirtyTracker::clearAll()
SoftPTEDirtyTracker::getType()
SoftPTEDirtyTracker::startTracking()
SoftPTEDirtyTracker::stopTracking()
SoftPTEDirtyTracker::getDirtyPages()
SoftPTEDirtyTracker::startThreadLocalTracking()
SoftPTEDirtyTracker::stopThreadLocalTracking()
SoftPTEDirtyTracker::getThreadLocalDirtyPages()
SoftPTEDirtyTracker::getBothDirtyPages()
- Class faabric::util::SpinLockQueue
- Class faabric::util::SystemConfig
SystemConfig
SystemConfig::SystemConfig()
SystemConfig::print()
SystemConfig::reset()
SystemConfig::serialisation
SystemConfig::logLevel
SystemConfig::logFile
SystemConfig::stateMode
SystemConfig::deltaSnapshotEncoding
SystemConfig::redisStateHost
SystemConfig::redisQueueHost
SystemConfig::redisPort
SystemConfig::overrideCpuCount
SystemConfig::overrideFreeCpuStart
SystemConfig::batchSchedulerMode
SystemConfig::globalMessageTimeout
SystemConfig::boundTimeout
SystemConfig::reaperIntervalSeconds
SystemConfig::defaultMpiWorldSize
SystemConfig::endpointInterface
SystemConfig::endpointHost
SystemConfig::endpointPort
SystemConfig::endpointNumThreads
SystemConfig::functionServerThreads
SystemConfig::stateServerThreads
SystemConfig::snapshotServerThreads
SystemConfig::pointToPointServerThreads
SystemConfig::dirtyTrackingMode
SystemConfig::diffingMode
SystemConfig::plannerHost
SystemConfig::plannerPort
- Class faabric::util::ThreadSafeDirtyTrackingRecord
ThreadSafeDirtyTrackingRecord
ThreadSafeDirtyTrackingRecord::ThreadSafeDirtyTrackingRecord()
ThreadSafeDirtyTrackingRecord::trackRegion()
ThreadSafeDirtyTrackingRecord::markPage()
ThreadSafeDirtyTrackingRecord::getDirtyFlags()
ThreadSafeDirtyTrackingRecord::isInitialised()
ThreadSafeDirtyTrackingRecord::getNPages()
ThreadSafeDirtyTrackingRecord::reset()
- Class faabric::util::TokenPool
- Class faabric::util::UffdDirtyTracker
UffdDirtyTracker
UffdDirtyTracker::UffdDirtyTracker()
UffdDirtyTracker::~UffdDirtyTracker()
UffdDirtyTracker::clearAll()
UffdDirtyTracker::getType()
UffdDirtyTracker::startTracking()
UffdDirtyTracker::stopTracking()
UffdDirtyTracker::getDirtyPages()
UffdDirtyTracker::startThreadLocalTracking()
UffdDirtyTracker::stopThreadLocalTracking()
UffdDirtyTracker::getThreadLocalDirtyPages()
UffdDirtyTracker::getBothDirtyPages()
UffdDirtyTracker::sigbusHandler()