free(plug->name);
free(plug);
plug=NULL;
- xbt_ex_free(&e);
+ xbt_ex_free(e);
} else {
RETHROW;
}
sock->port = -1;
sock->peer_port = -1;
sock->peer_name = NULL;
+ sock->peer_proc = NULL;
sock->data = NULL;
sock->bufdata = NULL;
*dst = sock;
- xbt_dynar_push(((gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id))->sockets,dst);
+ xbt_dynar_push(((gras_trp_procdata_t)
+ gras_libdata_by_id(gras_trp_libdata_id))->sockets,dst);
XBT_OUT;
}
*/
gras_socket_t
gras_socket_server(unsigned short port) {
- return gras_socket_server_ext(port,32,0);
+ return gras_socket_server_ext(port,32*1024,0);
}
/**
gras_socket_t
gras_socket_client(const char *host,
unsigned short port) {
- return gras_socket_client_ext(host,port,32,0);
+ return gras_socket_client_ext(host,port,32*1024,0);
}
char *gras_socket_peer_name(gras_socket_t sock) {
return sock->peer_name;
}
+char *gras_socket_peer_proc(gras_socket_t sock) {
+ return sock->peer_proc;
+}
+
+void gras_socket_peer_proc_set(gras_socket_t sock,char*peer_proc) {
+ sock->peer_proc = peer_proc;
+}
/** \brief Check if the provided socket is a measurement one (or a regular one) */
int gras_socket_is_meas(gras_socket_t sock) {
"No need to accept on non-measurement sockets (it's automatic)");
if (!peer->accepting) {
- /* nothing to accept here */
+ /* nothing to accept here (must be in SG) */
+ /* BUG: FIXME: this is BAD! it makes tricky to free the accepted socket*/
return peer;
}