/* $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. */
#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 "Transport/transport_interface.h"
+#include "Virtu/virtu_interface.h" /* socketset_get() */
+
+/**
+ * s_gras_socket:
+ *
+ * Description of a socket.
+ */
+typedef struct gras_trp_bufdata_ gras_trp_bufdata_t;
+
+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 raw :1; /* true if this is an experiment socket instead of messaging */
- 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;
+ int sd;
+ int port; /* port on this side */
+ int peer_port; /* port on the other side */
+ char *peer_name; /* hostname of 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;
};
+
+gras_error_t gras_trp_socket_new(int incomming,
+ gras_socket_t **dst);
+
+/* The drivers */
+typedef gras_error_t (*gras_trp_setup_t)(gras_trp_plugin_t *dst);
-/**********************************************************************
- * 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);
+gras_error_t gras_trp_tcp_setup(gras_trp_plugin_t *plug);
+gras_error_t gras_trp_file_setup(gras_trp_plugin_t *plug);
+gras_error_t gras_trp_sg_setup(gras_trp_plugin_t *plug);
+gras_error_t gras_trp_buf_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 (whith 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.
-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);
+ 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).
+
+ Hu! You evil problem! Taste my axe!
+
+*/
+gras_error_t gras_trp_buf_init_sock(gras_socket_t *sock);
#endif /* GRAS_TRP_PRIVATE_H */
