*/
gras_error_t
gras_trp_select(double timeout,
- gras_socket_t **dst) {
+ gras_socket_t *dst) {
gras_error_t errcode;
double startTime=gras_os_time();
gras_trp_sg_sock_data_t *sockdata;
gras_trp_plugin_t *trp;
- gras_socket_t *sock_iter; /* iterating over all sockets */
+ gras_socket_t sock_iter; /* iterating over all sockets */
int cursor,cpt;
gras_sg_portrec_t pr; /* iterating to find the chanel of expeditor */
TRY(gras_trp_plugin_get_by_name("buf",&trp));
- TRY(gras_trp_socket_new(1,dst));
+ gras_trp_socket_new(1,dst);
(*dst)->plugin = trp;
(*dst)->incoming = 1;
(*dst)->port = -1;
- if (!(sockdata = gras_new(gras_trp_sg_sock_data_t,1)))
- RAISE_MALLOC;
-
+ sockdata = gras_new(gras_trp_sg_sock_data_t,1);
sockdata->from_PID = MSG_process_self_PID();
sockdata->to_PID = r_pid;
sockdata->to_host = MSG_process_get_host(MSG_process_from_PID(r_pid));
MSG_process_get_name(MSG_process_self()),
MSG_host_get_name(MSG_host_self()));
*/
- // MSG_process_sleep(1);
- MSG_process_sleep(0.01);
+ /* MSG_process_sleep(1); */
+ MSG_process_sleep(0.001);
}
} while (gras_os_time()-startTime < timeout
|| MSG_task_Iprobe((m_channel_t) pd->chan));
gras_error_t gras_trp_file_setup(gras_trp_plugin_t *plug) {
return mismatch_error;
}
+
+
+