---

network.H

Go to the documentation of this file.

#ifndef NETWORK_HAS_BEEN_INCLUDED
#define NETWORK_HAS_BEEN_INCLUDED

#ifdef WIN32
#include <windows.h>
#include <winsock.h>
#include <io.h>
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#endif

#include "std/config.H"
#include "tty/tty.H"
#include "net_stream.H"

class Network_obs
{
 public:
   enum event {accept_str=0, remove_str};

   virtual ~Network_obs() {}
            Network_obs() {}

   virtual void notify_net( const event &e, NetStream *s ) = 0;
};

//: Network server
class DllImpExp Network: public FD_EVENT {
   friend class NetStream;
   static int   NETWORK_SERVER_BACKLOG;

 protected:
   int          nStreams_;
   NetStream   *streams_[256];
   str_list     tags_;
   int          port_;    // port number we're listening for connections on
   str_ptr      name_;    // name of the host we're running on
   bool         first_;   // whether this is the primary connection server
   int          _at_barrier;

   ARRAY<Network_obs *>  _obs_list;

   void          die(const char *msg);

   NetStream    *wait_for_connect();
   char         *configure (int port, int backlog = NETWORK_SERVER_BACKLOG);
   void          accept_stream(void);
   void          remove_stream(NetStream *s);

   /* -------------- FD_EVENT methods -------------- */
   void          sample    ()               { accept_stream(); }


   /* -------------- overload-able class functions -------------- */
   virtual void       add_client(NetStream * /*cli*/) { }
   virtual void       interpret (NETenum /*code*/, NetStream * /*sender*/) { }
   virtual NetStream *new_stream(int port, const char *host)  
                        { return new NetStream(port,host);}
   virtual NetStream *new_stream(int fd, struct sockaddr_in *a)  
                        { return new NetStream(fd,a); }


 public:
              Network() : nStreams_(0),name_(""), first_(0), _at_barrier(0) { }
  virtual   ~Network() { cerr << "removing network" << endl;
  FD_MANAGER::rem_event(this); }

   void       connect_to (NetStream *s);
   void       add_stream (NetStream *s)   { streams_[nStreams_++] = s;
                                              s->add_network(this);
                                              s->subscribe(tags_); }
   void       start      (           int port=0);
   void       start      (char *host,int port) { start();
                                             connect_to(new_stream(port,host));}
   void       send_stream(ostrstream &);
   void       flush_data ();
  
   void       subscribe  (Cstr_ptr &tag)   { tags_ += tag;
                                             for (int i=0; i < nStreams_; i++)
                                               streams_[i]->subscribe(tag); }
   NetStream *operator[] (int i)           { return streams_[i]; }
   int        num_streams(void)  const     { return nStreams_; }
   int        port       (void)  const     { return port_; }
   Cstr_ptr  &name       (void)  const     { return name_; }
   int        processing (void)  const;

   void       barrier    ();
   void       add_net_obs(Network_obs *o)  { _obs_list += o; }
   void       rem_net_obs(Network_obs *o)  { _obs_list -= o; }
   void       notify_net (Network_obs::event e,
                          NetStream *s) { for(int i=0;i<_obs_list.num();i++)
                                             _obs_list[i]->notify_net(e,s); }
};


#ifdef WIN32
ssize_t write_win32(int fildes, const void *buf, size_t nbyte);
ssize_t read_win32 (int fildes, void *buf, size_t nbyte);
DllImpExp int num_bytes_to_read(int fildes);
#else
int num_bytes_to_read(int fildes);
#endif

#endif  /* NETWORK_HAS_BEEN_INCLUDED */

---