- int i;
-
- int size = SIMIX_host_get_number();
-
- smpi_global = xbt_new(s_smpi_global_t, 1);
-
- // config variable
- smpi_global->reference_speed = SMPI_DEFAULT_SPEED;
-
- smpi_global->root_ready = 0;
- smpi_global->ready_process_count = 0;
-
- // start/stop
- smpi_global->start_stop_mutex = SIMIX_mutex_init();
- smpi_global->start_stop_cond = SIMIX_cond_init();
-
- // host info blank until sim starts
- // FIXME: is this okay?
- smpi_global->hosts = NULL;
- smpi_global->host_count = 0;
-
- // running hosts
- smpi_global->running_hosts_count_mutex = SIMIX_mutex_init();
- smpi_global->running_hosts_count = 0;
-
- // mallocators
- smpi_global->request_mallocator = xbt_mallocator_new(SMPI_REQUEST_MALLOCATOR_SIZE,
- smpi_request_new, smpi_request_free, smpi_request_reset);
- smpi_global->message_mallocator = xbt_mallocator_new(SMPI_MESSAGE_MALLOCATOR_SIZE,
- smpi_message_new, smpi_message_free, smpi_message_reset);
-
- // queues
- smpi_global->pending_send_request_queues = xbt_new(xbt_fifo_t, size);
- smpi_global->pending_send_request_queues_mutexes = xbt_new(smx_mutex_t, size);
- smpi_global->pending_recv_request_queues = xbt_new(xbt_fifo_t, size);
- smpi_global->pending_recv_request_queues_mutexes = xbt_new(smx_mutex_t, size);
- smpi_global->received_message_queues = xbt_new(xbt_fifo_t, size);
- smpi_global->received_message_queues_mutexes = xbt_new(smx_mutex_t, size);
-
- // sender/receiver processes
- smpi_global->sender_processes = xbt_new(smx_process_t, size);
- smpi_global->receiver_processes = xbt_new(smx_process_t, size);
-
- // timers
- smpi_global->timers = xbt_new(xbt_os_timer_t, size);
- smpi_global->timers_mutexes = xbt_new(smx_mutex_t, size);
-
- for(i = 0; i < size; i++) {
- smpi_global->pending_send_request_queues[i] = xbt_fifo_new();
- smpi_global->pending_send_request_queues_mutexes[i] = SIMIX_mutex_init();
- smpi_global->pending_recv_request_queues[i] = xbt_fifo_new();
- smpi_global->pending_recv_request_queues_mutexes[i] = SIMIX_mutex_init();
- smpi_global->received_message_queues[i] = xbt_fifo_new();
- smpi_global->received_message_queues_mutexes[i] = SIMIX_mutex_init();
- smpi_global->timers[i] = xbt_os_timer_new();
- smpi_global->timers_mutexes[i] = SIMIX_mutex_init();
- }
+ int index = smpi_group_index(smpi_comm_group(comm), request->dst);
+ smpi_process_data_t data = smpi_process_remote_data(index);
+ xbt_fifo_item_t item;
+ MPI_Request req;
+
+ print_request("Isend", request);
+ xbt_fifo_foreach(data->pending_recv, item, req, MPI_Request) {
+ if (req->comm == request->comm
+ && (req->src == MPI_ANY_SOURCE || req->src == request->src)
+ && (req->tag == MPI_ANY_TAG || req->tag == request->tag)) {
+ print_request("Match found", req);
+ xbt_fifo_remove_item(data->pending_recv, item);
+ /* Materialize the *_ANY_* fields from corresponding irecv request */
+ req->src = request->src;
+ req->tag = request->tag;
+ req->match = request;
+ request->rdv = req->rdv;
+ request->match = req;
+ return;
+ }
+ }
+ request->rdv = SIMIX_rdv_create(NULL);
+ xbt_fifo_push(data->pending_sent, request);
+}