void SIMIX_request_init(void)
{
s_smx_req_t req;
- int i, nthreads = SIMIX_context_get_parallel_threads();
+ int i, nthreads = SIMIX_context_get_nthreads();
req_lists = xbt_new0(xbt_swag_t, nthreads);
for(i=0; i < nthreads; i++)
void SIMIX_request_destroy(void)
{
- int i, nthreads = SIMIX_context_get_parallel_threads();
+ int i, nthreads = SIMIX_context_get_nthreads();
for(i=0; i < nthreads; i++)
xbt_swag_free(req_lists[i]);
{
int i;
smx_req_t req = NULL;
- int nthreads = SIMIX_context_get_parallel_threads();
+ int nthreads = SIMIX_context_get_nthreads();
for(i=0; i < nthreads; i++){
if((req = xbt_swag_extract(req_lists[i]))){
SIMIX_request_answer(req);
break;
- case REQ_COMM_GET_SRC_BUFF:
- req->comm_get_src_buff.result =
- SIMIX_comm_get_src_buff(req->comm_get_src_buff.comm);
- SIMIX_request_answer(req);
- break;
-
- case REQ_COMM_GET_DST_BUFF:
- req->comm_get_dst_buff.result =
- SIMIX_comm_get_dst_buff(req->comm_get_dst_buff.comm);
- SIMIX_request_answer(req);
- break;
-
- case REQ_COMM_GET_SRC_BUFF_SIZE:
- req->comm_get_src_buff_size.result =
- SIMIX_comm_get_src_buff_size(req->comm_get_src_buff_size.comm);
- SIMIX_request_answer(req);
- break;
-
- case REQ_COMM_GET_DST_BUFF_SIZE:
- req->comm_get_dst_buff_size.result =
- SIMIX_comm_get_dst_buff_size(req->comm_get_dst_buff_size.comm);
- SIMIX_request_answer(req);
- break;
-
case REQ_COMM_GET_SRC_PROC:
req->comm_get_src_proc.result =
SIMIX_comm_get_src_proc(req->comm_get_src_proc.comm);