/* -*- C++ -*- */ // $Id$ // ============================================================================ // // = LIBRARY // ace // // = FILENAME // DEV_IO.h // // = AUTHOR // Gerhard Lenzer and Douglas C. Schmidt // // ============================================================================ #ifndef ACE_DEV_IO_H #define ACE_DEV_IO_H #include "ace/DEV.h" #include "ace/DEV_Addr.h" #if !defined (ACE_LACKS_PRAGMA_ONCE) #pragma once #endif /* ACE_LACKS_PRAGMA_ONCE */ class ACE_Export ACE_DEV_IO : public ACE_DEV { // = TITLE // Read/Write operations on Devices. public: friend class ACE_DEV_Connector; ACE_DEV_IO (void); // Default constructor. // = Various send operations. ssize_t send (const void *buf, size_t n) const; // send upto bytes in . ssize_t recv (void *buf, size_t n) const; // Recv upto bytes in . ssize_t send_n (const void *buf, size_t n) const; // Send n bytes, keep trying until n are sent. ssize_t recv_n (void *buf, size_t n) const; // Recv n bytes, keep trying until n are received. #if defined (ACE_HAS_STREAM_PIPES) ssize_t recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *band, int *flags) const; // Recv bytes via STREAM pipes using "band" mode. ssize_t send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int band, int flags) const; // Send bytes via STREAM pipes using "band" mode. ssize_t recv (ACE_Str_Buf *cntl, ACE_Str_Buf *data, int *flags) const; // Recv and via STREAM pipes. ssize_t send (const ACE_Str_Buf *cntl, const ACE_Str_Buf *data, int flags = 0) const; // Send and via STREAM pipes. #endif /* ACE_HAS_STREAM_PIPES */ ssize_t send (const iovec iov[], size_t n) const; // Send iovecs via <::writev>. ssize_t recv (iovec iov[], size_t n) const; // Recv iovecs via <::readv>. ssize_t send (size_t n, ...) const; // Send N char *ptrs and int lengths. Note that the char *'s // precede the ints (basically, an varargs version of writev). The // count N is the *total* number of trailing arguments, *not* a // couple of the number of tuple pairs! ssize_t recv (size_t n, ...) const; // This is an interface to ::readv, that doesn't use the struct // iovec explicitly. The ... can be passed as an arbitrary number // of (char *ptr, int len) tuples. However, the count N is the // *total* number of trailing arguments, *not* a couple of the // number of tuple pairs! ssize_t send (const void *buf, size_t n, ACE_OVERLAPPED *overlapped) const; // Send bytes via Win32 WriteFile using overlapped I/O. ssize_t recv (void *buf, size_t n, ACE_OVERLAPPED *overlapped) const; // Recv bytes via Win32 ReadFile using overlapped I/O. void dump (void) const; // Dump the state of an object. // = The following two methods are no-ops to keep the // happy. int get_local_addr (ACE_DEV_Addr &) const; // Return the local endpoint address. int get_remote_addr (ACE_DEV_Addr &) const; // Return the address of the remotely connected peer (if there is // one). ACE_ALLOC_HOOK_DECLARE; // Declare the dynamic allocation hooks. // = Meta-type info typedef ACE_DEV_Addr PEER_ADDR; private: ACE_DEV_Addr addr_; // Address of device we are connected to. }; #if !defined (ACE_LACKS_INLINE_FUNCTIONS) #include "ace/DEV_IO.i" #endif #endif /* ACE_DEV_IO_H */