malleabilityDataStructures.h 1.71 KB
Newer Older
1
2
3
4
5
6
#ifndef MALLEABILITY_DATA_STRUCTURES_H
#define MALLEABILITY_DATA_STRUCTURES_H

/*
 * Shows available data structures for inner ussage.
 */
7
8
#include <stdlib.h>
#include <stdio.h>
9
#include <mpi.h>
10
#include <pthread.h>
11
#include "malleabilityStates.h"
12

13
14
#define DEBUG_FUNC(debug_string, rank, numP) printf("MaM [P%d/%d]: %s -- %s:%s:%d\n", rank, numP, debug_string, __FILE__, __func__, __LINE__)

15
16
17
18
19
20
21
22
23
24
25
26
27
/* --- TIME CAPTURE STRUCTURE --- */
typedef struct {
  // Spawn, Sync and Async time
  double spawn_start, spawn_time;
  double sync_start,  sync_end;
  double async_start, async_end;
  double malleability_start, malleability_end;

  MPI_Datatype times_type;
} malleability_times_t;

/* --- GLOBAL STRUCTURES --- */
typedef struct {
28
29
30
31
32
  unsigned int spawn_method;
  unsigned int spawn_dist;
  unsigned int spawn_strategies;
  unsigned int red_method;
  unsigned int red_strategies;
33
34
35
36

  malleability_times_t *times;
} malleability_config_t;

iker_martin's avatar
iker_martin committed
37
typedef struct { 
38
39
  int myId, numP, numC, zombie;
  int root, root_collectives;
iker_martin's avatar
iker_martin committed
40
  int num_parents, root_parents;
41
  pthread_t async_thread;
42
  MPI_Comm comm, thread_comm, original_comm;
43
44
  MPI_Comm intercomm, tmp_comm;
  MPI_Comm *user_comm;
45
  MPI_Datatype struct_type;
46
47
48
49

  // Specific vars for Wait_targets strat
  int wait_targets_posted;
  MPI_Request wait_targets;
50
51
52
  
  char *name_exec, *nodelist;
  int num_cpus, num_nodes, nodelist_len;
53
  int internode_group;
54
55
56
} malleability_t;

/* --- VARIABLES --- */
57
58
extern malleability_config_t *mall_conf;
extern malleability_t *mall;
59
extern int state;
60

61
62
63
/* --- FUNCTIONS --- */
void MAM_Def_main_datatype();
void MAM_Free_main_datatype();
64
void MAM_Comm_main_structures(MPI_Comm comm, int rootBcast);
65

66
67
void MAM_print_comms_state();
void MAM_comms_update(MPI_Comm comm);
68

69
#endif