ermyth/include/connection.h

/**
 * connection.h: This contains the connection_t structure.
 *
 * Copyright © 2007 Pippijn van Steenhoven / The Ermyth Team
 * Rights to this code are as documented in COPYING.
 *
 *
 * Portions of this file were derived from sources bearing the following license:
 * Copyright © 2005 Atheme Development Group
 * Rights to this code are as documented in doc/pod/license.pod.
 *
 * $Id: connection.h,v 1.7 2007-09-16 18:54:42 pippijn Exp $
 */

#ifndef CONNECTION_H
#define CONNECTION_H

#include <deque>

#include <util/containers.h>
#include <ermyth/callback.h>

#define SENDQSIZE (4096 - 40)

/* packetqueue struct */
struct packetqueue : zero_initialised
{
  node_t node;
  int firstused;                /* offset of first used byte */
  int firstfree;                /* 1 + offset of last used byte */
  char buf[SENDQSIZE];

  packetqueue ()
  : firstused (0), firstfree (0)
  {
  }
};

enum connection_flag
{
  CF_UPLINK     = 1 << 0,
  CF_DCCOUT     = 1 << 1,
  CF_DCCIN      = 1 << 2,
  
  CF_CONNECTING = 1 << 3,
  CF_LISTENING  = 1 << 4,
  CF_CONNECTED  = 1 << 5,
  CF_DEAD       = 1 << 6,
  
  CF_NONEWLINE  = 1 << 7,
  CF_SEND_EOF   = 1 << 8,     /* shutdown(2) write end if sendque empty */
  CF_SEND_DEAD  = 1 << 9      /* write end shut down */
};

class connection_t : public object, public zero_initialised
{
  void _destroy ()
  {
    delete this;
  }

  struct callbacks
  {
    functor::callback1<connection_t *> connected;
  };

public:
  unsigned flags;

  bool is_uplink     () { return flags & CF_UPLINK;              }
  bool is_dcc        () { return flags & (CF_DCCOUT | CF_DCCIN); }
  bool is_dccout     () { return flags & CF_DCCOUT;              }
  bool is_dccin      () { return flags & CF_DCCIN;               }
  bool is_dead       () { return flags & CF_DEAD;                }
  bool is_connecting () { return flags & CF_CONNECTING;          }
  bool is_listening  () { return flags & CF_LISTENING;           }

public:
  unsigned index; // for list_type
  typedef indexing_vector<connection_t> list_type;
  static list_type list;

public:

  typedef std::deque<packetqueue *> queue;

  char name[HOSTLEN];
  char hbuf[BUFSIZE + 1];

  queue recvq;
  queue sendq;

  int fd;
  int pollslot;

  time_t first_recv;
  time_t last_recv;

  struct sockaddr_in *sa;
  struct sockaddr saddr;
  unsigned int saddr_size;

  void (*read_handler) (connection_t *);
  void (*write_handler) (connection_t *);

  void (*recvq_handler) (connection_t *);
  void (*close_handler) (connection_t *);
  connection_t *listener;
  void *userdata;

  static callbacks callback;

public:
  static connection_t *create (char const * const name, int fd, unsigned int flags,
                               void (*read_handler) (connection_t *), void (*write_handler) (connection_t *));
  static connection_t *open_tcp (char const * const host, char const * const vhost, unsigned int port,
                                 void (*read_handler) (connection_t *), void (*write_handler) (connection_t *));
  static connection_t *open_listener_tcp (char const * const host, unsigned int port, void (*read_handler) (connection_t *));
  static connection_t *accept_tcp (connection_t *, void (*)(connection_t *), void (*)(connection_t *));

  void setselect (connection_t *cptr, void (*)(connection_t *), void (*)(connection_t *));
  void close ();
  void close_soon ();
  void close_soon_children ();
  static void close_all (void);
  static void stats (void (*)(char const *, void *), void *);
  void write (char *format, ...);
  void write_raw (char *data);
  static connection_t *find (int);
  static void select (time_t delay);
  static int count (void);
};

