UTPipeline.F90 File Reference

Go to the source code of this file.

Modules
module	UTPipeline

Functions/Subroutines
subroutine	UTPipeline::UTPipeline_init (itemSize, maxItems, channelSize, comm, numChannels, procList, logUnit)
subroutine	UTPipeline::UTPipeline_initComm ()
subroutine	UTPipeline::UTPipeline_finalizeComm (doAsyncReturn)
subroutine	UTPipeline::UTPipeline_finalize
subroutine	UTPipeline::UTPipeline_progressRecvComm
subroutine	UTPipeline::utpipe_handleOldRecvMsg ()
subroutine	UTPipeline::UTPipeline_sendFullestChannel
subroutine	UTPipeline::utpipe_postSendMsg (index)
subroutine	UTPipeline::utpipe_postRecvMsg (index)
subroutine	UTPipeline::UTPipeline_progressComm (doFlush)
subroutine	UTPipeline::UTPipeline_progressSendComm ()
subroutine	UTPipeline::UTPipeline_closeSendChannels (isClosing)
subroutine	UTPipeline::utpipe_progressClosePromise ()
subroutine	UTPipeline::UTPipeline_isCommDone (isCommDone)
subroutine	UTPipeline::UTPipeline_isDone (isDone)
subroutine	UTPipeline::UTPipeline_numItems (numItems)
subroutine	UTPipeline::UTPipeline_isEmpty (isEmpty)
subroutine	UTPipeline::UTPipeline_getItems (userArray, userMaxCount, userCount)
subroutine	UTPipeline::utpipe_saveRecvItems (index, isSaved)
subroutine	UTPipeline::UTPipeline_sendItem (item, procID, isHandled)
subroutine	UTPipeline::UTPipeline_iterateItems (readOnlyFn)
subroutine	UTPipeline::Driver_checkMPIErrorCode (errorCode)
subroutine	UTPipeline::Driver_abort (msg)

Variables
integer, parameter	UTPipeline::FLASH_INTEGER = MPI_INTEGER
integer, parameter	UTPipeline::FLASH_REAL = MPI_DOUBLE_PRECISION
real, dimension(:,:,:), allocatable, save	UTPipeline::utpipe_sendBuf
real, dimension(:,:,:), allocatable, save	UTPipeline::utpipe_recvBuf
real, dimension(:,:), allocatable, save	UTPipeline::utpipe_itemBuf
integer, parameter	UTPipeline::utpipe_tag = 1235
integer, dimension(:,:), allocatable, save	UTPipeline::utpipe_recvStatus
integer, dimension(:), allocatable, save	UTPipeline::utpipe_recvRequest
integer, dimension(:), allocatable, save	UTPipeline::utpipe_recvIndex
integer, dimension(:), allocatable, save	UTPipeline::utpipe_recvCount
integer, dimension(:,:), allocatable, save	UTPipeline::utpipe_sendStatus
integer, dimension(:), allocatable, save	UTPipeline::utpipe_sendRequest
integer, dimension(:), allocatable, save	UTPipeline::utpipe_sendIndex
integer, dimension(:), allocatable, save	UTPipeline::utpipe_sendCount
integer, dimension(:), allocatable, save	UTPipeline::utpipe_procList
integer, save	UTPipeline::utpipe_itemCount
integer, save	UTPipeline::utpipe_comm
integer, save	UTPipeline::utpipe_size
integer, save	UTPipeline::utpipe_rank
integer, save	UTPipeline::utpipe_itemSize
integer, save	UTPipeline::utpipe_maxItems
integer, save	UTPipeline::utpipe_channelSize
integer, save	UTPipeline::utpipe_numChannels
logical, save	UTPipeline::utpipe_isSendCommDone
logical, save	UTPipeline::utpipe_isRecvCommDone
logical, save	UTPipeline::utpipe_isInitialized = .false.
logical, save	UTPipeline::utpipe_isCommInitialized = .false.
logical, save	UTPipeline::utpipe_isCommDone = .false.
integer, save	UTPipeline::utpipe_logUnit
logical, save	UTPipeline::utpipe_doLog
integer, dimension(:), allocatable, save	UTPipeline::utpipe_sendState
integer, parameter	UTPipeline::OPEN_STATE = -3000
integer, parameter	UTPipeline::PROMISE_TO_CLOSE_STATE = -4000
integer, parameter	UTPipeline::WAITING_TO_CLOSE_STATE = -5000
integer, parameter	UTPipeline::CLOSE_STATE = -6000