/* * 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; }