dm_mqueue_util Module

Utility procedures for message queue access.


Uses

  • module~~dm_mqueue_util~~UsesGraph module~dm_mqueue_util dm_mqueue_util module~dm_error dm_error module~dm_mqueue_util->module~dm_error module~dm_mqueue dm_mqueue module~dm_mqueue_util->module~dm_mqueue module~dm_type dm_type module~dm_mqueue_util->module~dm_type module~dm_util dm_util module~dm_mqueue_util->module~dm_util module~dm_ascii dm_ascii module~dm_error->module~dm_ascii module~dm_kind dm_kind module~dm_error->module~dm_kind module~dm_mqueue->module~dm_error module~dm_mqueue->module~dm_type module~dm_id dm_id module~dm_mqueue->module~dm_id module~dm_mqueue->module~dm_kind module~dm_log dm_log module~dm_mqueue->module~dm_log module~dm_observ dm_observ module~dm_mqueue->module~dm_observ unix unix module~dm_mqueue->unix module~dm_util->module~dm_error module~dm_util->module~dm_kind iso_fortran_env iso_fortran_env module~dm_kind->iso_fortran_env module~dm_log->module~dm_error module~dm_log->module~dm_id module~dm_log->module~dm_kind module~dm_log->module~dm_observ module~dm_node dm_node module~dm_log->module~dm_node module~dm_sensor dm_sensor module~dm_log->module~dm_sensor module~dm_target dm_target module~dm_log->module~dm_target module~dm_time dm_time module~dm_log->module~dm_time module~dm_uuid dm_uuid module~dm_log->module~dm_uuid module~dm_observ->module~dm_error module~dm_observ->module~dm_util module~dm_observ->module~dm_id module~dm_observ->module~dm_kind module~dm_observ->module~dm_node module~dm_request dm_request module~dm_observ->module~dm_request module~dm_response dm_response module~dm_observ->module~dm_response module~dm_observ->module~dm_sensor module~dm_observ->module~dm_target module~dm_observ->module~dm_time module~dm_observ->module~dm_uuid module~dm_node->module~dm_id module~dm_node->module~dm_kind module~dm_request->module~dm_error module~dm_request->module~dm_util module~dm_request->module~dm_id module~dm_request->module~dm_kind module~dm_request->module~dm_response module~dm_request->module~dm_time module~dm_string dm_string module~dm_request->module~dm_string module~dm_response->module~dm_error module~dm_response->module~dm_util module~dm_response->module~dm_id module~dm_response->module~dm_kind module~dm_sensor->module~dm_id module~dm_sensor->module~dm_kind module~dm_sensor->module~dm_node module~dm_target->module~dm_util module~dm_target->module~dm_id module~dm_target->module~dm_kind module~dm_time->module~dm_error module~dm_time->module~dm_util module~dm_time->module~dm_kind module~dm_string->module~dm_error module~dm_string->module~dm_kind

Used by

  • module~~dm_mqueue_util~~UsedByGraph module~dm_mqueue_util dm_mqueue_util module~dmpack dmpack module~dmpack->module~dm_mqueue_util

Interfaces

public interface dm_mqueue_forward

Generic function to forward derived types via message queue.

  • private function mqueue_forward_observ(observ, name, blocking, allow_self, verbose) result(rc)

    Forwards given observation to next receiver. This function creates log messages, unless verbose is passed and .false..

    If name is passed and equals the next receiver, the receiver will be skipped, unless allow_self is .true.. This behaviour prevents the observation from being forwarded back to the sender if the sender is the next receiver in the list.

    Arguments

    Type IntentOptional Attributes Name
    type(observ_type), intent(inout) :: observ

    Observation to forward.
    character(len=*), intent(in), optional :: name

    App name.
    logical, intent(in), optional :: blocking

    Blocking message queue access.
    logical, intent(in), optional :: allow_self

    Allow forwarding to name.
    logical, intent(in), optional :: verbose

    Create log messages (enabled by default).

    Return Value integer