- trp_pd = (gras_trp_procdata_t)gras_libdata_by_name("gras_trp");
- pd->pid = PID++;
-
- if (SIMIX_process_self() != NULL ) {
- pd->ppid = gras_os_getpid();
- }
- else pd->ppid = -1;
-
- trp_pd->mutex = SIMIX_mutex_init();
- trp_pd->cond = SIMIX_cond_init();
- trp_pd->mutex_meas = SIMIX_mutex_init();
- trp_pd->cond_meas = SIMIX_cond_init();
- trp_pd->active_socket = xbt_fifo_new();
- trp_pd->active_socket_meas = xbt_fifo_new();
-
+ trp_pd = (gras_trp_procdata_t)gras_libdata_by_name("gras_trp");
+ pd->pid = PID++;
+
+ if (SIMIX_process_self() != NULL ) {
+ pd->ppid = gras_os_getpid();
+ }
+ else pd->ppid = -1;
+
+ trp_pd->msg_selectable_sockets = xbt_queue_new(0,sizeof(gras_socket_t));
+
+ trp_pd->meas_selectable_sockets = xbt_queue_new(0,sizeof(gras_socket_t));
+