if (issuer != simix_global->maestro_process){
issuer->request.issuer = issuer;
- if (smx_parallel_contexts)
+ if (SIMIX_context_is_parallel())
xbt_os_mutex_acquire(sync_req_positions);
xbt_heap_push(req_todo,&issuer->request,issuer->pid);
DEBUG4("Pushed request %s (%d) of %s; now %d requests waiting",
SIMIX_request_name(issuer->request.call), issuer->request.call,
issuer->name,xbt_heap_size(req_todo));
- if (smx_parallel_contexts)
+ if (SIMIX_context_is_parallel())
xbt_os_mutex_release(sync_req_positions);
DEBUG3("Yield process '%s' on request of type %s (%d)", issuer->name,
req->comm_isend.src_buff,
req->comm_isend.src_buff_size,
req->comm_isend.match_fun,
- req->comm_isend.data);
+ req->comm_isend.data,
+ req->comm_isend.detached);
SIMIX_request_answer(req);
break;
break;
case REQ_RDV_GET_HEAD:
- req->rdv_get_head.result = SIMIX_rdv_get_head(req->rdv_get_head.rdv);
+ req->rdv_get_head.result = SIMIX_rdv_get_head(req->rdv_get_head.rdv);
SIMIX_request_answer(req);
break;
req->host_execute.result = SIMIX_host_execute(
req->host_execute.name,
req->host_execute.host,
- req->host_execute.computation_amount);
+ req->host_execute.computation_amount,
+ req->host_execute.priority);
SIMIX_request_answer(req);
break;
break;
case REQ_PROCESS_CREATE:
- req->process_create.result = SIMIX_process_create(
+ SIMIX_process_create(
+ req->process_create.process,
req->process_create.name,
req->process_create.code,
req->process_create.data,