gFTL_StringInteger64Map | w | pFIO_MultiCommServerMod | |
w | |||
iso_c_binding | w | ||
w | |||
iso_fortran_env | w | ||
w | |||
MAPL_ErrorHandlingMod | w | ||
w | |||
MAPL_KeywordEnforcerMod | w | ||
w | |||
MAPL_SimpleCommSplitterMod | w | ||
w | |||
MAPL_SplitCommunicatorMod | w | ||
w | |||
mpi | w | ||
w | |||
pFIO_AbstractDataReferenceMod | w | ||
w | |||
pFIO_AbstractDataReferenceVectorMod | w | ||
w | |||
pFIO_AbstractDirectoryServiceMod | w | ||
w | |||
pFIO_AbstractMessageMod | w | ||
w | |||
pFIO_AbstractServerMod | w | ||
w | |||
pFIO_AbstractSocketMod | w | ||
w | |||
pFIO_AbstractSocketVectorMod | w | ||
w | |||
pFIO_AttributeMod | w | ||
w | |||
pFIO_BaseServerMod | w | ||
w | |||
pFIO_CollectiveStageDataMessageMod | w | ||
w | |||
pFIO_ConstantsMod | w | ||
w | |||
pFIO_ForwardDataMessageMod | w | ||
w | |||
pFIO_HistoryCollectionMod | w | ||
w | |||
pFIO_HistoryCollectionVectorMod | w | ||
w | |||
pFIO_HistoryCollectionVectorUtilMod | w | ||
w | |||
pFIO_LocalMemReferenceMod | w | ||
w | |||
pFIO_MessageVectorMod | w | ||
w | |||
pFIO_MessageVectorUtilMod | w | ||
w | |||
pFIO_MpiSocketMod | w | ||
w | |||
pFIO_NetCDF4_FileFormatterMod | w | ||
w | |||
pFIO_RDMAReferenceMod | w | ||
w | |||
pFIO_ServerThreadMod | w | ||
w | |||
pFIO_ServerThreadVectorMod | w | ||
w | |||
pFIO_ShmemReferenceMod | w | ||
w | |||
pFIO_StringAttributeMapMod | w | ||
w | |||
pFIO_StringAttributeMapUtilMod | w | ||
w | |||
pFIO_UtilitiesMod | w | ||
w |
Type | Intent | Optional | Attributes | Name | ||
---|---|---|---|---|---|---|
integer, | intent(in) | :: | server_comm | |||
character(len=*), | intent(in) | :: | port_name | |||
integer, | intent(in) | :: | nwriter_per_node | |||
integer, | intent(out), | optional | :: | rc |
Type | Visibility | Attributes | Name | Initial | |||
---|---|---|---|---|---|---|---|
character(len=:), | public, | allocatable | :: | port_name | |||
integer, | public | :: | InNode_Comm | ||||
integer, | public | :: | InNode_Rank | ||||
integer, | public | :: | InNode_npes | ||||
integer, | public | :: | NodeRoot_Comm | ||||
integer, | public | :: | Node_Num | ||||
integer, | public | :: | Node_Rank | ||||
integer, | public, | allocatable | :: | Node_Ranks(:) | |||
integer, | public | :: | back_Comm | ||||
integer, | public, | allocatable | :: | back_ranks(:) | |||
integer, | public | :: | comm | ||||
integer, | public | :: | front_Comm | ||||
integer, | public, | allocatable | :: | front_ranks(:) | |||
integer, | public | :: | nfront | ||||
integer, | public | :: | npes | ||||
integer, | public | :: | num_clients | = | 0 | ||
integer, | public | :: | nwriter | ||||
integer, | public | :: | rank | ||||
integer, | public | :: | server_Comm | ||||
integer, | public | :: | status | ||||
logical, | public | :: | I_am_back_root | ||||
logical, | public | :: | I_am_front_root | ||||
logical, | public | :: | all_backlog_is_empty | = | .true. | ||
logical, | public, | allocatable | :: | serverthread_done_msgs(:) | |||
logical, | public | :: | terminate | ||||
type(AbstractDataReferenceVector), | public | :: | MemdataRefPtrs | ||||
type(AbstractDataReferenceVector), | public | :: | dataRefPtrs | ||||
type(ServerThreadVector), | public | :: | threads | ||||
type(SimpleCommSplitter), | public | :: | splitter | ||||
type(StringInteger64Map), | public | :: | prefetch_offset | ||||
type(StringInteger64Map), | public | :: | stage_offset |
private function new_MultiCommServer (server_comm, port_name, nwriter_per_node, rc) |
procedure, public :: I_am_NodeRoot | |
procedure, public :: I_am_ServerRoot | |
procedure, public :: add_DataReference | |
procedure, public :: add_connection | |
procedure, public :: am_I_reading_PE | |
procedure, public :: clean_up | |
procedure, public :: clear_DataReference | |
procedure, public :: clear_RequestHandle | |
procedure, public :: create_remote_win | |
procedure, public :: distribute_task | |
procedure, public :: get_AllBacklogIsEmpty | |
procedure, public :: get_DataFromMem | |
procedure, public :: get_DataReference | |
procedure, public :: get_communicator | |
procedure, public :: get_dmessage | |
procedure, public :: get_status | |
procedure, public :: get_writing_PE | |
procedure, public :: init | |
procedure, public :: put_dataToFile => put_DataToFile | |
procedure, public :: receive_output_data | |
procedure, public :: report_profile | |
procedure, public :: set_AllBacklogIsEmpty | |
procedure, public :: set_collective_request | |
procedure, public :: set_status | |
procedure, public :: start | |
procedure, public :: update_status |