+++ /dev/null
-/* gs_fd_net_driver.c */
-
-#include "DataDesc/gs_private.h"
-
-struct s_gs_fd_net_driver {
- /**/
- int dummy;
-};
-
-struct s_gs_fd_connection {
- int fd;
-};
-
-static
-struct s_gs_net_driver_ops *net_driver_ops = NULL;
-
-static
-struct s_gs_connection_ops *connection_ops = NULL;
-
-struct s_gs_net_driver_ops *
-gs_fd_net_driver(void) {
- if (!connection_ops) {
- connection_ops = calloc(1, sizeof(struct s_gs_connection_ops));
-
- connection_ops->_init = gs_fd_connection__init;
- connection_ops->_exit = gs_fd_connection__exit;
- connection_ops->write = gs_fd_connection_write;
- connection_ops->read = gs_fd_connection_read;
- connection_ops->flush = gs_fd_connection_flush;
- }
-
- if (!net_driver_ops) {
- net_driver_ops = calloc(1, sizeof(struct s_gs_net_driver_ops));
-
- net_driver_ops->_init = gs_fd__init;
- net_driver_ops->_exit = gs_fd__exit;
- }
-
- return net_driver_ops;
-}
-
-void
-gs_fd__init(struct s_gs_net_driver *p_net_driver) {
-
- struct s_gs_fd_net_driver *p_fd = NULL;
-
- p_fd = calloc(1, sizeof(struct s_gs_fd_net_driver));
- p_net_driver->connection_ops = connection_ops;
- p_net_driver->specific = p_fd;
-}
-
-void
-gs_fd__exit(struct s_gs_net_driver *p_net_driver) {
-
- struct s_gs_fd_net_driver *p_fd = p_net_driver->specific;
-
- free(p_fd);
-
- p_net_driver->specific = NULL;
-}
-
-
-void
-gs_fd_connection__init(struct s_gs_connection *p_connection,
- void *arg) {
-
- struct s_gs_fd_net_connection_arg *p_fd_arg = arg;
- struct s_gs_fd_connection *p_fd_cnx = NULL;
-
- p_fd_cnx = calloc(1, sizeof(struct s_gs_fd_connection));
- p_fd_cnx->fd = p_fd_arg->fd;
- p_connection->specific = p_fd_cnx;
-}
-
-void
-gs_fd_connection__exit(struct s_gs_connection *p_connection) {
- struct s_gs_fd_connection *p_fd_cnx = p_connection->specific;
-
- free(p_fd_cnx);
-
- p_connection->specific = NULL;
-}
-
-void
-gs_fd_connection_write(struct s_gs_connection *p_connection,
- void *_ptr,
- long int length) {
- struct s_gs_fd_connection *p_fd_cnx = p_connection->specific;
- unsigned char *ptr = _ptr;
-
- if (p_connection->direction != e_gs_connection_direction_outgoing)
- GS_FAILURE("invalid operation");
-
- while (length) {
- int status = 0;
-
- status = write(p_fd_cnx->fd, ptr, (size_t)length);
- fprintf(stderr, "write(%d, %p, %ld);\n", p_fd_cnx->fd, ptr, length);
-
- if (status == -1) {
- perror("write");
- GS_FAILURE("system call failed");
- }
-
- if (status) {
- length -= status;
- ptr += status;
- } else {
- GS_FAILURE("file descriptor closed");
- }
- }
-}
-
-void
-gs_fd_connection_read(struct s_gs_connection *p_connection,
- void *_ptr,
- long int length) {
- struct s_gs_fd_connection *p_fd_cnx = p_connection->specific;
- unsigned char *ptr = _ptr;
-
- if (p_connection->direction != e_gs_connection_direction_incoming)
- GS_FAILURE("invalid operation");
-
- while (length) {
- int status = 0;
-
- status = read(p_fd_cnx->fd, ptr, (size_t)length);
- fprintf(stderr, "read(%d, %p, %ld);\n", p_fd_cnx->fd, ptr, length);
-
- if (status == -1) {
- perror("write");
- GS_FAILURE("system call failed");
- }
-
- if (status) {
- length -= status;
- ptr += status;
- } else {
- GS_FAILURE("file descriptor closed");
- }
- }
-}
-void
-gs_fd_connection_flush(struct s_gs_connection *p_connection) {
- (void)p_connection;
-
- /* */
-}
-
