+ XBT_CDEBUG(gras_trp_meas,
+ "Recvd %ld msgs of %lu (size of each: %ld) from %s:%d",
+ got_sofar, msg_amount, msg_size, gras_socket_peer_name(peer),
+ gras_socket_peer_port(peer));
+
+ if (gras_if_RL())
+ free(chunk);
+ XBT_OUT();
+}
+
+/**
+ * \brief Something similar to the good old accept system call.
+ *
+ * Make sure that there is someone speaking to the provided server socket.
+ * In RL, it does an accept(2) and return the result as last argument.
+ * In SG, as accepts are useless, it returns the provided argument as result.
+ * You should thus test whether (peer != accepted) before closing both of them.
+ *
+ * You should only call this on measurement sockets. It is automatically
+ * done for regular sockets, but you usually want more control about
+ * what's going on with measurement sockets.
+ */
+gras_socket_t gras_socket_meas_accept(gras_socket_t peer)
+{
+ gras_socket_t res;
+ THROW0(unknown_error,0,"measurement sockets were broken in this release of SimGrid and should be ported back in the future."
+ "If you depend on it, sorry, you have to use an older version, or wait for the future version using it...");
+
+ xbt_assert0(peer->meas,
+ "No need to accept on non-measurement sockets (it's automatic)");
+
+ if (!peer->accepting) {
+ /* nothing to accept here (must be in SG) */
+ /* BUG: FIXME: this is BAD! it makes tricky to free the accepted socket */
+ return peer;
+ }
+
+ res = (peer->plugin->socket_accept) (peer);
+ res->meas = peer->meas;
+ XBT_CDEBUG(gras_trp_meas, "meas_accepted onto %d", res->sd);
+
+ return res;
+}
+
+
+/*
+ * Creating procdata for this module
+ */
+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");
+ res->name_len = 0;
+ res->sockets = xbt_dynar_new_sync(sizeof(gras_socket_t *), NULL);
+ res->myport = 0;
+
+ return (void *) res;
+}
+
+/*
+ * Freeing procdata for this module
+ */
+static void gras_trp_procdata_free(void *data)
+{
+ gras_trp_procdata_t res = (gras_trp_procdata_t) data;
+
+ xbt_dynar_free(&(res->sockets));
+ free(res->name);
+ free(res);
+}
+
+void gras_trp_socketset_dump(const char *name)
+{
+ gras_trp_procdata_t procdata =
+ (gras_trp_procdata_t) gras_libdata_by_id(gras_trp_libdata_id);
+
+ unsigned int it;
+ gras_socket_t s;
+
+ XBT_INFO("** Dump the socket set %s", name);
+ xbt_dynar_foreach(procdata->sockets, it, s) {
+ XBT_INFO(" %p -> %s:%d %s",
+ s, gras_socket_peer_name(s), gras_socket_peer_port(s),
+ s->valid ? "(valid)" : "(peer dead)");
+ }
+ XBT_INFO("** End of socket set %s", name);
+}
+
+/*
+ * Module registration
+ */
+int gras_trp_libdata_id;
+void gras_trp_register()
+{
+ gras_trp_libdata_id =
+ gras_procdata_add("gras_trp", gras_trp_procdata_new,
+ gras_trp_procdata_free);
+}