"Results/DataRedist/Synch/config56.ini" did not exist on "30685e95cb2e1d56f3dd616e4218df64b785fd40"
malleabilityDataStructures.h 1.98 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
/* --- PHYSICAL DIST STRUCTURE --- */
16
17
struct physical_dist {
  int target_qty, already_created;
18
  int info_type;
19
20
};

21
/* --- SPAWN STRUCTURE --- */
22
23
24
25
26
27
28
29
30
31
32
33
34
typedef struct {
  int myId, root, root_parents;
  int spawn_qty, initial_qty, target_qty;
  int already_created;
  int spawn_method, spawn_is_single, spawn_is_async;
  char *cmd; //Executable name
  MPI_Info mapping;
  MPI_Datatype dtype;
  struct physical_dist dist; // Used to create mapping var

  MPI_Comm comm, returned_comm;
} Spawn_data;

35
36
37
38
39
40
41
42
43
44
45
46
47
/* --- 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 {
48
49
50
51
52
  unsigned int spawn_method;
  unsigned int spawn_dist;
  unsigned int spawn_strategies;
  unsigned int red_method;
  unsigned int red_strategies;
53
54
55
56
57

  malleability_times_t *times;
} malleability_config_t;

typedef struct { //FIXME numC_spawned no se esta usando
58
  int myId, numP, numC, root, root_parents, zombie;
59
  int is_intercomm;
60
61
  pthread_t async_thread;
  MPI_Comm comm, thread_comm;
62
63
  MPI_Comm intercomm, tmp_comm;
  MPI_Comm *user_comm;
64
  MPI_Datatype struct_type;
65
66
67
68
69
70
71
72
  
  char *name_exec, *nodelist;
  int num_cpus, num_nodes, nodelist_len;
} malleability_t;

/* --- VARIABLES --- */
malleability_config_t *mall_conf;
malleability_t *mall;
73
extern int state;
74

75
76
77
78
79
80
/* --- FUNCTIONS --- */
void MAM_Def_main_datatype();
void MAM_Free_main_datatype();
void MAM_Comm_main_structures(int rootBcast);


81
#endif