sock->outgoing = incoming ? 0:1;
sock->accepting = incoming ? 1:0;
sock->meas = 0;
- sock->recv_ok = 1;
+ sock->recvd = 0;
sock->valid = 1;
sock->moredata = 0;
*dst = sock;
- xbt_dynar_push(((gras_trp_procdata_t)
- gras_libdata_by_id(gras_trp_libdata_id))->sockets,dst);
XBT_OUT;
}
sock->outgoing?'y':'n',
sock->accepting?'y':'n');
} CATCH(e) {
- int cursor;
- gras_socket_t sock_iter;
- xbt_dynar_t socks = ((gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id))->sockets;
- xbt_dynar_foreach(socks, cursor, sock_iter) {
- if (sock_iter==sock) {
- xbt_dynar_cursor_rm(socks,&cursor);
- }
- }
+
free(sock);
RETHROW;
}
if (!measurement)
((gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id))->myport = port;
+ xbt_dynar_push(((gras_trp_procdata_t)
+ gras_libdata_by_id(gras_trp_libdata_id))->sockets,&sock);
return sock;
}
/**
sock->outgoing?'y':'n',
sock->accepting?'y':'n');
} CATCH(e) {
- xbt_dynar_pop(((gras_trp_procdata_t)
- gras_libdata_by_id(gras_trp_libdata_id))->sockets,NULL);
free(sock);
- xbt_backtrace_display(&e);
- RETHROW;
+ RETHROW;
}
-
+ xbt_dynar_push(((gras_trp_procdata_t)
+ gras_libdata_by_id(gras_trp_libdata_id))->sockets,&sock);
return sock;
}
void gras_socket_close(gras_socket_t sock) {
xbt_dynar_t sockets = ((gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id))->sockets;
gras_socket_t sock_iter = NULL;
- int cursor;
+ unsigned int cursor;
XBT_IN;
VERB1("Close %p",sock);
/*
* Creating procdata for this module
*/
-static void *gras_trp_procdata_new() {
+static void *gras_trp_procdata_new(void) {
gras_trp_procdata_t res = xbt_new(s_gras_trp_procdata_t,1);
res->name = xbt_strdup("gras_trp");
gras_trp_procdata_t procdata =
(gras_trp_procdata_t)gras_libdata_by_id(gras_trp_libdata_id);
- int it;
+ unsigned int it;
gras_socket_t s;
INFO1("** Dump the socket set %s",name);