---

net_stream.H

Go to the documentation of this file.

#ifndef GLUE_NET_NET_STREAM_H
#define GLUE_NET_NET_STREAM_H
#include "tty/tty.H"
#include "mem_push.H"
#include "std/strstream.H" // localize strstream.h weirdness
#include "std/fstream.H" // localize fstream.h weirdness
#include "std/strings.H"

class Network;

//:  Provides a channel for communications.
//
//          Clients can connect to another server by creating a
//          NetStream.
//
//          NetServer returns new NetStream instances for
//          each client connection.
//
class DllImpExp NetStream : public FD_EVENT {
   friend class Network;
 public:
   enum StreamFlags {
       write    = 0x1,
       read     = 0x2,
       rw       = 0x3,
       ascii    = 0x4,
       ascii_w  = 0x5,
       ascii_r  = 0x6,
       ascii_rw = 0x7
   };

              NetStream (int port, const char         *name);
              NetStream (int fd,   struct sockaddr_in *client,bool block=false);
   NetStream& operator= (const NetStream&);
   virtual   ~NetStream();

   str_ptr    name       (void) const  { return name_; }
   str_ptr    print_name (void) const  { return print_name_; }
   int        port       (void) const  { return port_; }
   int        processing (void) const  { return processing_; }
   Network*   network    (void) const  { return network_; }
   void       subscribe  (Cstr_ptr  &t){ tags_ += t; }
   void       subscribe  (Cstr_list &t){ tags_  = t; }

   void       set_port   (int p);
   void       add_network(Network *n)  { network_ = n; }
   virtual void flush_data (void);
   int        read_stuff   (void);
   
   virtual void sample();

   // Do not block when using TCP - send packet ASAP
   void       no_tcp_delay();
   void flush();

   static void no_linger(int fd);
   static NetStream *ostream_to_NetStream(ostream *os)
      { return ostream_map.find((long) os);}
   ostream *ostr() { return _ostr;}
   istream *istr() { return _istr;}

 protected:
   void        set_blocking(bool val) const;
   ssize_t     write_to_net (const void *buf, size_t nbyte) const;
   ssize_t     read_from_net(      void *buf, size_t nbyte) const;
   int         interpret    (void);
   void        remove_me(); // Remove this stream from its Network
   ostrstream  *_ostr;
   istream     *_istr;
   STDmem_queue _in_queue;
   ARRAY<char>  _charbuf;
   void init_streams(bool readable, bool writeable);

 private:
   
   void _die(const char *msg);

   str_list tags_;
   str_ptr  print_name_;
   str_ptr  name_;
   int      port_;
   int      msgSize_;
   int      processing_;
   Network *network_;
   static HASH<NetStream *> ostream_map;
};

enum NETenum { 
     NETadd_connection, 
     NETquit, 
     NETflush, 
     NETapp,
     NETidentify,
     NETbroadcast,
     NETbarrier,
     NETswap_ack,
     NETbad
};
DllImpExp istream &operator >> (istream &,  NETenum    &);
DllImpExp ostream &operator << (ostream &,  NETenum     );
#endif

---