trunk/include/fdlist.h

/*
 *  ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
 *
 *  Copyright (c) 1997-2014 ircd-hybrid development team
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 *  USA
 */

/*! \file fdlist.h
 * \brief The file descriptor list header.
 * \version $Id$
 */

#ifndef INCLUDED_fdlist_h
#define INCLUDED_fdlist_h
#define FILEIO_V2

#include "ircd_defs.h"
#define FD_DESC_SZ 128  /* hostlen + comment */

enum
{
  COMM_OK,
  COMM_ERR_BIND,
  COMM_ERR_DNS,
  COMM_ERR_TIMEOUT,
  COMM_ERR_CONNECT,
  COMM_ERROR,
  COMM_ERR_MAX
};

struct _fde;
struct Client;

/* Callback for completed connections */
/* int fd, int status, void * */
typedef void CNCB(struct _fde *, int, void *);

typedef struct _fde
{
  /* New-school stuff, again pretty much ripped from squid */
  /*
   * Yes, this gives us only one pending read and one pending write per
   * filedescriptor. Think though: when do you think we'll need more?
   */
  int fd;  /* So we can use the fde_t as a callback ptr */
  int comm_index;  /* where in the poll list we live */
  int evcache;          /* current fd events as set up by the underlying I/O */
  char desc[FD_DESC_SZ];
  void (*read_handler)(struct _fde *, void *);
  void *read_data;
  void (*write_handler)(struct _fde *, void *);
  void *write_data;
  void (*timeout_handler)(struct _fde *, void *);
  void *timeout_data;
  time_t timeout;
  void (*flush_handler)(struct _fde *, void *);
  void *flush_data;
  time_t flush_timeout;

  struct
  {
    unsigned int open:1;
    unsigned int is_socket:1;
  } flags;

  struct
  {
    /* We don't need the host here ? */
    struct irc_ssaddr S;
    struct irc_ssaddr hostaddr;
    CNCB *callback;
    void *data;
    /* We'd also add the retry count here when we get to that -- adrian */
  } connect;
#ifdef HAVE_LIBCRYPTO
  SSL *ssl;
#endif
  struct _fde *hnext;
} fde_t;

#define FD_HASH_SIZE 1024

extern int number_fd;
extern int hard_fdlimit;
extern fde_t *fd_hash[];
extern fde_t *fd_next_in_loop;

extern void fdlist_init(void);
extern fde_t *lookup_fd(int);
extern void fd_open(fde_t *, int, int, const char *);
extern void fd_close(fde_t *);
extern void fd_dump(struct Client *);
extern void fd_note(fde_t *, const char *, ...);
extern void close_standard_fds(void);
extern void close_fds(fde_t *);
#endif /* INCLUDED_fdlist_h */
Revision:	4461
Committed:	Wed Aug 13 17:05:26 2014 UTC (11 years, 11 months ago) by michael
Content type:	text/x-chdr
File size:	3002 byte(s)
Log Message:	- Removed stupid PF typedef in fdlist.h which prevented both gcc and clang from spitting out a warning about the first argument of s_bsd:ssl_handshake() being an 'int' when it really has to be a 'fde_t' pointer. - Fixed first argument of s_bsd:ssl_handshake() which should be a 'fde_t' pointer instead of an 'int'.
#	User	Rev	Content
1	adx	30	/*
2	michael	2865	* ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3	adx	30	*
4	michael	2865	* Copyright (c) 1997-2014 ircd-hybrid development team
5	adx	30	*
6			* This program is free software; you can redistribute it and/or modify
7			* it under the terms of the GNU General Public License as published by
8			* the Free Software Foundation; either version 2 of the License, or
9			* (at your option) any later version.
10			*
11			* This program is distributed in the hope that it will be useful,
12			* but WITHOUT ANY WARRANTY; without even the implied warranty of
13			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14			* GNU General Public License for more details.
15			*
16			* You should have received a copy of the GNU General Public License
17			* along with this program; if not, write to the Free Software
18			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
19			* USA
20			*/
21
22	michael	2865	/*! \file fdlist.h
23			* \brief The file descriptor list header.
24			* \version $Id$
25			*/
26
27	adx	30	#ifndef INCLUDED_fdlist_h
28			#define INCLUDED_fdlist_h
29			#define FILEIO_V2
30
31			#include "ircd_defs.h"
32			#define FD_DESC_SZ 128 /* hostlen + comment */
33
34	michael	2865	enum
35			{
36			COMM_OK,
37			COMM_ERR_BIND,
38			COMM_ERR_DNS,
39			COMM_ERR_TIMEOUT,
40			COMM_ERR_CONNECT,
41			COMM_ERROR,
42			COMM_ERR_MAX
43	adx	30	};
44
45			struct _fde;
46			struct Client;
47
48			/* Callback for completed connections */
49			/* int fd, int status, void * */
50			typedef void CNCB(struct _fde , int, void );
51
52	michael	2865	typedef struct _fde
53			{
54	adx	30	/* New-school stuff, again pretty much ripped from squid */
55			/*
56			* Yes, this gives us only one pending read and one pending write per
57			* filedescriptor. Think though: when do you think we'll need more?
58			*/
59	michael	2865	int fd; /* So we can use the fde_t as a callback ptr */
60			int comm_index; /* where in the poll list we live */
61	adx	30	int evcache; /* current fd events as set up by the underlying I/O */
62			char desc[FD_DESC_SZ];
63	michael	4461	void (read_handler)(struct _fde , void *);
64	adx	30	void *read_data;
65	michael	4461	void (write_handler)(struct _fde , void *);
66	adx	30	void *write_data;
67	michael	4461	void (timeout_handler)(struct _fde , void *);
68	adx	30	void *timeout_data;
69			time_t timeout;
70	michael	4461	void (flush_handler)(struct _fde , void *);
71	adx	30	void *flush_data;
72			time_t flush_timeout;
73	michael	992
74	michael	2865	struct
75			{
76	adx	30	unsigned int open:1;
77			unsigned int is_socket:1;
78			} flags;
79
80	michael	2865	struct
81			{
82	adx	30	/* We don't need the host here ? */
83			struct irc_ssaddr S;
84			struct irc_ssaddr hostaddr;
85			CNCB *callback;
86			void *data;
87			/* We'd also add the retry count here when we get to that -- adrian */
88			} connect;
89			#ifdef HAVE_LIBCRYPTO
90			SSL *ssl;
91			#endif
92			struct _fde *hnext;
93			} fde_t;
94
95	michael	1654	#define FD_HASH_SIZE 1024
96	adx	30
97			extern int number_fd;
98			extern int hard_fdlimit;
99			extern fde_t *fd_hash[];
100			extern fde_t *fd_next_in_loop;
101
102			extern void fdlist_init(void);
103			extern fde_t *lookup_fd(int);
104			extern void fd_open(fde_t , int, int, const char );
105			extern void fd_close(fde_t *);
106			extern void fd_dump(struct Client *);
107	michael	1015	extern void fd_note(fde_t , const char , ...);
108	adx	30	extern void close_standard_fds(void);
109			extern void close_fds(fde_t *);
110			#endif /* INCLUDED_fdlist_h */