socket%2B%2B-1.10/test/commObj.h

//----------------------------------------------------------------------------
// File: CommObj.hh
// Author: Bala Swaminathan 5/12/94
// This file contains interface of the Network Communication Object class.
// 
// Copyright 1994, Washington University in St. Louis
//----------------------------------------------------------------------------

// The following CommObj is modeled using the sockets.
// Each PRO creates a CommObj of type CommObj::PRIMARY and this becomes
// its main socket. Later whenever it needs a "new" socket it either
// (1) creates a socket of type CommObj::SECONDARY and then "connects"
// to another PRO's primary socket, or (2) the PRO can "accept" a connection
// from another PRO's secondary socket. This "accepting" a connection, if
// succesful, results in the creation of a socket of type CommObj::SECONDARY.

#ifndef CommObj_hh
#define CommObj_hh

#include "sockinet.h"

class CommObj : public sockinetbuf {
public:
  enum type { PRIMARY, SECONDARY };
public:
  CommObj (const type ty = SECONDARY,    // "do-nothing" constructor
           const int portID=0)          // can specify a port (for PRIMARY)
    : sockinetbuf(sockbuf::sock_stream)  // TCP Sockets
      {
        if (ty == PRIMARY) {
          sockinetaddr addr (INADDR_ANY, portID);
          // this creates addr of INADDR_ANY and port=0
          // i.e. sockets bound to any address can "connect" to us
          bind (addr);    // bind to the above address
          listen ();      // now listen (default 5) for new connections
        }
      }
  CommObj (const sockbuf& sb): sockinetbuf (sb) {}

  const sockinetbuf  sbuf () { return *this; } // for DEUBUGGING purposes
};

// The CommController manages all the CommObj instances in the PROTOCOL.
//    (* the list of CommObj* maintained by CommController are not shown *)

class CommController {
public:
  CommController (int portID=0)           // creates the PERIMARY CommObj
    {
      c_server = new CommObj (CommObj::PRIMARY, portID);
    }
  ~CommController ()                      // close all sockets and delete list
    { delete c_server; }
  CommObj* server ()                       // return "main" socket
    { return c_server; }
  CommObj  accept ()                // accept connection on the SERVER Commobj
    {
      //  return c_server->accept();
      sockinetaddr sa;
      sockinetbuf si = c_server->accept(sa);
      cout << "   accept(): peer.host = " << sa.gethostname() << endl;
      cout << "   accept(): peer.port = " << sa.getport() << endl;
      cout << "     acc: local.host = " << (si).localhost() << endl;
      cout << "     acc: local.port = " << (si).localport() << endl;
      cout << "     acc: peer.host  = " << (si).peerhost() << endl;
      cout << "     acc: peer.port  = " << (si).peerport() << endl;
      return si;
    }
private:
  CommObj*       c_server;          // the server or the main Object
};

#endif CommObj_hh

Revision:	1.2
Committed:	Mon Jun 10 14:10:44 2002 UTC (22 years, 4 months ago) by tdb
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.1:	+0 -0 lines
State:	*FILE REMOVED*
Error occurred while calculating annotation data.
Log Message:	Tidy up of files. These are all old things that are not only no longer used but are also probably useless to anyone other than us. This saves checking them out all the time, and makes the "cms/source" tree contain only current stuff. They'll still exist in the attic's though :)
#	Content
1	//----------------------------------------------------------------------------
2	// File: CommObj.hh
3	// Author: Bala Swaminathan 5/12/94
4	// This file contains interface of the Network Communication Object class.
5	//
6	// Copyright 1994, Washington University in St. Louis
7	//----------------------------------------------------------------------------
8
9	// The following CommObj is modeled using the sockets.
10	// Each PRO creates a CommObj of type CommObj::PRIMARY and this becomes
11	// its main socket. Later whenever it needs a "new" socket it either
12	// (1) creates a socket of type CommObj::SECONDARY and then "connects"
13	// to another PRO's primary socket, or (2) the PRO can "accept" a connection
14	// from another PRO's secondary socket. This "accepting" a connection, if
15	// succesful, results in the creation of a socket of type CommObj::SECONDARY.
16
17	#ifndef CommObj_hh
18	#define CommObj_hh
19
20	#include "sockinet.h"
21
22	class CommObj : public sockinetbuf {
23	public:
24	enum type { PRIMARY, SECONDARY };
25	public:
26	CommObj (const type ty = SECONDARY, // "do-nothing" constructor
27	const int portID=0) // can specify a port (for PRIMARY)
28	: sockinetbuf(sockbuf::sock_stream) // TCP Sockets
29	{
30	if (ty == PRIMARY) {
31	sockinetaddr addr (INADDR_ANY, portID);
32	// this creates addr of INADDR_ANY and port=0
33	// i.e. sockets bound to any address can "connect" to us
34	bind (addr); // bind to the above address
35	listen (); // now listen (default 5) for new connections
36	}
37	}
38	CommObj (const sockbuf& sb): sockinetbuf (sb) {}
39
40	const sockinetbuf sbuf () { return *this; } // for DEUBUGGING purposes
41	};
42
43	// The CommController manages all the CommObj instances in the PROTOCOL.
44	// (* the list of CommObj* maintained by CommController are not shown *)
45
46	class CommController {
47	public:
48	CommController (int portID=0) // creates the PERIMARY CommObj
49	{
50	c_server = new CommObj (CommObj::PRIMARY, portID);
51	}
52	~CommController () // close all sockets and delete list
53	{ delete c_server; }
54	CommObj* server () // return "main" socket
55	{ return c_server; }
56	CommObj accept () // accept connection on the SERVER Commobj
57	{
58	// return c_server->accept();
59	sockinetaddr sa;
60	sockinetbuf si = c_server->accept(sa);
61	cout << " accept(): peer.host = " << sa.gethostname() << endl;
62	cout << " accept(): peer.port = " << sa.getport() << endl;
63	cout << " acc: local.host = " << (si).localhost() << endl;
64	cout << " acc: local.port = " << (si).localport() << endl;
65	cout << " acc: peer.host = " << (si).peerhost() << endl;
66	cout << " acc: peer.port = " << (si).peerport() << endl;
67	return si;
68	}
69	private:
70	CommObj* c_server; // the server or the main Object
71	};
72
73	#endif CommObj_hh
74