pFIO_ServerThreadMod Module


Uses

Used by

  • module~~pfio_serverthreadmod~~UsedByGraph module~pfio_serverthreadmod pFIO_ServerThreadMod module~mockserverthreadmod MockServerThreadMod module~mockserverthreadmod->module~pfio_serverthreadmod module~pfio pFIO module~pfio->module~pfio_serverthreadmod module~pfio_baseservermod pFIO_BaseServerMod module~pfio_baseservermod->module~pfio_serverthreadmod module~pfio_directoryservicemod pFIO_DirectoryServiceMod module~pfio_directoryservicemod->module~pfio_serverthreadmod module~pfio_mpiservermod pFIO_MpiServerMod module~pfio_mpiservermod->module~pfio_serverthreadmod module~pfio_multicommservermod pFIO_MultiCommServerMod module~pfio_multicommservermod->module~pfio_serverthreadmod module~pfio_multigroupservermod pFIO_MultiGroupServerMod module~pfio_multigroupservermod->module~pfio_serverthreadmod module~pfio_multilayerservermod pFIO_MultiLayerServerMod module~pfio_multilayerservermod->module~pfio_serverthreadmod module~pfio_openmpservermod pFIO_OpenMPServerMod module~pfio_openmpservermod->module~pfio_serverthreadmod module~pfio_serverthreadvectormod pFIO_ServerThreadVectorMod module~pfio_serverthreadvectormod->module~pfio_serverthreadmod module~test_serverthread Test_ServerThread module~test_serverthread->module~pfio_serverthreadmod module~test_simplesocket test_SimpleSocket module~test_simplesocket->module~pfio_serverthreadmod

Interfaces

public interface ServerThread

  • private function new_ServerThread(sckt, server, rc) result(s)

    Arguments

    Type IntentOptional Attributes Name
    class(AbstractSocket), intent(in), target :: sckt
    class(AbstractServer), intent(in), optional, target :: server
    integer, intent(out), optional :: rc

    Return Value type(ServerThread)


Derived Types

type, public, extends(BaseThread) ::  ServerThread

Components

Type Visibility Attributes Name Initial
logical, public :: terminate = .false.
type(HistoryCollectionVector), public :: hist_collections
type(MessageVector), public :: request_backlog

Constructor

private function new_ServerThread (sckt, server, rc)

Type-Bound Procedures

procedure, public :: clear_RequestHandle
procedure, public :: clear_backlog
procedure, public :: clear_hist_collections
procedure, public :: clear_subarray
procedure, public :: clear_terminate
procedure, public :: do_terminate
procedure, public :: erase_RequestHandle
procedure, public :: get_DataFromFile
procedure, public :: get_DataFromMem
procedure, public :: get_RequestHandle
procedure, public :: get_connection
procedure, public :: get_hist_collection
procedure, public :: handle
procedure, public :: handle_AddReadDataCollection
procedure, public :: handle_AddWriteDataCollection
procedure, public :: handle_CollectivePrefetchData
procedure, public :: handle_CollectiveStageData
procedure, public :: handle_Done
procedure, public :: handle_Done_collective_prefetch
procedure, public :: handle_Done_collective_stage
procedure, public :: handle_Done_prefetch
procedure, public :: handle_Done_stage
procedure, public :: handle_HandShake
procedure, public :: handle_Id
procedure, public :: handle_ModifyMetadata
procedure, public :: handle_PrefetchData
procedure, public :: handle_ReplaceMetadata
procedure, public :: handle_StageData
procedure, public :: handle_Terminate
generic, public :: handle_cmd => handle_Done
generic, public :: handle_cmd => handle_Done_prefetch
generic, public :: handle_cmd => handle_Done_collective_prefetch
generic, public :: handle_cmd => handle_Done_stage
generic, public :: handle_cmd => handle_Done_collective_stage
generic, public :: handle_cmd => handle_AddReadDataCollection
generic, public :: handle_cmd => handle_AddWriteDataCollection
generic, public :: handle_cmd => handle_Id
generic, public :: handle_cmd => handle_PrefetchData
generic, public :: handle_cmd => handle_CollectivePrefetchData
generic, public :: handle_cmd => handle_StageData
generic, public :: handle_cmd => handle_CollectiveStageData
generic, public :: handle_cmd => handle_Terminate
generic, public :: handle_cmd => handle_ModifyMetadata
generic, public :: handle_cmd => handle_ReplaceMetadata
generic, public :: handle_cmd => handle_HandShake
procedure, public :: init
procedure, public :: insert_RequestHandle
procedure, public :: isEmpty_RequestHandle
procedure, public :: put_DataToFile
procedure, public :: read_and_gather
procedure, public :: read_and_share
procedure, public :: receive_output_data
procedure, public :: run
procedure, public :: set_collective_request
procedure, public :: set_connection
procedure, public :: set_rank
procedure, public :: set_terminate