pegasus/unrealircd
1
0
Fork 0
mirror of https://github.com/unrealircd/unrealircd.git synced 2026-06-12 19:14:46 +02:00
Code Activity
Files
4d5d474bbdc07a1a362dfa915fdeda16c2e6819f
unrealircd/src/ircd.c
T
stskeeps 4d5d474bbd +- Removed SJOIN/SJOIN2 support in SJOIN 
+- Fixed a +f bug, found by NiQuiL
+- Applied McSkaf's winlocal.patch, seems to work ok, fixed some problems
+  though in unix/win32 (cptr->fd can be -3. Should fix some READ ERRORS as
+  well. McSkaf, do me a favour and remove all of the C++ comments in the
+  source (//) or modify them to /* */
2001-05-01 15:03:07 +00:00

1552 lines
37 KiB
C
Raw Blame History

/************************************************************************
* Unreal Internet Relay Chat Daemon, src/ircd.c
* Copyright (C) 1990 Jarkko Oikarinen and
* University of Oulu, Computing Center
*
* 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 1, 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., 675 Mass Ave, Cambridge, MA 02139, USA.
*/
#ifndef lint
static char sccsid[] =
"@(#)ircd.c 2.48 3/9/94 (C) 1988 University of Oulu, \
Computing Center and Jarkko Oikarinen";
#endif
#include "config.h"
#include "struct.h"
#include "common.h"
#include "sys.h"
#include "numeric.h"
#include "userload.h"
#include "msg.h"
#include <sys/stat.h>
#include <signal.h>
#include <fcntl.h>
#include <sys/types.h>
#ifndef _WIN32
#include <sys/file.h>
#include <pwd.h>
#include <sys/time.h>
#else
#include <io.h>
#include <direct.h>
#endif
#ifdef HPUX
#define _KERNEL /* HPUX has the world's worst headers... */
#endif
#ifndef _WIN32
#include <sys/resource.h>
#endif
#ifdef HPUX
#undef _KERNEL
#endif
#include <errno.h>
#include "h.h"
#ifndef NO_FDLIST
#include "fdlist.h"
#endif
#ifdef STRIPBADWORDS
#include "badwords.h"
#endif
#include "version.h"
#include "proto.h"
ID_Copyright
("(C) 1988 University of Oulu, Computing Center and Jarkko Oikarinen");
ID_Notes("2.48 3/9/94");
#ifdef __FreeBSD__
char *malloc_options = "h" MALLOC_FLAGS_EXTRA;
#endif
/* Added DrBin */
#ifndef BIG_SECURITY_HOLE
int un_uid = 99;
int un_gid = 99;
#endif
/* End */
#ifndef _WIN32
extern char unreallogo[];
#endif
LoopStruct loop;
extern aMotd *opermotd;
extern aMotd *svsmotd;
extern aMotd *motd;
extern aMotd *rules;
extern aMotd *botmotd;
#ifdef SHOWCONNECTINFO
int R_do_dns, R_fin_dns, R_fin_dnsc, R_fail_dns, R_do_id, R_fin_id, R_fail_id;
#ifdef SOCKSPORT
int R_do_socks, R_no_socks, R_good_socks;
#endif
char REPORT_DO_DNS[128], REPORT_FIN_DNS[128], REPORT_FIN_DNSC[128],
REPORT_FAIL_DNS[128], REPORT_DO_ID[128], REPORT_FIN_ID[128],
REPORT_FAIL_ID[128];
#ifdef SOCKSPORT
char REPORT_DO_SOCKS[128], REPORT_NO_SOCKS[128], REPORT_GOOD_SOCKS[128];
#endif
#endif
extern ircstats IRCstats;
aClient me; /* That's me */
char *me_hash;
aClient *client = &me; /* Pointer to beginning of Client list */
extern char backupbuf[8192];
#ifdef _WIN32
extern void CleanUpSegv(int sig);
#endif
#ifndef NO_FDLIST
fdlist default_fdlist;
fdlist busycli_fdlist;
fdlist serv_fdlist;
fdlist oper_fdlist;
fdlist unknown_fdlist;
float currentrate;
float currentrate2; /* outgoing */
float highest_rate = 0;
float highest_rate2 = 0;
int lifesux = 0;
int LRV = LOADRECV;
TS LCF = LOADCFREQ;
int currlife = 0;
int HTMLOCK = 0;
int noisy_htm = 1;
TS check_fdlists();
#endif
unsigned char conf_debuglevel = 0;
void save_stats(void)
{
FILE *stats = fopen("ircd.stats", "w");
if (!stats)
return;
fprintf(stats, "%li\n", IRCstats.clients);
fprintf(stats, "%li\n", IRCstats.invisible);
fprintf(stats, "%li\n", IRCstats.servers);
fprintf(stats, "%li\n", IRCstats.operators);
fprintf(stats, "%li\n", IRCstats.unknown);
fprintf(stats, "%li\n", IRCstats.me_clients);
fprintf(stats, "%li\n", IRCstats.me_servers);
fprintf(stats, "%li\n", IRCstats.me_max);
fprintf(stats, "%li\n", IRCstats.global_max);
fclose(stats);
}
void server_reboot(char *);
void restart PROTO((char *));
static void open_debugfile(), setup_signals();
extern void init_glines(void);
TS last_garbage_collect = 0;
char **myargv;
int portnum = -1; /* Server port number, listening this */
char *configfile = CONFIGFILE; /* Server configuration file */
int debuglevel = -1; /* Server debug level */
int bootopt = 0; /* Server boot option flags */
char *debugmode = ""; /* -"- -"- -"- */
char *sbrk0; /* initial sbrk(0) */
static int dorehash = 0;
static char *dpath = DPATH;
int booted = FALSE;
TS nextconnect = 1; /* time for next try_connections call */
TS nextping = 1; /* same as above for check_pings() */
TS nextdnscheck = 0; /* next time to poll dns to force timeouts */
TS nextexpire = 1; /* next expire run on the dns cache */
TS nextkillcheck = 1; /* next time to check for nickserv kills */
TS lastlucheck = 0;
#ifdef UNREAL_DEBUG
#undef CHROOTDIR
#define CHROOT
#endif
TS NOW;
#if defined(PROFIL) && !defined(_WIN32)
extern etext();
VOIDSIG s_monitor()
{
static int mon = 0;
#ifdef POSIX_SIGNALS
struct sigaction act;
#endif
(void)moncontrol(mon);
mon = 1 - mon;
#ifdef POSIX_SIGNALS
act.sa_handler = s_rehash;
act.sa_flags = 0;
(void)sigemptyset(&act.sa_mask);
(void)sigaddset(&act.sa_mask, SIGUSR1);
(void)sigaction(SIGUSR1, &act, NULL);
#else
(void)signal(SIGUSR1, s_monitor);
#endif
}
#endif
VOIDSIG s_die()
{
#ifdef USE_SYSLOG
(void)syslog(LOG_CRIT, "Server Killed By SIGTERM");
#endif
flush_connections(me.fd);
#ifndef _WIN32
exit(-1);
#endif
}
#ifndef _WIN32
static VOIDSIG s_rehash()
#else
VOIDSIG s_rehash()
#endif
{
#ifdef POSIX_SIGNALS
struct sigaction act;
#endif
dorehash = 1;
#ifdef POSIX_SIGNALS
act.sa_handler = s_rehash;
act.sa_flags = 0;
(void)sigemptyset(&act.sa_mask);
(void)sigaddset(&act.sa_mask, SIGHUP);
(void)sigaction(SIGHUP, &act, NULL);
#else
# ifndef _WIN32
(void)signal(SIGHUP, s_rehash); /* sysV -argv */
# endif
#endif
}
void restart(mesg)
char *mesg;
{
#ifdef USE_SYSLOG
(void)syslog(LOG_WARNING, "Restarting Server because: %s", mesg);
#endif
server_reboot(mesg);
}
VOIDSIG s_restart()
{
static int restarting = 0;
#ifdef USE_SYSLOG
(void)syslog(LOG_WARNING, "Server Restarting on SIGINT");
#endif
if (restarting == 0)
{
/* Send (or attempt to) a dying scream to oper if present */
restarting = 1;
server_reboot("SIGINT");
}
}
VOIDSIG s_segv()
{
#ifdef POSIX_SIGNALS
struct sigaction act;
#endif
int i;
FILE *log;
int p;
static TS segv_last = (TS)0;
#ifdef RENAME_CORE
char corename[512];
#else
# define corename "core"
#endif
if (!segv_last)
{
sendto_ops("Recieved first Segfault, doing re-enter test");
segv_last = TStime();
return;
}
if ((TStime() - segv_last) > 5)
{
#ifdef USE_SYSLOG
(void)syslog(LOG_WARNING, "Possible fake segfault");
#endif
segv_last = TStime();
return;
}
#ifdef POSIX_SIGNALS
act.sa_flags = 0;
act.sa_handler = SIG_DFL;
(void)sigemptyset(&act.sa_mask);
(void)sigaction(SIGSEGV, &act, NULL);
#else
(void)signal(SIGSEGV, SIG_DFL);
#endif
#ifdef USE_SYSLOG
(void)syslog(LOG_WARNING, "Server terminating: Segmention fault!!!");
(void)closelog();
#endif
sendto_realops
("Aieeee!!! Server terminating: Segmention fault (buf: %s)",
backupbuf);
sendto_serv_butone(&me,
":%s GLOBOPS :AIEEE!!! Server Terminating: Segmention fault (buf: %s)",
me.name, backupbuf);
sendto_all_butone(NULL, &me,
"NOTICE ALL :SEGFAULT! I'm Meeeeellllting, what a world!");
log = fopen(lPATH, "a");
if (log)
{
fprintf(log,
"%li - Aieeee!!! Server terminating: Segmention fault (buf: %s)\n",
time(NULL), backupbuf);
fclose(log);
}
#if !defined(_WIN32) && !defined(_AMIGA)
p = getpid();
if (fork())
{
return;
}
write_pidfile();
#ifdef RENAME_CORE
(void)ircsprintf(corename, "core.%d", p);
(void)rename("core", corename);
#endif
sendto_realops
("Dumped core to %s - please read Unreal.nfo on what to do!",
corename);
#endif
flush_connections(me.fd);
#ifndef _WIN32
for (i = 3; i < MAXCONNECTIONS; i++)
{
(void)close(i);
}
kill(p, SIGQUIT);
#else
for (i = 0; i < highest_fd; i++)
{
if (closesocket(i) == -1)
close(i);
}
#endif
exit(-1);
}
void server_reboot(mesg)
char *mesg;
{
int i;
sendto_realops("Aieeeee!!! Restarting server... %s", mesg);
Debug((DEBUG_NOTICE, "Restarting server... %s", mesg));
flush_connections(me.fd);
/*
** fd 0 must be 'preserved' if either the -d or -i options have
** been passed to us before restarting.
*/
#ifdef USE_SYSLOG
(void)closelog();
#endif
#ifndef _WIN32
for (i = 3; i < MAXCONNECTIONS; i++)
(void)close(i);
if (!(bootopt & (BOOT_TTY | BOOT_DEBUG)))
(void)close(2);
(void)close(1);
if ((bootopt & BOOT_CONSOLE) || isatty(0))
(void)close(0);
(void)execv(MYNAME, myargv);
#else
for (i = 0; i < highest_fd; i++)
if (closesocket(i) == -1)
close(i);
(void)execv(myargv[0], myargv);
#endif
#ifdef USE_SYSLOG
/* Have to reopen since it has been closed above */
openlog(myargv[0], LOG_PID | LOG_NDELAY, LOG_FACILITY);
syslog(LOG_CRIT, "execv(%s,%s) failed: %m\n", MYNAME, myargv[0]);
closelog();
#endif
#ifndef _WIN32
Debug((DEBUG_FATAL, "Couldn't restart server: %s", strerror(errno)));
#else
Debug((DEBUG_FATAL, "Couldn't restart server: %s",
strerror(GetLastError())));
#endif
exit(-1);
}
char *areason;
/*
** try_connections
**
** Scan through configuration and try new connections.
** Returns the calendar time when the next call to this
** function should be made latest. (No harm done if this
** is called earlier or later...)
*/
static TS try_connections(currenttime)
TS currenttime;
{
ConfigItem_link *aconf;
ConfigItem_deny_link *deny;
aClient *cptr;
int connecting, confrq;
TS next = 0;
ConfigItem_class *cltmp;
connecting = FALSE;
Debug((DEBUG_NOTICE, "Connection check at : %s",
myctime(currenttime)));
for (aconf = conf_link; aconf; aconf = (ConfigItem_link *) aconf->next)
{
/* Also when already connecting! (update holdtimes) --SRB */
if (!(aconf->options & CONNECT_AUTO))
continue;
cltmp = aconf->class;
/*
** Skip this entry if the use of it is still on hold until
** future. Otherwise handle this entry (and set it on hold
** until next time). Will reset only hold times, if already
** made one successfull connection... [this algorithm is
** a bit fuzzy... -- msa >;) ]
*/
if ((aconf->hold > currenttime))
{
if ((next > aconf->hold) || (next == 0))
next = aconf->hold;
continue;
}
confrq = cltmp->connfreq;
aconf->hold = currenttime + confrq;
/*
** Found a CONNECT config with port specified, scan clients
** and see if this server is already connected?
*/
cptr = find_name(aconf->servername, (aClient *)NULL);
if (!cptr && (cltmp->clients < cltmp->maxclients))
{
/* Check connect rules to see if we're allowed to try */
for (deny = conf_deny_link; deny;
deny = (ConfigItem_deny_link *) deny->next)
if (!match(deny->mask, aconf->servername)
&& crule_eval(deny->rule))
break;
if (connect_server(aconf, (aClient *)NULL,
(struct hostent *)NULL) == 0)
sendto_realops("Connection to %s[%s] activated.",
aconf->servername, aconf->hostname);
}
if ((next > aconf->hold) || (next == 0))
next = aconf->hold;
}
Debug((DEBUG_NOTICE, "Next connection check : %s", myctime(next)));
return (next);
}
/* Now find_kill is only called when a kline-related command is used:
AKILL/RAKILL/KLINE/UNKLINE/REHASH. Very significant CPU usage decrease.
-- Barubary */
extern TS check_pings(TS currenttime, int check_kills)
{
aClient *cptr;
ConfigItem_ban *bconf = NULL;
int ping = 0, killflag = 0, i = 0;
TS oldest = 0;
static char banbuf[1024];
for (i = 0; i <= highest_fd; i++)
{
/* If something we should not touch .. */
if (!(cptr = local[i]) || IsMe(cptr) || IsLog(cptr))
continue;
/*
** Note: No need to notify opers here. It's
** already done when "FLAGS_DEADSOCKET" is set.
*/
if (cptr->flags & FLAGS_DEADSOCKET)
{
(void)exit_client(cptr, cptr, &me, "Dead socket");
continue;
}
bconf = NULL;
if (check_kills)
{
if (IsPerson(cptr))
{
bconf =
Find_ban(make_user_host(cptr->
user ? cptr->user->username : cptr->
username,
cptr->user ? cptr->user->realhost : cptr->
sockhost), CONF_BAN_USER);
if (bconf)
killflag = 1;
else
killflag = 0;
}
}
else
killflag = 0;
if (check_kills && !killflag && IsPerson(cptr))
{
if (bconf =
Find_ban(inetntoa((char *)&cptr->ip), CONF_BAN_IP))
{
killflag = 1;
}
if (find_tkline_match(cptr, 0) < 0)
{
continue;
}
if (!IsAnOper(cptr)
&& (bconf =
Find_ban(cptr->info, CONF_BAN_REALNAME)))
{
killflag = 1;
}
}
if (killflag)
{
if (IsPerson(cptr))
{
sendto_realops
("Kill line active for %s (%s)",
get_client_name(cptr, FALSE),
bconf ?
bconf->
reason ? bconf->reason : "no reason" :
"no reason");
if (bconf && bconf->reason)
{
ircsprintf(banbuf,
"User has been banned (%s)",
bconf->reason);
(void)exit_client(cptr, cptr, &me,
banbuf);
}
else
{
(void)exit_client(cptr, cptr, &me,
"User has been banned");
}
}
else
{
exit_client(cptr, cptr, &me, "Banned");
}
continue;
}
/* If we go here, its a ping timeout */
ping =
IsRegistered(cptr) ? (cptr->class ? cptr->
class->pingfreq : CONNECTTIMEOUT) : CONNECTTIMEOUT;
Debug((DEBUG_DEBUG, "c(%s)=%d p %d k %d a %d", cptr->name,
cptr->status, ping, killflag,
currenttime - cptr->lasttime));
if (ping < (currenttime - cptr->lasttime))
{
if (((cptr->flags & FLAGS_PINGSENT)
&& ((currenttime - cptr->lasttime) >= (2 * ping)))
|| ((!IsRegistered(cptr)
&& (currenttime - cptr->since) >= ping)))
{
if (!IsRegistered(cptr) &&
(DoingDNS(cptr) || DoingAuth(cptr)
#ifdef SOCKSPORT
|| DoingSocks(cptr)
#endif
))
{
if (cptr->authfd >= 0)
{
#ifndef _WIN32
(void)close(cptr->authfd);
#else
(void)closesocket(cptr->authfd);
#endif
cptr->authfd = -1;
cptr->count = 0;
*cptr->buffer = '\0';
}
#ifdef SOCKSPORT
if (cptr->socksfd >= 0)
{
#ifndef _WIN32
(void)close(cptr->socksfd);
#else
(void)closesocket(cptr->socksfd);
#endif /* _WIN32 */
cptr->socksfd = -1;
}
#endif /* SOCKSPORT */
#ifdef SHOWCONNECTINFO
if (DoingDNS(cptr))
sendto_one(cptr,REPORT_FAIL_DNS);
else if (DoingAuth(cptr))
sendto_one(cptr,REPORT_FAIL_ID);
#ifdef SOCKSPORT
else
sendto_one(cptr,REPORT_NO_SOCKS);
#endif /* SOCKSPORT */
#endif
Debug((DEBUG_NOTICE,"DNS/AUTH timeout %s",get_client_name(cptr, TRUE)));
del_queries((char *)cptr);
ClearAuth(cptr);
ClearDNS(cptr);
#ifdef SOCKSPORT
ClearSocks(cptr);
#endif
SetAccess(cptr);
cptr->firsttime = currenttime;
cptr->lasttime = currenttime;
continue;
}
if (IsServer(cptr) || IsConnecting(cptr) || IsHandshake(cptr))
{
sendto_realops("No response from %s, closing link",get_client_name(cptr, FALSE));
sendto_serv_butone(&me,":%s GLOBOPS :No response from %s, closing link",me.name, get_client_name(cptr,FALSE));
}
exit_client(cptr, cptr, &me, "Ping timeout");
continue;
}
else if (IsRegistered(cptr) && ((cptr->flags & FLAGS_PINGSENT) == 0))
{
/*
* if we havent PINGed the connection and we havent
* heard from it in a while, PING it to make sure
* it is still alive.
*/
cptr->flags |= FLAGS_PINGSENT;
/* not nice but does the job */
cptr->lasttime = currenttime - ping;
sendto_one(cptr, "%s :%s",
IsToken(cptr) ? TOK_PING : MSG_PING,
me.name);
}
}
/*
* Check UNKNOWN connections - if they have been in this state
* for > 100s, close them.
*/
if (IsUnknown(cptr))
if (cptr->firsttime ? ((TStime() - cptr->firsttime) > 100) : 0)
(void)exit_client(cptr, cptr, &me, "Connection Timed Out");
}
/* EXPLANATION
* on a server with a large volume of clients, at any given point
* there may be a client which needs to be pinged the next second,
* or even right away (a second may have passed while running
* check_pings). Preserving CPU time is more important than
* pinging clients out at exact times, IMO. Therefore, I am going to make
* check_pings always return currenttime + 9. This means that it may take
* a user up to 9 seconds more than pingfreq to timeout. Oh well.
* Plus, the number is 9 to 'stagger' our check_pings calls out over
* time, to avoid doing it and the other tasks ircd does at the same time
* all the time (which are usually done on intervals of 5 seconds or so).
* - lucas
*
*/
oldest = currenttime + 9;
Debug((DEBUG_NOTICE, "Next check_ping() call at: %s, %d %d %d",
myctime(oldest), ping, oldest, currenttime));
return oldest;
}
/*
** bad_command
** This is called when the commandline is not acceptable.
** Give error message and exit without starting anything.
*/
static int bad_command()
{
#ifndef _WIN32
(void)printf
("Usage: ircd %s[-h servername] [-p portnumber] [-x loglevel] [-t] [-H]\n",
#ifdef CMDLINE_CONFIG
"[-f config] "
#else
""
#endif
);
(void)printf("Server not started\n\n");
#else
MessageBox(NULL,
"Usage: wircd [-h servername] [-p portnumber] [-x loglevel]\n",
"UnrealIRCD/32", MB_OK);
#endif
return (-1);
}
char chess[] = {
85, 110, 114, 101, 97, 108, 0
};
#ifndef _WIN32
int main(argc, argv)
#else
int InitwIRCD(argc, argv)
#endif
int argc;
char *argv[];
{
#ifdef _WIN32
WORD wVersionRequested = MAKEWORD(1, 1);
WSADATA wsaData;
#else
uid_t uid, euid;
TS delay = 0;
#endif
int i, ggg;
int portarg = 0;
#ifdef FORCE_CORE
struct rlimit corelim;
#endif
#ifndef NO_FDLIST
TS nextfdlistcheck = 0; /*end of priority code */
#endif
TS last_tune = 0;
static TS lastglinecheck = 0;
#if !defined(_WIN32) && !defined(_AMIGA)
sbrk0 = (char *)sbrk((size_t)0);
uid = getuid();
euid = geteuid();
# ifdef PROFIL
(void)monstartup(0, etext);
(void)moncontrol(1);
(void)signal(SIGUSR1, s_monitor);
# endif
#endif
#ifdef CHROOTDIR
if (chdir(dpath))
{
perror("chdir");
exit(-1);
}
res_init();
if (chroot(DPATH))
{
(void)fprintf(stderr, "ERROR: Cannot chdir/chroot\n");
exit(5);
}
#endif /*CHROOTDIR*/
myargv = argv;
#ifndef _WIN32
(void)umask(077); /* better safe than sorry --SRB */
#else
WSAStartup(wVersionRequested, &wsaData);
for (i = 0; i < MAXCONNECTIONS; ++i) // winlocal
local[i] = NULL; // winlocal
#endif
bzero((char *)&me, sizeof(me));
setup_signals();
initload();
init_ircstats();
clear_scache_hash_table();
#ifdef FORCE_CORE
corelim.rlim_cur = corelim.rlim_max = RLIM_INFINITY;
if (setrlimit(RLIMIT_CORE, &corelim))
printf("unlimit core size failed; errno = %d\n", errno);
#endif
/*
** All command line parameters have the syntax "-fstring"
** or "-f string" (e.g. the space is optional). String may
** be empty. Flag characters cannot be concatenated (like
** "-fxyz"), it would conflict with the form "-fstring".
*/
while (--argc > 0 && (*++argv)[0] == '-')
{
char *p = argv[0] + 1;
int flag = *p++;
if (flag == '\0' || *p == '\0')
if (argc > 1 && argv[1][0] != '-')
{
p = *++argv;
argc -= 1;
}
else
p = "";
switch (flag)
{
#ifndef _WIN32
case 'a':
bootopt |= BOOT_AUTODIE;
break;
case 'c':
bootopt |= BOOT_CONSOLE;
break;
case 'q':
bootopt |= BOOT_QUICK;
break;
case 'd':
(void)setuid((uid_t) uid);
#else
case 'd':
#endif
dpath = p;
break;
case 'F':
bootopt |= BOOT_NOFORK;
break;
#ifndef _WIN32
#ifdef CMDLINE_CONFIG
case 'f':
(void)setuid((uid_t) uid);
configfile = p;
break;
#endif
case 'h':
if (!strchr(p, '.'))
{
(void)printf
("ERROR: %s is not valid: Server names must contain at least 1 \".\"\n",
p); exit(1);
}
strncpyzt(me.name, p, sizeof(me.name));
break;
case 'H':
unrealmanual();
exit(0);
#endif
case 'p':
if ((portarg = atoi(p)) > 0)
portnum = portarg;
break;
case 's':
(void)printf("sizeof(aClient) == %u\n", sizeof(aClient));
(void)printf("sizeof(aChannel) == %u\n",
sizeof(aChannel));
(void)printf("sizeof(aServer) == %u\n",
sizeof(aServer));
(void)printf("sizeof(Link) == %u\n", sizeof(Link));
(void)printf("sizeof(anUser) == %u\n",
sizeof(anUser));
(void)printf("sizeof(aTKline) == %u\n",
sizeof(aTKline));
(void)printf("sizeof(struct ircstatsx) == %u\n",
sizeof(struct ircstatsx));
(void)printf("aClient remote == %u\n",
CLIENT_REMOTE_SIZE); exit(0);
break;
#ifndef _WIN32
case 't':
(void)setuid((uid_t) uid);
bootopt |= BOOT_TTY;
break;
case 'v':
(void)printf("%s\n", version);
#else
case 'v':
MessageBox(NULL, version,
"UnrealIRCD/Win32 version", MB_OK);
#endif
exit(0);
case 'C':
conf_debuglevel = atoi(p);
break;
case 'x':
#ifdef DEBUGMODE
# ifndef _WIN32
(void)setuid((uid_t) uid);
# endif
debuglevel = atoi(p);
debugmode = *p ? p : "0";
bootopt |= BOOT_DEBUG;
break;
#else
# ifndef _WIN32
(void)fprintf(stderr,
"%s: DEBUGMODE must be defined for -x y\n",
myargv[0]);
# else
MessageBox(NULL,
"DEBUGMODE must be defined for -x option",
"UnrealIRCD/32", MB_OK);
# endif
exit(0);
#endif
default:
bad_command();
break;
}
}
#ifndef CHROOT
if (chdir(dpath))
{
# ifndef _WIN32
perror("chdir");
# else
MessageBox(NULL, strerror(GetLastError()),
"UnrealIRCD/32: chdir()", MB_OK);
# endif
exit(-1);
}
#endif
#if !defined(IRC_UID) && !defined(_WIN32)
if ((uid != euid) && !euid)
{
(void)fprintf(stderr,
"ERROR: do not run ircd setuid root. Make it setuid a\
normal user.\n");
exit(-1);
}
#endif
#if (!defined(CHROOTDIR) || (defined(IRC_UID) && defined(IRC_GID))) \
&& !defined(_WIN32)
# ifndef AIX
(void)setuid((uid_t) uid);
(void)setuid((uid_t) euid);
# endif
/*
* Modified 13/2000 DrBin
* We need to have better controll over running as root ... see config.h
*/
if ((int)getuid() == 0)
{
#ifndef BIG_SECURITY_HOLE
if ((IRC_UID == 0) || (IRC_GID == 0))
{
(void)fprintf(stderr, "ERROR: SETUID and SETGID have not been set properly"
"\nPlease read your documentation\n(HINT:SETUID or SETGID can not be 0)\n");
exit(-1);
}
else
{
/* run as a specified user */
(void)fprintf(stderr,
"WARNING: ircd invloked as root\n changing to uid = %d\n",
IRC_UID);
(void)fprintf(stderr,
" changing to gid %d.\n",
IRC_GID); (void)setuid(IRC_UID);
(void)setgid(IRC_GID);
}
#else
/* check for setuid root as usual */
(void)fprintf(stderr,
"ERROR: do not run ircd setuid root. Make it setuid a\
normal user.\n");
exit(-1);
# endif
}
#endif /*CHROOTDIR/UID/GID/_WIN32 */
#ifndef _WIN32
/* didn't set debuglevel */
/* but asked for debugging output to tty */
if ((debuglevel < 0) && (bootopt & BOOT_TTY))
{
(void)fprintf(stderr,
"you specified -t without -x. use -x <n>\n");
exit(-1);
}
#endif
if (argc > 0)
return bad_command(); /* This should exit out */
#ifndef _WIN32
fprintf(stderr, unreallogo);
#endif
fprintf(stderr, " v%s\n\n", VERSIONONLY);
clear_client_hash_table();
clear_channel_hash_table();
clear_notify_hash_table();
bzero(&loop, sizeof(loop));
init_CommandHash();
initlists();
initwhowas();
initstats();
booted = FALSE;
/* Hack to stop people from being able to read the config file */
#if !defined(_WIN32) && !defined(_AMIGA) && defined(DEFAULT_PERMISSIONS)
chmod(CPATH,DEFAULT_PERMISSIONS);
#endif
init_dynconf();
init_conf2(configfile);
validate_configuration();
booted = TRUE;
load_tunefile();
make_umodestr();
make_cmodestr();
fprintf(stderr,
"* Dynamic configuration initialized .. booting IRCd.\n");
fprintf(stderr,
"---------------------------------------------------------------------\n");
open_debugfile();
#ifndef NO_FDLIST
init_fdlist(&serv_fdlist);
init_fdlist(&busycli_fdlist);
init_fdlist(&default_fdlist);
init_fdlist(&oper_fdlist);
init_fdlist(&unknown_fdlist);
{
int i;
for (i = MAXCONNECTIONS + 1; i > 0; i--)
default_fdlist.entry[i] = i - 1;
}
#endif
if (portnum < 0)
portnum = PORTNUM;
me.port = portnum;
(void)init_sys();
me.flags = FLAGS_LISTEN;
me.fd = -1;
SetMe(&me);
make_server(&me);
#ifdef USE_SYSLOG
openlog(myargv[0], LOG_PID | LOG_NDELAY, LOG_FACILITY);
#endif
/* Put in our info */
strncpyzt(me.info, conf_me->info, sizeof(me.info));
strncpyzt(me.name, conf_me->name, sizeof(me.name));
/* We accept the first listen record */
portnum = conf_listen->port;
me.ip.S_ADDR =
*conf_listen->ip != '*' ? inet_addr(conf_listen->ip) : INADDR_ANY;
Debug((DEBUG_ERROR, "Port = %d", portnum));
if (inetport(&me, conf_listen->ip, portnum))
exit(1);
conf_listen->options |= LISTENER_BOUND;
me.umodes = conf_listen->options;
run_configuration();
#ifdef STATIC_LINKING
l_commands_init();
#endif
botmotd = (aMotd *) read_file(BPATH, &botmotd);
rules = (aMotd *) read_rules(RPATH);
opermotd = (aMotd *) read_file(OPATH, &opermotd);
motd = (aMotd *) read_motd(MPATH);
svsmotd = (aMotd *) read_file(VPATH, &svsmotd);
(void)get_my_name(&me, me.sockhost, sizeof(me.sockhost) - 1);
if (me.name[0] == '\0')
strncpyzt(me.name, me.sockhost, sizeof(me.name));
me.hopcount = 0;
me.authfd = -1;
me.next = NULL;
me.user = NULL;
me.from = &me;
me.class = (ConfigItem_class *) conf_listen;
/* This listener will never go away */
conf_listen->clients++;
#ifdef SOCKSPORT
me.socksfd = -1;
#endif
me_hash = find_or_add(me.name);
me.serv->up = me_hash;
me.serv->numeric = conf_me->numeric;
add_server_to_table(&me);
me.lasttime = me.since = me.firsttime = TStime();
(void)add_to_client_hash_table(me.name, &me);
#if !defined(_AMIGA) && !defined(_WIN32) && !defined(NO_FORKING)
if (!(bootopt & BOOT_NOFORK))
if (fork())
exit(0);
#endif
#ifdef SHOWCONNECTINFO
(void)ircsprintf(REPORT_DO_DNS, ":%s %s", me.name, BREPORT_DO_DNS);
(void)ircsprintf(REPORT_FIN_DNS, ":%s %s", me.name, BREPORT_FIN_DNS);
(void)ircsprintf(REPORT_FIN_DNSC, ":%s %s", me.name, BREPORT_FIN_DNSC);
(void)ircsprintf(REPORT_FAIL_DNS, ":%s %s", me.name, BREPORT_FAIL_DNS);
(void)ircsprintf(REPORT_DO_ID, ":%s %s", me.name, BREPORT_DO_ID);
(void)ircsprintf(REPORT_FIN_ID, ":%s %s", me.name, BREPORT_FIN_ID);
(void)ircsprintf(REPORT_FAIL_ID, ":%s %s", me.name, BREPORT_FAIL_ID);
#ifdef SOCKSPORT
(void)ircsprintf(REPORT_DO_SOCKS, ":%s %s", me.name, BREPORT_DO_SOCKS);
(void)ircsprintf(REPORT_NO_SOCKS, ":%s %s", me.name, BREPORT_NO_SOCKS);
(void)ircsprintf(REPORT_GOOD_SOCKS, ":%s %s",
me.name, BREPORT_GOOD_SOCKS);
#endif
R_do_dns = strlen(REPORT_DO_DNS);
R_fin_dns = strlen(REPORT_FIN_DNS);
R_fin_dnsc = strlen(REPORT_FIN_DNSC);
R_fail_dns = strlen(REPORT_FAIL_DNS);
R_do_id = strlen(REPORT_DO_ID);
R_fin_id = strlen(REPORT_FIN_ID);
R_fail_id = strlen(REPORT_FAIL_ID);
#ifdef SOCKSPORT
R_do_socks = strlen(REPORT_DO_SOCKS);
R_no_socks = strlen(REPORT_NO_SOCKS);
R_good_socks = strlen(REPORT_GOOD_SOCKS);
#endif /* SOCKSPORT */
#endif
#ifdef SOCKSPORT
init_socks(&me);
#endif
write_pidfile();
#ifdef USE_SSL
init_ssl();
#endif
Debug((DEBUG_NOTICE, "Server ready..."));
#ifdef USE_SYSLOG
syslog(LOG_NOTICE, "Server Ready");
#endif
loop.ircd_booted = 1;
module_loadall();
#ifndef NO_FDLIST
check_fdlists(TStime());
#endif
nextkillcheck = TStime() + (TS)1;
#ifdef _WIN32
return 1;
}
void SocketLoop(void *dummy)
{
TS delay = 0, now;
static TS lastglinecheck = 0;
TS last_tune;
#ifndef NO_FDLIST
TS nextfdlistcheck = 0; /*end of priority code */
#endif
while (1)
#else
for (;;)
#endif
{
now = TStime();
if ((now - lastglinecheck) > 4)
{
tkl_check_expire();
lastglinecheck = now;
#ifdef STATSWRITING
save_stats();
#endif
}
if (loop.do_tkl_sweep)
{
tkl_sweep();
loop.do_tkl_sweep = 0;
}
/* we want accuarte time here not the fucked up TStime() :P -Stskeeps */
if ((time(NULL) - last_tune) > 300)
{
last_tune = time(NULL);
save_tunefile();
}
if (((now - last_garbage_collect) >
GARBAGE_COLLECT_EVERY || (loop.do_garbage_collect == 1)))
{
extern int freelinks;
extern Link *freelink;
Link p;
int ii;
if (loop.do_garbage_collect == 1)
sendto_realops("Doing garbage collection ..");
if (freelinks > HOW_MANY_FREELINKS_ALLOWED)
{
ii = freelinks;
while (freelink
&& (freelinks > HOW_MANY_FREELINKS_ALLOWED))
{
freelinks--;
p.next = freelink;
freelink = freelink->next;
MyFree(p.next);
}
if (loop.do_garbage_collect == 1)
{
loop.do_garbage_collect = 0;
sendto_realops
("Cleaned up %i garbage blocks",
(ii - freelinks));
}
}
if (loop.do_garbage_collect == 1)
loop.do_garbage_collect = 0;
last_garbage_collect = now;
}
/*
** Run through the hashes and check lusers every
** second
** also check for expiring glines
*/
#ifndef NO_FDLIST
{
static TS lasttime = 0;
static long lastrecvK, lastsendK;
static int lrv;
if (now - lasttime < LCF)
goto done_check;
lasttime = now;
lrv = LRV * LCF;
if ((me.receiveK - lrv >= lastrecvK) || HTMLOCK == 1)
{
if (!lifesux)
{
lifesux = 1;
if (noisy_htm)
sendto_realops
("Entering high-traffic mode (incoming = %0.2f kb/s (LRV = %dk/s, outgoing = %0.2f kb/s currently)",
currentrate, LRV,
currentrate2);}
else
{
lifesux++; /* Ok, life really sucks! */
LCF += 2; /* wait even longer */
if (noisy_htm)
sendto_realops
("Still high-traffic mode %d%s (%d delay): %0.2f kb/s",
lifesux,
(lifesux >
9) ? " (TURBO)" :
"", (int)LCF, currentrate);
/* Reset htm here, because its been on a little too long.
* Bad Things(tm) tend to happen with HTM on too long -epi */
if (lifesux > 15)
{
if (noisy_htm)
sendto_realops
("Resetting HTM and raising limit to: %dk/s\n",
LRV + 5);
LCF = LOADCFREQ;
lifesux = 0;
LRV += 5;
}
}
}
else
{
LCF = LOADCFREQ;
if (lifesux)
{
lifesux = 0;
if (noisy_htm)
sendto_realops
("Resuming standard operation (incoming = %0.2f kb/s, outgoing = %0.2f kb/s now)",
currentrate, currentrate2);
}
}
lastrecvK = me.receiveK;
lastsendK = me.sendK;
done_check:
if (lasttime != now)
{
currentrate =
((float)(me.receiveK -
lastrecvK)) / ((float)(now - lasttime));
currentrate2 =
((float)(me.sendK -
lastsendK)) / ((float)(now - lasttime));
if (currentrate > highest_rate)
highest_rate = currentrate;
if (currentrate2 > highest_rate2)
highest_rate2 = currentrate2;
}
;
}
#endif
if (IRCstats.clients > IRCstats.global_max)
IRCstats.global_max = IRCstats.clients;
if (IRCstats.me_clients > IRCstats.me_max)
IRCstats.me_max = IRCstats.me_clients;
/*
** We only want to connect if a connection is due,
** not every time through. Note, if there are no
** active C lines, this call to Tryconnections is
** made once only; it will return 0. - avalon
*/
if (nextconnect && now >= nextconnect)
nextconnect = try_connections(now);
/*
** DNS checks. One to timeout queries, one for cache expiries.
*/
if (now >= nextdnscheck)
nextdnscheck = timeout_query_list(now);
if (now >= nextexpire)
nextexpire = expire_cache(now);
/*
** take the smaller of the two 'timed' event times as
** the time of next event (stops us being late :) - avalon
** WARNING - nextconnect can return 0!
*/
if (nextconnect)
delay = MIN(nextping, nextconnect);
else
delay = nextping;
delay = MIN(nextdnscheck, delay);
delay = MIN(nextexpire, delay);
delay -= now;
/*
** Adjust delay to something reasonable [ad hoc values]
** (one might think something more clever here... --msa)
** We don't really need to check that often and as long
** as we don't delay too long, everything should be ok.
** waiting too long can cause things to timeout...
** i.e. PINGS -> a disconnection :(
** - avalon
*/
if (delay < 1)
delay = 1;
else
delay = MIN(delay, TIMESEC);
#ifdef NO_FDLIST
(void)read_message(delay);
#else
(void)read_message(0, &serv_fdlist); /* servers */
(void)read_message(1, &busycli_fdlist); /* busy clients */
if (lifesux)
{
(void)read_message(1, &serv_fdlist);
/* read servs more often */
if (lifesux > 9) /* life really sucks */
{
(void)read_message(1, &busycli_fdlist);
(void)read_message(1, &serv_fdlist);
}
flush_fdlist_connections(&serv_fdlist);
}
{
static TS lasttime = 0;
if ((lasttime + (lifesux + 1) * 2) < (now = TStime()))
{
read_message(delay, NULL); /* check everything */
lasttime = now;
}
}
#endif
//Debug((DEBUG_DEBUG, "Got message(s)"));
now = TStime();
/*
** ...perhaps should not do these loops every time,
** but only if there is some chance of something
** happening (but, note that conf->hold times may
** be changed elsewhere--so precomputed next event
** time might be too far away... (similarly with
** ping times) --msa
*/
#ifdef NO_FDLIST
if (now >= nextping)
#else
if (now >= nextping && !lifesux)
#endif
nextping = check_pings(now, 0);
if (dorehash)
{
(void)rehash(&me, &me, 1);
dorehash = 0;
}
/*
** Flush output buffers on all connections now if they
** have data in them (or at least try to flush)
** -avalon
*/
#ifndef NO_FDLIST
/* check which clients are active */
if (now > nextfdlistcheck)
nextfdlistcheck = check_fdlists(now);
#endif
flush_connections(me.fd);
}
}
#ifndef NO_FDLIST
TS check_fdlists(now)
TS now;
{
aClient *cptr;
int pri; /* temp. for priority */
int i, j;
j = 0;
for (i = highest_fd; i >= 0; i--)
{
if (!(cptr = local[i]))
continue;
if (IsServer(cptr) || IsListening(cptr) || IsOper(cptr) || DoingAuth(cptr))
{
busycli_fdlist.entry[++j] = i;
continue;
}
pri = cptr->priority;
if (cptr->receiveM == cptr->lastrecvM)
pri += 2; /* lower a bit */
else
pri -= 30;
if (pri < 0)
pri = 0;
if (pri > 80)
pri = 80;
cptr->lastrecvM = cptr->receiveM;
cptr->priority = pri;
if ((pri < 10) || (!lifesux && (pri < 25)))
busycli_fdlist.entry[++j] = i;
}
busycli_fdlist.last_entry = j; /* rest of the fdlist is garbage */
return (now + FDLISTCHKFREQ + lifesux * FDLISTCHKFREQ);
}
#endif
/*
* open_debugfile
*
* If the -t option is not given on the command line when the server is
* started, all debugging output is sent to the file set by LPATH in config.h
* Here we just open that file and make sure it is opened to fd 2 so that
* any fprintf's to stderr also goto the logfile. If the debuglevel is not
* set from the command line by -x, use /dev/null as the dummy logfile as long
* as DEBUGMODE has been defined, else dont waste the fd.
*/
static void open_debugfile()
{
#ifdef DEBUGMODE
int fd;
aClient *cptr;
if (debuglevel >= 0)
{
cptr = make_client(NULL, NULL);
cptr->fd = 2;
SetLog(cptr);
cptr->port = debuglevel;
cptr->flags = 0;
cptr->listener = cptr;
local[2] = cptr;
(void)strcpy(cptr->sockhost, me.sockhost);
# ifndef _WIN32
(void)printf("isatty = %d ttyname = %#x\n",
isatty(2), (u_int)ttyname(2));
if (!(bootopt & BOOT_TTY)) /* leave debugging output on fd 2 */
{
(void)truncate(LOGFILE, 0);
if ((fd = open(LOGFILE, O_WRONLY | O_CREAT, 0600)) < 0)
if ((fd = open("/dev/null", O_WRONLY)) < 0)
exit(-1);
if (fd != 2)
{
(void)dup2(fd, 2);
(void)close(fd);
}
strncpyzt(cptr->name, LOGFILE, sizeof(cptr->name));
}
else if (isatty(2) && ttyname(2))
strncpyzt(cptr->name, ttyname(2), sizeof(cptr->name));
else
# endif
(void)strcpy(cptr->name, "FD2-Pipe");
Debug((DEBUG_FATAL,
"Debug: File <%s> Level: %d at %s", cptr->name,
cptr->port, myctime(time(NULL))));
}
else
local[2] = NULL;
#endif
return;
}
static void setup_signals()
{
#ifndef _WIN32
#ifdef POSIX_SIGNALS
struct sigaction act;
act.sa_handler = SIG_IGN;
act.sa_flags = 0;
(void)sigemptyset(&act.sa_mask);
(void)sigaddset(&act.sa_mask, SIGPIPE);
(void)sigaddset(&act.sa_mask, SIGALRM);
# ifdef SIGWINCH
(void)sigaddset(&act.sa_mask, SIGWINCH);
(void)sigaction(SIGWINCH, &act, NULL);
# endif
(void)sigaction(SIGPIPE, &act, NULL);
act.sa_handler = dummy;
(void)sigaction(SIGALRM, &act, NULL);
act.sa_handler = s_rehash;
(void)sigemptyset(&act.sa_mask);
(void)sigaddset(&act.sa_mask, SIGHUP);
(void)sigaction(SIGHUP, &act, NULL);
act.sa_handler = s_restart;
(void)sigaddset(&act.sa_mask, SIGINT);
(void)sigaction(SIGINT, &act, NULL);
act.sa_handler = s_die;
(void)sigaddset(&act.sa_mask, SIGTERM);
(void)sigaction(SIGTERM, &act, NULL);
/* handling of SIGSEGV as well -sts */
#ifndef PROPER_COREDUMP
act.sa_handler = s_segv;
(void)sigaddset(&act.sa_mask, SIGSEGV);
(void)sigaction(SIGSEGV, &act, NULL);
#endif
#else
# ifndef HAVE_RELIABLE_SIGNALS
(void)signal(SIGPIPE, dummy);
# ifdef SIGWINCH
(void)signal(SIGWINCH, dummy);
# endif
# else
# ifdef SIGWINCH
(void)signal(SIGWINCH, SIG_IGN);
# endif
(void)signal(SIGPIPE, SIG_IGN);
# endif
(void)signal(SIGALRM, dummy);
(void)signal(SIGHUP, s_rehash);
(void)signal(SIGTERM, s_die);
(void)signal(SIGINT, s_restart);
(void)signal(SIGSEGV, s_segv);
#endif
#ifdef RESTARTING_SYSTEMCALLS
/*
** At least on Apollo sr10.1 it seems continuing system calls
** after signal is the default. The following 'siginterrupt'
** should change that default to interrupting calls.
*/
(void)siginterrupt(SIGALRM, 1);
#endif
#else
(void)signal(SIGSEGV,CleanUpSegv);
#endif
}
View Git Blame Copy Permalink