diff options
Diffstat (limited to 'ircd/class.c')
| -rw-r--r-- | ircd/class.c | 256 |
1 files changed, 256 insertions, 0 deletions
diff --git a/ircd/class.c b/ircd/class.c new file mode 100644 index 0000000..e3457c8 --- /dev/null +++ b/ircd/class.c @@ -0,0 +1,256 @@ +/* + * IRC - Internet Relay Chat, ircd/class.c + * Copyright (C) 1990 Darren Reed + * + * 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 rcsid[] = "@(#)$Id: class.c,v 1.6 1997/12/19 13:35:57 kalt Exp $"; +#endif + +#include "os.h" +#include "s_defines.h" +#define CLASS_C +#include "s_externs.h" +#undef CLASS_C + +#define BAD_CONF_CLASS -1 +#define BAD_PING -2 +#define BAD_CLIENT_CLASS -3 + +aClass *classes; + +int get_conf_class(aconf) +aConfItem *aconf; +{ + if ((aconf) && Class(aconf)) + return (ConfClass(aconf)); + + Debug((DEBUG_DEBUG,"No Class For %s", + (aconf) ? aconf->name : "*No Conf*")); + + return (BAD_CONF_CLASS); + +} + +static int get_conf_ping(aconf) +aConfItem *aconf; +{ + if ((aconf) && Class(aconf)) + return (ConfPingFreq(aconf)); + + Debug((DEBUG_DEBUG,"No Ping For %s", + (aconf) ? aconf->name : "*No Conf*")); + + return (BAD_PING); +} + + + +int get_client_class(acptr) +aClient *acptr; +{ + Reg Link *tmp; + Reg aClass *cl; + int retc = BAD_CLIENT_CLASS; + + if (acptr && !IsMe(acptr) && (acptr->confs)) + for (tmp = acptr->confs; tmp; tmp = tmp->next) + { + if (!tmp->value.aconf || + !(cl = tmp->value.aconf->class)) + continue; + if (Class(cl) > retc) + retc = Class(cl); + } + + Debug((DEBUG_DEBUG,"Returning Class %d For %s",retc,acptr->name)); + + return (retc); +} + +int get_client_ping(acptr) +aClient *acptr; +{ + int ping = 0, ping2; + aConfItem *aconf; + Link *link; + + link = acptr->confs; + + if (link) + while (link) + { + aconf = link->value.aconf; + if (aconf->status & (CONF_CLIENT|CONF_CONNECT_SERVER| + CONF_NOCONNECT_SERVER| + CONF_ZCONNECT_SERVER)) + { + ping2 = get_conf_ping(aconf); + if ((ping2 != BAD_PING) && ((ping > ping2) || + !ping)) + ping = ping2; + } + link = link->next; + } + else + { + ping = PINGFREQUENCY; + Debug((DEBUG_DEBUG,"No Attached Confs")); + } + if (ping <= 0) + ping = PINGFREQUENCY; + Debug((DEBUG_DEBUG,"Client %s Ping %d", acptr->name, ping)); + return (ping); +} + +int get_con_freq(clptr) +aClass *clptr; +{ + if (clptr) + return (MAX(60, ConFreq(clptr))); + else + return (CONNECTFREQUENCY); +} + +/* + * When adding a class, check to see if it is already present first. + * if so, then update the information for that class, rather than create + * a new entry for it and later delete the old entry. + * if no present entry is found, then create a new one and add it in + * immeadiately after the first one (class 0). + */ +void add_class(class, ping, confreq, maxli, sendq, hlocal, uhlocal, + hglobal, uhglobal) +int class, ping, confreq, maxli, hlocal, uhlocal, hglobal, uhglobal; +long sendq; +{ + aClass *t, *p; + + t = find_class(class); + if ((t == classes) && (class != 0)) + { + p = (aClass *)make_class(); + NextClass(p) = NextClass(t); + NextClass(t) = p; + MaxSendq(p) = QUEUELEN; + istat.is_class++; + } + else + p = t; + Debug((DEBUG_DEBUG, +"Add Class %d: p %x t %x - cf: %d pf: %d ml: %d sq: %l ml: %d.%d mg: %d.%d", + class, p, t, confreq, ping, maxli, QUEUELEN, hlocal, uhlocal, + hglobal, uhglobal)); + Class(p) = class; + ConFreq(p) = confreq; + PingFreq(p) = ping; + MaxLinks(p) = maxli; + if (sendq) + MaxSendq(p) = sendq; + MaxHLocal(p) = hlocal; + MaxUHLocal(p) = uhlocal; + MaxHGlobal(p) = hglobal; + MaxUHGlobal(p) = uhglobal; + if (p != t) + Links(p) = 0; +} + +aClass *find_class(cclass) +int cclass; +{ + aClass *cltmp; + + for (cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp)) + if (Class(cltmp) == cclass) + return cltmp; + return classes; +} + +void check_class() +{ + Reg aClass *cltmp, *cltmp2; + + Debug((DEBUG_DEBUG, "Class check:")); + + for (cltmp2 = cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp2)) + { + Debug((DEBUG_DEBUG, + "Class %d : CF: %d PF: %d ML: %d LI: %d SQ: %ld", + Class(cltmp), ConFreq(cltmp), PingFreq(cltmp), + MaxLinks(cltmp), Links(cltmp), MaxSendq(cltmp))); + if (MaxLinks(cltmp) < 0) + { + NextClass(cltmp2) = NextClass(cltmp); + if (Links(cltmp) <= 0) + { + free_class(cltmp); + istat.is_class--; + } + } + else + cltmp2 = cltmp; + } +} + +void initclass() +{ + classes = (aClass *)make_class(); + istat.is_class++; + + Class(FirstClass()) = 0; + ConFreq(FirstClass()) = CONNECTFREQUENCY; + PingFreq(FirstClass()) = PINGFREQUENCY; + MaxLinks(FirstClass()) = MAXIMUM_LINKS; + MaxSendq(FirstClass()) = QUEUELEN; + Links(FirstClass()) = 0; + NextClass(FirstClass()) = NULL; +} + +void report_classes(sptr, to) +aClient *sptr; +char *to; +{ + Reg aClass *cltmp; + + for (cltmp = FirstClass(); cltmp; cltmp = NextClass(cltmp)) + sendto_one(sptr, rpl_str(RPL_STATSYLINE, to), 'Y', + Class(cltmp), PingFreq(cltmp), ConFreq(cltmp), + MaxLinks(cltmp), MaxSendq(cltmp), + MaxHLocal(cltmp), MaxUHLocal(cltmp), + MaxHGlobal(cltmp), MaxUHGlobal(cltmp)); +} + +long get_sendq(cptr) +aClient *cptr; +{ + Reg int sendq = QUEUELEN, retc = BAD_CLIENT_CLASS; + Reg Link *tmp; + Reg aClass *cl; + + if (cptr->serv) + sendq = MaxSendq(cptr->serv->nline->class); + else if (cptr && !IsMe(cptr) && (cptr->confs)) + for (tmp = cptr->confs; tmp; tmp = tmp->next) + { + if (!tmp->value.aconf || + !(cl = tmp->value.aconf->class)) + continue; + if (Class(cl) > retc) + sendq = MaxSendq(cl); + } + return sendq; +} |