/[svn]/ircd-hybrid/branches/8.2.x/src/fdlist.c
ViewVC logotype

Contents of /ircd-hybrid/branches/8.2.x/src/fdlist.c

Parent Directory Parent Directory | Revision Log Revision Log


Revision 6554 - (show annotations)
Sat Oct 3 16:56:36 2015 UTC (4 years, 11 months ago) by michael
File MIME type: text/x-chdr
File size: 4780 byte(s)
- Use EXIT_FAILURE in some places instead of hardcoded values

1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 1997-2015 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 #ifdef HAVE_LIBCRYPTO
133 if (F->ssl)
134 SSL_free(F->ssl);
135 #endif
136
137 if (fd_hash[hashv] == F)
138 fd_hash[hashv] = F->hnext;
139 else
140 {
141 fde_t *prev;
142
143 /* let it core if not found */
144 for (prev = fd_hash[hashv]; prev->hnext != F; prev = prev->hnext)
145 ;
146 prev->hnext = F->hnext;
147 }
148
149 /* Unlike squid, we're actually closing the FD here! -- adrian */
150 close(F->fd);
151 number_fd--;
152
153 memset(F, 0, sizeof(fde_t));
154 }
155
156 /*
157 * fd_dump() - dump the list of active filedescriptors
158 */
159 void
160 fd_dump(struct Client *source_p, int parc, char *parv[])
161 {
162 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
163 for (fde_t *F = fd_hash[i]; F; F = F->hnext)
164 sendto_one_numeric(source_p, &me, RPL_STATSDEBUG | SND_EXPLICIT,
165 "F :fd %-5d desc '%s'", F->fd, F->desc);
166 }
167
168 /*
169 * fd_note() - set the fd note
170 *
171 * Note: must be careful not to overflow fd_table[fd].desc when
172 * calling.
173 */
174 void
175 fd_note(fde_t *F, const char *format, ...)
176 {
177 va_list args;
178
179 if (format)
180 {
181 va_start(args, format);
182 vsnprintf(F->desc, sizeof(F->desc), format, args);
183 va_end(args);
184 }
185 else
186 F->desc[0] = '\0';
187 }
188
189 /* Make sure stdio descriptors (0-2) and profiler descriptor (3)
190 * always go somewhere harmless. Use -foreground for profiling
191 * or executing from gdb */
192 void
193 close_standard_fds(void)
194 {
195 for (unsigned int i = 0; i < LOWEST_SAFE_FD; ++i)
196 {
197 close(i);
198
199 if (open("/dev/null", O_RDWR) < 0)
200 exit(EXIT_FAILURE); /* we're hosed if we can't even open /dev/null */
201 }
202 }
203
204 void
205 close_fds(fde_t *one)
206 {
207 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
208 for (fde_t *F = fd_hash[i]; F; F = F->hnext)
209 if (F != one)
210 close(F->fd);
211 }

Properties

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

svnadmin@ircd-hybrid.org
ViewVC Help
Powered by ViewVC 1.1.28