X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/6e9085979401423afcde6d001562b6ffd23021e8..3d27a1e82ea26521deee4ab0bab6543ab4339da9:/src/simix/smx_user.c diff --git a/src/simix/smx_user.c b/src/simix/smx_user.c index dae8115567..7c39d30260 100644 --- a/src/simix/smx_user.c +++ b/src/simix/smx_user.c @@ -9,12 +9,12 @@ XBT_LOG_EXTERNAL_DEFAULT_CATEGORY(simix); */ smx_host_t SIMIX_req_host_get_by_name(const char *name) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_BY_NAME; - req.host_get_by_name.name = name; - SIMIX_request_push(&req); - return req.host_get_by_name.result; + req->call = REQ_HOST_GET_BY_NAME; + req->host_get_by_name.name = name; + SIMIX_request_push(); + return req->host_get_by_name.result; } /** @@ -25,12 +25,12 @@ smx_host_t SIMIX_req_host_get_by_name(const char *name) */ const char* SIMIX_req_host_get_name(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_NAME; - req.host_get_name.host = host; - SIMIX_request_push(&req); - return req.host_get_name.result; + req->call = REQ_HOST_GET_NAME; + req->host_get_name.host = host; + SIMIX_request_push(); + return req->host_get_name.result; } /** @@ -41,12 +41,12 @@ const char* SIMIX_req_host_get_name(smx_host_t host) */ xbt_dict_t SIMIX_req_host_get_properties(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_PROPERTIES; - req.host_get_properties.host = host; - SIMIX_request_push(&req); - return req.host_get_properties.result; + req->call = REQ_HOST_GET_PROPERTIES; + req->host_get_properties.host = host; + SIMIX_request_push(); + return req->host_get_properties.result; } /** @@ -58,12 +58,12 @@ xbt_dict_t SIMIX_req_host_get_properties(smx_host_t host) */ double SIMIX_req_host_get_speed(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_SPEED; - req.host_get_speed.host = host; - SIMIX_request_push(&req); - return req.host_get_speed.result; + req->call = REQ_HOST_GET_SPEED; + req->host_get_speed.host = host; + SIMIX_request_push(); + return req->host_get_speed.result; } /** @@ -73,12 +73,12 @@ double SIMIX_req_host_get_speed(smx_host_t host) */ double SIMIX_req_host_get_available_speed(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_AVAILABLE_SPEED; - req.host_get_available_speed.host = host; - SIMIX_request_push(&req); - return req.host_get_available_speed.result; + req->call = REQ_HOST_GET_AVAILABLE_SPEED; + req->host_get_available_speed.host = host; + SIMIX_request_push(); + return req->host_get_available_speed.result; } /** @@ -90,12 +90,12 @@ double SIMIX_req_host_get_available_speed(smx_host_t host) */ int SIMIX_req_host_get_state(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_STATE; - req.host_get_state.host = host; - SIMIX_request_push(&req); - return req.host_get_state.result; + req->call = REQ_HOST_GET_STATE; + req->host_get_state.host = host; + SIMIX_request_push(); + return req->host_get_state.result; } /** @@ -106,12 +106,12 @@ int SIMIX_req_host_get_state(smx_host_t host) */ void* SIMIX_req_host_get_data(smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_GET_DATA; - req.host_get_data.host = host; - SIMIX_request_push(&req); - return req.host_get_data.result; + req->call = REQ_HOST_GET_DATA; + req->host_get_data.host = host; + SIMIX_request_push(); + return req->host_get_data.result; } /** @@ -123,12 +123,12 @@ void* SIMIX_req_host_get_data(smx_host_t host) */ void SIMIX_req_host_set_data(smx_host_t host, void *data) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_SET_DATA; - req.host_set_data.host = host; - req.host_set_data.data = data; - SIMIX_request_push(&req); + req->call = REQ_HOST_SET_DATA; + req->host_set_data.host = host; + req->host_set_data.data = data; + SIMIX_request_push(); } /** \brief Creates an action that executes some computation of an host. @@ -144,14 +144,14 @@ void SIMIX_req_host_set_data(smx_host_t host, void *data) smx_action_t SIMIX_req_host_execute(const char *name, smx_host_t host, double computation_amount) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTE; - req.host_execute.name = name; - req.host_execute.host = host; - req.host_execute.computation_amount = computation_amount; - SIMIX_request_push(&req); - return req.host_execute.result; + req->call = REQ_HOST_EXECUTE; + req->host_execute.name = name; + req->host_execute.host = host; + req->host_execute.computation_amount = computation_amount; + SIMIX_request_push(); + return req->host_execute.result; } /** \brief Creates an action that may involve parallel computation on @@ -175,18 +175,18 @@ smx_action_t SIMIX_req_host_parallel_execute(const char *name, double amount, double rate) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_PARALLEL_EXECUTE; - req.host_parallel_execute.name = name; - req.host_parallel_execute.host_nb = host_nb; - req.host_parallel_execute.host_list = host_list; - req.host_parallel_execute.computation_amount = computation_amount; - req.host_parallel_execute.communication_amount = communication_amount; - req.host_parallel_execute.amount = amount; - req.host_parallel_execute.rate = rate; - SIMIX_request_push(&req); - return req.host_parallel_execute.result; + req->call = REQ_HOST_PARALLEL_EXECUTE; + req->host_parallel_execute.name = name; + req->host_parallel_execute.host_nb = host_nb; + req->host_parallel_execute.host_list = host_list; + req->host_parallel_execute.computation_amount = computation_amount; + req->host_parallel_execute.communication_amount = communication_amount; + req->host_parallel_execute.amount = amount; + req->host_parallel_execute.rate = rate; + SIMIX_request_push(); + return req->host_parallel_execute.result; } /** @@ -197,11 +197,11 @@ smx_action_t SIMIX_req_host_parallel_execute(const char *name, */ void SIMIX_req_host_execution_destroy(smx_action_t execution) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_DESTROY; - req.host_execution_destroy.execution = execution; - SIMIX_request_push(&req); + req->call = REQ_HOST_EXECUTION_DESTROY; + req->host_execution_destroy.execution = execution; + SIMIX_request_push(); } /** @@ -212,11 +212,11 @@ void SIMIX_req_host_execution_destroy(smx_action_t execution) */ void SIMIX_req_host_execution_cancel(smx_action_t execution) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_CANCEL; - req.host_execution_cancel.execution = execution; - SIMIX_request_push(&req); + req->call = REQ_HOST_EXECUTION_CANCEL; + req->host_execution_cancel.execution = execution; + SIMIX_request_push(); } /** @@ -227,12 +227,12 @@ void SIMIX_req_host_execution_cancel(smx_action_t execution) */ double SIMIX_req_host_execution_get_remains(smx_action_t execution) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_GET_REMAINS; - req.host_execution_get_remains.execution = execution; - SIMIX_request_push(&req); - return req.host_execution_get_remains.result; + req->call = REQ_HOST_EXECUTION_GET_REMAINS; + req->host_execution_get_remains.execution = execution; + SIMIX_request_push(); + return req->host_execution_get_remains.result; } /** @@ -243,12 +243,12 @@ double SIMIX_req_host_execution_get_remains(smx_action_t execution) */ e_smx_state_t SIMIX_req_host_execution_get_state(smx_action_t execution) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_GET_STATE; - req.host_execution_get_state.execution = execution; - SIMIX_request_push(&req); - return req.host_execution_get_state.result; + req->call = REQ_HOST_EXECUTION_GET_STATE; + req->host_execution_get_state.execution = execution; + SIMIX_request_push(); + return req->host_execution_get_state.result; } /** @@ -260,33 +260,14 @@ e_smx_state_t SIMIX_req_host_execution_get_state(smx_action_t execution) */ void SIMIX_req_host_execution_set_priority(smx_action_t execution, double priority) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_SET_PRIORITY; - req.host_execution_set_priority.execution = execution; - req.host_execution_set_priority.priority = priority; - SIMIX_request_push(&req); + req->call = REQ_HOST_EXECUTION_SET_PRIORITY; + req->host_execution_set_priority.execution = execution; + req->host_execution_set_priority.priority = priority; + SIMIX_request_push(); } -#ifdef HAVE_TRACING -/** - * \brief Set the category of an execution action. - * - * This functions changes the priority only. It calls a surf function. - * \param execution The execution action - * \param priority The new priority - */ -void SIMIX_req_host_execution_set_category(smx_action_t execution, const char *category) -{ - s_smx_req_t req; - - req.call = REQ_HOST_EXECUTION_SET_CATEGORY; - req.host_execution_set_category.execution = execution; - req.host_execution_set_category.category = xbt_strdup (category); - SIMIX_request_push(&req); -} -#endif - /** * \brief Waits for the completion of an execution action. * @@ -294,11 +275,11 @@ void SIMIX_req_host_execution_set_category(smx_action_t execution, const char *c */ void SIMIX_req_host_execution_wait(smx_action_t execution) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_HOST_EXECUTION_WAIT; - req.host_execution_wait.execution = execution; - SIMIX_request_push(&req); + req->call = REQ_HOST_EXECUTION_WAIT; + req->host_execution_wait.execution = execution; + SIMIX_request_push(); } /** @@ -323,18 +304,18 @@ smx_process_t SIMIX_req_process_create(const char *name, int argc, char **argv, xbt_dict_t properties) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_CREATE; - req.process_create.name = name; - req.process_create.code = code; - req.process_create.data = data; - req.process_create.hostname = hostname; - req.process_create.argc = argc; - req.process_create.argv = argv; - req.process_create.properties = properties; - SIMIX_request_push(&req); - return req.process_create.result; + req->call = REQ_PROCESS_CREATE; + req->process_create.name = name; + req->process_create.code = code; + req->process_create.data = data; + req->process_create.hostname = hostname; + req->process_create.argc = argc; + req->process_create.argv = argv; + req->process_create.properties = properties; + SIMIX_request_push(); + return req->process_create.result; } /** \brief Kills a SIMIX process. @@ -345,11 +326,11 @@ smx_process_t SIMIX_req_process_create(const char *name, */ void SIMIX_req_process_kill(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_KILL; - req.process_kill.process = process; - SIMIX_request_push(&req); + req->call = REQ_PROCESS_KILL; + req->process_kill.process = process; + SIMIX_request_push(); } /** @@ -363,13 +344,13 @@ void SIMIX_req_process_kill(smx_process_t process) */ void SIMIX_req_process_change_host(smx_process_t process, const char *source, const char *dest) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_CHANGE_HOST; - req.process_change_host.process = process; - req.process_change_host.source = source; - req.process_change_host.dest = dest; - SIMIX_request_push(&req); + req->call = REQ_PROCESS_CHANGE_HOST; + req->process_change_host.process = process; + req->process_change_host.source = source; + req->process_change_host.dest = dest; + SIMIX_request_push(); } /** @@ -382,11 +363,11 @@ void SIMIX_req_process_change_host(smx_process_t process, const char *source, co */ void SIMIX_req_process_suspend(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_SUSPEND; - req.process_suspend.process = process; - SIMIX_request_push(&req); + req->call = REQ_PROCESS_SUSPEND; + req->process_suspend.process = process; + SIMIX_request_push(); } /** @@ -399,11 +380,11 @@ void SIMIX_req_process_suspend(smx_process_t process) */ void SIMIX_req_process_resume(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_RESUME; - req.process_resume.process = process; - SIMIX_request_push(&req); + req->call = REQ_PROCESS_RESUME; + req->process_resume.process = process; + SIMIX_request_push(); } /** @@ -413,11 +394,11 @@ void SIMIX_req_process_resume(smx_process_t process) */ int SIMIX_req_process_count(void) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_COUNT; - SIMIX_request_push(&req); - return req.process_count.result; + req->call = REQ_PROCESS_COUNT; + SIMIX_request_push(); + return req->process_count.result; } /** @@ -429,12 +410,12 @@ int SIMIX_req_process_count(void) */ void* SIMIX_req_process_get_data(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_GET_DATA; - req.process_get_data.process = process; - SIMIX_request_push(&req); - return req.process_get_data.result; + req->call = REQ_PROCESS_GET_DATA; + req->process_get_data.process = process; + SIMIX_request_push(); + return req->process_get_data.result; } /** @@ -446,12 +427,12 @@ void* SIMIX_req_process_get_data(smx_process_t process) */ void SIMIX_req_process_set_data(smx_process_t process, void *data) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_SET_DATA; - req.process_set_data.process = process; - req.process_set_data.data = data; - SIMIX_request_push(&req); + req->call = REQ_PROCESS_SET_DATA; + req->process_set_data.process = process; + req->process_set_data.data = data; + SIMIX_request_push(); } /** @@ -463,12 +444,12 @@ void SIMIX_req_process_set_data(smx_process_t process, void *data) */ smx_host_t SIMIX_req_process_get_host(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_GET_HOST; - req.process_get_host.process = process; - SIMIX_request_push(&req); - return req.process_get_host.result; + req->call = REQ_PROCESS_GET_HOST; + req->process_get_host.process = process; + SIMIX_request_push(); + return req->process_get_host.result; } /** @@ -480,12 +461,12 @@ smx_host_t SIMIX_req_process_get_host(smx_process_t process) */ const char* SIMIX_req_process_get_name(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_GET_NAME; - req.process_get_name.process = process; - SIMIX_request_push(&req); - return req.process_get_name.result; + req->call = REQ_PROCESS_GET_NAME; + req->process_get_name.process = process; + SIMIX_request_push(); + return req->process_get_name.result; } /** @@ -497,12 +478,12 @@ const char* SIMIX_req_process_get_name(smx_process_t process) */ int SIMIX_req_process_is_suspended(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_IS_SUSPENDED; - req.process_is_suspended.process = process; - SIMIX_request_push(&req); - return req.process_is_suspended.result; + req->call = REQ_PROCESS_IS_SUSPENDED; + req->process_is_suspended.process = process; + SIMIX_request_push(); + return req->process_is_suspended.result; } /** \ingroup m_process_management @@ -512,12 +493,12 @@ int SIMIX_req_process_is_suspended(smx_process_t process) */ xbt_dict_t SIMIX_req_process_get_properties(smx_process_t process) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_GET_PROPERTIES; - req.process_get_properties.process = process; - SIMIX_request_push(&req); - return req.process_get_properties.result; + req->call = REQ_PROCESS_GET_PROPERTIES; + req->process_get_properties.process = process; + SIMIX_request_push(); + return req->process_get_properties.result; } /** \brief Creates a new sleep SIMIX action. @@ -531,12 +512,12 @@ xbt_dict_t SIMIX_req_process_get_properties(smx_process_t process) */ e_smx_state_t SIMIX_req_process_sleep(double duration) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_PROCESS_SLEEP; - req.process_sleep.duration = duration; - SIMIX_request_push(&req); - return req.process_sleep.result; + req->call = REQ_PROCESS_SLEEP; + req->process_sleep.duration = duration; + SIMIX_request_push(); + return req->process_sleep.result; } /** @@ -546,13 +527,13 @@ e_smx_state_t SIMIX_req_process_sleep(double duration) */ smx_rdv_t SIMIX_req_rdv_create(const char *name) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_RDV_CREATE; - req.rdv_create.name = name; + req->call = REQ_RDV_CREATE; + req->rdv_create.name = name; - SIMIX_request_push(&req); - return req.rdv_create.result; + SIMIX_request_push(); + return req->rdv_create.result; } @@ -562,22 +543,22 @@ smx_rdv_t SIMIX_req_rdv_create(const char *name) */ void SIMIX_req_rdv_destroy(smx_rdv_t rdv) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_RDV_DESTROY; - req.rdv_destroy.rdv = rdv; + req->call = REQ_RDV_DESTROY; + req->rdv_destroy.rdv = rdv; - SIMIX_request_push(&req); + SIMIX_request_push(); } smx_rdv_t SIMIX_req_rdv_get_by_name(const char *name) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_RDV_GEY_BY_NAME; - req.rdv_get_by_name.name = name; - SIMIX_request_push(&req); - return req.rdv_get_by_name.result; + req->call = REQ_RDV_GEY_BY_NAME; + req->rdv_get_by_name.name = name; + SIMIX_request_push(); + return req->rdv_get_by_name.result; } /** @@ -589,14 +570,14 @@ smx_rdv_t SIMIX_req_rdv_get_by_name(const char *name) */ int SIMIX_req_rdv_comm_count_by_host(smx_rdv_t rdv, smx_host_t host) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_RDV_COMM_COUNT_BY_HOST; - req.rdv_comm_count_by_host.rdv = rdv; - req.rdv_comm_count_by_host.host = host; + req->call = REQ_RDV_COMM_COUNT_BY_HOST; + req->rdv_comm_count_by_host.rdv = rdv; + req->rdv_comm_count_by_host.host = host; - SIMIX_request_push(&req); - return req.rdv_comm_count_by_host.result; + SIMIX_request_push(); + return req->rdv_comm_count_by_host.result; } /** @@ -606,419 +587,626 @@ int SIMIX_req_rdv_comm_count_by_host(smx_rdv_t rdv, smx_host_t host) */ smx_action_t SIMIX_req_rdv_get_head(smx_rdv_t rdv) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_RDV_GET_HEAD; - req.rdv_get_head.rdv = rdv; + req->call = REQ_RDV_GET_HEAD; + req->rdv_get_head.rdv = rdv; - SIMIX_request_push(&req); - return req.rdv_get_head.result; + SIMIX_request_push(); + return req->rdv_get_head.result; } smx_action_t SIMIX_req_comm_isend(smx_rdv_t rdv, double task_size, double rate, - void *src_buff, size_t src_buff_size, void *data) + void *src_buff, size_t src_buff_size, + int (*match_fun)(void *, void *), void *data) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); xbt_assert0(rdv, "No rendez-vous point defined for isend"); - req.call = REQ_COMM_ISEND; - req.comm_isend.rdv = rdv; - req.comm_isend.task_size = task_size; - req.comm_isend.rate = rate; - req.comm_isend.src_buff = src_buff; - req.comm_isend.src_buff_size = src_buff_size; - req.comm_isend.data = data; + req->call = REQ_COMM_ISEND; + req->comm_isend.rdv = rdv; + req->comm_isend.task_size = task_size; + req->comm_isend.rate = rate; + req->comm_isend.src_buff = src_buff; + req->comm_isend.src_buff_size = src_buff_size; + req->comm_isend.match_fun = match_fun; + req->comm_isend.data = data; - SIMIX_request_push(&req); - return req.comm_isend.result; + SIMIX_request_push(); + return req->comm_isend.result; } -smx_action_t SIMIX_req_comm_irecv(smx_rdv_t rdv, void *dst_buff, size_t * dst_buff_size) +smx_action_t SIMIX_req_comm_irecv(smx_rdv_t rdv, void *dst_buff, size_t * dst_buff_size, + int (*match_fun)(void *, void *), void *data) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); xbt_assert0(rdv, "No rendez-vous point defined for isend"); - req.call = REQ_COMM_IRECV; - req.comm_irecv.rdv = rdv; - req.comm_irecv.dst_buff = dst_buff; - req.comm_irecv.dst_buff_size = dst_buff_size; + req->call = REQ_COMM_IRECV; + req->comm_irecv.rdv = rdv; + req->comm_irecv.dst_buff = dst_buff; + req->comm_irecv.dst_buff_size = dst_buff_size; + req->comm_irecv.match_fun = match_fun; + req->comm_irecv.data = data; - SIMIX_request_push(&req); - return req.comm_irecv.result; + SIMIX_request_push(); + return req->comm_irecv.result; } void SIMIX_req_comm_destroy(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_DESTROY; - req.comm_destroy.comm = comm; + req->call = REQ_COMM_DESTROY; + req->comm_destroy.comm = comm; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_comm_cancel(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_CANCEL; - req.comm_cancel.comm = comm; + req->call = REQ_COMM_CANCEL; + req->comm_cancel.comm = comm; - SIMIX_request_push(&req); + SIMIX_request_push(); } unsigned int SIMIX_req_comm_waitany(xbt_dynar_t comms) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_WAITANY; - req.comm_waitany.comms = comms; + req->call = REQ_COMM_WAITANY; + req->comm_waitany.comms = comms; - SIMIX_request_push(&req); - return req.comm_waitany.result; + SIMIX_request_push(); + return req->comm_waitany.result; } int SIMIX_req_comm_testany(xbt_dynar_t comms) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); if (xbt_dynar_length(comms)==0) return -1; - WARN0("SIMIX_comm_testany is not implemented yet. Using waitany instead. This changes the semantic..."); - req.call = REQ_COMM_WAITANY; - req.comm_waitany.comms = comms; + req->call = REQ_COMM_TESTANY; + req->comm_testany.comms = comms; - SIMIX_request_push(&req); - return req.comm_waitany.result; + SIMIX_request_push(); + return req->comm_testany.result; } void SIMIX_req_comm_wait(smx_action_t comm, double timeout) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); + + req->call = REQ_COMM_WAIT; + req->comm_wait.comm = comm; + req->comm_wait.timeout = timeout; + + SIMIX_request_push(); +} + +#ifdef HAVE_TRACING +/** + * \brief Set the category of an action. + * + * This functions changes the category only. It calls a surf function. + * \param execution The execution action + * \param category The tracing category + */ +void SIMIX_req_set_category(smx_action_t action, const char *category) +{ + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_WAIT; - req.comm_wait.comm = comm; - req.comm_wait.timeout = timeout; + req->call = REQ_SET_CATEGORY; + req->set_category.action = action; + req->set_category.category = category; - SIMIX_request_push(&req); + SIMIX_request_push(); } +#endif int SIMIX_req_comm_test(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_TEST; - req.comm_test.comm = comm; + req->call = REQ_COMM_TEST; + req->comm_test.comm = comm; - SIMIX_request_push(&req); - return req.comm_test.result; + SIMIX_request_push(); + return req->comm_test.result; } double SIMIX_req_comm_get_remains(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_REMAINS; - req.comm_get_remains.comm = comm; + req->call = REQ_COMM_GET_REMAINS; + req->comm_get_remains.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_remains.result; + SIMIX_request_push(); + return req->comm_get_remains.result; } e_smx_state_t SIMIX_req_comm_get_state(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); + + req->call = REQ_COMM_GET_STATE; + req->comm_get_state.comm = comm; + + SIMIX_request_push(); + return req->comm_get_state.result; +} + +void *SIMIX_req_comm_get_src_data(smx_action_t comm) +{ + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_STATE; - req.comm_get_state.comm = comm; + req->call = REQ_COMM_GET_SRC_DATA; + req->comm_get_src_data.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_state.result; + SIMIX_request_push(); + return req->comm_get_src_data.result; } -void *SIMIX_req_comm_get_data(smx_action_t comm) +void *SIMIX_req_comm_get_dst_data(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_DATA; - req.comm_get_data.comm = comm; + req->call = REQ_COMM_GET_DST_DATA; + req->comm_get_dst_data.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_data.result; + SIMIX_request_push(); + return req->comm_get_dst_data.result; } void *SIMIX_req_comm_get_src_buff(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_SRC_BUFF; - req.comm_get_src_buff.comm = comm; + req->call = REQ_COMM_GET_SRC_BUFF; + req->comm_get_src_buff.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_src_buff.result; + SIMIX_request_push(); + return req->comm_get_src_buff.result; } void *SIMIX_req_comm_get_dst_buff(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_DST_BUFF; - req.comm_get_dst_buff.comm = comm; + req->call = REQ_COMM_GET_DST_BUFF; + req->comm_get_dst_buff.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_dst_buff.result; + SIMIX_request_push(); + return req->comm_get_dst_buff.result; } size_t SIMIX_req_comm_get_src_buff_size(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_SRC_BUFF_SIZE; - req.comm_get_src_buff_size.comm = comm; + req->call = REQ_COMM_GET_SRC_BUFF_SIZE; + req->comm_get_src_buff_size.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_src_buff_size.result; + SIMIX_request_push(); + return req->comm_get_src_buff_size.result; } size_t SIMIX_req_comm_get_dst_buff_size(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_DST_BUFF_SIZE; - req.comm_get_dst_buff_size.comm = comm; + req->call = REQ_COMM_GET_DST_BUFF_SIZE; + req->comm_get_dst_buff_size.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_dst_buff_size.result; + SIMIX_request_push(); + return req->comm_get_dst_buff_size.result; } smx_process_t SIMIX_req_comm_get_src_proc(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_SRC_PROC; - req.comm_get_src_proc.comm = comm; + req->call = REQ_COMM_GET_SRC_PROC; + req->comm_get_src_proc.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_src_proc.result; + SIMIX_request_push(); + return req->comm_get_src_proc.result; } smx_process_t SIMIX_req_comm_get_dst_proc(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_GET_DST_PROC; - req.comm_get_dst_proc.comm = comm; + req->call = REQ_COMM_GET_DST_PROC; + req->comm_get_dst_proc.comm = comm; - SIMIX_request_push(&req); - return req.comm_get_dst_proc.result; + SIMIX_request_push(); + return req->comm_get_dst_proc.result; } #ifdef HAVE_LATENCY_BOUND_TRACKING int SIMIX_req_comm_is_latency_bounded(smx_action_t comm) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COMM_IS_LATENCY_BOUNDED; - req.comm_is_latency_bounded.comm = comm; + req->call = REQ_COMM_IS_LATENCY_BOUNDED; + req->comm_is_latency_bounded.comm = comm; - SIMIX_request_push(&req); - return req.comm_is_latency_bounded.result; + SIMIX_request_push(); + return req->comm_is_latency_bounded.result; } #endif smx_mutex_t SIMIX_req_mutex_init(void) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_MUTEX_INIT; + req->call = REQ_MUTEX_INIT; - SIMIX_request_push(&req); - return req.mutex_init.result; + SIMIX_request_push(); + return req->mutex_init.result; } void SIMIX_req_mutex_destroy(smx_mutex_t mutex) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_MUTEX_DESTROY; - req.mutex_destroy.mutex = mutex; + req->call = REQ_MUTEX_DESTROY; + req->mutex_destroy.mutex = mutex; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_mutex_lock(smx_mutex_t mutex) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_MUTEX_LOCK; - req.mutex_lock.mutex = mutex; + req->call = REQ_MUTEX_LOCK; + req->mutex_lock.mutex = mutex; - SIMIX_request_push(&req); + SIMIX_request_push(); } int SIMIX_req_mutex_trylock(smx_mutex_t mutex) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_MUTEX_TRYLOCK; - req.mutex_trylock.mutex = mutex; + req->call = REQ_MUTEX_TRYLOCK; + req->mutex_trylock.mutex = mutex; - SIMIX_request_push(&req); - return req.mutex_trylock.result; + SIMIX_request_push(); + return req->mutex_trylock.result; } void SIMIX_req_mutex_unlock(smx_mutex_t mutex) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_MUTEX_UNLOCK; - req.mutex_unlock.mutex = mutex; + req->call = REQ_MUTEX_UNLOCK; + req->mutex_unlock.mutex = mutex; - SIMIX_request_push(&req); + SIMIX_request_push(); } smx_cond_t SIMIX_req_cond_init(void) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_INIT; + req->call = REQ_COND_INIT; - SIMIX_request_push(&req); - return req.cond_init.result; + SIMIX_request_push(); + return req->cond_init.result; } void SIMIX_req_cond_destroy(smx_cond_t cond) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_DESTROY; - req.cond_destroy.cond = cond; + req->call = REQ_COND_DESTROY; + req->cond_destroy.cond = cond; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_cond_signal(smx_cond_t cond) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_SIGNAL; - req.cond_signal.cond = cond; + req->call = REQ_COND_SIGNAL; + req->cond_signal.cond = cond; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_cond_wait(smx_cond_t cond, smx_mutex_t mutex) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_WAIT; - req.cond_wait.cond = cond; - req.cond_wait.mutex = mutex; + req->call = REQ_COND_WAIT; + req->cond_wait.cond = cond; + req->cond_wait.mutex = mutex; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_cond_wait_timeout(smx_cond_t cond, smx_mutex_t mutex, double timeout) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_WAIT_TIMEOUT; - req.cond_wait_timeout.cond = cond; - req.cond_wait_timeout.mutex = mutex; - req.cond_wait_timeout.timeout = timeout; + req->call = REQ_COND_WAIT_TIMEOUT; + req->cond_wait_timeout.cond = cond; + req->cond_wait_timeout.mutex = mutex; + req->cond_wait_timeout.timeout = timeout; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_cond_broadcast(smx_cond_t cond) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_COND_BROADCAST; - req.cond_broadcast.cond = cond; + req->call = REQ_COND_BROADCAST; + req->cond_broadcast.cond = cond; - SIMIX_request_push(&req); + SIMIX_request_push(); } smx_sem_t SIMIX_req_sem_init(int capacity) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_INIT; - req.sem_init.capacity = capacity; + req->call = REQ_SEM_INIT; + req->sem_init.capacity = capacity; - SIMIX_request_push(&req); - return req.sem_init.result; + SIMIX_request_push(); + return req->sem_init.result; } void SIMIX_req_sem_destroy(smx_sem_t sem) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_DESTROY; - req.sem_destroy.sem = sem; + req->call = REQ_SEM_DESTROY; + req->sem_destroy.sem = sem; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_sem_release(smx_sem_t sem) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_RELEASE; - req.sem_release.sem = sem; + req->call = REQ_SEM_RELEASE; + req->sem_release.sem = sem; - SIMIX_request_push(&req); + SIMIX_request_push(); } int SIMIX_req_sem_would_block(smx_sem_t sem) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_WOULD_BLOCK; - req.sem_would_block.sem = sem; + req->call = REQ_SEM_WOULD_BLOCK; + req->sem_would_block.sem = sem; - SIMIX_request_push(&req); - return req.sem_would_block.result; + SIMIX_request_push(); + return req->sem_would_block.result; } void SIMIX_req_sem_acquire(smx_sem_t sem) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_ACQUIRE; - req.sem_acquire.sem = sem; + req->call = REQ_SEM_ACQUIRE; + req->sem_acquire.sem = sem; - SIMIX_request_push(&req); + SIMIX_request_push(); } void SIMIX_req_sem_acquire_timeout(smx_sem_t sem, double timeout) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_ACQUIRE_TIMEOUT; - req.sem_acquire_timeout.sem = sem; - req.sem_acquire_timeout.timeout = timeout; + req->call = REQ_SEM_ACQUIRE_TIMEOUT; + req->sem_acquire_timeout.sem = sem; + req->sem_acquire_timeout.timeout = timeout; - SIMIX_request_push(&req); + SIMIX_request_push(); } int SIMIX_req_sem_get_capacity(smx_sem_t sem) { - s_smx_req_t req; + smx_req_t req = SIMIX_req_mine(); - req.call = REQ_SEM_GET_CAPACITY; - req.sem_get_capacity.sem = sem; + req->call = REQ_SEM_GET_CAPACITY; + req->sem_get_capacity.sem = sem; - SIMIX_request_push(&req); - return req.sem_get_capacity.result; + SIMIX_request_push(); + return req->sem_get_capacity.result; } +/* ************************************************************************** */ +/** @brief gets the result of previous syscall + * + * This function is only useful in state machine mechanism. + * + * In this case, the execution of every SIMIX_req_* function above was cut at + * SIMIX_request_push(), which calls yield() which calls suspend(), which longjmp + * to the point right before running the user code. When the control is passed + * back to the user, he needs to get the result of the syscall he did. + * That is why this function is made for. + * + * To extend this function, simply make sure that the end of the SIMIX_req_* + * function matches what is written in this big switch + */ +void *SIMIX_request_get_result(int kind) { + smx_req_t req = SIMIX_req_mine(); + switch ((e_smx_req_t) kind) { + case REQ_NO_REQ: + xbt_die("There is no request waiting, cannot provide the result"); + case REQ_HOST_GET_BY_NAME: + return req->host_get_by_name.result; + case REQ_HOST_GET_NAME: + return (void*)req->host_get_name.result; + case REQ_HOST_GET_PROPERTIES: + return req->host_get_properties.result; + case REQ_HOST_GET_SPEED: + return &req->host_get_speed.result; /* double */ + case REQ_HOST_GET_AVAILABLE_SPEED: + return &req->host_get_available_speed.result; /* double */ + case REQ_HOST_GET_STATE: + return &req->host_get_state.result; /* int */ + case REQ_HOST_GET_DATA: + return req->host_get_data.result; + case REQ_HOST_SET_DATA: + return NULL; /* void */ + case REQ_HOST_EXECUTE: + return req->host_execute.result; + case REQ_HOST_PARALLEL_EXECUTE: + return req->host_parallel_execute.result; + case REQ_HOST_EXECUTION_DESTROY: + return NULL; /* void */ + case REQ_HOST_EXECUTION_CANCEL: + return NULL; /* void */ + case REQ_HOST_EXECUTION_GET_REMAINS: + return &req->host_execution_get_remains.result; /* double */ + case REQ_HOST_EXECUTION_GET_STATE: + return &req->host_execution_get_state.result; /* e_smx_state_t */ + case REQ_HOST_EXECUTION_SET_PRIORITY: + return NULL; /* void */ + case REQ_HOST_EXECUTION_WAIT: + return NULL; /* void */ + case REQ_PROCESS_CREATE: + return req->process_create.result; + case REQ_PROCESS_KILL: + return NULL; /* void */ + case REQ_PROCESS_CHANGE_HOST: + return NULL; /* void */ + case REQ_PROCESS_SUSPEND: + return NULL; /* void */ + case REQ_PROCESS_RESUME: + return NULL; /* void */ + case REQ_PROCESS_COUNT: + return &req->process_count.result; /* int */ + case REQ_PROCESS_GET_DATA: + return req->process_get_data.result; + case REQ_PROCESS_SET_DATA: + return NULL; /* void */ + case REQ_PROCESS_GET_HOST: + return req->process_get_host.result; + case REQ_PROCESS_GET_NAME: + return (void*)req->process_get_name.result; + case REQ_PROCESS_IS_SUSPENDED: + return &req->process_is_suspended.result; /* int */ + case REQ_PROCESS_GET_PROPERTIES: + return req->process_get_properties.result; + case REQ_PROCESS_SLEEP: + return &req->process_sleep.result; /* e_smx_state_t */ + case REQ_RDV_CREATE: + return req->rdv_create.result; + case REQ_RDV_DESTROY: + return NULL; /* void */ + case REQ_RDV_GEY_BY_NAME: + return req->rdv_get_by_name.result; + case REQ_RDV_COMM_COUNT_BY_HOST: + return &req->rdv_comm_count_by_host.result; /* int */ + case REQ_RDV_GET_HEAD: + return req->rdv_get_head.result; + case REQ_COMM_ISEND: + return req->comm_isend.result; + case REQ_COMM_IRECV: + return req->comm_irecv.result; + case REQ_COMM_DESTROY: + case REQ_COMM_CANCEL: + return NULL; /* void */ + case REQ_COMM_WAITANY: + return &req->comm_waitany.result; + case REQ_COMM_TESTANY: + return &req->comm_testany.result; + case REQ_COMM_WAIT: + return NULL; /* void */ +#ifdef HAVE_TRACING + case REQ_SET_CATEGORY: + return NULL; /* void */ +#endif + case REQ_COMM_TEST: + return &req->comm_test.result; /* int */ + case REQ_COMM_GET_REMAINS: + return &req->comm_get_remains.result; /* double */ + case REQ_COMM_GET_STATE: + return &req->comm_get_state.result; /* e_smx_state_t */ + case REQ_COMM_GET_SRC_DATA: + return req->comm_get_src_data.result; + case REQ_COMM_GET_DST_DATA: + return req->comm_get_dst_data.result; + case REQ_COMM_GET_SRC_BUFF: + return req->comm_get_src_buff.result; + case REQ_COMM_GET_DST_BUFF: + return req->comm_get_dst_buff.result; + case REQ_COMM_GET_SRC_BUFF_SIZE: + return &req->comm_get_src_buff_size.result; /* size_t */ + case REQ_COMM_GET_DST_BUFF_SIZE: + return &req->comm_get_dst_buff_size.result; /* size_t */ + case REQ_COMM_GET_SRC_PROC: + return req->comm_get_src_proc.result; + case REQ_COMM_GET_DST_PROC: + return req->comm_get_dst_proc.result; + + #ifdef HAVE_LATENCY_BOUND_TRACKING + case REQ_COMM_IS_LATENCY_BOUNDED: + return &req->comm_is_latency_bounded.result; /* int */ + #endif + + case REQ_MUTEX_INIT: + return req->mutex_init.result; + case REQ_MUTEX_DESTROY: + case REQ_MUTEX_LOCK: + case REQ_MUTEX_UNLOCK: + return NULL; /* void */ + + case REQ_MUTEX_TRYLOCK: + return &req->mutex_trylock.result; /* int */ + + case REQ_COND_INIT: + return req->cond_init.result; + case REQ_COND_DESTROY: + case REQ_COND_SIGNAL: + case REQ_COND_WAIT: + case REQ_COND_WAIT_TIMEOUT: + case REQ_COND_BROADCAST: + return NULL; /* void */ + + case REQ_SEM_INIT: + return req->sem_init.result; + case REQ_SEM_DESTROY: + case REQ_SEM_RELEASE: + case REQ_SEM_ACQUIRE: + case REQ_SEM_ACQUIRE_TIMEOUT: + return NULL; /* void */ + + case REQ_SEM_WOULD_BLOCK: + return &req->sem_would_block.result; /* int */ + case REQ_SEM_GET_CAPACITY: + return &req->sem_get_capacity.result; /* int */ + } + THROW_IMPOSSIBLE; +} +/** @brief returns the id of the lastly done syscall + * Mainly (only?) useful for statemachine contextes + */ +int SIMIX_request_last_id() { + return SIMIX_req_mine()->call; +}