Go to the source code of this file.
Definition in file machine.h.
| void ConverseInit | ( | int | argc, | |
| char ** | argv, | |||
| CmiStartFn | start_function, | |||
| int | user_calls_scheduler, | |||
| int | init_returns | |||
| ) |
Definition at line 1557 of file machine.c.
References _Cmi_mynode, _Cmi_mynodesize, _Cmi_mype, _Cmi_numnodes, _Cmi_numpes, blockingReceiveFlag, CcdCallOnConditionKeep(), CdsFifo_Create(), Cmi_argv, Cmi_dim, Cmi_nodestart, Cmi_startfn, Cmi_usrsched, CMI_VMI_AsyncMsgCount, CMI_VMI_Barrier_Count, CMI_VMI_Cluster, CMI_VMI_Cluster_Mapping_Received, CMI_VMI_Compute_Cluster_Mapping(), CMI_VMI_CONNECTION_DISCONNECTED, CMI_VMI_Connection_Timeout, CMI_VMI_Distribute_Cluster_Mapping(), CMI_VMI_Eager_Interval, CMI_VMI_Eager_Long_Buffer_Size, CMI_VMI_Eager_Long_Buffers, CMI_VMI_Eager_Protocol, CMI_VMI_Eager_Short_Message_Boundary, CMI_VMI_Eager_Short_Pollset, CMI_VMI_Eager_Short_Pollset_Size, CMI_VMI_Eager_Short_Pollset_Size_Maximum, CMI_VMI_Eager_Short_Slots, CMI_VMI_Eager_Threshold, CMI_VMI_Grid_Objects, CMI_VMI_Grid_Objects_Index, CMI_VMI_Grid_Queue, CMI_VMI_Grid_Queue_Interval, CMI_VMI_Grid_Queue_Maximum, CMI_VMI_Grid_Queue_Threshold, CMI_VMI_Handles, CMI_VMI_Initialize_VMI(), CMI_VMI_Maximum_Handles, CMI_VMI_Medium_Message_Boundary, CMI_VMI_Memory_Pool, CMI_VMI_Message_Receive_Count, CMI_VMI_Next_Handle, CMI_VMI_Open_Connections(), CMI_VMI_Probe_Clusters, CMI_VMI_Processes, CMI_VMI_Program_Key, CMI_VMI_Read_Environment(), CMI_VMI_Small_Message_Boundary, CMI_VMI_Startup_Charmrun(), CMI_VMI_Startup_CRM(), CMI_VMI_Startup_Type, CMI_VMI_Terminate_VMI_Hack, CMI_VMI_Wait_Cluster_Mapping(), CMI_VMI_WAN_Latency, CmiAbort(), CmiBarrier(), CmiGetArgc(), CmiGetArgFlag(), CmiGetArgInt(), CmiNodeStateInit(), CmiNotifyIdle(), CmiPrintf(), CmiProbeLatencies(), CmiStartThreads(), CmiTimerInit(), ConverseCommonInit(), ConverseExit(), ConverseRunPE(), CsdScheduler(), CthInit(), elan_base, elan_port, elan_q, enableBufferPooling, enableGetBasedSend, gk_head_ptr1, gk_head_ptr2, gk_tail_ptr1, gk_tail_ptr2, gk_timeout1, gk_timeout2, localMidBufferQueue, localSmallBufferQueue, malloc(), MID_MESSAGE_SIZE, midQSize, msgBuf, n, PCQueueCreate(), printf(), request_bytes, request_max, sleep(), SMALL_MESSAGE_SIZE, smallQSize, and value.
| void ConverseExit | ( | ) |
Definition at line 1257 of file machine.c.
References _Cmi_numpes, CdsFifo_Destroy(), CMI_VMI_Charmrun_Socket, CMI_VMI_Close_Connections(), CMI_VMI_Eager_Short_Pollset, CMI_VMI_Grid_Objects, CMI_VMI_Handles, CMI_VMI_Processes, CMI_VMI_Program_Key, CMI_VMI_Socket_Send(), CMI_VMI_Startup_Type, CMI_VMI_Terminate_VMI(), CMI_VMI_Terminate_VMI_Hack, CMI_VMI_Username, CmiAllAsyncMsgsSent(), CmiBarrier(), CmiMyPe(), CmiPrintf(), CmiReleaseSentMessages(), ConverseCommonExit(), cur_unsent, elan_base, ElanSendQueuedMessages(), free(), CMI_VMI_Charmrun_Message_Header_T::msg_len, CMI_VMI_Charmrun_Message_Header_T::msg_type, PumpMsgs(), registerElanEvents(), and status().
| void CmiAbort | ( | const char * | message | ) |
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 8 of file charm_standalone.C.
| int CmiScanf | ( | const char * | format, | |
| ... | ||||
| ) |
Definition at line 847 of file machine.c.
References _Cmi_mype, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Eager_Short_Message_Boundary, CMI_VMI_Handle_Allocate(), CMI_VMI_Handle_Deallocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_Processes, CMI_VMI_PUBLISH_TYPE_GET, CMI_VMI_RDMA_Put_Completion_Handler(), CMI_VMI_SEND_HANDLE_TYPE_RDMAGET, CmiAlloc(), CmiAsyncSendFn(), CmiGetState(), CmiSendSelf(), context, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Send_Handle_T::eager_short, 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_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, CmiStateStruct::pe, process, 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_Short_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, size, status(), sz, and CMI_VMI_Publish_Message_T::type.
| CmiCommHandle CmiAsyncSendFn | ( | int | destrank, | |
| int | msgsize, | |||
| char * | msg | |||
| ) |
Definition at line 1097 of file machine.c.
References _Cmi_mype, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Eager_Short_Message_Boundary, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_Processes, 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_Small_Message_Boundary, CMI_VMI_Stream_Completion_Handler(), CmiAlloc(), context, CMI_VMI_Handle_T::data, CMI_VMI_Send_Handle_T::data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Send_Handle_T::eager_short, ElanSendFn(), 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_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, process, 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_Short_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, size, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
Definition at line 1101 of file machine.c.
References _Cmi_mype, CMI_VMI_Send_Handle_Eager_Short_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CdsFifo_Enqueue(), CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Eager_Short_Message_Boundary, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_Processes, 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_Small_Message_Boundary, CMI_VMI_Stream_Completion_Handler(), CmiAsyncSendFn(), CmiFree(), CmiGetState(), CmiMyPe(), CmiPrintf(), CmiSendSelf(), CmiWallTimer(), context, CQdCreate(), data, CMI_VMI_Send_Handle_T::eager_long, CMI_VMI_Send_Handle_T::eager_short, elan_port, 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_Eager_Short_Slot_Footer_T::msgsize, CMI_VMI_Handle_T::msgsize, CMI_VMI_Send_Handle_Eager_Short_T::offset, CmiStateStruct::pe, process, 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_Short_T::remote_buffer, CMI_VMI_Send_Handle_Eager_Long_T::remote_buffer, CMI_VMI_Handle_T::send, CMI_VMI_Send_Handle_T::send_handle_type, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, size, status(), CMI_VMI_Send_Handle_T::stream, stretchFlag, sz, traceUserBracketEvent(), and CMI_VMI_Publish_Message_T::type.
| void CmiSyncBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1182 of file machine.c.
References _Cmi_mype, _Cmi_numpes, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Handle_Allocate(), CMI_VMI_Handle_Deallocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_Processes, 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(), CmiGetState(), CmiMyPe(), CmiSyncSendFn(), context, CMI_VMI_Handle_T::data, CMI_VMI_Send_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, CmiStateStruct::pe, 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, SendSpanningChildren(), size, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
| CmiCommHandle CmiAsyncBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1199 of file machine.c.
References _Cmi_mype, _Cmi_numpes, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_NONE, CMI_VMI_Processes, 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_Small_Message_Boundary, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CmiAllAsyncMsgsSent(), CmiAsyncSendFn(), CmiGetState(), context, CMI_VMI_Handle_T::data, CMI_VMI_Send_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, CmiStateStruct::pe, 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, size, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
| void CmiFreeBroadcastFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1211 of file machine.c.
References _Cmi_mype, _Cmi_numpes, CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_AsyncMsgCount, CMI_VMI_CacheEntry_From_Context(), CMI_VMI_Eager_Protocol, CMI_VMI_Handle_Allocate(), CMI_VMI_HANDLE_TYPE_SEND, CMI_VMI_Medium_Message_Boundary, CMI_VMI_MESSAGE_DISPOSITION_FREE, CMI_VMI_Processes, 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_Small_Message_Boundary, CMI_VMI_Spanning_Children_Count(), CMI_VMI_Stream_Completion_Handler(), CmiFree(), CmiSyncBroadcastFn(), context, CMI_VMI_Handle_T::data, CMI_VMI_Send_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, size, status(), CMI_VMI_Send_Handle_T::stream, sz, and CMI_VMI_Publish_Message_T::type.
| void CmiSyncBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1217 of file machine.c.
References _Cmi_numpes, CdsFifo_Enqueue(), CmiAlloc(), CmiGetState(), CmiSyncBroadcastFn(), CmiSyncSendFn(), CmiStateStruct::pe, SendSpanningChildren(), and size.
| CmiCommHandle CmiAsyncBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1232 of file machine.c.
References _Cmi_numpes, CdsFifo_Enqueue(), CmiAllAsyncMsgsSent(), CmiAlloc(), CmiAsyncBroadcastFn(), CmiAsyncSendFn(), and size.
| void CmiFreeBroadcastAllFn | ( | int | msgsize, | |
| char * | msg | |||
| ) |
Definition at line 1241 of file machine.c.
References _Cmi_numpes, CdsFifo_Enqueue(), CMI_VMI_Medium_Message_Boundary, CMI_VMI_Small_Message_Boundary, CmiAlloc(), CmiFree(), CmiFreeBroadcastFn(), CmiGetState(), CmiSyncBroadcastFn(), CmiSyncSendFn(), CmiStateStruct::pe, SendSpanningChildren(), and size.
| int CmiAsyncMsgSent | ( | CmiCommHandle | commhandle | ) |
Definition at line 343 of file machine.c.
References msg_list::e, elan_base, msg_list::next, CMI_VMI_Handle_T::refcount, and sent_msgs.
| int CmiAllAsyncMsgsSent | ( | ) |
Definition at line 314 of file machine.c.
References CMI_VMI_AsyncMsgCount, CmiReleaseSentMessages(), cur_unsent, msg_list::e, elan_base, msg_list::next, and sent_msgs.
| void CmiReleaseCommHandle | ( | CmiCommHandle | commhandle | ) |
Definition at line 370 of file machine.c.
References CMI_VMI_Send_Handle_Stream_T::cacheentry, CMI_VMI_Send_Handle_RDMAGet_T::cacheentry, CMI_VMI_Send_Handle_RDMABroadcast_T::cacheentry, CMI_VMI_Send_Handle_Eager_Long_T::cacheentry, CMI_VMI_Eager_Protocol, 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_Handle_T::data, CMI_VMI_Send_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.
| void* CmiGetNonLocal | ( | ) |
Definition at line 757 of file machine.c.
References CMI_VMI_Common_Receive(), CMI_VMI_Eager_Short_Pollset, CMI_VMI_Eager_Short_Pollset_Size, CMI_VMI_Message_Receive_Count, CmiGetState(), CmiIdleLock_checkMessage(), CmiReleaseSentMessages(), CMI_VMI_Handle_T::data, CMI_VMI_Receive_Handle_T::data, CMI_VMI_Receive_Handle_T::eager_short, ElanSendQueuedMessages(), CMI_VMI_Receive_Handle_Eager_Short_T::footer, CmiStateStruct::idle, CMI_VMI_Eager_Short_Slot_Footer_T::msgsize, PCQueuePop(), process, PumpMsgs(), CMI_VMI_Handle_T::receive, CmiStateStruct::recv, CMI_VMI_Eager_Short_Slot_Footer_T::sentinel, status(), and sz.
| void CmiProbeLatencies | ( | ) |
Definition at line 2490 of file machine.c.
References _Cmi_mype, _Cmi_numpes, CMI_VMI_Latency_Vectors_Received, CMI_VMI_Processes, malloc(), status(), and sz.
Referenced by ConverseInit().
| int CmiGridQueueGetInterval | ( | ) |
| int CmiGridQueueGetThreshold | ( | ) |
Definition at line 2595 of file machine.c.
References CMI_VMI_Grid_Objects, CMI_VMI_Grid_Objects_Compare(), CMI_VMI_Grid_Objects_Index, CMI_VMI_Grid_Queue, CMI_VMI_Grid_Queue_Maximum, 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().
Definition at line 2625 of file machine.c.
References CMI_VMI_Grid_Objects, CMI_VMI_Grid_Objects_Index, CMI_VMI_Grid_Queue, 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.
| void CmiGridQueueDeregisterAll | ( | ) |
| int CmiGridQueueLookup |