Namespace list

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