From 71b4710c4834d747e44451bd7806c5ac4effbcc5 Mon Sep 17 00:00:00 2001 From: Nicolas Noble Date: Tue, 16 Jul 2013 16:21:37 -0700 Subject: Adding StdIO classes. --- Makefile | 2 ++ includes/StdIO.h | 40 +++++++++++++++++++++++++++++++ src/StdIO.cc | 72 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 3 files changed, 114 insertions(+) create mode 100644 includes/StdIO.h create mode 100644 src/StdIO.cc diff --git a/Makefile b/Makefile index cbbaeed..77eda31 100644 --- a/Makefile +++ b/Makefile @@ -51,6 +51,8 @@ Buffer.cc \ BStream.cc \ ZHandle.cc \ \ +StdIO.cc \ +\ Task.cc \ TaskMan.cc \ \ diff --git a/includes/StdIO.h b/includes/StdIO.h new file mode 100644 index 0000000..9b7e362 --- /dev/null +++ b/includes/StdIO.h @@ -0,0 +1,40 @@ +#pragma once + +#include +#include + +namespace Balau { + +// these classes might very well need to have their own +// special version for win32; at least from a Handle. +class StdIN : public Selectable { + public: + StdIN(); + virtual const char * getName(); + virtual void close() throw (GeneralException); + private: + virtual ssize_t recv(int sockfd, void *buf, size_t len, int flags); + virtual ssize_t send(int sockfd, const void *buf, size_t len, int flags); +}; + +class StdOUT : public Selectable { + public: + StdOUT(); + virtual const char * getName(); + virtual void close() throw (GeneralException); + private: + virtual ssize_t recv(int sockfd, void *buf, size_t len, int flags); + virtual ssize_t send(int sockfd, const void *buf, size_t len, int flags); +}; + +class StdERR : public Selectable { + public: + StdERR(); + virtual const char * getName(); + virtual void close() throw (GeneralException); + private: + virtual ssize_t recv(int sockfd, void *buf, size_t len, int flags); + virtual ssize_t send(int sockfd, const void *buf, size_t len, int flags); +}; + +}; diff --git a/src/StdIO.cc b/src/StdIO.cc new file mode 100644 index 0000000..ccdeac2 --- /dev/null +++ b/src/StdIO.cc @@ -0,0 +1,72 @@ +#include "StdIO.h" + +/** stdin **/ +Balau::StdIN::StdIN() { + setFD(0); +} + +const char * Balau::StdIN::getName() { + return "stdin"; +} + +void Balau::StdIN::close() throw (GeneralException) { + ::close(0); + internalClose(); +} + +ssize_t Balau::StdIN::recv(int sockfd, void *buf, size_t len, int flags) { + IAssert(sockfd == 0, "StdIN::recv called, but not on stdin"); + + return ::read(0, buf, len); +} + +ssize_t Balau::StdIN::send(int sockfd, const void *buf, size_t len, int flags) { + return 0; +} + +/** stdout **/ +Balau::StdOUT::StdOUT() { + setFD(1); +} + +const char * Balau::StdOUT::getName() { + return "stdout"; +} + +void Balau::StdOUT::close() throw (GeneralException) { + ::close(1); + internalClose(); +} + +ssize_t Balau::StdOUT::recv(int sockfd, void *buf, size_t len, int flags) { + return 0; +} + +ssize_t Balau::StdOUT::send(int sockfd, const void *buf, size_t len, int flags) { + IAssert(sockfd == 1, "StdOUT::send called, but not on stdout"); + return ::write(1, buf, len); +} + +/** stderr **/ +Balau::StdERR::StdERR() { + setFD(2); +} + +const char * Balau::StdERR::getName() { + return "stderr"; +} + +void Balau::StdERR::close() throw (GeneralException) { + ::close(2); + internalClose(); +} + +ssize_t Balau::StdERR::recv(int sockfd, void *buf, size_t len, int flags) { + return 0; +} + +ssize_t Balau::StdERR::send(int sockfd, const void *buf, size_t len, int flags) { + IAssert(sockfd == 2, "StdERR::send called, but not on stderr"); + return ::write(2, buf, len); +} + -- cgit v1.2.3