-
Notifications
You must be signed in to change notification settings - Fork 23
/
comm.h
35 lines (29 loc) · 1.15 KB
/
comm.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
#ifndef COMM_H
#define COMM_H
#include "mpi.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "structs.h"
#include "system.h"
#include "sort.h"
extern int my_rank;
extern int np;
//MPI Related Methods
void Transfer_Data(TransData* my_data,Link** sys,int* assignments,UnivVars* GlobalVars);
void Transfer_Data_Finish(TransData* my_data,Link** sys,int* assignments,UnivVars* GlobalVars);
void Exchange_InitState_At_Forced(Link** system,unsigned int N,unsigned int* assignments,short int* getting,unsigned int* res_list,unsigned int res_size,unsigned int** id_to_loc,UnivVars* GlobalVars);
TransData* Initialize_TransData();
void Flush_TransData(TransData* data);
void TransData_Free(TransData* data);
//PostgreSQL Database Methods
ConnData* CreateConnData(char* connectstring);
void ConnData_Free(ConnData* conninfo);
void SwitchDB(ConnData* conninfo,char connectinfo[]);
int ConnectPGDB(ConnData* conninfo);
void DisconnectPGDB(ConnData* conninfo);
int CheckResError(PGresult* res,char* event);
int CheckResState(PGresult* res,short int error_code);
void CheckConnConnection(ConnData* conninfo);
void ShutUp(void *arg, const char *message);
#endif