libs/core/async_mpi/src/mpi_future.cpp
void add_to_request_queue(future_data_ptr data)
        {
            // place this future data request in our queue for handling
            get_request_queue().enqueue(data);
            ++(get_mpi_info().request_queue_size_);

            mpi_debug.debug(debug::str<>("request queued"), get_mpi_info(),
                "request", debug::hex<8>(data->request_));
        }
// used internally to add an MPI_Request to the lockfree queue
// that will be used by the polling routines to check when requests
// have completed
used internally to add an MPI_Request to the lockfree queue
that will be used by the polling routines to check when requests
have completed
used internally to add an MPI_Request to the lockfree queue that will be used by the polling routines to check when requests have completed
void add_to_request_queue(future_data_ptr data)
        {
            get_request_queue().enqueue(data);
            ++(get_mpi_info().request_queue_size_);
            mpi_debug.debug(debug::str<>("request queued"), get_mpi_info(),
                "request", debug::hex<8>(data->request_));
        }
void add_to_request_queue ( future_data_ptr data ) { get_request_queue ( ) . enqueue ( data ) ; ++ ( get_mpi_info ( ) . request_queue_size_ ) ; mpi_debug . debug ( debug :: str < > ( " " ) , get_mpi_info ( ) , " " , debug :: hex < 8 > ( data -> request_ ) ) ; }
used internally to add an MPI_Request to the lockfree queue
that will be used by the polling routines to check when requests
have completed
used internally to add an MPI_Request to the lockfree queue that will be used by the polling routines to check when requests have completed
// place this future data request in our queue for handling