#endif
Revision:	1.8
Committed:	Sat Sep 22 14:27:26 2007 UTC (16 years, 8 months ago) by pippijn
Content type:	text/plain
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.7:	+2 -2 lines
Log Message:	split up ermyth into ermyth-modules, libermyth (currently just ermyth-util) and ermyth-core
#	User	Rev	Content
1	pippijn	1.7	/**
2			* connection.h: This contains the connection_t structure.
3			*
4			* Copyright © 2007 Pippijn van Steenhoven / The Ermyth Team
5			* Rights to this code are as documented in COPYING.
6			*
7			*
8			* Portions of this file were derived from sources bearing the following license:
9	pippijn	1.1	* Copyright © 2005 Atheme Development Group
10	pippijn	1.2	* Rights to this code are as documented in doc/pod/license.pod.
11	pippijn	1.1	*
12	pippijn	1.8	* $Id: connection.h,v 1.7 2007-09-16 18:54:42 pippijn Exp $
13	pippijn	1.1	*/
14
15			#ifndef CONNECTION_H
16			#define CONNECTION_H
17
18			#include <deque>
19
20	pippijn	1.8	#include <util/containers.h>
21	pippijn	1.3	#include <ermyth/callback.h>
22	pippijn	1.1
23			#define SENDQSIZE (4096 - 40)
24
25			/* packetqueue struct */
26	pippijn	1.3	struct packetqueue : zero_initialised
27	pippijn	1.1	{
28			node_t node;
29			int firstused; /* offset of first used byte */
30			int firstfree; /* 1 + offset of last used byte */
31			char buf[SENDQSIZE];
32
33			packetqueue ()
34			: firstused (0), firstfree (0)
35			{
36			}
37			};
38
39	pippijn	1.5	enum connection_flag
40			{
41			CF_UPLINK = 1 << 0,
42			CF_DCCOUT = 1 << 1,
43			CF_DCCIN = 1 << 2,
44
45			CF_CONNECTING = 1 << 3,
46			CF_LISTENING = 1 << 4,
47			CF_CONNECTED = 1 << 5,
48			CF_DEAD = 1 << 6,
49
50			CF_NONEWLINE = 1 << 7,
51			CF_SEND_EOF = 1 << 8, /* shutdown(2) write end if sendque empty */
52			CF_SEND_DEAD = 1 << 9 /* write end shut down */
53			};
54
55			class connection_t : public object, public zero_initialised
56	pippijn	1.1	{
57	pippijn	1.3	void _destroy ()
58			{
59			delete this;
60			}
61
62			struct callbacks
63			{
64			functor::callback1<connection_t *> connected;
65			};
66
67			public:
68	pippijn	1.5	unsigned flags;
69
70			bool is_uplink () { return flags & CF_UPLINK; }
71			bool is_dcc () { return flags & (CF_DCCOUT \| CF_DCCIN); }
72			bool is_dccout () { return flags & CF_DCCOUT; }
73			bool is_dccin () { return flags & CF_DCCIN; }
74			bool is_dead () { return flags & CF_DEAD; }
75			bool is_connecting () { return flags & CF_CONNECTING; }
76			bool is_listening () { return flags & CF_LISTENING; }
77	pippijn	1.4
78	pippijn	1.5	public:
79	pippijn	1.6	unsigned index; // for list_type
80	pippijn	1.5	typedef indexing_vector<connection_t> list_type;
81			static list_type list;
82	pippijn	1.4
83			public:
84	pippijn	1.3
85	pippijn	1.1	typedef std::deque<packetqueue *> queue;
86
87			char name[HOSTLEN];
88			char hbuf[BUFSIZE + 1];
89
90			queue recvq;
91			queue sendq;
92
93			int fd;
94			int pollslot;
95
96			time_t first_recv;
97			time_t last_recv;
98
99			struct sockaddr_in *sa;
100			struct sockaddr saddr;
101			unsigned int saddr_size;
102
103			void (read_handler) (connection_t );
104			void (write_handler) (connection_t );
105
106			void (recvq_handler) (connection_t );
107			void (close_handler) (connection_t );
108			connection_t *listener;
109			void *userdata;
110
111			static callbacks callback;
112	pippijn	1.4
113			public:
114			static connection_t create (char const const name, int fd, unsigned int flags,
115			void (read_handler) (connection_t ), void (write_handler) (connection_t ));
116			static connection_t open_tcp (char const const host, char const * const vhost, unsigned int port,
117			void (read_handler) (connection_t ), void (write_handler) (connection_t ));
118			static connection_t open_listener_tcp (char const const host, unsigned int port, void (read_handler) (connection_t ));
119			static connection_t accept_tcp (connection_t , void ()(connection_t ), void ()(connection_t ));
120
121			void setselect (connection_t cptr, void ()(connection_t ), void ()(connection_t *));
122			void close ();
123			void close_soon ();
124			void close_soon_children ();
125			static void close_all (void);
126			static void stats (void ()(char const , void ), void );
127			void write (char *format, ...);
128			void write_raw (char *data);
129			static connection_t *find (int);
130			static void select (time_t delay);
131			static int count (void);
132	pippijn	1.3	};
133	pippijn	1.1
134			#endif