1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
|
/*
* Copyright (c) 2005 Atheme Development Group
* Rights to this code are as documented in doc/LICENSE.
*
* This contains the connection_t structure.
*
*/
#ifndef CONNECTION_H
#define CONNECTION_H
typedef union sockaddr_any_ sockaddr_any_t;
union sockaddr_any_
{
struct sockaddr sa;
struct sockaddr_in sin;
struct sockaddr_in6 sin6;
};
#define SOCKADDR(foo) (struct sockaddr *) &(foo)
#define SOCKADDR_IN(foo) (struct sockaddr_in *) &(foo)
#define SOCKADDR_IN6(foo) (struct sockaddr_in6 *) &(foo)
typedef struct connection_ connection_t;
struct connection_
{
char name[HOSTLEN];
char hbuf[BUFSIZE + 1];
mowgli_list_t recvq;
mowgli_list_t sendq;
int fd;
int pollslot;
time_t first_recv;
time_t last_recv;
size_t sendq_limit;
sockaddr_any_t saddr;
socklen_t saddr_size;
void (*read_handler)(connection_t *);
void (*write_handler)(connection_t *);
unsigned int flags;
void (*recvq_handler)(connection_t *);
void (*close_handler)(connection_t *);
connection_t *listener;
void *userdata;
};
#define CF_UPLINK 0x00000001
#define CF_DCCOUT 0x00000002
#define CF_DCCIN 0x00000004
#define CF_CONNECTING 0x00000008
#define CF_LISTENING 0x00000010
#define CF_CONNECTED 0x00000020
#define CF_DEAD 0x00000040
#define CF_NONEWLINE 0x00000080
#define CF_SEND_EOF 0x00000100 /* shutdown(2) write end if sendq empty */
#define CF_SEND_DEAD 0x00000200 /* write end shut down */
#define CF_IS_UPLINK(x) ((x)->flags & CF_UPLINK)
#define CF_IS_DCC(x) ((x)->flags & (CF_DCCOUT | CF_DCCIN))
#define CF_IS_DCCOUT(x) ((x)->flags & CF_DCCOUT)
#define CF_IS_DCCIN(x) ((x)->flags & CF_DCCIN)
#define CF_IS_DEAD(x) ((x)->flags & CF_DEAD)
#define CF_IS_CONNECTING(x) ((x)->flags & CF_CONNECTING)
#define CF_IS_LISTENING(x) ((x)->flags & CF_LISTENING)
extern connection_t *connection_add(const char *, int, unsigned int,
void(*)(connection_t *),
void(*)(connection_t *));
extern connection_t *connection_open_tcp(char *, char *, unsigned int,
void(*)(connection_t *),
void(*)(connection_t *));
extern connection_t *connection_open_listener_tcp(char *, unsigned int,
void(*)(connection_t *));
extern connection_t *connection_accept_tcp(connection_t *,
void(*)(connection_t *),
void(*)(connection_t *));
extern void connection_setselect_read(connection_t *, void(*)(connection_t *));
extern void connection_setselect_write(connection_t *, void(*)(connection_t *));
extern void connection_close(connection_t *);
extern void connection_close_soon(connection_t *);
extern void connection_close_soon_children(connection_t *);
extern void connection_close_all(void);
extern void connection_close_all_fds(void);
extern void connection_stats(void (*)(const char *, void *), void *);
extern connection_t *connection_find(int);
extern void connection_select(int delay);
//inline int connection_count(void);
extern mowgli_list_t connection_list;
#endif
/* vim:cinoptions=>s,e0,n0,f0,{0,}0,^0,=s,ps,t0,c3,+s,(2s,us,)20,*30,gs,hs
* vim:ts=8
* vim:sw=8
* vim:noexpandtab
*/
|
