ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/fdlist.c
Revision: 7105
Committed: Sat Jan 23 20:11:27 2016 UTC (8 years, 2 months ago) by michael
Content type: text/x-csrc
File size: 4766 byte(s)
Log Message:
- Incorporate gnutls support by Adam & Attila

File Contents

# Content
1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 1997-2016 ircd-hybrid development team
5 *
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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 * USA
20 */
21
22 /*! \file fdlist.c
23 * \brief Maintains a list of file descriptors.
24 * \version $Id$
25 */
26
27 #include "stdinc.h"
28 #include "fdlist.h"
29 #include "client.h" /* struct Client */
30 #include "event.h"
31 #include "ircd.h" /* GlobalSetOptions */
32 #include "irc_string.h"
33 #include "s_bsd.h" /* comm_setselect */
34 #include "conf.h" /* ConfigServerInfo */
35 #include "send.h"
36 #include "memory.h"
37 #include "numeric.h"
38 #include "misc.h"
39 #include "res.h"
40
41 fde_t *fd_hash[FD_HASH_SIZE];
42 fde_t *fd_next_in_loop = NULL;
43 int number_fd = LEAKED_FDS;
44 int hard_fdlimit = 0;
45
46
47 void
48 fdlist_init(void)
49 {
50 int fdmax;
51 struct rlimit limit;
52
53 if (!getrlimit(RLIMIT_NOFILE, &limit))
54 {
55 limit.rlim_cur = limit.rlim_max;
56 setrlimit(RLIMIT_NOFILE, &limit);
57 }
58
59 fdmax = getdtablesize();
60
61 /* allow MAXCLIENTS_MIN clients even at the cost of MAX_BUFFER and
62 * some not really LEAKED_FDS */
63 fdmax = IRCD_MAX(fdmax, LEAKED_FDS + MAX_BUFFER + MAXCLIENTS_MIN);
64
65 /* under no condition shall this raise over 65536
66 * for example user ip heap is sized 2*hard_fdlimit */
67 hard_fdlimit = IRCD_MIN(fdmax, 65536);
68 }
69
70 static inline unsigned int
71 hash_fd(int fd)
72 {
73 return ((unsigned int)fd) % FD_HASH_SIZE;
74 }
75
76 fde_t *
77 lookup_fd(int fd)
78 {
79 fde_t *F = fd_hash[hash_fd(fd)];
80
81 while (F)
82 {
83 if (F->fd == fd)
84 return F;
85 F = F->hnext;
86 }
87
88 return NULL;
89 }
90
91 /* Called to open a given filedescriptor */
92 void
93 fd_open(fde_t *F, int fd, int is_socket, const char *desc)
94 {
95 unsigned int hashv = hash_fd(fd);
96
97 assert(fd >= 0);
98 assert(!F->flags.open);
99
100 F->fd = fd;
101 F->comm_index = -1;
102
103 if (desc)
104 strlcpy(F->desc, desc, sizeof(F->desc));
105
106 /* Note: normally we'd have to clear the other flags,
107 * but currently F is always cleared before calling us.. */
108 F->flags.open = 1;
109 F->flags.is_socket = is_socket;
110 F->hnext = fd_hash[hashv];
111 fd_hash[hashv] = F;
112
113 number_fd++;
114 }
115
116 /* Called to close a given filedescriptor */
117 void
118 fd_close(fde_t *F)
119 {
120 unsigned int hashv = hash_fd(F->fd);
121
122 assert(F->flags.open);
123
124 if (F == fd_next_in_loop)
125 fd_next_in_loop = F->hnext;
126
127 if (F->flags.is_socket)
128 comm_setselect(F, COMM_SELECT_WRITE | COMM_SELECT_READ, NULL, NULL, 0);
129
130 delete_resolver_queries(F);
131
132 if (tls_isusing(&F->ssl))
133 tls_free(&F->ssl);
134
135 if (fd_hash[hashv] == F)
136 fd_hash[hashv] = F->hnext;
137 else
138 {
139 fde_t *prev;
140
141 /* let it core if not found */
142 for (prev = fd_hash[hashv]; prev->hnext != F; prev = prev->hnext)
143 ;
144 prev->hnext = F->hnext;
145 }
146
147 /* Unlike squid, we're actually closing the FD here! -- adrian */
148 close(F->fd);
149 number_fd--;
150
151 memset(F, 0, sizeof(fde_t));
152 }
153
154 /*
155 * fd_dump() - dump the list of active filedescriptors
156 */
157 void
158 fd_dump(struct Client *source_p, int parc, char *parv[])
159 {
160 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
161 for (fde_t *F = fd_hash[i]; F; F = F->hnext)
162 sendto_one_numeric(source_p, &me, RPL_STATSDEBUG | SND_EXPLICIT,
163 "F :fd %-5d desc '%s'", F->fd, F->desc);
164 }
165
166 /*
167 * fd_note() - set the fd note
168 *
169 * Note: must be careful not to overflow fd_table[fd].desc when
170 * calling.
171 */
172 void
173 fd_note(fde_t *F, const char *format, ...)
174 {
175 va_list args;
176
177 if (format)
178 {
179 va_start(args, format);
180 vsnprintf(F->desc, sizeof(F->desc), format, args);
181 va_end(args);
182 }
183 else
184 F->desc[0] = '\0';
185 }
186
187 /* Make sure stdio descriptors (0-2) and profiler descriptor (3)
188 * always go somewhere harmless. Use -foreground for profiling
189 * or executing from gdb */
190 void
191 close_standard_fds(void)
192 {
193 for (unsigned int i = 0; i < LOWEST_SAFE_FD; ++i)
194 {
195 close(i);
196
197 if (open("/dev/null", O_RDWR) < 0)
198 exit(EXIT_FAILURE); /* we're hosed if we can't even open /dev/null */
199 }
200 }
201
202 void
203 close_fds(fde_t *one)
204 {
205 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
206 for (fde_t *F = fd_hash[i]; F; F = F->hnext)
207 if (F != one)
208 close(F->fd);
209 }

Properties

Name Value
svn:eol-style native
svn:keywords Id Revision