- void *specific;
-};
-
-/**********************************************************************
- * Internal stuff to the module. Other modules shouldn't fool with it *
- **********************************************************************/
-
-/* TCP driver */
-gras_error_t gras_trp_tcp_init(void);
-void gras_trp_tcp_exit(gras_trp_plugin_t *plugin);
-gras_error_t gras_trp_tcp_socket_client(const char *host,
- unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
-gras_error_t gras_trp_tcp_socket_server(unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
-void gras_trp_tcp_socket_close(gras_trp_sock_t **sd);
-gras_error_t gras_trp_tcp_select(double timeOut,
- gras_trp_sock_t **sd);
+ It gets tricky since gras_socket_close is part of the common API, not
+ only the RL one. */
+extern gras_socket_t _gras_lastly_selected_socket;
+
+/**
+ * s_gras_socket:
+ *
+ * Description of a socket.
+ */
+typedef struct gras_trp_bufdata_ gras_trp_bufdata_t;
+
+typedef struct s_gras_socket {
+ gras_trp_plugin_t plugin;
+
+ int incoming:1; /* true if we can read from this sock */
+ int outgoing:1; /* true if we can write on this sock */
+ int accepting:1; /* true if master incoming sock in tcp */
+ int meas:1; /* true if this is an experiment socket instead of messaging */
+ int valid:1; /* false if a select returned that the peer quitted, forcing us to "close" the socket */
+ int moredata:1; /* TCP socket use a buffer and read operation get as much
+ data as possible. It is possible that several messages
+ are received in one shoot, and select won't catch them
+ afterward again.
+ This boolean indicates that this is the case, so that we
+ don't call select in that case. Note that measurement
+ sockets are not concerned since they use the TCP
+ interface directly, with no buffer. */
+
+ int recvd:1; /* true if the recvd_val field contains one byte of the stream (that we peek'ed to check the socket validity) */
+ char recvd_val; /* what we peeked from the socket, if any */
+
+ unsigned long int buf_size; /* what to say to the OS.
+ Field here to remember it when accepting */
+
+ int sd;
+
+ void *data; /* plugin specific data */
+
+ /* buffer plugin specific data. Yeah, C is not OO, so I got to trick */
+ gras_trp_bufdata_t *bufdata;
+} s_gras_socket_t;
+
+void gras_trp_socket_new(int incomming, gras_socket_t * dst);
+
+/* The drivers */
+typedef void (*gras_trp_setup_t) (gras_trp_plugin_t dst);
+
+void gras_trp_tcp_setup(gras_trp_plugin_t plug);
+void gras_trp_iov_setup(gras_trp_plugin_t plug);
+void gras_trp_file_setup(gras_trp_plugin_t plug);
+void gras_trp_sg_setup(gras_trp_plugin_t plug);
+
+/* FIXME: this should be solved by SIMIX
+
+ I'm tired of that shit. the select in SG has to create a socket to expeditor
+ manually do deal with the weirdness of the hostdata, themselves here to deal
+ with the weird channel concept of SG and convert them back to ports.
+
+ When introducing buffered transport (which I want to get used in SG to debug
+ the buffering itself), we should not make the rest of the code aware of the
+ change and not specify code for this. This is bad design.
+
+ But there is bad design all over the place, so fuck off for now, when we can
+ get rid of MSG and rely directly on SG, this crude hack can go away. But in
+ the meanwhile, I want to sleep this night (FIXME).