if(i==0) {
//The fisrt node is the tracker
arguments_tracker = xbt_malloc0(sizeof(char*) * 2);
- arguments_tracker[0] = bprintf("tracker");
+ arguments_tracker[0] = xbt_strdup("tracker");
arguments_tracker[1] = bprintf("%f", tracker_deadline);
MSG_process_create_with_arguments("tracker", tracker, NULL, host, 2, arguments_tracker);
} else {
//Other nodes are peers
int argument_size;
arguments_peer = xbt_malloc0(sizeof(char*) * 4);
- arguments_peer[0] = bprintf("peer");
+ arguments_peer[0] = xbt_strdup("peer");
arguments_peer[1] = bprintf("%d", i);
arguments_peer[2] = bprintf("%f", peer_deadline);
//The first peers will be seeders
if(seed_count > 0) {
seed_count--;
- arguments_peer[3] = bprintf("1");
+ arguments_peer[3] = xbt_strdup("1");
argument_size = 4;
} else {
//Other ars leechers
msg_file_t file = NULL;
s_msg_stat_t stat;
void *ptr = NULL;
- char* mount = bprintf("/home");
+ char* mount = xbt_strdup("/home");
double read,write;
if(!strcmp(MSG_process_get_name(MSG_process_self()),"0"))
msg_file_t file = NULL;
s_msg_stat_t stat;
void *ptr = NULL;
- char* mount = bprintf("/home");
+ char* mount = xbt_strdup("/home");
double write;
// First open
MSG_function_register("host", host);
unsigned long nb_hosts = xbt_dynar_length(hosts);
XBT_INFO("Number of host '%lu'",nb_hosts);
- char* name_host = bprintf("0");
+ char* name_host = xbt_strdup("0");
MSG_process_create( name_host, host, NULL, xbt_dynar_get_as(hosts,0,msg_host_t) );
free(name_host);
{
int my_pid = MSG_process_get_PID(MSG_process_self());
- char *my_mailbox = bprintf("%s", argv[1]);
+ char *my_mailbox = xbt_strdup(argv[1]);
msg_task_t grant = NULL, release = NULL;
int client(int argc, char *argv[])
{
int my_pid = MSG_process_get_PID(MSG_process_self());
- char *my_mailbox = bprintf("%s", argv[1]);
+ char *my_mailbox = xbt_strdup(argv[1]);
const char* kind;
while(1){
jxbt_throw_host_failure(env,NULL);
break;
default:
- jxbt_throw_native(env,bprintf("communication failed"));
+ jxbt_throw_native(env,xbt_strdup("communication failed"));
}
}
rv = MSG_main();
XBT_DEBUG("Done running MSG_MAIN");
jxbt_check_res("MSG_main()", rv, MSG_OK,
- bprintf
- ("unexpected error : MSG_main() failed .. please report this bug "));
+ xbt_strdup("unexpected error : MSG_main() failed .. please report this bug "));
XBT_INFO("MSG_main finished; Cleaning up the simulation...");
/* Cleanup java hosts */
if (context->iwannadie) {
context->iwannadie = 0;
JNIEnv *env = get_current_thread_env();
- jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", bprintf("Process killed :)"));
+ jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", xbt_strdup("Process killed :)"));
THROWF(cancel_error, 0, "process cancelled");
}
else {
smx_ctx_java_t ctx_java = (smx_ctx_java_t)context;
/* I am the current process and I am dying */
if (context->iwannadie) {
- context->iwannadie = 0;
- JNIEnv *env = get_current_thread_env();
- jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", bprintf("Process killed :)"));
- THROWF(cancel_error, 0, "process cancelled");
- }
- else {
+ context->iwannadie = 0;
+ JNIEnv *env = get_current_thread_env();
+ jxbt_throw_by_name(env, "org/simgrid/msg/ProcessKilledError", xbt_strdup("Process killed :)"));
+ THROWF(cancel_error, 0, "process cancelled");
+ } else {
smx_ctx_base_stop(context);
/* detach the thread and kills it */
JNIEnv *env = ctx_java->jenv;
/* Clean Simulator data */
if (xbt_swag_size(host->process_list) != 0) {
- char *msg =
- bprintf("Shutting down host, but it's not empty:");
+ char *msg = xbt_strdup("Shutting down host, but it's not empty:");
char *tmp;
smx_process_t process = NULL;
this_prefix = bprintf("%s \\_ ", prefix);
child_prefix = bprintf("%s | ", prefix);
} else {
- this_prefix = bprintf("%s", prefix);
- child_prefix = bprintf("%s", prefix);
+ this_prefix = xbt_strdup(prefix);
+ child_prefix = xbt_strdup(prefix);
}
dynar = xbt_dynar_new(sizeof(xbt_log_category_t), NULL);