|
|
@@ -70,7 +70,7 @@ void copy_data_and_param(void)
|
|
|
{
|
|
|
printf("%s:%d trace\n", __FILE__, __LINE__);
|
|
|
//copying datas
|
|
|
- STARPU_MALLOC(starpu_top_datas, starpu_top_data_cpt*sizeof(struct starpu_top_data*));
|
|
|
+ _STARPU_MALLOC(starpu_top_datas, starpu_top_data_cpt*sizeof(struct starpu_top_data*));
|
|
|
struct starpu_top_data* cur = starpu_top_first_data;
|
|
|
unsigned int i = 0;
|
|
|
for(i = 0; i < starpu_top_data_cpt; i++)
|
|
|
@@ -79,7 +79,7 @@ void copy_data_and_param(void)
|
|
|
cur = cur->next;
|
|
|
}
|
|
|
//copying params
|
|
|
- STARPU_MALLOC(starpu_top_params, starpu_top_param_cpt*sizeof(struct starpu_top_param*));
|
|
|
+ _STARPU_MALLOC(starpu_top_params, starpu_top_param_cpt*sizeof(struct starpu_top_param*));
|
|
|
struct starpu_top_param* cur2 = starpu_top_first_param;
|
|
|
for(i = 0; i < starpu_top_param_cpt; i++)
|
|
|
{
|
|
|
@@ -118,14 +118,14 @@ static void starpu_top_get_device_type(int id, char* type)
|
|
|
static void starpu_top_send_devices_info(void)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 5*sizeof(char));
|
|
|
+ _STARPU_MALLOC(message, 5*sizeof(char));
|
|
|
snprintf(message,5,"DEV\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
|
|
|
unsigned int i;
|
|
|
for(i=0;i<starpu_worker_get_count();i++)
|
|
|
{
|
|
|
- STARPU_MALLOC(message, sizeof(char)*128);
|
|
|
+ _STARPU_MALLOC(message, sizeof(char)*128);
|
|
|
char dev_type[10];
|
|
|
char dev_name[64];
|
|
|
starpu_top_get_device_type(i,dev_type);
|
|
|
@@ -134,7 +134,7 @@ static void starpu_top_send_devices_info(void)
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
}
|
|
|
|
|
|
- STARPU_MALLOC(message, 6*sizeof(char));
|
|
|
+ _STARPU_MALLOC(message, 6*sizeof(char));
|
|
|
snprintf(message,6,"/DEV\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
}
|
|
|
@@ -160,22 +160,22 @@ void starpu_top_init_and_wait(const char* server_name)
|
|
|
|
|
|
//sending server information (report to protocol)
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, strlen("SERVERINFO\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("SERVERINFO\n")+1);
|
|
|
sprintf(message, "%s", "SERVERINFO\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
- STARPU_MALLOC(message, strlen(server_name)+2);
|
|
|
+ _STARPU_MALLOC(message, strlen(server_name)+2);
|
|
|
sprintf(message, "%s\n", server_name);
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
- STARPU_MALLOC(message, 25);
|
|
|
+ _STARPU_MALLOC(message, 25);
|
|
|
sprintf(message, "%llu\n", current_timestamp());
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
- STARPU_MALLOC(message, strlen("/SERVERINFO\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("/SERVERINFO\n")+1);
|
|
|
sprintf(message,"%s", "/SERVERINFO\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
|
|
|
|
|
|
//sending data list
|
|
|
- STARPU_MALLOC(message, strlen("DATA\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("DATA\n")+1);
|
|
|
sprintf(message, "%s", "DATA\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
struct starpu_top_data * cur_data = starpu_top_first_data;
|
|
|
@@ -184,12 +184,12 @@ void starpu_top_init_and_wait(const char* server_name)
|
|
|
_starpu_top_message_add(_starpu_top_mt,message_for_topdata_init(cur_data));
|
|
|
cur_data = cur_data->next;
|
|
|
}
|
|
|
- STARPU_MALLOC(message, strlen("/DATA\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("/DATA\n")+1);
|
|
|
sprintf(message, "%s", "/DATA\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
|
|
|
//sending parameter list
|
|
|
- STARPU_MALLOC(message, strlen("PARAMS\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("PARAMS\n")+1);
|
|
|
sprintf(message, "%s", "PARAMS\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
struct starpu_top_param * cur_param = starpu_top_first_param;
|
|
|
@@ -200,7 +200,7 @@ void starpu_top_init_and_wait(const char* server_name)
|
|
|
cur_param = cur_param->next;
|
|
|
}
|
|
|
printf("%s:%d parameters sended\n", __FILE__, __LINE__);
|
|
|
- STARPU_MALLOC(message, strlen("/PARAMS\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("/PARAMS\n")+1);
|
|
|
sprintf(message, "%s", "/PARAMS\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
|
|
|
@@ -213,7 +213,7 @@ void starpu_top_init_and_wait(const char* server_name)
|
|
|
copy_data_and_param();
|
|
|
|
|
|
//sending READY message
|
|
|
- STARPU_MALLOC(message, strlen("READY\n")+1);
|
|
|
+ _STARPU_MALLOC(message, strlen("READY\n")+1);
|
|
|
sprintf(message, "%s", "READY\n");
|
|
|
_starpu_top_message_add(_starpu_top_mt,message);
|
|
|
|
|
|
@@ -265,7 +265,7 @@ struct starpu_top_data * starpu_top_add_data_boolean(const char* data_name,
|
|
|
int active)
|
|
|
{
|
|
|
struct starpu_top_data *data;
|
|
|
- STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
+ _STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
data->id = starpu_top_data_cpt++;
|
|
|
data->name = data_name;
|
|
|
data->type = STARPU_TOP_DATA_BOOLEAN;
|
|
|
@@ -283,7 +283,7 @@ struct starpu_top_data * starpu_top_add_data_integer(const char* data_name,
|
|
|
int active)
|
|
|
{
|
|
|
struct starpu_top_data *data;
|
|
|
- STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
+ _STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
data->id = starpu_top_data_cpt++;
|
|
|
data->name = data_name;
|
|
|
data->type = STARPU_TOP_DATA_INTEGER;
|
|
|
@@ -303,7 +303,7 @@ struct starpu_top_data* starpu_top_add_data_float(const char* data_name,
|
|
|
int active)
|
|
|
{
|
|
|
struct starpu_top_data *data;
|
|
|
- STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
+ _STARPU_MALLOC(data, sizeof(struct starpu_top_data));
|
|
|
data->id = starpu_top_data_cpt++;
|
|
|
data->name = data_name;
|
|
|
data->type = STARPU_TOP_DATA_FLOAT;
|
|
|
@@ -320,7 +320,7 @@ struct starpu_top_data* starpu_top_add_data_float(const char* data_name,
|
|
|
char *message_for_topdata_init(struct starpu_top_data* data)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
+ _STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
switch(data->type)
|
|
|
{
|
|
|
case STARPU_TOP_DATA_BOOLEAN:
|
|
|
@@ -360,7 +360,7 @@ char *message_for_topparam_init(struct starpu_top_param* param)
|
|
|
switch(param->type)
|
|
|
{
|
|
|
case STARPU_TOP_PARAM_BOOLEAN:
|
|
|
- STARPU_MALLOC(message, 256);
|
|
|
+ _STARPU_MALLOC(message, 256);
|
|
|
sprintf(message,
|
|
|
"BOOL;%u;%s;%d\n",
|
|
|
param->id,
|
|
|
@@ -368,7 +368,7 @@ char *message_for_topparam_init(struct starpu_top_param* param)
|
|
|
(*(int*)(param->value)) ? 1 : 0);
|
|
|
break;
|
|
|
case STARPU_TOP_PARAM_INTEGER:
|
|
|
- STARPU_MALLOC(message, 256);
|
|
|
+ _STARPU_MALLOC(message, 256);
|
|
|
sprintf(message,
|
|
|
"INT;%u;%s;%d;%d;%d\n",param->id,
|
|
|
param->name,
|
|
|
@@ -377,7 +377,7 @@ char *message_for_topparam_init(struct starpu_top_param* param)
|
|
|
*(int*)(param->value));
|
|
|
break;
|
|
|
case STARPU_TOP_PARAM_FLOAT:
|
|
|
- STARPU_MALLOC(message, 256);
|
|
|
+ _STARPU_MALLOC(message, 256);
|
|
|
sprintf(message,
|
|
|
"FLOAT;%u;%s;%f;%f;%f\n",
|
|
|
param->id,
|
|
|
@@ -392,7 +392,7 @@ char *message_for_topparam_init(struct starpu_top_param* param)
|
|
|
{
|
|
|
length += strlen(param->enum_values[i])+1;
|
|
|
}
|
|
|
- STARPU_MALLOC(message, 256+length);
|
|
|
+ _STARPU_MALLOC(message, 256+length);
|
|
|
sprintf(message,
|
|
|
"ENUM;%u;%s;",
|
|
|
param->id,
|
|
|
@@ -438,7 +438,7 @@ struct starpu_top_param* starpu_top_register_parameter_boolean(const char* param
|
|
|
{
|
|
|
STARPU_ASSERT(!_starpu_top_status_get());
|
|
|
struct starpu_top_param *param;
|
|
|
- STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
+ _STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
param->callback = callback;
|
|
|
param->name = param_name;
|
|
|
param->id = starpu_top_param_cpt++;
|
|
|
@@ -459,7 +459,7 @@ struct starpu_top_param* starpu_top_register_parameter_integer(const char* param
|
|
|
{
|
|
|
STARPU_ASSERT(!_starpu_top_status_get());
|
|
|
struct starpu_top_param *param;
|
|
|
- STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
+ _STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
param->callback = callback;
|
|
|
param->name = param_name;
|
|
|
param->id = starpu_top_param_cpt++;
|
|
|
@@ -482,7 +482,7 @@ struct starpu_top_param* starpu_top_register_parameter_float(const char* param_n
|
|
|
{
|
|
|
STARPU_ASSERT(!_starpu_top_status_get());
|
|
|
struct starpu_top_param *param;
|
|
|
- STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
+ _STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
param->callback = callback;
|
|
|
param->name = param_name;
|
|
|
param->id = starpu_top_param_cpt++;
|
|
|
@@ -505,7 +505,7 @@ struct starpu_top_param* starpu_top_register_parameter_enum(const char* param_na
|
|
|
{
|
|
|
STARPU_ASSERT(!_starpu_top_status_get());
|
|
|
struct starpu_top_param *param;
|
|
|
- STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
+ _STARPU_MALLOC(param, sizeof(struct starpu_top_param));
|
|
|
param->callback = callback;
|
|
|
param->name = param_name;
|
|
|
param->id = starpu_top_param_cpt++;
|
|
|
@@ -530,7 +530,7 @@ void starpu_top_update_data_boolean(const struct starpu_top_data* data, int valu
|
|
|
if(data->active)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
+ _STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
sprintf(message,
|
|
|
"U;%u;%d;%llu\n",
|
|
|
data->id,
|
|
|
@@ -547,7 +547,7 @@ void starpu_top_update_data_integer(const struct starpu_top_data* data, int valu
|
|
|
if(data->active)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
+ _STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
sprintf(message,
|
|
|
"U;%u;%d;%llu\n",
|
|
|
data->id,
|
|
|
@@ -564,7 +564,7 @@ void starpu_top_update_data_float(const struct starpu_top_data* data, double val
|
|
|
if(data->active)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
+ _STARPU_MALLOC(message, 256+strlen(data->name));
|
|
|
sprintf(message,
|
|
|
"U;%u;%f;%llu\n",
|
|
|
data->id, value,
|
|
|
@@ -578,7 +578,7 @@ void starpu_top_update_parameter(const struct starpu_top_param* param)
|
|
|
if (!_starpu_top_status_get())
|
|
|
return;
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, 50);
|
|
|
+ _STARPU_MALLOC(message, 50);
|
|
|
|
|
|
switch(param->type)
|
|
|
{
|
|
|
@@ -614,7 +614,7 @@ void starpu_top_debug_log(const char* debug_message)
|
|
|
{
|
|
|
//length can be up to strlen*2, if message contains only unwanted chars
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, strlen(debug_message)*2+16);
|
|
|
+ _STARPU_MALLOC(message, strlen(debug_message)*2+16);
|
|
|
sprintf(message,"MESSAGE;");
|
|
|
|
|
|
//escape unwanted char : ; and \n
|
|
|
@@ -643,7 +643,7 @@ void starpu_top_debug_lock(const char* debug_message)
|
|
|
if(starpu_top_debug_on)
|
|
|
{
|
|
|
char *message;
|
|
|
- STARPU_MALLOC(message, strlen(debug_message)*2+16);
|
|
|
+ _STARPU_MALLOC(message, strlen(debug_message)*2+16);
|
|
|
sprintf(message,"LOCK;");
|
|
|
char* cur = message+5;
|
|
|
while(*debug_message!='\0')
|
|
|
@@ -778,7 +778,7 @@ void starpu_top_change_debug_mode(const char*message)
|
|
|
}
|
|
|
|
|
|
char *m;
|
|
|
- STARPU_MALLOC(m, strlen(message)+1);
|
|
|
+ _STARPU_MALLOC(m, strlen(message)+1);
|
|
|
sprintf(m,"%s",message);
|
|
|
_starpu_top_message_add(_starpu_top_mt,m);
|
|
|
}
|