Go to the source code of this file.
Definition in file machine.c.
| CpvDeclare | ( | void * | , | |
| CmiLocalQueue | ||||
| ) |
| CpvDeclare | ( | void * | , | |
| CMI_VMI_RemoteQueue | ||||
| ) |
| void CthInit | ( | char ** | argv | ) |
Definition at line 906 of file threads.c.
References CthBaseInit(), CthDummy(), CthThreadInit(), malloc(), p, CthProcInfo::stackbase, CthProcInfo::switchbuf, and CthProcInfo::switchbuf_sp.
Referenced by ConverseInit(), ConverseRunPE(), and KillOnAllSigs().
| void ConverseInit | ( | int | argc, | |
| char ** | argv, | |||
| CmiStartFn | start_function, | |||
| int | user_calls_scheduler, | |||
| int | init_returns | |||
| ) |
Definition at line 127 of file machine.c.
References CcdCallOnConditionKeep(), CdsFifo_Create(), Cmi_argv, Cmi_argvcopy, Cmi_smp_mode_setting, Cmi_startfn, CMI_VMI_Cluster_Mapping_Received, CMI_VMI_Compute_Cluster_Mapping(), CMI_VMI_CONNECTION_DISCONNECTED, CMI_VMI_Distribute_Cluster_Mapping(), CMI_VMI_Initialize_VMI(), CMI_VMI_Open_Connections(), CMI_VMI_Program_Key, CMI_VMI_Read_Environment(), CMI_VMI_Startup_Charmrun(), CMI_VMI_Startup_CRM(), CMI_VMI_Wait_Cluster_Mapping(), CmiAbort(), CmiBarrier(), CmiCopyArgs(), CmiCreateLock(), CmiGetArgc(), CmiGetArgFlag(), CmiGetArgInt(), CmiInitPxshm(), CmiInitXpmem(), CmiNotifyIdle(), CmiPrintf(), CmiProbeLatencies(), CmiStartThreads(), COMM_THREAD_NOT_EXIST, COMM_THREAD_ONLY_RECV, COMM_THREAD_SEND_RECV, COMM_WORK_THREADS_SEND_RECV, ConverseCommonInit(), ConverseExit(), ConverseRunPE(), CsdScheduler(), CthInit(), LrtsInit(), malloc(), printf(), refcount, and value.
Referenced by CharmLibInit(), fmain_(), KillOnAllSigs(), main(), and TCHARM_Init().
| void ConverseExit | ( | void | ) |
Definition at line 363 of file machine.c.
References CdsFifo_Destroy(), Cmi_smp_mode_setting, CMI_VMI_Close_Connections(), CMI_VMI_Program_Key, CMI_VMI_Socket_Send(), CMI_VMI_Terminate_VMI(), CMI_VMI_Username, CmiBarrier(), CmiExitPxshm(), CmiExitXpmem(), CmiLock(), CmiMyPe(), CmiPrintf(), CmiUnlock(), CmiYield(), COMM_THREAD_NOT_EXIST, COMM_THREAD_ONLY_RECV, ConverseCommonExit(), free(), LrtsDrainResources(), LrtsExit(), CMI_VMI_Charmrun_Message_Header_T::msg_len, CMI_VMI_Charmrun_Message_Header_T::msg_type, and status().
Referenced by _exitHandler(), CkMessageDetailReplayDone(), ConverseInit(), ConverseRunPE(), KillOnAllSigs(), and TraceCounter::traceInit().
| void CmiAbort | ( | const char * | message | ) |
Serial version of common Charm++ routines:.
Serial version of common Charm++ routines:.
Currently only used for FEM_ALONE mode.
Orion Sky Lawlor, olawlor@acm.org, 2003/8/15
Definition at line 459 of file machine.c.
References abort(), CmiExitPxshm(), CmiExitXpmem(), LrtsAbort(), and printf().
Referenced by __cmi_assert(), _callWhenIdle(), _checkpointBarrierHandler(), _cmiZeroHandler(), _exitHandler(), _handlePhase1(), _initHandler(), _libExitHandler(), _nullFn(), _ObjectQHandler(), _parseCommandLineOpts(), _processHandler(), _receiveLocationHandler(), _removeProcessedLogHandler(), _ticketHandler(), _TokenHandler(), LogPool::add(), CkReductionMgr::addContribution(), NetFEM_update::addElems(), LBDatabase::addLoadbalancer(), NetFEM_update::addNodes(), advanceNodes(), ammasso_check_err(), ammasso_check_post_err(), AMPI_Allgather(), AMPI_Allgatherv(), AMPI_Alltoall(), AMPI_Alltoall2(), AMPI_Alltoallv(), AMPI_Gather(), AMPI_Gatherv(), AMPI_Iallgather(), AMPI_Ialltoall(), AMPI_MemCheckpoint(), AMPI_Scan(), AMPI_Scatter(), AMPI_Scatterv(), AMPI_Sendrecv(), ARMCI_Wait(), CkDelegateMgr::ArraySectionSend(), TraceProjections::beginComputation(), TraceProjections::beginExecute(), TraceCounter::beginExecute(), TraceProjections::beginExecuteLocal(), TraceCounter::beginOverview(), CkMemCheckPT::BuddyPE(), BufferAlloc(), GreedyAgentLB::BuildCpuArray(), GreedyAgentLB::BuildObjectArray(), PUP::fromTextFile::bytes(), PUP::toTextFile::bytes(), PUP::toTextUtil::bytes(), PUP::sizer::bytes(), PUP_toNetwork4_unpack::bytes(), PUP_toNetwork4_pack::bytes(), PUP_toNetwork_unpack::bytes(), PUP_toNetwork_pack::bytes(), PUP_fmt::bytes(), call_mmap_anywhere(), call_mmap_fixed(), call_munmap(), ccs_killpe(), CcsBufferMessage(), CcsImpl_ccs2converse(), CcsReply(), CcsSendReply(), CcsSetMergeFn(), CharmLibInit(), checkBufferedLocalMessageCopy(), chpt< StateType >::checkpoint(), CkFindObjectPtr(), CkGetSectionInfo(), CkHashFunction_pointer(), CkMessageWatcherInit(), CkPointer< T >::CkPointer(), CkSendMsg(), CkSendMsgBranchGroup(), CldComputeNeighborData(), CldEnqueue(), CldEnqueueGroup(), CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Grid_Objects_Compare(), CMI_VMI_Read_Environment(), CmiAllAsyncMsgsSent(), CmiAmmassoOpenQueuePairs(), CmiAsyncBroadcastFn(), CmiAsyncMsgSent(), CmiCheckGmStatus(), CmiCommLock(), CmiCommUnlock(), CmiFree(), CmiGetArgIntDesc(), CmiGetArgLongDesc(), CmiGetArgStringDesc(), CmiGetDynamicReduction(), CmiGetReductionCreate(), CmiGroupInit(), CmiInitCPUAffinity(), CmiInitMemAffinity(), CmiInitPxshm(), CmiInitSysvshm(), CmiInitXpmem(), CmiIOInit(), CmiIsomalloc(), CmiIsomallocBlockListFree(), CmiIsomallocBlockListPup(), CmiIsomallocPup(), CmiMachineExit(), CmiMachineInit(), CmiMemoryMarkBlock(), CmiMXMakeConnection(), CmiNodeReduce(), CmiNodeReduceStruct(), CmiOutOfMemory(), CmiPoolFree(), CmiProcessPriority(), CmiReleaseSentMessages(), CmiScanf(), CmiSendMessageXpmem(), CmiSetCPUAffinity(), CmiStartCounters(), CmiStopCounters(), CmiTmpAlloc(), CmiTmpFree(), CmiUsePersistentHandle(), CmmFree(), eventQueue::CommitEvents(), TopoLB::computePartitions(), TopoCentLB::computePartitions(), CkMulticastMgr::contribute(), ConverseInit(), CopyMsg(), cpd_memory_single_pup(), CpdDebugCallAllocationTree(), CpdDebugCallMemStat(), CpdFreezeModeScheduler(), CpdSearchLeaks(), cpuAffinityRecvHandler(), CQdCallWhenIdle(), CQdHandlePhase1(), CqsEnqueueGeneral(), RefinerApprox::create(), Refiner::create(), CkMemCheckPT::createEntry(), CreateLBFunc_Def(), createqp(), LogPool::createRC(), createShmObjectsAndSems(), LogPool::createSts(), LogPool::createTopo(), TraceBluegene::creatFiles(), CtgFree(), CtgPup(), CthAliasCreate(), CthAliasEnable(), CthCreate(), CthCreateInner(), CthNoStrategy(), CthPup(), CthPupBase(), CthSuspend(), CWeb_Invalid(), CWeb_Reduce(), CWebPerformanceRegisterFunction(), Strategy::deliver(), StringPool::dump(), TraceCounter::endExecute(), TraceProjections::endExecuteLocal(), TraceCounter::endOverview(), EnqueueOutgoingDgram(), extract_args(), PeTable::ExtractAndPack(), PeTable::ExtractAndVectorize(), TopoCentLB::extractMax(), FEM_Coarsen_Operation(), fillblock(), CkHashtable::findEntry(), TraceMemory::flush(), PUP::fromMemBuf(), get_callback_dest(), CkMemCheckPTInfo::getCopy(), MSA::MSA3D< ENTRY, ENTRY_OPS_CLASS, ENTRIES_PER_PAGE >::getInitialAccum(), MSA::MSA3D< ENTRY, ENTRY_OPS_CLASS, ENTRIES_PER_PAGE >::getInitialWrite(), NetFEM_update::getItem(), getMeshCoord(), grab_slots(), Group::Group(), RouterStrategy::handleMessage(), PipeBroadcastConverse::handleMessage(), hostInfo(), liveVizConfig::init(), init_ranges(), initBigSimTrace(), initHandlerRec(), initInfiOtherNodeData(), ConvComlibManager::insertMessage(), ConvComlibManager::insertStrategy(), CkMemCheckPT::isMaster(), isomallocfn(), KillOnAllSigs(), KLevelTree::KLevelTree(), LV3D_save_init(), LV3D_save_view(), main::main(), map_failed(), match(), matchTest(), memAbort(), mempool_malloc(), meta_free(), MPI_BAND(), MPI_BOR(), MPI_BXOR(), MPI_LAND(), MPI_LOR(), MPI_LXOR(), MPI_MAXLOC(), MPI_MINLOC(), MPISendOneMsg(), ArmciVirtualProcessor::msgGop(), NborBaseLB::NborBaseLB(), on_timeout(), CountLogPool::openFile(), LogPool::openLog(), TraceLogger::openLogFiles(), CkPointer< T >::operator=(), _CkOStream::output(), PUP::fromTextFile::parseError(), GridMetisLB::Partition_ClusterObjects_Into_PEs(), PCQueuePop(), pollCq(), pollRecvCq(), pollSendCq(), POSEreadCmdLine(), print_node0(), processAmmassoControlMessage(), processAsyncEvents(), processMessage(), ProcessMessage(), processRecvWC(), PipeBroadcastConverse::propagate(), PumpEvents(), PumpMsgs(), PumpMsgsBlocking(), NetFEM_update::pup(), pup_checkMPIerr(), PUP_getRegEntry(), PUPbytes(), PUP::er::pupCmiAllocBuf(), CkHashtable::put(), put_callback(), readGlobals(), readMHz(), CentralLB::readStatsMsgs(), recv_callback(), CkMemCheckPT::recvData(), CkMulticastMgr::recvRedMsg(), CkMulticastMgr::reduceFragment(), TraceCounter::registerArg(), TraceLogger::RegisterLanguage(), CkCompactVec< T >::remove(), CkVec< CkZeroPtr< T, PUP_PTR > >::remove(), Refiner::removeComputes(), chpt< StateType >::restore(), CkLocMgr::restore(), CkLocMgr::resume(), Chare::sanitycheck(), PUP::seekBlock::seek(), PUP::seekBlock::seekBlock(), CkCallback::send(), send_callback(), SendMsgBuf(), PrefixRouter::sendMulticast(), sendRemoveLogRequests(), CkMulticastMgr::sendToSection(), FEM_Attribute::set(), PhaseTable::setEp(), PhaseEntry::setEp(), SumLogPool::setEp(), CountLogPool::setEp(), ConvComlibManager::setStrategy(), RouterStrategy::setupRouter(), OrbLB::sort_partition(), LBDB::StartLB(), PhaseTable::startPhase(), TraceCore::startPtc(), NeighborCommLB::Strategy(), strategyHandler(), SumLogPool::SumLogPool(), MSA::MSAHandle< MSA::MSA1D< ElemList, DefaultListEntry< ElemList, true >, MSA_DEFAULT_ENTRIES_PER_PAGE > >::syncRelease(), TokenAlloc(), PUP::toMemBuf(), TopologyAgent::TopologyAgent(), TraceCounter::traceInit(), TraceProjections::TraceProjections(), TraceProjector::traceRegisterUserEvent(), TraceProjections::traceRegisterUserEvent(), parallelTransfer_c::transfer(), parallelSurfaceTransfer_c::transfer(), BaseLB::turnOff(), BaseLB::turnOn(), ParFUMShadowArray::unlockSharedIdxls(), minHeap::update(), SumLogPool::updateSummaryDetail(), TopoLB::work(), TopoCentLB::work(), RotateLB::work(), RefineTopoLB::work(), RandCentLB::work(), OrbLB::work(), GreedyLB::work(), GreedyCommLB::work(), CommLB::work(), BlockLB::work(), TraceSummaryBOC::write(), SumLogPool::write(), CentralLB::writeStatsMsgs(), TraceUtilization::writeSts(), SumLogPool::writeSts(), writeSts(), CountLogPool::writeSts(), and WSLB::WSLB().
| void CmiMemLock | ( | ) |
Definition at line 560 of file machine.c.
Referenced by CmiMemoryMark(), CmiMemoryMarkBlock(), CmiMemorySweep(), free_nomigrate(), infi_CmiAlloc(), infi_CmiFree(), KillOnAllSigs(), and malloc_nomigrate().
| void CmiMemUnlock | ( | ) |
Definition at line 572 of file machine.c.
Referenced by CmiMemoryMark(), CmiMemoryMarkBlock(), CmiMemorySweep(), free_nomigrate(), infi_CmiAlloc(), infi_CmiFree(), KillOnAllSigs(), and malloc_nomigrate().
| int CmiScanf | ( | const char * | format, | |
| ... | ||||
| ) |
Definition at line 799 of file machine.c.
References CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_Handle_Deallocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CmiAlloc(), CmiFreeSendFn(), CMI_VMI_Process_T::connection, context, CopyMsg(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Process_T::eager_long_send_handles, CMI_VMI_Process_T::eager_long_send_size, CMI_VMI_Send_Handle_T::eager_short, CMI_VMI_Process_T::eager_short_receive_credits_replentish, CMI_VMI_Process_T::eager_short_send_credits_available, CMI_VMI_Process_T::eager_short_send_handles, CMI_VMI_Process_T::eager_short_send_index, CMI_VMI_Process_T::eager_short_send_size, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_Eager_Long_T::maxsize, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, CMI_VMI_Send_Handle_RDMAGet_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Send_Handle_Eager_Short_T::rdmaop, CMI_VMI_Handle_T::refcount, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Short_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, status(), sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CmiAsyncSendFn(), CmiSyncBroadcastAllFn(), CmiSyncBroadcastFn1(), Converse::CmiSyncSend(), BroadcastStrategy::handleHypercube(), KillOnAllSigs(), and QdState::propagate().
| void CmiPushPE | ( | int | pe, | |
| void * | msg | |||
| ) |
Definition at line 985 of file machine.c.
References _Cmi_noprocforcommthread, CdsFifo_Enqueue(), CmiGetState(), CmiPushImmediateMsg(), CmiStateStruct::idle, and CmiStateStruct::recv.
Referenced by AssembleDatagram(), CmiFreeSendFn(), CmiSendMessagePxshm(), CmiSendMessageXpmem(), handleOneRecvedMsg(), handoverMessage(), handoverSysvshmMessage(), KillOnAllSigs(), FuncNodeHelper::parallelizeFunc(), processMessage(), ProcessMessage(), processProcBcastMsg(), SendToPeers(), SingleHelperStealWork(), and FuncSingleHelper::stealWork().
| CmiCommHandle CmiAsyncSendFn | ( | int | destrank, | |
| int | msgsize, | |||
| char * | msg | |||
| ) |
Definition at line 994 of file machine.c.
References _cmi_log2(), CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Stream_Completion_Handler(), CmiAlloc(), CmiNodeOf(), CmiSendNetworkFunc(), CmiSyncSendFn(), CMI_VMI_Process_T::connection, context, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Process_T::eager_long_send_handles, CMI_VMI_Process_T::eager_long_send_size, CMI_VMI_Send_Handle_T::eager_short, CMI_VMI_Process_T::eager_short_receive_credits_replentish, CMI_VMI_Process_T::eager_short_send_credits_available, CMI_VMI_Process_T::eager_short_send_handles, CMI_VMI_Process_T::eager_short_send_index, CMI_VMI_Process_T::eager_short_send_size, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_Eager_Long_T::maxsize, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, CMI_VMI_Send_Handle_RDMAGet_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Send_Handle_Eager_Short_T::rdmaop, CMI_VMI_Handle_T::refcount, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Short_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by KillOnAllSigs().
Definition at line 1212 of file machine.c.
References CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Stream_Completion_Handler(), CmiFree(), CmiMyPe(), CmiNodeOf(), CmiPushPE(), CmiRankOf(), CmiSendNetworkFunc(), CmiSendSelf(), CMI_VMI_Process_T::connection, context, CQdCreate(), data, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Process_T::eager_long_send_handles, CMI_VMI_Process_T::eager_long_send_size, CMI_VMI_Send_Handle_T::eager_short, CMI_VMI_Process_T::eager_short_receive_credits_replentish, CMI_VMI_Process_T::eager_short_send_credits_available, CMI_VMI_Process_T::eager_short_send_handles, CMI_VMI_Process_T::eager_short_send_index, CMI_VMI_Process_T::eager_short_send_size, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, CMI_VMI_Send_Handle_RDMAGet_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Send_Handle_Eager_Short_T::rdmaop, CMI_VMI_Handle_T::refcount, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Short_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CkStartQD(), Converse::CmiSyncSendAndFree(), CmiSyncSendFn(), KillOnAllSigs(), and QdState::sendCount().
| void CmiSyncBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1426 of file machine.c.
References CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_Handle_Deallocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_SEND_HANDLE_TYPE_RDMABROADCAST, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CmiFree(), CmiSyncBroadcastFn1(), context, CopyMsg(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_RDMABroadcast_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CmiFreeBroadcastAllFn(), Converse::CmiSyncBroadcast(), CmiSyncBroadcastAllFn(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1636 of file machine.c.
References CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMABROADCAST, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CmiAbort(), context, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_RDMABroadcast_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CmiAsyncBroadcastAllFn(), and KillOnAllSigs().
| void CmiFreeBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1893 of file machine.c.
References CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMABROADCAST, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CmiFree(), CmiSyncBroadcastFn1(), context, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_RDMABroadcast_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CmiFreeBroadcastAllFn(), Converse::CmiSyncBroadcastAndFree(), and KillOnAllSigs().
| void CmiSyncBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 2148 of file machine.c.
References CdsFifo_Enqueue(), CmiAlloc(), CmiFree(), CmiMyPe(), CmiSyncBroadcastFn(), CmiSyncBroadcastFn1(), CmiSyncSendFn(), and CopyMsg().
Referenced by Converse::CmiSyncBroadcastAll(), and KillOnAllSigs().
| CmiCommHandle CmiAsyncBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 2167 of file machine.c.
References CdsFifo_Enqueue(), CmiAlloc(), CmiAsyncBroadcastFn(), CmiSendSelf(), and CopyMsg().
Referenced by KillOnAllSigs().
| void CmiFreeBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 2194 of file machine.c.
References CdsFifo_Enqueue(), CmiAlloc(), CmiFree(), CmiFreeBroadcastFn(), CmiGetReference(), CmiSendSelf(), CmiSyncBroadcastFn(), CmiSyncBroadcastFn1(), and CopyMsg().
Referenced by Converse::CmiSyncBroadcastAllAndFree(), and KillOnAllSigs().
| int CmiAsyncMsgSent | ( | CmiCommHandle | commhandle | ) |
Definition at line 2234 of file machine.c.
References CmiAbort(), done, MPI_SUCCESS, MPI_Test(), msg_list::next, CMI_VMI_Handle_T::refcount, and msg_list::req.
Referenced by KillOnAllSigs().
| int CmiAllAsyncMsgsSent | ( | void | ) |
Definition at line 2254 of file machine.c.
References CmiAbort(), done, MPI_SUCCESS, MPI_Test(), msg_list::next, and msg_list::req.
Referenced by SendMsgBuf().
| void CmiReleaseCommHandle | ( | CmiCommHandle | commhandle | ) |
Definition at line 2266 of file machine.c.
References CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Handle_Deallocate(), CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_SEND_HANDLE_TYPE_EAGER_LONG, CMI_VMI_SEND_HANDLE_TYPE_RDMABROADCAST, CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CmiFree(), context, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), and CMI_VMI_Send_Handle_T::stream.
Referenced by KillOnAllSigs().
| void* CmiGetNonLocal | ( | void | ) |
In SMP mode with comm thread, it's possible a normal msg is sent from an immediate msg which is executed on comm thread. In this case, the msg is sent to the network queue of the work thread. Therefore, even there's only one worker thread, the polling of network queue is still required.
Definition at line 2355 of file machine.c.
References AdvanceCommunication(), CdsFifo_Dequeue(), CdsFifo_Enqueue(), CMI_VMI_Common_Receive(), CMI_VMI_Send_Spanning_Children(), CmiGetState(), CmiMyPe(), CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_T::eager_short, CMI_VMI_Process_T::eager_short_count, CMI_VMI_Process_T::eager_short_receive_handles, CMI_VMI_Process_T::eager_short_receive_index, CMI_VMI_Process_T::eager_short_receive_size, CMI_VMI_Receive_Handle_Eager_Short_T::footer, free(), CmiStateStruct::idle, gk_delayed_msgs::msg, msg, gk_delayed_msgs::msgsize, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, gk_delayed_msgs::next, PCQueuePop(), CMI_VMI_Process_T::rank, CMI_VMI_Handle_T::receive, CmiStateStruct::recv, gk_delayed_msgs::sender, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, status(), sz, and gk_delayed_msgs::time.
Referenced by CmiDeliverSpecificMsg(), CsdNextMessage(), and KillOnAllSigs().
| void CmiProbeLatencies | ( | ) |
Definition at line 2567 of file machine.c.
Referenced by CMI_VMI_Common_Receive(), CMI_VMI_RDMA_Get_Completion_Handler(), CkLocMgr::deliver(), GridMetisLB::Get_Cluster(), GridHybridSeedLB::Get_Cluster(), GridHybridLB::Get_Cluster(), GridCommRefineLB::Get_Cluster(), and GridCommLB::Get_Cluster().
| int CmiGridQueueGetInterval | ( | ) |
| int CmiGridQueueGetThreshold | ( | ) |
Definition at line 2600 of file machine.c.
References CMI_VMI_Grid_Objects_Compare(), CmiGridQueueLookup(), CMI_VMI_Grid_Object_T::gid, CMI_VMI_Grid_Object_T::index1, CMI_VMI_Grid_Object_T::index2, CMI_VMI_Grid_Object_T::index3, CMI_VMI_Grid_Object_T::nInts, and qsort().
Referenced by CkLocMgr::deliver().
Definition at line 2630 of file machine.c.
References CMI_VMI_Grid_Object_T::gid, CMI_VMI_Grid_Object_T::index1, CMI_VMI_Grid_Object_T::index2, CMI_VMI_Grid_Object_T::index3, and CMI_VMI_Grid_Object_T::nInts.
Referenced by CkLocMgr::deliver().
| void CmiGridQueueDeregisterAll | ( | ) |
Definition at line 2691 of file machine.c.
References CMI_VMI_Grid_Objects_Compare(), CMI_VMI_Grid_Object_T::gid, CMI_VMI_Grid_Object_T::index1, CMI_VMI_Grid_Object_T::index2, CMI_VMI_Grid_Object_T::index3, CMI_VMI_Grid_Object_T::nInts, and ptr.
Referenced by CmiGridQueueLookupMsg(), and CmiGridQueueRegister().
| int CmiGridQueueLookupMsg | ( | char * | msg | ) |
Definition at line 2745 of file machine.c.
References CMI_VMI_Envelope_utype::s_array::arr, CMI_VMI_Envelope_utype::array, CmiGridQueueLookup(), CMI_VMI_Envelope_utype::s_array::index, CMI_VMI_Envelope_sattribs::mtype, CMI_VMI_Envelope::s_attribs, and CMI_VMI_Envelope::u_type.
Referenced by _skipCldHandler().
| int CMI_VMI_Grid_Objects_Compare | ( | const void * | ptr1, | |
| const void * | ptr2 | |||
| ) |
Definition at line 2764 of file machine.c.
References CmiAbort(), CMI_VMI_Grid_Object_T::gid, CMI_VMI_Grid_Object_T::index1, CMI_VMI_Grid_Object_T::index2, CMI_VMI_Grid_Object_T::index3, and CMI_VMI_Grid_Object_T::nInts.
Referenced by CmiGridQueueLookup(), and CmiGridQueueRegister().
| void CmiDestroyPersistent | ( | PersistentHandle | phandle | ) |
| void CMI_VMI_Read_Environment | ( | ) |
Definition at line 2985 of file machine.c.
References CMI_VMI_Charmrun_IP, CMI_VMI_CRM_Hostname, CMI_VMI_Program_Key, CMI_VMI_Username, CmiAbort(), free(), and value.
Referenced by ConverseInit().
| int CMI_VMI_Startup_CRM | ( | ) |
Definition at line 3150 of file machine.c.
References CMI_VMI_CRM_Register_Message_T::cluster, CMI_VMI_CRM_Hostname, CMI_VMI_Program_Key, CMI_VMI_Socket_Receive(), CMI_VMI_Socket_Send(), CmiPrintf(), free(), CMI_VMI_CRM_Register_Message_T::key, CMI_VMI_CRM_Register_Message_T::key_length, malloc(), CMI_VMI_CRM_Register_Message_T::node_context, ntohl(), CMI_VMI_CRM_Register_Message_T::numpes, and printf().
Referenced by ConverseInit().
| int CMI_VMI_Startup_Charmrun | ( | ) |
Definition at line 3342 of file machine.c.
References CMI_VMI_Charmrun_IP, CMI_VMI_Socket_Receive(), CMI_VMI_Socket_Send(), CMI_VMI_Charmrun_Register_Message_T::dataport, free(), CMI_VMI_Charmrun_Register_Message_T::mach_id, malloc(), CMI_VMI_Charmrun_Message_Header_T::msg_len, CMI_VMI_Charmrun_Message_Header_T::msg_type, CMI_VMI_Charmrun_Register_Message_T::node_IP, CMI_VMI_Charmrun_Register_Message_T::node_number, ntohl(), and CMI_VMI_Charmrun_Register_Message_T::numpes.
Referenced by ConverseInit().
| int CMI_VMI_Initialize_VMI | ( | ) |
Definition at line 3443 of file machine.c.
References CMI_VMI_Bucket1_Pool, CMI_VMI_Bucket2_Pool, CMI_VMI_Bucket3_Pool, CMI_VMI_Bucket4_Pool, CMI_VMI_Bucket5_Pool, CMI_VMI_Connection_Handler(), CMI_VMI_Disconnection_Handler(), CMI_VMI_Program_Key, CMI_VMI_Stream_Notification_Handler(), free(), malloc(), and status().
Referenced by ConverseInit().
| int CMI_VMI_Terminate_VMI | ( | ) |
Definition at line 3534 of file machine.c.
References CMI_VMI_Bucket1_Pool, CMI_VMI_Bucket2_Pool, CMI_VMI_Bucket3_Pool, CMI_VMI_Bucket4_Pool, CMI_VMI_Bucket5_Pool, and status().
Referenced by ConverseExit().
Definition at line 3573 of file machine.c.
Referenced by CMI_VMI_Startup_Charmrun(), CMI_VMI_Startup_CRM(), CmiError(), CmiPrintf(), and ConverseExit().
Definition at line 3599 of file machine.c.
Referenced by CMI_VMI_Startup_Charmrun(), and CMI_VMI_Startup_CRM().
| int CMI_VMI_Open_Connections | ( | ) |
Definition at line 3634 of file machine.c.
References CMI_VMI_CONNECTION_CONNECTED, CMI_VMI_CONNECTION_ERROR, CMI_VMI_Open_Connection(), CMI_VMI_Program_Key, free(), malloc(), CMI_VMI_Connect_Message_T::rank, start_time, and status().
Referenced by ConverseInit().
| int CMI_VMI_Open_Connection | ( | int | remote_rank, | |
| char * | remote_key, | |||
| PVMI_BUFFER | connect_message_buffer | |||
| ) |
Definition at line 3744 of file machine.c.
References CMI_VMI_CONNECTION_CONNECTING, CMI_VMI_Connection_Response_Handler(), CMI_VMI_Username, CMI_VMI_Process_T::connection, CMI_VMI_Process_T::connection_state, localAddress, CMI_VMI_Process_T::node_IP, and status().
Referenced by CMI_VMI_Open_Connections().
| VMI_CONNECT_RESPONSE CMI_VMI_Connection_Handler | ( | PVMI_CONNECT | connection, | |
| PVMI_SLAB | slab, | |||
| ULONG | data_size | |||
| ) |
Definition at line 3809 of file machine.c.
References CMI_VMI_CONNECTION_CONNECTED, CMI_VMI_RDMA_Get_Notification_Handler(), CMI_VMI_RDMA_Publish_Notification_Handler(), CMI_VMI_RDMA_Put_Notification_Handler(), data, free(), malloc(), ntohl(), CMI_VMI_Connect_Message_T::rank, size, and status().
Referenced by CMI_VMI_Initialize_VMI().
| void CMI_VMI_Connection_Response_Handler | ( | PVOID | context, | |
| PVOID | response, | |||
| USHORT | size, | |||
| PVOID | handle, | |||
| VMI_CONNECT_RESPONSE | remote_status | |||
| ) |
Definition at line 3885 of file machine.c.
References CMI_VMI_CONNECTION_CONNECTED, CMI_VMI_CONNECTION_DISCONNECTED, CMI_VMI_CONNECTION_ERROR, CMI_VMI_RDMA_Get_Notification_Handler(), CMI_VMI_RDMA_Publish_Notification_Handler(), CMI_VMI_RDMA_Put_Notification_Handler(), CMI_VMI_Process_T::connection, CMI_VMI_Process_T::connection_state, CMI_VMI_Process_T::node_IP, CMI_VMI_Process_T::rank, and status().
Referenced by CMI_VMI_Open_Connection().
| int CMI_VMI_Close_Connections | ( | ) |
Definition at line 3957 of file machine.c.
References CMI_VMI_CONNECTION_DISCONNECTED, CMI_VMI_CONNECTION_DISCONNECTING, CMI_VMI_Disconnection_Response_Handler(), start_time, and status().
Referenced by ConverseExit().
| void CMI_VMI_Disconnection_Handler | ( | PVMI_CONNECT | connection | ) |
Definition at line 4016 of file machine.c.
References CMI_VMI_CONNECTION_DISCONNECTED, and CMI_VMI_Process_T::connection_state.
Referenced by CMI_VMI_Initialize_VMI().
| void CMI_VMI_Disconnection_Response_Handler | ( | PVMI_CONNECT | connection, | |
| PVOID | context, | |||
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 4033 of file machine.c.
References CMI_VMI_CONNECTION_DISCONNECTED, and CMI_VMI_Process_T::connection_state.
Referenced by CMI_VMI_Close_Connections().
| void CMI_VMI_Reply_Latencies | ( | int | sourcerank | ) |
Definition at line 4049 of file machine.c.
References CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Stream_Completion_Handler(), CmiAlloc(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Latency_Vector_Reply_Message_T::latency, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, and sz.
Referenced by CMI_VMI_Common_Receive().
| void CMI_VMI_Compute_Cluster_Mapping | ( | ) |
| void CMI_VMI_Distribute_Cluster_Mapping | ( | ) |
Definition at line 4152 of file machine.c.
References CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Cluster_Mapping_Message_T::cluster, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Stream_Completion_Handler(), CmiAlloc(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, and sz.
Referenced by ConverseInit().
| void CMI_VMI_Wait_Cluster_Mapping | ( | ) |
Definition at line 4222 of file machine.c.
References CMI_VMI_Cluster_Mapping_Received, and status().
Referenced by ConverseInit().
| PVMI_CACHE_ENTRY CMI_VMI_CacheEntry_From_Context | ( | void * | context | ) |
Definition at line 4415 of file machine.c.
References CMI_VMI_Receive_Handle_Eager_Long_T::cacheentry, CMI_VMI_Receive_Handle_Eager_Short_T::cacheentry, CMI_VMI_RECEIVE_HANDLE_TYPE_EAGER_LONG, CMI_VMI_RECEIVE_HANDLE_TYPE_EAGER_SHORT, CmiAbort(), CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_T::eager_long, CMI_VMI_Receive_Handle_T::eager_short, CMI_VMI_Handle_T::receive, and CMI_VMI_Receive_Handle_T::receive_handle_type.
Referenced by CmiAsyncBroadcastFn(), CmiAsyncSendFn(), CmiFreeBroadcastFn(), CmiFreeSendFn(), CmiSyncBroadcastFn(), and CmiSyncSendFn().
| CMI_VMI_Handle_T* CMI_VMI_Handle_Allocate | ( | ) |
Definition at line 4445 of file machine.c.
References realloc(), refcount, and status().
Referenced by CMI_VMI_Distribute_Cluster_Mapping(), CMI_VMI_Eager_Long_Setup(), CMI_VMI_Eager_Short_Setup(), CMI_VMI_RDMA_Publish_Notification_Handler(), CMI_VMI_Reply_Latencies(), CMI_VMI_Send_Spanning_Children(), CmiAsyncBroadcastFn(), CmiAsyncSendFn(), CmiFreeBroadcastFn(), CmiFreeSendFn(), CmiSyncBroadcastFn(), and CmiSyncSendFn().
| void CMI_VMI_Handle_Deallocate | ( | CMI_VMI_Handle_T * | handle | ) |
Definition at line 4483 of file machine.c.
References CMI_VMI_Handle_T::refcount.
Referenced by CMI_VMI_RDMA_Get_Completion_Handler(), CMI_VMI_RDMA_Get_Notification_Handler(), CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_Stream_Completion_Handler(), CmiReleaseCommHandle(), CmiSyncBroadcastFn(), and CmiSyncSendFn().
| void CMI_VMI_Eager_Short_Setup | ( | int | sender_rank | ) |
Definition at line 4495 of file machine.c.
References CMI_VMI_Receive_Handle_Eager_Short_T::cacheentry, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_RECEIVE, CMI_VMI_PUBLISH_TYPE_EAGER_SHORT, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_RECEIVE_HANDLE_TYPE_EAGER_SHORT, CmiAlloc(), CMI_VMI_Process_T::connection, CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_Eager_Short_T::eager_buffer, CMI_VMI_Receive_Handle_T::eager_short, CMI_VMI_Process_T::eager_short_receive_handles, CMI_VMI_Process_T::eager_short_receive_size, CMI_VMI_Receive_Handle_Eager_Short_T::footer, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::msg, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Handle_T::msgsize, CMI_VMI_Receive_Handle_Eager_Short_T::publish_buffer, CMI_VMI_Receive_Handle_Eager_Short_T::publishes_pending, CMI_VMI_Handle_T::receive, CMI_VMI_Receive_Handle_T::receive_handle_type, CMI_VMI_Handle_T::refcount, CMI_VMI_Receive_Handle_Eager_Short_T::sender_rank, status(), and CMI_VMI_Publish_Message_T::type.
Referenced by CMI_VMI_Common_Receive(), CmiNotifyIdle(), and CmiRegisterReceivePersistent().
Definition at line 4594 of file machine.c.
References CMI_VMI_Receive_Handle_Eager_Long_T::cacheentry, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_RECEIVE, CMI_VMI_PUBLISH_TYPE_EAGER_LONG, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_RECEIVE_HANDLE_TYPE_EAGER_LONG, CmiAlloc(), CMI_VMI_Process_T::connection, CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_T::eager_long, CMI_VMI_Process_T::eager_long_receive_handles, CMI_VMI_Process_T::eager_long_receive_size, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Receive_Handle_Eager_Long_T::maxsize, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Receive_Handle_Eager_Long_T::publishes_pending, CMI_VMI_Handle_T::receive, CMI_VMI_Receive_Handle_T::receive_handle_type, CMI_VMI_Handle_T::refcount, CMI_VMI_Receive_Handle_Eager_Long_T::sender_rank, status(), and CMI_VMI_Publish_Message_T::type.
Referenced by CMI_VMI_Common_Receive(), CmiNotifyIdle(), and CmiRegisterReceivePersistent().
| VMI_RECV_STATUS CMI_VMI_Stream_Notification_Handler | ( | PVMI_CONNECT | connection, | |
| PVMI_STREAM_RECV | stream, | |||
| VMI_STREAM_COMMAND | command, | |||
| PVOID | context, | |||
| PVMI_SLAB | slab | |||
| ) |
Definition at line 4671 of file machine.c.
References CMI_VMI_Common_Receive(), CmiAlloc(), msg, CMI_VMI_Process_T::normal_short_count, CMI_VMI_Process_T::rank, and status().
Referenced by CMI_VMI_Initialize_VMI().
| void CMI_VMI_Stream_Completion_Handler | ( | PVOID | context, | |
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 4718 of file machine.c.
References CMI_VMI_Send_Handle_Stream_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_Handle_Deallocate(), CMI_VMI_MESSAGE_DISPOSITION_ENQUEUE, CMI_VMI_MESSAGE_DISPOSITION_FREE, CmiFree(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, status(), and CMI_VMI_Send_Handle_T::stream.
Referenced by CMI_VMI_Distribute_Cluster_Mapping(), CMI_VMI_Reply_Latencies(), CMI_VMI_Send_Spanning_Children(), CmiAsyncBroadcastFn(), CmiAsyncSendFn(), CmiFreeBroadcastFn(), CmiFreeSendFn(), and CmiSyncBroadcastFn().
| void CMI_VMI_RDMA_Publish_Notification_Handler | ( | PVMI_CONNECT | connection, | |
| PVMI_REMOTE_BUFFER | remote_buffer, | |||
| PVMI_SLAB | publish_data, | |||
| ULONG | publish_data_size | |||
| ) |
Definition at line 4777 of file machine.c.
References CMI_VMI_Receive_Handle_RDMAGet_T::cacheentry, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_RECEIVE, CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_PUBLISH_TYPE_EAGER_LONG, CMI_VMI_PUBLISH_TYPE_EAGER_SHORT, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Get_Completion_Handler(), CMI_VMI_RECEIVE_HANDLE_TYPE_RDMAGET, CMI_VMI_SEND_HANDLE_TYPE_EAGER_LONG, CMI_VMI_SEND_HANDLE_TYPE_EAGER_SHORT, CmiAlloc(), CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Process_T::eager_long_send_handles, CMI_VMI_Process_T::eager_long_send_size, CMI_VMI_Process_T::eager_short_send_credits_available, CMI_VMI_Process_T::eager_short_send_handles, CMI_VMI_Process_T::eager_short_send_size, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::msg, msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Receive_Handle_RDMAGet_T::process, CMI_VMI_Receive_Handle_T::rdmaget, CMI_VMI_Handle_T::receive, CMI_VMI_Receive_Handle_T::receive_handle_type, CMI_VMI_Handle_T::refcount, status(), and CMI_VMI_Publish_Message_T::type.
Referenced by CMI_VMI_Connection_Handler(), and CMI_VMI_Connection_Response_Handler().
| void CMI_VMI_RDMA_Publish_Completion_Handler | ( | PVOID | context, | |
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 4900 of file machine.c.
References CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_RECEIVE_HANDLE_TYPE_EAGER_SHORT, CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CMI_VMI_Receive_Handle_T::data, CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_T::eager_long, CMI_VMI_Receive_Handle_T::eager_short, CMI_VMI_Handle_T::handle_type, CMI_VMI_Receive_Handle_Eager_Long_T::publishes_pending, CMI_VMI_Receive_Handle_Eager_Short_T::publishes_pending, CMI_VMI_Send_Handle_RDMABroadcast_T::publishes_pending, CMI_VMI_Send_Handle_RDMAGet_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Handle_T::receive, CMI_VMI_Receive_Handle_T::receive_handle_type, CMI_VMI_Handle_T::send, and CMI_VMI_Send_Handle_T::send_handle_type.
Referenced by CMI_VMI_Eager_Long_Setup(), CMI_VMI_Eager_Short_Setup(), CMI_VMI_Send_Spanning_Children(), CmiAsyncBroadcastFn(), CmiAsyncSendFn(), CmiFreeBroadcastFn(), and CmiFreeSendFn().
| void CMI_VMI_RDMA_Put_Notification_Handler | ( | PVMI_CONNECT | connection, | |
| UINT32 | rdma_size, | |||
| UINT32 | context, | |||
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 4929 of file machine.c.
References CMI_VMI_Common_Receive(), CMI_VMI_Process_T::eager_long_count, CMI_VMI_Handle_T::msg, msg, CMI_VMI_Process_T::rank, and status().
Referenced by CMI_VMI_Connection_Handler(), and CMI_VMI_Connection_Response_Handler().
| void CMI_VMI_RDMA_Put_Completion_Handler | ( | PVMI_RDMA_OP | rdmaop, | |
| PVOID | context, | |||
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 4971 of file machine.c.
References CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Handle_Deallocate(), CMI_VMI_MESSAGE_DISPOSITION_FREE, CmiFree(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, and status().
Referenced by CmiAsyncSendFn(), CmiFreeSendFn(), and CmiSyncSendFn().
| void CMI_VMI_RDMA_Get_Notification_Handler | ( | PVMI_CONNECT | connection, | |
| UINT32 | context, | |||
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 5017 of file machine.c.
References CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_Handle_Deallocate(), CMI_VMI_MESSAGE_DISPOSITION_ENQUEUE, CMI_VMI_MESSAGE_DISPOSITION_FREE, CmiFree(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Send_Handle_T::rdmaget, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, and status().
Referenced by CMI_VMI_Connection_Handler(), and CMI_VMI_Connection_Response_Handler().
| void CMI_VMI_RDMA_Get_Completion_Handler | ( | PVMI_RDMA_OP | rdmaop, | |
| PVOID | context, | |||
| VMI_STATUS | remote_status | |||
| ) |
Definition at line 5065 of file machine.c.
References CMI_VMI_Receive_Handle_RDMAGet_T::cacheentry, CMI_VMI_Common_Receive(), CMI_VMI_Handle_Deallocate(), CmiGetCluster(), CMI_VMI_Receive_Handle_T::data, CMI_VMI_Handle_T::data, malloc(), gk_delayed_msgs::msg, CMI_VMI_Handle_T::msg, msg, gk_delayed_msgs::msgsize, CMI_VMI_Handle_T::msgsize, gk_delayed_msgs::next, CMI_VMI_Process_T::normal_long_count, CMI_VMI_Receive_Handle_RDMAGet_T::process, CMI_VMI_Process_T::rank, CMI_VMI_Receive_Handle_T::rdmaget, CMI_VMI_Handle_T::receive, gk_delayed_msgs::sender, status(), and gk_delayed_msgs::time.
Referenced by CMI_VMI_RDMA_Publish_Notification_Handler().
| int CMI_VMI_Spanning_Children_Count | ( | char * | msg | ) |
Definition at line 5138 of file machine.c.
Referenced by CMI_VMI_Send_Spanning_Children(), CmiAsyncBroadcastFn(), CmiFreeBroadcastFn(), and CmiSyncBroadcastFn().
| void CMI_VMI_Send_Spanning_Children | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 5179 of file machine.c.
References CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_MESSAGE_DISPOSITION_ENQUEUE, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Publish_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMABROADCAST, CMI_VMI_SEND_HANDLE_TYPE_STREAM, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CMI_VMI_Send_Handle_T::data, CMI_VMI_Handle_T::data, CMI_VMI_Handle_T::handle_type, CMI_VMI_Handle_T::index, CMI_VMI_Send_Handle_T::message_disposition, CMI_VMI_Handle_T::msg, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_RDMABroadcast_T::publishes_pending, CMI_VMI_Send_Handle_T::rdmabroadcast, CMI_VMI_Handle_T::refcount, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Referenced by CMI_VMI_Common_Receive(), and CmiGetNonLocal().
Definition at line 5315 of file machine.c.
References CdsFifo_Enqueue(), CMI_VMI_Cluster_Mapping_Message_T::cluster, CMI_VMI_Cluster_Mapping_Received, CMI_VMI_Eager_Long_Setup(), CMI_VMI_Eager_Short_Setup(), CMI_VMI_Reply_Latencies(), CMI_VMI_Send_Spanning_Children(), CmiFree(), CmiGetCluster(), CMI_VMI_Process_T::eager_short_send_credits_available, CMI_VMI_Latency_Vector_Reply_Message_T::latency, malloc(), CMI_VMI_Persistent_Request_Message_T::maxsize, gk_delayed_msgs::msg, gk_delayed_msgs::msgsize, gk_delayed_msgs::next, CMI_VMI_Process_T::rank, gk_delayed_msgs::sender, and gk_delayed_msgs::time.
Referenced by CMI_VMI_RDMA_Get_Completion_Handler(), CMI_VMI_RDMA_Put_Notification_Handler(), CMI_VMI_Stream_Notification_Handler(), and CmiGetNonLocal().
| USHORT VMI_DEVICE_RUNTIME |
| PVMI_NETADDRESS localAddress |
Referenced by CMI_VMI_Open_Connection().
| VMIStreamRecv recvFn |
Definition at line 28 of file machine.c.
Referenced by CkMessageWatcherInit(), CmiSyncBroadcastFn1(), KillOnAllSigs(), and node_addresses_store().
| int _Cmi_myrank = 0 |
| char* CMI_VMI_Username |
Definition at line 39 of file machine.c.
Referenced by CMI_VMI_Open_Connection(), CMI_VMI_Read_Environment(), and ConverseExit().
| char* CMI_VMI_Program_Key |
Definition at line 40 of file machine.c.
Referenced by CMI_VMI_Initialize_VMI(), CMI_VMI_Open_Connections(), CMI_VMI_Read_Environment(), CMI_VMI_Startup_CRM(), ConverseExit(), and ConverseInit().
| volatile int CMI_VMI_Message_Receive_Count |
| volatile int CMI_VMI_AsyncMsgCount |
| volatile int CMI_VMI_Barrier_Count |
| char CMI_VMI_Charmrun_IP[1024] |
Definition at line 65 of file machine.c.
Referenced by CMI_VMI_Read_Environment(), and CMI_VMI_Startup_Charmrun().
| char* CMI_VMI_CRM_Hostname |
Definition at line 69 of file machine.c.
Referenced by CMI_VMI_Read_Environment(), and CMI_VMI_Startup_CRM().
| BOOLEAN CMI_VMI_Cluster_Mapping_Received |
Definition at line 80 of file machine.c.
Referenced by CMI_VMI_Common_Receive(), CMI_VMI_Wait_Cluster_Mapping(), and ConverseInit().
| PVMI_BUFFER_POOL CMI_VMI_Bucket1_Pool |
Definition at line 82 of file machine.c.
Referenced by CMI_VMI_CmiAlloc(), CMI_VMI_CmiFree(), CMI_VMI_Initialize_VMI(), and CMI_VMI_Terminate_VMI().
| PVMI_BUFFER_POOL CMI_VMI_Bucket2_Pool |
Definition at line 83 of file machine.c.
Referenced by CMI_VMI_CmiAlloc(), CMI_VMI_CmiFree(), CMI_VMI_Initialize_VMI(), and CMI_VMI_Terminate_VMI().
| PVMI_BUFFER_POOL CMI_VMI_Bucket3_Pool |
Definition at line 84 of file machine.c.
Referenced by CMI_VMI_CmiAlloc(), CMI_VMI_CmiFree(), CMI_VMI_Initialize_VMI(), and CMI_VMI_Terminate_VMI().
| PVMI_BUFFER_POOL CMI_VMI_Bucket4_Pool |
Definition at line 85 of file machine.c.
Referenced by CMI_VMI_CmiAlloc(), CMI_VMI_CmiFree(), CMI_VMI_Initialize_VMI(), and CMI_VMI_Terminate_VMI().
| PVMI_BUFFER_POOL CMI_VMI_Bucket5_Pool |
Definition at line 86 of file machine.c.
Referenced by CMI_VMI_CmiAlloc(), CMI_VMI_CmiFree(), CMI_VMI_Initialize_VMI(), and CMI_VMI_Terminate_VMI().
1.5.5