Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/VibeDevelopers/Comet.
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667/* * ircd-ratbox: an advanced Internet Relay Chat Daemon(ircd). * m_stats.c: Sends the user statistics or config information. * * Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center * Copyright (C) 1996-2002 Hybrid Development Team * Copyright (C) 2002-2005 ircd-ratbox development team * * 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 2 of the License, 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 * USA */
#include "stdinc.h"#include "class.h" /* report_classes */#include "client.h" /* Client */#include "match.h"#include "ircd.h" /* me */#include "listener.h" /* show_ports */#include "msg.h" /* Message */#include "hostmask.h" /* report_mtrie_conf_links */#include "numeric.h" /* ERR_xxx */#include "scache.h" /* list_scache */#include "send.h" /* sendto_one */#include "s_conf.h" /* ConfItem */#include "s_serv.h" /* hunt_server */#include "s_stats.h"#include "s_user.h" /* show_opers */#include "parse.h"#include "modules.h"#include "hook.h"#include "s_newconf.h"#include "hash.h"#include "reject.h"#include "whowas.h"#include "rb_radixtree.h"#include "response.h"#include "sslproc.h"#include "s_assert.h"
static const char stats_desc[] = "Provides the STATS command to inspect various server/network information";
static void m_stats (struct MsgBuf *, struct Client *, struct Client *, int, const char **);
struct Message stats_msgtab = { "STATS", false, false, false, false, {mg_unreg, {m_stats, 2}, {m_stats, 3}, mg_ignore, mg_ignore, {m_stats, 2}}};
int doing_stats_hook;int doing_stats_show_idle_hook;
mapi_clist_av1 stats_clist[] = { &stats_msgtab, NULL };mapi_hlist_av1 stats_hlist[] = { { "doing_stats", &doing_stats_hook }, { "doing_stats_show_idle", &doing_stats_show_idle_hook }, { NULL, NULL }};
DECLARE_MODULE_AV2(stats, NULL, NULL, stats_clist, stats_hlist, NULL, NULL, NULL, stats_desc);
const char *Lformat = "%s %d %"PRIu32" %"PRIu32" %"PRIu32" %"PRIu32" :%"PRId64" %"PRId64" %s";
static void stats_l_list(struct Client *s, const char *, bool, bool, rb_dlink_list *, char, bool (*check_fn)(struct Client *source_p, struct Client *target_p));static void stats_l_client(struct Client *source_p, struct Client *target_p, char statchar);
typedef void (*handler_t)(struct Client *source_p);typedef void (*handler_parv_t)(struct Client *source_p, int parc, const char *parv[]);
struct stats_cmd{ union { handler_t handler; handler_parv_t handler_parv; }; const char *need_priv; bool need_parv; bool need_admin;};
static void stats_dns_servers(struct Client *);static void stats_delay(struct Client *);static void stats_hash(struct Client *);static void stats_connect(struct Client *);static void stats_tdeny(struct Client *);static void stats_deny(struct Client *);static void stats_exempt(struct Client *);static void stats_events(struct Client *);static void stats_prop_klines(struct Client *);static void stats_auth(struct Client *);static void stats_tklines(struct Client *);static void stats_klines(struct Client *);static void stats_messages(struct Client *);static void stats_dnsbl(struct Client *);static void stats_oper(struct Client *);static void stats_privset(struct Client *);static void stats_operedup(struct Client *);static void stats_ports(struct Client *);static void stats_tresv(struct Client *);static void stats_resv(struct Client *);static void stats_secure(struct Client *);static void stats_ssld(struct Client *);static void stats_usage(struct Client *);static void stats_tstats(struct Client *);static void stats_uptime(struct Client *);static void stats_servers(struct Client *);static void stats_tgecos(struct Client *);static void stats_gecos(struct Client *);static void stats_class(struct Client *);static void stats_memory(struct Client *);static void stats_servlinks(struct Client *);static void stats_ltrace(struct Client *, int, const char **);static void stats_comm(struct Client *);static void stats_capability(struct Client *);
#define HANDLER_NORM(fn, admin, priv) \ { { .handler = fn }, .need_parv = false, .need_priv = priv, .need_admin = admin }#define HANDLER_PARV(fn, admin, priv) \ { { .handler_parv = fn }, .need_parv = true, .need_priv = priv, .need_admin = admin }
/* This table contains the possible stats items, in order: * stats letter, function to call, operonly? adminonly? --fl_ * * Previously in this table letters were a column. I fixed it to use modern * C initalisers so we don't have to iterate anymore * --Elizafox */static struct stats_cmd stats_cmd_table[256] = {/* letter handler admin priv */ ['a'] = HANDLER_NORM(stats_dns_servers, true, NULL), ['A'] = HANDLER_NORM(stats_dns_servers, true, NULL), ['b'] = HANDLER_NORM(stats_delay, true, NULL), ['B'] = HANDLER_NORM(stats_hash, true, NULL), ['c'] = HANDLER_NORM(stats_connect, false, NULL), ['C'] = HANDLER_NORM(stats_capability, false, "oper:general"), ['d'] = HANDLER_NORM(stats_tdeny, false, "oper:general"), ['D'] = HANDLER_NORM(stats_deny, false, "oper:general"), ['e'] = HANDLER_NORM(stats_exempt, false, "oper:general"), ['E'] = HANDLER_NORM(stats_events, true, NULL), ['f'] = HANDLER_NORM(stats_comm, true, NULL), ['F'] = HANDLER_NORM(stats_comm, true, NULL), ['g'] = HANDLER_NORM(stats_prop_klines, false, "oper:general"), ['i'] = HANDLER_NORM(stats_auth, false, NULL), ['I'] = HANDLER_NORM(stats_auth, false, NULL), ['k'] = HANDLER_NORM(stats_tklines, false, NULL), ['K'] = HANDLER_NORM(stats_klines, false, NULL), ['l'] = HANDLER_PARV(stats_ltrace, false, NULL), ['L'] = HANDLER_PARV(stats_ltrace, false, NULL), ['m'] = HANDLER_NORM(stats_messages, false, NULL), ['M'] = HANDLER_NORM(stats_messages, false, NULL), ['n'] = HANDLER_NORM(stats_dnsbl, false, NULL), ['o'] = HANDLER_NORM(stats_oper, false, NULL), ['O'] = HANDLER_NORM(stats_privset, false, "oper:privs"), ['p'] = HANDLER_NORM(stats_operedup, false, NULL), ['P'] = HANDLER_NORM(stats_ports, false, NULL), ['q'] = HANDLER_NORM(stats_tresv, false, "oper:general"), ['Q'] = HANDLER_NORM(stats_resv, false, "oper:general"), ['r'] = HANDLER_NORM(stats_usage, false, "oper:general"), ['R'] = HANDLER_NORM(stats_usage, false, "oper:general"), ['s'] = HANDLER_NORM(stats_secure, false, "oper:general"), ['S'] = HANDLER_NORM(stats_ssld, true, NULL), ['t'] = HANDLER_NORM(stats_tstats, false, "oper:general"), ['T'] = HANDLER_NORM(stats_tstats, false, "oper:general"), ['u'] = HANDLER_NORM(stats_uptime, false, NULL), ['v'] = HANDLER_NORM(stats_servers, false, NULL), ['V'] = HANDLER_NORM(stats_servers, false, NULL), ['x'] = HANDLER_NORM(stats_tgecos, false, "oper:general"), ['X'] = HANDLER_NORM(stats_gecos, false, "oper:general"), ['y'] = HANDLER_NORM(stats_class, false, NULL), ['Y'] = HANDLER_NORM(stats_class, false, NULL), ['z'] = HANDLER_NORM(stats_memory, false, "oper:general"), ['?'] = HANDLER_NORM(stats_servlinks, false, NULL),};
/* * m_stats by fl_ * Modified heavily by Elizafox * parv[1] = stat letter/command * parv[2] = (if present) server/mask in stats L, or target * * This will search the tables for the appropriate stats letter, * if found execute it. */static voidm_stats(struct MsgBuf *msgbuf_p, struct Client *client_p, struct Client *source_p, int parc, const char *parv[]){ static time_t last_used = 0; struct stats_cmd *cmd; unsigned char statchar;
statchar = parv[1][0];
if(MyClient(source_p) && !IsOperGeneral(source_p) && parc > 2) { /* Check the user is actually allowed to do /stats, and isnt flooding */ if((last_used + ConfigFileEntry.pace_wait) > rb_current_time()) { begin_local_response_batch(); /* safe enough to give this on a local connect only */ sendto_one(source_p, form_str(RPL_LOAD2HI), me.name, source_p->name, "STATS"); sendto_one_numeric(source_p, RPL_ENDOFSTATS, form_str(RPL_ENDOFSTATS), statchar); return; } else last_used = rb_current_time(); }
if (hunt_server(client_p, source_p, ":%s STATS %s :%s", 2, parc, parv) != HUNTED_ISME) return;
begin_local_response_batch();
hook_data_int data = { .client = source_p, .arg1 = NULL, .arg2 = (int) statchar, .result = 0, };
call_hook(doing_stats_hook, &data);
if (data.result != 0) goto stats_out;
/* Look up */ cmd = &stats_cmd_table[statchar]; if(cmd->handler != NULL) { /* The stats table says what privs are needed, so check --fl_ */ const char *missing_priv = NULL; if(cmd->need_admin && !IsOperAdmin(source_p)) missing_priv = "admin"; else if(cmd->need_priv && !HasPrivilege(source_p, cmd->need_priv)) missing_priv = cmd->need_priv;
if(missing_priv != NULL) { if(!IsOper(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str(ERR_NOPRIVILEGES)); } else { if(!strncmp(missing_priv, "oper:", 5)) missing_priv += 5; sendto_one(source_p, form_str(ERR_NOPRIVS), me.name, source_p->name, missing_priv); } goto stats_out; }
if(cmd->need_parv) cmd->handler_parv(source_p, parc, parv); else cmd->handler(source_p); }
stats_out: /* Send the end of stats notice */ sendto_one_numeric(source_p, RPL_ENDOFSTATS, form_str(RPL_ENDOFSTATS), statchar);}
static voidstats_dns_servers (struct Client *source_p){ rb_dlink_node *n;
RB_DLINK_FOREACH(n, nameservers.head) { sendto_one_numeric(source_p, RPL_STATSDEBUG, "A :%s", (char *)n->data); }}
static voidstats_delay(struct Client *source_p){ struct nd_entry *nd; rb_dictionary_iter iter;
RB_DICTIONARY_FOREACH(nd, &iter, nd_dict) { sendto_one_notice(source_p, ":Delaying: %s for %ld", nd->name, (long) nd->expire); }}
static voidstats_hash_cb(const char *buf, void *client_p){ sendto_one_numeric(client_p, RPL_STATSDEBUG, "B :%s", buf);}
static voidstats_hash(struct Client *source_p){ sendto_one_numeric(source_p, RPL_STATSDEBUG, "B :%-30s %-15s %-10s %-10s %-10s %-10s", "NAME", "TYPE", "OBJECTS", "DEPTH SUM", "AVG DEPTH", "MAX DEPTH");
rb_dictionary_stats_walk(stats_hash_cb, source_p); rb_radixtree_stats_walk(stats_hash_cb, source_p);}
static voidstats_connect(struct Client *source_p){ static char buf[BUFSIZE]; struct server_conf *server_p; char *s; rb_dlink_node *ptr;
if((ConfigFileEntry.stats_c_oper_only || (ConfigServerHide.flatten_links && !IsExemptShide(source_p))) && !IsOperGeneral(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str(ERR_NOPRIVILEGES)); return; }
RB_DLINK_FOREACH(ptr, server_conf_list.head) { server_p = ptr->data;
if(ServerConfIllegal(server_p)) continue;
s = buf;
if(IsOperGeneral(source_p)) { if(ServerConfAutoconn(server_p)) *s++ = 'A'; if(ServerConfSCTP(server_p)) *s++ = 'M'; if(ServerConfSSL(server_p)) *s++ = 'S'; if(ServerConfTb(server_p)) *s++ = 'T'; }
if(s == buf) *s++ = '*';
*s = '\0';
sendto_one_numeric(source_p, RPL_STATSCLINE, form_str(RPL_STATSCLINE), "*@127.0.0.1", buf, server_p->name, server_p->port, server_p->class_name, server_p->certfp ? server_p->certfp : "*"); }}
/* stats_tdeny() * * input - client to report to * output - none * side effects - client is given temp dline list. */static voidstats_tdeny (struct Client *source_p){ char *host, *pass, *user, *oper_reason; struct AddressRec *arec; struct ConfItem *aconf; int i;
for (i = 0; i < ATABLE_SIZE; i++) { for (arec = atable[i]; arec; arec = arec->next) { if(arec->type == CONF_DLINE) { aconf = arec->aconf;
if(!(aconf->flags & CONF_FLAGS_TEMPORARY)) continue;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSDLINE, form_str (RPL_STATSDLINE), 'd', host, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } } }}
/* stats_deny() * * input - client to report to * output - none * side effects - client is given dline list. */static voidstats_deny (struct Client *source_p){ char *host, *pass, *user, *oper_reason; struct AddressRec *arec; struct ConfItem *aconf; int i;
for (i = 0; i < ATABLE_SIZE; i++) { for (arec = atable[i]; arec; arec = arec->next) { if(arec->type == CONF_DLINE) { aconf = arec->aconf;
if(aconf->flags & CONF_FLAGS_TEMPORARY) continue;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSDLINE, form_str (RPL_STATSDLINE), 'D', host, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } } }}
/* stats_exempt() * * input - client to report to * output - none * side effects - client is given list of exempt blocks */static voidstats_exempt(struct Client *source_p){ char *name, *host, *user, *classname, *desc; const char *pass; struct AddressRec *arec; struct ConfItem *aconf; int i, port;
if(ConfigFileEntry.stats_e_disabled) { sendto_one_numeric(source_p, ERR_DISABLED, form_str(ERR_DISABLED), "STATS e"); return; }
for (i = 0; i < ATABLE_SIZE; i++) { for (arec = atable[i]; arec; arec = arec->next) { if(arec->type == CONF_EXEMPTDLINE) { aconf = arec->aconf; get_printable_conf (aconf, &name, &host, &pass, &user, &port, &classname, &desc);
sendto_one_numeric(source_p, RPL_STATSDLINE, form_str(RPL_STATSDLINE), 'e', host, pass, "", ""); } } }}
static voidstats_events_cb(char *str, void *ptr){ sendto_one_numeric(ptr, RPL_STATSDEBUG, "E :%s", str);}
static voidstats_events (struct Client *source_p){ rb_dump_events(stats_events_cb, source_p);}
static voidstats_prop_klines(struct Client *source_p){ struct ConfItem *aconf; char *user, *host, *pass, *oper_reason; rb_dictionary_iter state;
RB_DICTIONARY_FOREACH(aconf, &state, prop_bans_dict) { /* Skip non-klines and deactivated klines. */ if (aconf->status != CONF_KILL) continue;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSKLINE, form_str(RPL_STATSKLINE), 'g', host, user, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); }}
static voidstats_auth (struct Client *source_p){ /* Oper only, if unopered, return ERR_NOPRIVS */ if((ConfigFileEntry.stats_i_oper_only == 2) && !IsOperGeneral (source_p)) sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES));
/* If unopered, Only return matching auth blocks */ else if((ConfigFileEntry.stats_i_oper_only == 1) && !IsOperGeneral (source_p)) { struct ConfItem *aconf; char *name, *host, *user, *classname, *desc; const char *pass = "*"; int port;
if(MyConnect (source_p)) aconf = find_conf_by_address (source_p->host, source_p->sockhost, NULL, (struct sockaddr *)&source_p->localClient->ip, CONF_CLIENT, GET_SS_FAMILY(&source_p->localClient->ip), source_p->username, NULL); else aconf = find_conf_by_address (source_p->host, NULL, NULL, NULL, CONF_CLIENT, 0, source_p->username, NULL);
if(aconf == NULL) return;
get_printable_conf (aconf, &name, &host, &pass, &user, &port, &classname, &desc); if(!EmptyString(aconf->spasswd)) pass = aconf->spasswd;
sendto_one_numeric(source_p, RPL_STATSILINE, form_str(RPL_STATSILINE), name, pass, show_iline_prefix(source_p, aconf, user), host, port, classname, desc); }
/* Theyre opered, or allowed to see all auth blocks */ else report_auth (source_p);}
static voidstats_tklines(struct Client *source_p){ /* Oper only, if unopered, return ERR_NOPRIVS */ if((ConfigFileEntry.stats_k_oper_only == 2) && !IsOperGeneral (source_p)) sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES));
/* If unopered, Only return matching klines */ else if((ConfigFileEntry.stats_k_oper_only == 1) && !IsOperGeneral (source_p)) { struct ConfItem *aconf; char *host, *pass, *user, *oper_reason;
if(MyConnect (source_p)) aconf = find_conf_by_address (source_p->host, source_p->sockhost, NULL, (struct sockaddr *)&source_p->localClient->ip, CONF_KILL, GET_SS_FAMILY(&source_p->localClient->ip), source_p->username, NULL); else aconf = find_conf_by_address (source_p->host, NULL, NULL, NULL, CONF_KILL, 0, source_p->username, NULL);
if(aconf == NULL) return;
/* dont report a permanent kline as a tkline */ if((aconf->flags & CONF_FLAGS_TEMPORARY) == 0) return;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSKLINE, form_str(RPL_STATSKLINE), (aconf->flags & CONF_FLAGS_TEMPORARY) ? 'k' : 'K', host, user, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } /* Theyre opered, or allowed to see all klines */ else { struct ConfItem *aconf; rb_dlink_node *ptr; int i; char *user, *host, *pass, *oper_reason;
for(i = 0; i < LAST_TEMP_TYPE; i++) { RB_DLINK_FOREACH(ptr, temp_klines[i].head) { aconf = ptr->data;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSKLINE, form_str(RPL_STATSKLINE), 'k', host, user, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } } }}
/* report_Klines() * * inputs - Client to report to, mask * outputs - * side effects - Reports configured K-lines to client_p. */static voidreport_Klines(struct Client *source_p){ char *host, *pass, *user, *oper_reason; struct AddressRec *arec; struct ConfItem *aconf = NULL; int i;
for (i = 0; i < ATABLE_SIZE; i++) { for (arec = atable[i]; arec; arec = arec->next) { if(arec->type == CONF_KILL) { aconf = arec->aconf;
/* its a tempkline, theyre reported elsewhere */ if(aconf->flags & CONF_FLAGS_TEMPORARY) continue;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason); sendto_one_numeric(source_p, RPL_STATSKLINE, form_str(RPL_STATSKLINE), 'K', host, user, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } } }}
static voidstats_klines(struct Client *source_p){ /* Oper only, if unopered, return ERR_NOPRIVS */ if((ConfigFileEntry.stats_k_oper_only == 2) && !IsOperGeneral (source_p)) sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES));
/* If unopered, Only return matching klines */ else if((ConfigFileEntry.stats_k_oper_only == 1) && !IsOperGeneral (source_p)) { struct ConfItem *aconf; char *host, *pass, *user, *oper_reason;
/* search for a kline */ if(MyConnect (source_p)) aconf = find_conf_by_address (source_p->host, source_p->sockhost, NULL, (struct sockaddr *)&source_p->localClient->ip, CONF_KILL, GET_SS_FAMILY(&source_p->localClient->ip), source_p->username, NULL); else aconf = find_conf_by_address (source_p->host, NULL, NULL, NULL, CONF_KILL, 0, source_p->username, NULL);
if(aconf == NULL) return;
get_printable_kline(source_p, aconf, &host, &pass, &user, &oper_reason);
sendto_one_numeric(source_p, RPL_STATSKLINE, form_str(RPL_STATSKLINE), (aconf->flags & CONF_FLAGS_TEMPORARY) ? 'k' : 'K', host, user, pass, oper_reason ? "|" : "", oper_reason ? oper_reason : ""); } /* Theyre opered, or allowed to see all klines */ else report_Klines (source_p);}
static voidstats_messages(struct Client *source_p){ rb_dictionary_iter iter; struct Message *msg;
RB_DICTIONARY_FOREACH(msg, &iter, cmd_dict) { s_assert(msg->cmd != NULL); sendto_one_numeric(source_p, RPL_STATSCOMMANDS, form_str(RPL_STATSCOMMANDS), msg->cmd, msg->count, msg->bytes, msg->rcount); }}
static voidstats_dnsbl(struct Client *source_p){ rb_dictionary_iter iter; struct DNSBLEntry *entry;
if(dnsbl_stats == NULL) return;
RB_DICTIONARY_FOREACH(entry, &iter, dnsbl_stats) { /* use RPL_STATSDEBUG for now -- jilles */ sendto_one_numeric(source_p, RPL_STATSDEBUG, "n :%d %s", entry->hits, entry->host); }}
static voidstats_oper(struct Client *source_p){ struct oper_conf *oper_p; rb_dlink_node *ptr;
if(!IsOperGeneral(source_p) && ConfigFileEntry.stats_o_oper_only) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES)); return; }
RB_DLINK_FOREACH(ptr, oper_conf_list.head) { oper_p = ptr->data;
sendto_one_numeric(source_p, RPL_STATSOLINE, form_str(RPL_STATSOLINE), oper_p->username, oper_p->host, oper_p->name, HasPrivilege(source_p, "oper:privs") ? oper_p->privset->name : "0", "-1"); }}
static voidstats_capability_walk(const char *line, void *data){ struct Client *client_p = data;
sendto_one_numeric(client_p, RPL_STATSDEBUG, "C :%s", line);}
static voidstats_capability(struct Client *client_p){ capability_index_stats(stats_capability_walk, client_p);}
static voidstats_privset(struct Client *source_p){ privilegeset_report(source_p);}
/* stats_operedup() * * input - client pointer * output - none * side effects - client is shown a list of active opers */static voidstats_operedup (struct Client *source_p){ struct Client *target_p; rb_dlink_node *oper_ptr; unsigned int count = 0;
RB_DLINK_FOREACH (oper_ptr, oper_list.head) { target_p = oper_ptr->data;
if(!SeesOper(target_p, source_p)) continue;
if(target_p->user->away) continue;
count++;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "p :%s (%s@%s)", target_p->name, target_p->username, target_p->host); }
sendto_one_numeric(source_p, RPL_STATSDEBUG, "p :%u staff members", count);}
static voidstats_ports (struct Client *source_p){ if(!IsOperGeneral (source_p) && ConfigFileEntry.stats_P_oper_only) sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES)); else show_ports (source_p);}
static voidstats_tresv(struct Client *source_p){ struct ConfItem *aconf; rb_radixtree_iteration_state state; rb_dlink_node *ptr;
RB_DLINK_FOREACH(ptr, resv_conf_list.head) { aconf = ptr->data; if(aconf->hold) sendto_one_numeric(source_p, RPL_STATSQLINE, form_str(RPL_STATSQLINE), 'q', aconf->port, aconf->host, aconf->passwd); }
RB_RADIXTREE_FOREACH(aconf, &state, resv_tree) { if(aconf->hold) sendto_one_numeric(source_p, RPL_STATSQLINE, form_str(RPL_STATSQLINE), 'q', aconf->port, aconf->host, aconf->passwd); }}
static voidstats_resv(struct Client *source_p){ struct ConfItem *aconf; rb_radixtree_iteration_state state; rb_dlink_node *ptr;
RB_DLINK_FOREACH(ptr, resv_conf_list.head) { aconf = ptr->data; if(!aconf->hold) sendto_one_numeric(source_p, RPL_STATSQLINE, form_str(RPL_STATSQLINE), 'Q', aconf->port, aconf->host, aconf->passwd); }
RB_RADIXTREE_FOREACH(aconf, &state, resv_tree) { if(!aconf->hold) sendto_one_numeric(source_p, RPL_STATSQLINE, form_str(RPL_STATSQLINE), 'Q', aconf->port, aconf->host, aconf->passwd); }}
static voidstats_secure(struct Client *source_p){ struct AddressRec *arec; struct ConfItem *aconf; size_t i;
for (i = 0; i < ATABLE_SIZE; i++) { for (arec = atable[i]; arec; arec = arec->next) { if(arec->type == CONF_SECURE) { aconf = arec->aconf; sendto_one_numeric(source_p, RPL_STATSDEBUG, "s :%s", aconf->host); } } }}
static voidstats_ssld_foreach(void *data, pid_t pid, int cli_count, enum ssld_status status, const char *version){ struct Client *source_p = data;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "S :%ld %c %u :%s", (long)pid, status == SSLD_DEAD ? 'D' : (status == SSLD_SHUTDOWN ? 'S' : 'A'), cli_count, version);}
static voidstats_ssld(struct Client *source_p){ ssld_foreach_info(stats_ssld_foreach, source_p);}
static voidstats_usage (struct Client *source_p){ struct rusage rus; time_t secs; time_t rup;#ifdef hz# define hzz hz#else# ifdef HZ# define hzz HZ# else int hzz = 1;# endif#endif
if(getrusage(RUSAGE_SELF, &rus) == -1) { sendto_one_notice(source_p, ":Getruseage error: %s.", strerror(errno)); return; } secs = rus.ru_utime.tv_sec + rus.ru_stime.tv_sec; if(0 == secs) secs = 1;
rup = (rb_current_time() - startup_time) * hzz; if(0 == rup) rup = 1;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :CPU Secs %d:%02d User %d:%02d System %d:%02d", (int) (secs / 60), (int) (secs % 60), (int) (rus.ru_utime.tv_sec / 60), (int) (rus.ru_utime.tv_sec % 60), (int) (rus.ru_stime.tv_sec / 60), (int) (rus.ru_stime.tv_sec % 60)); sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :RSS %ld ShMem %ld Data %ld Stack %ld", rus.ru_maxrss, (long)(rus.ru_ixrss / rup), (long)(rus.ru_idrss / rup), (long)(rus.ru_isrss / rup)); sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :Swaps %d Reclaims %d Faults %d", (int) rus.ru_nswap, (int) rus.ru_minflt, (int) rus.ru_majflt); sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :Block in %d out %d", (int) rus.ru_inblock, (int) rus.ru_oublock); sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :Msg Rcv %d Send %d", (int) rus.ru_msgrcv, (int) rus.ru_msgsnd); sendto_one_numeric(source_p, RPL_STATSDEBUG, "R :Signals %d Context Vol. %d Invol %d", (int) rus.ru_nsignals, (int) rus.ru_nvcsw, (int) rus.ru_nivcsw);}
static voidstats_tstats (struct Client *source_p){ struct Client *target_p; struct ServerStatistics sp; rb_dlink_node *ptr;
memcpy(&sp, &ServerStats, sizeof(struct ServerStatistics));
RB_DLINK_FOREACH(ptr, serv_list.head) { target_p = ptr->data;
sp.is_sbs += target_p->localClient->sendB; sp.is_sbr += target_p->localClient->receiveB; sp.is_sti += (unsigned long long)(rb_current_time() - target_p->localClient->firsttime); sp.is_sv++; }
RB_DLINK_FOREACH(ptr, lclient_list.head) { target_p = ptr->data;
sp.is_cbs += target_p->localClient->sendB; sp.is_cbr += target_p->localClient->receiveB; sp.is_cti += (unsigned long long)(rb_current_time() - target_p->localClient->firsttime); sp.is_cl++; sp.is_cib += rb_dlink_list_length(&target_p->localClient->pending_batches); sp.is_cibl += target_p->localClient->pending_batch_lines; sp.is_rrb += rb_dlink_list_length(&target_p->localClient->pending_remote_responses); }
RB_DLINK_FOREACH(ptr, unknown_list.head) { sp.is_ni++; }
sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :accepts %u refused %u", sp.is_ac, sp.is_ref); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :rejected %u delaying %lu", sp.is_rej, delay_exit_length()); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :throttled refused %u throttle list size %lu", sp.is_thr, throttle_size()); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :nicks being delayed %lu", get_nd_count()); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :unknown commands %u prefixes %u", sp.is_unco, sp.is_unpf); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :nick collisions %u saves %u unknown closes %u", sp.is_kill, sp.is_save, sp.is_ni); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :wrong direction %u empty %u", sp.is_wrdi, sp.is_empt); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :numerics seen %u", sp.is_num); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :tgchange blocked msgs %u restricted addrs %lu", sp.is_tgch, rb_dlink_list_length(&tgchange_list)); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :ratelimit blocked commands %u", sp.is_rl); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :auth successes %u fails %u", sp.is_asuc, sp.is_abad); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :sasl successes %u fails %u", sp.is_ssuc, sp.is_sbad); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :Client Server"); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :connected %u %u", sp.is_cl, sp.is_sv); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :bytes sent %lluK %lluK", sp.is_cbs / 1024, sp.is_sbs / 1024); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :bytes recv %lluK %lluK", sp.is_cbr / 1024, sp.is_sbr / 1024); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :time connected %llu %llu", sp.is_cti, sp.is_sti); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :open client batches %u lines %u", sp.is_cib, sp.is_cibl); sendto_one_numeric(source_p, RPL_STATSDEBUG, "T :remote response batches %u", sp.is_rrb);}
static voidstats_uptime (struct Client *source_p){ time_t now;
now = rb_current_time() - startup_time; sendto_one_numeric(source_p, RPL_STATSUPTIME, form_str (RPL_STATSUPTIME), (int)(now / 86400), (int)((now / 3600) % 24), (int)((now / 60) % 60), (int)(now % 60)); sendto_one_numeric(source_p, RPL_STATSCONN, form_str (RPL_STATSCONN), MaxConnectionCount, MaxClientCount, Count.totalrestartcount);}
/* stats_servers() * * input - client pointer * output - none * side effects - client is shown lists of who connected servers */static voidstats_servers (struct Client *source_p){ struct Client *target_p; rb_dlink_node *ptr; time_t seconds; int days, hours, minutes; int j = 0;
if(ConfigServerHide.flatten_links && !IsOperGeneral(source_p) && !IsExemptShide(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES)); return; }
RB_DLINK_FOREACH (ptr, serv_list.head) { target_p = ptr->data;
j++; seconds = rb_current_time() - target_p->localClient->firsttime;
days = (int) (seconds / 86400); seconds %= 86400; hours = (int) (seconds / 3600); seconds %= 3600; minutes = (int) (seconds / 60); seconds %= 60;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "V :%s (%s!*@*) Idle: %d SendQ: %d " "Connected: %d day%s, %d:%02d:%02d", target_p->name, (target_p->serv->by[0] ? target_p->serv->by : "Remote."), (int) (rb_current_time() - target_p->localClient->lasttime), (int) rb_linebuf_len (&target_p->localClient->buf_sendq), days, (days == 1) ? "" : "s", hours, minutes, (int) seconds); }
sendto_one_numeric(source_p, RPL_STATSDEBUG, "V :%d Server(s)", j);}
static voidstats_tgecos(struct Client *source_p){ struct ConfItem *aconf; rb_dlink_node *ptr;
RB_DLINK_FOREACH(ptr, xline_conf_list.head) { aconf = ptr->data;
if(aconf->hold) sendto_one_numeric(source_p, RPL_STATSXLINE, form_str(RPL_STATSXLINE), 'x', aconf->port, aconf->host, aconf->passwd); }}
static voidstats_gecos(struct Client *source_p){ struct ConfItem *aconf; rb_dlink_node *ptr;
RB_DLINK_FOREACH(ptr, xline_conf_list.head) { aconf = ptr->data;
if(!aconf->hold) sendto_one_numeric(source_p, RPL_STATSXLINE, form_str(RPL_STATSXLINE), 'X', aconf->port, aconf->host, aconf->passwd); }}
static voidstats_class(struct Client *source_p){ if(ConfigFileEntry.stats_y_oper_only && !IsOperGeneral(source_p)) sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES)); else report_classes(source_p);}
static voidstats_memory (struct Client *source_p){ struct Client *target_p; struct Channel *chptr; rb_dlink_node *rb_dlink; rb_dlink_node *ptr; int channel_count = 0; int local_client_conf_count = 0; /* local client conf links */ int users_counted = 0; /* user structs */
int channel_users = 0; int channel_invites = 0; int channel_bans = 0; int channel_except = 0; int channel_invex = 0; int channel_quiets = 0;
int class_count = 0; /* classes */ int conf_count = 0; /* conf lines */ int users_invited_count = 0; /* users invited */ int user_channels = 0; /* users in channels */ int aways_counted = 0; size_t number_servers_cached; /* number of servers cached by scache */
size_t channel_memory = 0; size_t channel_ban_memory = 0; size_t channel_except_memory = 0; size_t channel_invex_memory = 0; size_t channel_quiet_memory = 0;
size_t away_memory = 0; /* memory used by aways */ size_t ww = 0; /* whowas array count */ size_t wwm = 0; /* whowas array memory used */ size_t conf_memory = 0; /* memory used by conf lines */ size_t mem_servers_cached; /* memory used by scache */
size_t linebuf_count = 0; size_t linebuf_memory_used = 0;
size_t total_channel_memory = 0; size_t totww = 0;
size_t local_client_count = 0; size_t local_client_memory_used = 0;
size_t remote_client_count = 0; size_t remote_client_memory_used = 0;
size_t total_memory = 0;
whowas_memory_usage(&ww, &wwm);
RB_DLINK_FOREACH(ptr, global_client_list.head) { target_p = ptr->data; if(MyConnect(target_p)) { local_client_conf_count++; }
if(target_p->user) { users_counted++; users_invited_count += rb_dlink_list_length(&target_p->user->invited); user_channels += rb_dlink_list_length(&target_p->user->channel); if(target_p->user->away) { aways_counted++; away_memory += (strlen(target_p->user->away) + 1); } } }
/* Count up all channels, ban lists, except lists, Invex lists */ RB_DLINK_FOREACH(ptr, global_channel_list.head) { chptr = ptr->data; channel_count++; channel_memory += (strlen(chptr->chname) + sizeof(struct Channel));
channel_users += rb_dlink_list_length(&chptr->members); channel_invites += rb_dlink_list_length(&chptr->invites);
RB_DLINK_FOREACH(rb_dlink, chptr->banlist.head) { channel_bans++;
channel_ban_memory += sizeof(rb_dlink_node) + sizeof(struct Ban); }
RB_DLINK_FOREACH(rb_dlink, chptr->exceptlist.head) { channel_except++;
channel_except_memory += (sizeof(rb_dlink_node) + sizeof(struct Ban)); }
RB_DLINK_FOREACH(rb_dlink, chptr->invexlist.head) { channel_invex++;
channel_invex_memory += (sizeof(rb_dlink_node) + sizeof(struct Ban)); }
RB_DLINK_FOREACH(rb_dlink, chptr->quietlist.head) { channel_quiets++;
channel_quiet_memory += (sizeof(rb_dlink_node) + sizeof(struct Ban)); } }
/* count up all classes */
class_count = rb_dlink_list_length(&class_list) + 1;
rb_count_rb_linebuf_memory(&linebuf_count, &linebuf_memory_used);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Users %u(%lu) Invites %u(%lu)", users_counted, (unsigned long) users_counted * sizeof(struct User), users_invited_count, (unsigned long) users_invited_count * sizeof(rb_dlink_node));
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :User channels %u(%lu) Aways %u(%zu)", user_channels, (unsigned long) user_channels * sizeof(rb_dlink_node), aways_counted, away_memory);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Attached confs %u(%lu)", local_client_conf_count, (unsigned long) local_client_conf_count * sizeof(rb_dlink_node));
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Conflines %u(%zu)", conf_count, conf_memory);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Classes %u(%lu)", class_count, (unsigned long) class_count * sizeof(struct Class));
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Channels %u(%zu)", channel_count, channel_memory);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Bans %u(%zu) Exceptions %u(%zu) Invex %u(%zu) Quiets %u(%zu)", channel_bans, channel_ban_memory, channel_except, channel_except_memory, channel_invex, channel_invex_memory, channel_quiets, channel_quiet_memory);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Channel members %u(%lu) invite %u(%lu)", channel_users, (unsigned long) channel_users * sizeof(rb_dlink_node), channel_invites, (unsigned long) channel_invites * sizeof(rb_dlink_node));
total_channel_memory = channel_memory + channel_ban_memory + channel_users * sizeof(rb_dlink_node) + channel_invites * sizeof(rb_dlink_node);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Whowas array %zu(%zu)", ww, wwm);
totww = wwm;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Hash: client %u(%lu) chan %u(%lu)", U_MAX, (unsigned long)(U_MAX * sizeof(rb_dlink_list)), CH_MAX, (unsigned long)(CH_MAX * sizeof(rb_dlink_list)));
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :linebuf %zu(%zu)", linebuf_count, linebuf_memory_used);
count_scache(&number_servers_cached, &mem_servers_cached);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :scache %zu(%zu)", number_servers_cached, mem_servers_cached);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :hostname hash %d(%lu)", HOST_MAX, (unsigned long)HOST_MAX * sizeof(rb_dlink_list));
total_memory = totww + total_channel_memory + conf_memory + class_count * sizeof(struct Class);
total_memory += mem_servers_cached; sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Total: whowas %zu channel %zu conf %zu", totww, total_channel_memory, conf_memory);
count_local_client_memory(&local_client_count, &local_client_memory_used); total_memory += local_client_memory_used;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Local client Memory in use: %zu(%zu)", local_client_count, local_client_memory_used);
count_remote_client_memory(&remote_client_count, &remote_client_memory_used); total_memory += remote_client_memory_used;
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :Remote client Memory in use: %zu(%zu)", remote_client_count, remote_client_memory_used);
sendto_one_numeric(source_p, RPL_STATSDEBUG, "z :TOTAL: %zu", total_memory);}
static voidstats_servlinks (struct Client *source_p){ static char Sformat[] = ":%s %d %s %s %d %"PRIu32" %"PRIu32" %"PRIu32" %"PRIu32" :%"PRId64" %"PRId64" %s"; long uptime, sendK, receiveK; struct Client *target_p; rb_dlink_node *ptr; int j = 0; char buf[128];
if(ConfigServerHide.flatten_links && !IsOperGeneral (source_p) && !IsExemptShide(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str (ERR_NOPRIVILEGES)); return; }
sendK = receiveK = 0;
RB_DLINK_FOREACH (ptr, serv_list.head) { target_p = ptr->data;
j++; sendK += target_p->localClient->sendK; receiveK += target_p->localClient->receiveK;
sendto_one(source_p, Sformat, get_id(&me, source_p), RPL_STATSLINKINFO, get_id(source_p, source_p), target_p->name, rb_linebuf_len(&target_p->localClient->buf_sendq), target_p->localClient->sendM, target_p->localClient->sendK, target_p->localClient->receiveM, target_p->localClient->receiveK, (int64_t)(rb_current_time() - target_p->localClient->firsttime), (int64_t)((rb_current_time() > target_p->localClient->lasttime) ? (rb_current_time() - target_p->localClient->lasttime) : 0), IsOperGeneral (source_p) ? show_capabilities (target_p) : "TS"); }
sendto_one_numeric(source_p, RPL_STATSDEBUG, "? :%u total server(s)", j);
snprintf(buf, sizeof buf, "%7.2f", _GMKv ((sendK))); sendto_one_numeric(source_p, RPL_STATSDEBUG, "? :Sent total : %s %s", buf, _GMKs (sendK)); snprintf(buf, sizeof buf, "%7.2f", _GMKv ((receiveK))); sendto_one_numeric(source_p, RPL_STATSDEBUG, "? :Recv total : %s %s", buf, _GMKs (receiveK));
uptime = (rb_current_time() - startup_time); snprintf(buf, sizeof buf, "%7.2f %s (%4.1f K/s)", _GMKv (me.localClient->sendK), _GMKs (me.localClient->sendK), (float) ((float) me.localClient->sendK / (float) uptime)); sendto_one_numeric(source_p, RPL_STATSDEBUG, "? :Server send: %s", buf); snprintf(buf, sizeof buf, "%7.2f %s (%4.1f K/s)", _GMKv (me.localClient->receiveK), _GMKs (me.localClient->receiveK), (float) ((float) me.localClient->receiveK / (float) uptime)); sendto_one_numeric(source_p, RPL_STATSDEBUG, "? :Server recv: %s", buf);}
static inline boolstats_l_should_show_oper(struct Client *source_p, struct Client *target_p){ return SeesOper(target_p, source_p);}
static voidstats_ltrace(struct Client *source_p, int parc, const char *parv[]){ bool doall = false; bool wilds = false; const char *name; char statchar = parv[1][0];
if (ConfigFileEntry.stats_l_oper_only == STATS_L_OPER_ONLY_YES && !IsOperGeneral(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str(ERR_NOPRIVILEGES)); return; }
/* this is def targeted at us somehow.. */ if (parc > 2 && !EmptyString(parv[2])) { /* directed at us generically? */ if (match(parv[2], me.name) || (!MyClient(source_p) && !irccmp(parv[2], me.id))) { name = me.name; doall = true; } else { name = parv[2]; wilds = strchr(name, '*') || strchr(name, '?'); }
/* must be directed at a specific person thats not us */ if (!doall && !wilds) { struct Client *target_p;
if (MyClient(source_p)) target_p = find_named_person(name); else target_p = find_person(name);
if (target_p != source_p && ConfigFileEntry.stats_l_oper_only != STATS_L_OPER_ONLY_NO && !IsOperGeneral(source_p)) { sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str(ERR_NOPRIVILEGES)); } else if (target_p != NULL) { stats_l_client(source_p, target_p, statchar); } else { sendto_one_numeric(source_p, ERR_NOSUCHSERVER, form_str(ERR_NOSUCHSERVER), name); }
return; } } else { name = me.name; doall = true; }
if (ConfigFileEntry.stats_l_oper_only != STATS_L_OPER_ONLY_NO && !IsOperGeneral(source_p)) { if (doall && MyClient(source_p)) stats_l_client(source_p, source_p, statchar); else sendto_one_numeric(source_p, ERR_NOPRIVILEGES, form_str(ERR_NOPRIVILEGES)); return; }
if (doall) { /* local opers get everyone */ if(MyOper(source_p)) { stats_l_list(source_p, name, doall, wilds, &unknown_list, statchar, NULL); stats_l_list(source_p, name, doall, wilds, &lclient_list, statchar, NULL); } else { /* they still need themselves if theyre local.. */ if(MyClient(source_p)) stats_l_client(source_p, source_p, statchar);
stats_l_list(source_p, name, doall, wilds, &local_oper_list, statchar, stats_l_should_show_oper); }
if (!ConfigServerHide.flatten_links || IsOperGeneral(source_p) || IsExemptShide(source_p)) stats_l_list(source_p, name, doall, wilds, &serv_list, statchar, NULL);
return; }
/* ok, at this point theyre looking for a specific client whos on * our server.. but it contains a wildcard. --fl */ stats_l_list(source_p, name, doall, wilds, &lclient_list, statchar, NULL);
return;}
static voidstats_l_list(struct Client *source_p, const char *name, bool doall, bool wilds, rb_dlink_list * list, char statchar, bool (*check_fn)(struct Client *source_p, struct Client *target_p)){ rb_dlink_node *ptr; struct Client *target_p;
/* send information about connections which match. note, we * dont need tests for IsInvisible(), because non-opers will * never get here for normal clients --fl */ RB_DLINK_FOREACH(ptr, list->head) { target_p = ptr->data;
if(!doall && wilds && !match(name, target_p->name)) continue;
if (check_fn == NULL || check_fn(source_p, target_p)) stats_l_client(source_p, target_p, statchar); }}
voidstats_l_client(struct Client *source_p, struct Client *target_p, char statchar){ if(IsAnyServer(target_p)) { sendto_one_numeric(source_p, RPL_STATSLINKINFO, Lformat, target_p->name, rb_linebuf_len(&target_p->localClient->buf_sendq), target_p->localClient->sendM, target_p->localClient->sendK, target_p->localClient->receiveM, target_p->localClient->receiveK, (int64_t)(rb_current_time() - target_p->localClient->firsttime), (int64_t)((rb_current_time() > target_p->localClient->lasttime) ? (rb_current_time() - target_p->localClient->lasttime) : 0), IsOperGeneral(source_p) ? show_capabilities(target_p) : "-"); }
else { /* fire the doing_stats_show_idle hook to allow modules to tell us whether to show the idle time */ hook_data_client_approval hdata_showidle;
hdata_showidle.client = source_p; hdata_showidle.target = target_p; hdata_showidle.approved = WHOIS_IDLE_SHOW;
call_hook(doing_stats_show_idle_hook, &hdata_showidle); sendto_one_numeric(source_p, RPL_STATSLINKINFO, Lformat, show_ip(source_p, target_p) ? (IsUpper(statchar) ? get_client_name(target_p, SHOW_IP) : get_client_name(target_p, HIDE_IP)) : get_client_name(target_p, MASK_IP), hdata_showidle.approved ? rb_linebuf_len(&target_p->localClient->buf_sendq) : 0, hdata_showidle.approved ? target_p->localClient->sendM : (uint32_t)0, hdata_showidle.approved ? target_p->localClient->sendK : (uint32_t)0, hdata_showidle.approved ? target_p->localClient->receiveM : (uint32_t)0, hdata_showidle.approved ? target_p->localClient->receiveK : (uint32_t)0, (int64_t)(rb_current_time() - target_p->localClient->firsttime), (int64_t)((rb_current_time() > target_p->localClient->lasttime) && hdata_showidle.approved ? (rb_current_time() - target_p->localClient->lasttime) : 0), "-"); }}
static voidrb_dump_fd_callback(int fd, const char *desc, void *data){ struct Client *source_p = data; sendto_one_numeric(source_p, RPL_STATSDEBUG, "F :fd %-3d desc '%s'", fd, desc);}
static voidstats_comm(struct Client *source_p){ rb_dump_fd(rb_dump_fd_callback, source_p);}