/* $Id$ */
-/* trp (transport) - send/receive a bunch of bytes */
+/* transport - low level communication (send/receive bunches of bytes) */
-/* This file implements the public interface of this module, exported to the*/
-/* other modules of GRAS, but not to the end user. */
+/* module's private interface masked even to other parts of GRAS. */
-/* Authors: Martin Quinson */
-/* Copyright (C) 2004 Martin Quinson. */
+/* Copyright (c) 2004 Martin Quinson. All rights reserved. */
/* This program is free software; you can redistribute it and/or modify it
- under the terms of the license (GNU LGPL) which comes with this package. */
+ * under the terms of the license (GNU LGPL) which comes with this package. */
#ifndef GRAS_TRP_PRIVATE_H
#define GRAS_TRP_PRIVATE_H
-#include "gras_private.h"
-/* A low-level socket type (each plugin implements it the way it prefers */
-//typedef void gras_trp_sock_t;
-
-/* A plugin type */
-struct gras_trp_plugin_ {
- const char *name;
-
- gras_error_t (*init)(void);
- void (*exit)(gras_trp_plugin_t *);
-
- gras_error_t (*socket_client_open)(const char *host,
- unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
- gras_error_t (*socket_server_open)(unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
- void (*socket_close)(gras_trp_sock_t **sd);
-
- gras_error_t (*select)(double timeOut,
- gras_trp_sock_t **sd);
+#include "xbt/sysdep.h"
+#include "xbt/log.h"
+#include "xbt/dynar.h"
+#include "xbt/dict.h"
+
+#include "gras/emul.h" /* gras_if_RL() */
+
+#include "gras_modinter.h" /* module init/exit */
+#include "gras/transport.h" /* rest of module interface */
+
+#include "gras/Transport/transport_interface.h" /* semi-public API */
+#include "gras/Virtu/virtu_interface.h" /* libdata management */
+
+extern int gras_trp_libdata_id; /* our libdata identifier */
+/**
+ * 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 recv_ok :1; /* true if it is valid to recv() on the socket (false if it is a file) */
+ 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. */
+
+ unsigned long int buf_size; /* what to say to the OS. field here to remember it when accepting */
- gras_error_t (*bloc_send)(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
- gras_error_t (*bloc_recv)(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
- gras_error_t (*flush)(gras_trp_sock_t *sd);
-
- 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);
+ int sd;
+ int port; /* port on this side */
+ int peer_port; /* port on the other side */
+ char *peer_name; /* hostname of the other side */
+ char *peer_proc; /* process on the other side */
+
+ 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);
+
+/*
+
+ 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).
-gras_error_t gras_trp_tcp_bloc_send(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
-
-gras_error_t gras_trp_tcp_bloc_recv(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
-gras_error_t gras_trp_tcp_flush(gras_trp_sock_t *sd);
-
-/* SG driver */
-gras_error_t gras_trp_sg_init(void);
-void gras_trp_sg_exit(gras_trp_plugin_t *plugin);
-gras_error_t gras_trp_sg_socket_client(const char *host,
- unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
-gras_error_t gras_trp_sg_socket_server(unsigned short port,
- int raw,
- unsigned int bufSize,
- /* OUT */ gras_trp_sock_t **dst);
-void gras_trp_sg_socket_close(gras_trp_sock_t **sd);
-gras_error_t gras_trp_sg_select(double timeOut,
- gras_trp_sock_t **sd);
-
-gras_error_t gras_trp_sg_bloc_send(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
-
-gras_error_t gras_trp_sg_bloc_recv(gras_trp_sock_t *sd,
- void *data,
- size_t size,
- double timeOut);
-gras_error_t gras_trp_sg_flush(gras_trp_sock_t *sd);
+ Hu! You evil problem! Taste my axe!
+*/
+gras_socket_t gras_trp_buf_init_sock(gras_socket_t sock);
#endif /* GRAS_TRP_PRIVATE_H */
