double startTime=gras_os_time();
gras_trp_procdata_t pd=(gras_trp_procdata_t)gras_libdata_get("gras_trp");
gras_trp_sg_sock_data_t *sockdata;
- gras_trp_plugin_t *trp;
+ gras_trp_plugin_t trp;
gras_socket_t sock_iter; /* iterating over all sockets */
int cursor,cpt;
DEBUG1("Consider %p as outgoing socket to expeditor",sock_iter);
sockdata = sock_iter->data;
- if (sock_iter->raw || !sock_iter->outgoing)
+ if (sock_iter->meas || !sock_iter->outgoing)
continue;
- if (sockdata->from_PID == r_pid) {
+ if (sockdata->to_PID == r_pid) {
*dst=sock_iter;
return no_error;
}
xbt_dynar_foreach(remote_hd->ports, cpt, pr) {
if (sockdata->to_chan == pr.tochan) {
- if (pr.raw) {
- DEBUG0("Damn, it's raw");
+ if (pr.meas) {
+ DEBUG0("Damn, it's for measurement");
continue;
}
}
}
if ((*dst)->peer_port == -10) {
- /* was raw */
+ /* was for measurement */
sockdata->to_chan = -1;
} else {
- /* found it, don't let it override by raw */
+ /* found it, don't let it override by meas */
break;
}
}
/* dummy implementations of the functions used in RL mode */
-xbt_error_t gras_trp_tcp_setup(gras_trp_plugin_t *plug) {
+xbt_error_t gras_trp_tcp_setup(gras_trp_plugin_t plug) {
return mismatch_error;
}
-xbt_error_t gras_trp_file_setup(gras_trp_plugin_t *plug) {
+xbt_error_t gras_trp_file_setup(gras_trp_plugin_t plug) {
return mismatch_error;
}