pcd_mpi/pcs_mpi_intf.c File Reference

#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <math.h>
#include <mpi.h>
#include <assert.h>
#include <stdint.h>
#include "../include/pch_intf.h"
#include "../include/uth_log.h"

Include dependency graph for pcs_mpi_intf.c:

Classes
struct	pct_buffer_struct
Defines
#define	MAX_NR_BUFFERS   1
Functions
int	pcr_is_parallel_initialized (void)
int	pcr_my_proc_rank (void)
int	pcr_my_proc_id (void)
int	pcr_nr_proc (void)
int	pcr_init_parallel (int *argc, char **argv, char *Work_dir, char *interactive_output_name, FILE **interactive_output_p, int *Nr_pr, int *My_id)
int	pcr_print_master ()
int	pcr_send_buffer_open (int Message_id, int Buffer_size)
int	pcr_buffer_pack_int (const int Message_id, const int Buffer_id, const int Nr_num, const int *Numbers)
int	pcr_buffer_pack_double (const int Message_id, const int Buffer_id, const int Nr_num, const double *Numbers)
int	pcr_buffer_pack_char (const int Message_id, const int Buffer_id, const int Nr_num, const char *Numbers)
int	pcr_buffer_send (int Message_id, int Buffer_id, int Dest_proc)
int	pcr_buffer_bcast (int Message_id, int Buffer_id, int Sender_proc)
int	pcr_buffer_receive (int Message_id, int Sender_proc, int Buffer_size)
int	pcr_buffer_unpack_int (int Message_id, int Buffer_id, int Nr_num, int *Numbers)
int	pcr_buffer_unpack_double (int Message_id, int Buffer_id, int Nr_num, double *Numbers)
int	pcr_buffer_unpack_char (int Message_id, int Buffer_id, int Nr_num, char *Numbers)
int	pcr_recv_buffer_close (int Message_id, int Buffer_id)
int	pcr_send_int (const int Dest_proc_id, const int Message_id, const int Nr_num, const int *Numbers)
int	pcr_send_double (const int Dest_proc_id, const int Message_id, const int Nr_num, const double *Numbers)
int	pcr_receive_int (int Sender_proc_id, int Message_id, int Nr_num, int *Numbers)
int	pcr_receive_double (int Sender_proc_id, int Message_id, int Nr_num, double *Numbers)
int	pcr_send_long (int Dest_proc_id, int Message_id, int Nr_num, long int *Numbers)
int	pcr_receive_long (int Sender_proc_id, int Message_id, int Nr_num, long int *Numbers)
int	pcr_send_bytes (const int Dest_proc_id, const int Message_id, const int Nr_bytes, const uint8_t *Bytes)
int	pcr_receive_bytes (int Sender_proc_id, int Message_id, int Nr_bytes, uint8_t *Bytes)
int	pcr_bcast_double (int Sender_proc_id, int Nr_num, double *Numbers)
int	pcr_bcast_int (int Sender_proc_id, int Nr_num, int *Numbers)
int	pcr_bcast_char (int Sender_proc_id, int Nr_num, char *Numbers)
int	pcr_allreduce_sum_int (const int Nr_num, const int *Numbers, int *Numbers_reduced)
int	pcr_allreduce_sum_double (const int Nr_num, const double *Numbers, double *Numbers_reduced)
int	pcr_allreduce_max_int (const int Nr_num, const int *Numbers, int *Numbers_reduced)
int	pcr_allreduce_max_double (int Nr_num, double *Numbers, double *Numbers_reduced)
int	pcr_exit_parallel ()
int	pcr_barrier (void)
int	pcr_allgather_int (const int send_values[], const int n_send_values, int gathered_values[], int n_gathered_values)
Variables
const int	PCC_ANY_PROC = -1
const int	PCC_USE_CURRENT_BUFFER = -1
const int	PCC_MASTER_PROC_ID = 1
FILE *	output_stream
const int	PCC_DEFAULT_BUFFER_SIZE = 10000000
void *	MPI_buffer
int	MPI_buffer_size
pct_buffer_struct	buffer_array [MAX_NR_BUFFERS]
int	pcv_nr_buffers = 0
int	pcv_my_rank
int	pcv_nr_proc
int	pcv_my_proc_id

---

Define Documentation

#define MAX_NR_BUFFERS   1

---

Function Documentation

int pcr_my_proc_rank

(

void

)

int pcr_receive_long	(	int	Sender_proc_id,
		int	Message_id,
		int	Nr_num,
		long int *	Numbers
	)

int pcr_send_long	(	int	Dest_proc_id,
		int	Message_id,
		int	Nr_num,
		long int *	Numbers
	)

---

Variable Documentation

pct_buffer_struct buffer_array[MAX_NR_BUFFERS]

void* MPI_buffer

int MPI_buffer_size

FILE* output_stream

int pcv_my_rank

int pcv_nr_buffers = 0