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

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

Parent Directory Parent Directory | Revision Log Revision Log


Revision 6554 - (hide annotations)
Sat Oct 3 16:56:36 2015 UTC (5 years 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 adx 30 /*
2 michael 2916 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 adx 30 *
4 michael 5346 * Copyright (c) 1997-2015 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 michael 4564 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 adx 30 * USA
20     */
21 michael 1243
22 michael 2916 /*! \file fdlist.c
23     * \brief Maintains a list of file descriptors.
24     * \version $Id$
25     */
26    
27 adx 30 #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 michael 4341 #include "conf.h" /* ConfigServerInfo */
35 adx 30 #include "send.h"
36     #include "memory.h"
37     #include "numeric.h"
38 michael 3347 #include "misc.h"
39 michael 3322 #include "res.h"
40 adx 30
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 michael 4877 void
48     fdlist_init(void)
49 adx 30 {
50     int fdmax;
51     struct rlimit limit;
52    
53 michael 1236 if (!getrlimit(RLIMIT_NOFILE, &limit))
54 adx 30 {
55     limit.rlim_cur = limit.rlim_max;
56 michael 1236 setrlimit(RLIMIT_NOFILE, &limit);
57 adx 30 }
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 michael 1736 hard_fdlimit = IRCD_MIN(fdmax, 65536);
68 adx 30 }
69    
70     static inline unsigned int
71     hash_fd(int fd)
72     {
73 michael 2916 return ((unsigned int)fd) % FD_HASH_SIZE;
74 adx 30 }
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 michael 2916 return F;
85 adx 30 F = F->hnext;
86     }
87    
88 michael 2916 return NULL;
89 adx 30 }
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 michael 5591
97 adx 30 assert(fd >= 0);
98 michael 5591 assert(!F->flags.open);
99 adx 30
100     F->fd = fd;
101     F->comm_index = -1;
102 michael 3603
103 adx 30 if (desc)
104     strlcpy(F->desc, desc, sizeof(F->desc));
105 michael 3603
106 adx 30 /* 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 michael 5591 assert(F->flags.open);
123    
124 adx 30 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 michael 992 delete_resolver_queries(F);
131 adx 30
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 michael 3603 else
140     {
141 adx 30 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 michael 436
153     memset(F, 0, sizeof(fde_t));
154 adx 30 }
155    
156     /*
157     * fd_dump() - dump the list of active filedescriptors
158     */
159     void
160 michael 4478 fd_dump(struct Client *source_p, int parc, char *parv[])
161 adx 30 {
162 michael 3590 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
163     for (fde_t *F = fd_hash[i]; F; F = F->hnext)
164 michael 5582 sendto_one_numeric(source_p, &me, RPL_STATSDEBUG | SND_EXPLICIT,
165 michael 3590 "F :fd %-5d desc '%s'", F->fd, F->desc);
166 adx 30 }
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 michael 3601 if (format)
180 adx 30 {
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 michael 3601 for (unsigned int i = 0; i < LOWEST_SAFE_FD; ++i)
196 adx 30 {
197     close(i);
198 michael 3601
199 michael 1329 if (open("/dev/null", O_RDWR) < 0)
200 michael 6554 exit(EXIT_FAILURE); /* we're hosed if we can't even open /dev/null */
201 adx 30 }
202     }
203    
204     void
205     close_fds(fde_t *one)
206     {
207 michael 3601 for (unsigned int i = 0; i < FD_HASH_SIZE; ++i)
208 michael 3603 for (fde_t *F = fd_hash[i]; F; F = F->hnext)
209 adx 30 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