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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
// Start of backends/multicore.h
struct futhark_context_config {
int in_use;
int debugging;
int profiling;
int logging;
char *cache_fname;
int num_tuning_params;
int64_t *tuning_params;
const char** tuning_param_names;
const char** tuning_param_vars;
const char** tuning_param_classes;
// Uniform fields above.
int num_threads;
};
static void backend_context_config_setup(struct futhark_context_config* cfg) {
cfg->num_threads = 0;
}
static void backend_context_config_teardown(struct futhark_context_config* cfg) {
(void)cfg;
}
void futhark_context_config_set_num_threads(struct futhark_context_config *cfg, int n) {
cfg->num_threads = n;
}
int futhark_context_config_set_tuning_param(struct futhark_context_config* cfg, const char *param_name, size_t param_value) {
(void)cfg; (void)param_name; (void)param_value;
return 1;
}
struct futhark_context {
struct futhark_context_config* cfg;
int detail_memory;
int debugging;
int profiling;
int profiling_paused;
int logging;
lock_t lock;
char *error;
lock_t error_lock;
FILE *log;
struct constants *constants;
struct free_list free_list;
struct event_list event_list;
int64_t peak_mem_usage_default;
int64_t cur_mem_usage_default;
struct program* program;
bool program_initialised;
// Uniform fields above.
lock_t event_list_lock;
struct scheduler scheduler;
int total_runs;
long int total_runtime;
int64_t tuning_timing;
int64_t tuning_iter;
};
int backend_context_setup(struct futhark_context* ctx) {
// Initialize rand()
fast_srand(time(0));
int tune_kappa = 0;
double kappa = 5.1f * 1000;
if (tune_kappa) {
if (determine_kappa(&kappa) != 0) {
ctx->error = strdup("Failed to determine kappa.");
return 1;
}
}
if (scheduler_init(&ctx->scheduler,
ctx->cfg->num_threads > 0 ?
ctx->cfg->num_threads : num_processors(),
kappa) != 0) {
ctx->error = strdup("Failed to initialise scheduler.");
return 1;
}
create_lock(&ctx->event_list_lock);
return 0;
}
void backend_context_teardown(struct futhark_context* ctx) {
(void)scheduler_destroy(&ctx->scheduler);
free_lock(&ctx->event_list_lock);
}
int futhark_context_sync(struct futhark_context* ctx) {
(void)ctx;
return 0;
}
struct mc_event {
// Time in microseconds.
uint64_t bef, aft;
};
static struct mc_event* mc_event_new(struct futhark_context* ctx) {
if (ctx->profiling && !ctx->profiling_paused) {
struct mc_event* e = malloc(sizeof(struct mc_event));
return e;
} else {
return NULL;
}
}
static int mc_event_report(struct str_builder* sb, struct mc_event* e) {
float ms = e->aft - e->bef;
str_builder(sb, ",\"duration\":%f", ms);
free(e);
return 0;
}
// End of backends/multicore.h
|
