]> jfr.im git - solanum.git/blob - src/client.c
charybdis 3.5.0.
[solanum.git] / src / client.c
1 /*
2 * charybdis: an advanced ircd.
3 * client.c: Controls clients.
4 *
5 * Copyright (C) 1990 Jarkko Oikarinen and University of Oulu, Co Center
6 * Copyright (C) 1996-2002 Hybrid Development Team
7 * Copyright (C) 2002-2005 ircd-ratbox development team
8 * Copyright (C) 2007 William Pitcock
9 *
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
14 *
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
23 * USA
24 *
25 * $Id: client.c 3514 2007-06-06 16:25:21Z nenolod $
26 */
27 #include "stdinc.h"
28 #include "config.h"
29
30 #include "client.h"
31 #include "class.h"
32 #include "common.h"
33 #include "hash.h"
34 #include "match.h"
35 #include "ircd.h"
36 #include "numeric.h"
37 #include "packet.h"
38 #include "s_auth.h"
39 #include "s_conf.h"
40 #include "s_newconf.h"
41 #include "logger.h"
42 #include "s_serv.h"
43 #include "s_stats.h"
44 #include "send.h"
45 #include "whowas.h"
46 #include "s_user.h"
47 #include "hash.h"
48 #include "hostmask.h"
49 #include "listener.h"
50 #include "hook.h"
51 #include "msg.h"
52 #include "monitor.h"
53 #include "blacklist.h"
54 #include "reject.h"
55 #include "scache.h"
56 #include "irc_dictionary.h"
57 #include "sslproc.h"
58 #include "s_assert.h"
59
60 #define DEBUG_EXITED_CLIENTS
61
62 static void check_pings_list(rb_dlink_list * list);
63 static void check_unknowns_list(rb_dlink_list * list);
64 static void free_exited_clients(void *unused);
65 static void exit_aborted_clients(void *unused);
66
67 static int exit_remote_client(struct Client *, struct Client *, struct Client *,const char *);
68 static int exit_remote_server(struct Client *, struct Client *, struct Client *,const char *);
69 static int exit_local_client(struct Client *, struct Client *, struct Client *,const char *);
70 static int exit_unknown_client(struct Client *, struct Client *, struct Client *,const char *);
71 static int exit_local_server(struct Client *, struct Client *, struct Client *,const char *);
72 static int qs_server(struct Client *, struct Client *, struct Client *, const char *comment);
73
74 static EVH check_pings;
75
76 static rb_bh *client_heap = NULL;
77 static rb_bh *lclient_heap = NULL;
78 static rb_bh *pclient_heap = NULL;
79 static rb_bh *user_heap = NULL;
80 static rb_bh *away_heap = NULL;
81 static char current_uid[IDLEN];
82 static int32_t current_connid = 0;
83
84 struct Dictionary *nd_dict = NULL;
85
86 enum
87 {
88 D_LINED,
89 K_LINED
90 };
91
92 rb_dlink_list dead_list;
93 #ifdef DEBUG_EXITED_CLIENTS
94 static rb_dlink_list dead_remote_list;
95 #endif
96
97 struct abort_client
98 {
99 rb_dlink_node node;
100 struct Client *client;
101 char notice[REASONLEN];
102 };
103
104 static rb_dlink_list abort_list;
105
106
107 /*
108 * init_client
109 *
110 * inputs - NONE
111 * output - NONE
112 * side effects - initialize client free memory
113 */
114 void
115 init_client(void)
116 {
117 /*
118 * start off the check ping event .. -- adrian
119 * Every 30 seconds is plenty -- db
120 */
121 client_heap = rb_bh_create(sizeof(struct Client), CLIENT_HEAP_SIZE, "client_heap");
122 lclient_heap = rb_bh_create(sizeof(struct LocalUser), LCLIENT_HEAP_SIZE, "lclient_heap");
123 pclient_heap = rb_bh_create(sizeof(struct PreClient), PCLIENT_HEAP_SIZE, "pclient_heap");
124 user_heap = rb_bh_create(sizeof(struct User), USER_HEAP_SIZE, "user_heap");
125 away_heap = rb_bh_create(AWAYLEN, AWAY_HEAP_SIZE, "away_heap");
126
127 rb_event_addish("check_pings", check_pings, NULL, 30);
128 rb_event_addish("free_exited_clients", &free_exited_clients, NULL, 4);
129 rb_event_addish("exit_aborted_clients", exit_aborted_clients, NULL, 1);
130 rb_event_add("flood_recalc", flood_recalc, NULL, 1);
131
132 nd_dict = irc_dictionary_create(irccmp);
133 }
134
135
136 /*
137 * make_client - create a new Client struct and set it to initial state.
138 *
139 * from == NULL, create local client (a client connected
140 * to a socket).
141 *
142 * from, create remote client (behind a socket
143 * associated with the client defined by
144 * 'from'). ('from' is a local client!!).
145 */
146 struct Client *
147 make_client(struct Client *from)
148 {
149 struct Client *client_p = NULL;
150 struct LocalUser *localClient;
151
152 client_p = rb_bh_alloc(client_heap);
153
154 if(from == NULL)
155 {
156 client_p->from = client_p; /* 'from' of local client is self! */
157
158 localClient = rb_bh_alloc(lclient_heap);
159 SetMyConnect(client_p);
160 client_p->localClient = localClient;
161
162 client_p->localClient->lasttime = client_p->localClient->firsttime = rb_current_time();
163
164 client_p->localClient->F = NULL;
165
166 if(current_connid+1 == 0)
167 current_connid++;
168
169 client_p->localClient->connid = ++current_connid;
170
171 if(current_connid+1 == 0)
172 current_connid++;
173
174 client_p->localClient->zconnid = ++current_connid;
175 add_to_cli_connid_hash(client_p);
176
177 client_p->preClient = rb_bh_alloc(pclient_heap);
178
179 /* as good a place as any... */
180 rb_dlinkAdd(client_p, &client_p->localClient->tnode, &unknown_list);
181 }
182 else
183 { /* from is not NULL */
184 client_p->localClient = NULL;
185 client_p->preClient = NULL;
186 client_p->from = from; /* 'from' of local client is self! */
187 }
188
189 SetUnknown(client_p);
190 strcpy(client_p->username, "unknown");
191
192 return client_p;
193 }
194
195 void
196 free_pre_client(struct Client *client_p)
197 {
198 struct Blacklist *blptr;
199
200 s_assert(NULL != client_p);
201
202 if(client_p->preClient == NULL)
203 return;
204
205 blptr = client_p->preClient->dnsbl_listed;
206 if (blptr != NULL)
207 unref_blacklist(blptr);
208 s_assert(rb_dlink_list_length(&client_p->preClient->dnsbl_queries) == 0);
209
210 rb_bh_free(pclient_heap, client_p->preClient);
211 client_p->preClient = NULL;
212 }
213
214 static void
215 free_local_client(struct Client *client_p)
216 {
217 s_assert(NULL != client_p);
218 s_assert(&me != client_p);
219
220 if(client_p->localClient == NULL)
221 return;
222
223 /*
224 * clean up extra sockets from P-lines which have been discarded.
225 */
226 if(client_p->localClient->listener)
227 {
228 s_assert(0 < client_p->localClient->listener->ref_count);
229 if(0 == --client_p->localClient->listener->ref_count
230 && !client_p->localClient->listener->active)
231 free_listener(client_p->localClient->listener);
232 client_p->localClient->listener = 0;
233 }
234
235 del_from_cli_connid_hash(client_p);
236 if(client_p->localClient->F != NULL)
237 {
238 rb_close(client_p->localClient->F);
239 }
240
241 if(client_p->localClient->passwd)
242 {
243 memset(client_p->localClient->passwd, 0,
244 strlen(client_p->localClient->passwd));
245 rb_free(client_p->localClient->passwd);
246 }
247
248 rb_free(client_p->localClient->auth_user);
249 rb_free(client_p->localClient->challenge);
250 rb_free(client_p->localClient->fullcaps);
251 rb_free(client_p->localClient->opername);
252 rb_free(client_p->localClient->mangledhost);
253 if (client_p->localClient->privset)
254 privilegeset_unref(client_p->localClient->privset);
255
256 if(IsSSL(client_p))
257 ssld_decrement_clicount(client_p->localClient->ssl_ctl);
258
259 if(IsCapable(client_p, CAP_ZIP))
260 ssld_decrement_clicount(client_p->localClient->z_ctl);
261
262 rb_bh_free(lclient_heap, client_p->localClient);
263 client_p->localClient = NULL;
264 }
265
266 void
267 free_client(struct Client *client_p)
268 {
269 s_assert(NULL != client_p);
270 s_assert(&me != client_p);
271 free_local_client(client_p);
272 free_pre_client(client_p);
273 rb_free(client_p->certfp);
274 rb_bh_free(client_heap, client_p);
275 }
276
277 /*
278 * check_pings - go through the local client list and check activity
279 * kill off stuff that should die
280 *
281 * inputs - NOT USED (from event)
282 * output - next time_t when check_pings() should be called again
283 * side effects -
284 *
285 *
286 * A PING can be sent to clients as necessary.
287 *
288 * Client/Server ping outs are handled.
289 */
290
291 /*
292 * Addon from adrian. We used to call this after nextping seconds,
293 * however I've changed it to run once a second. This is only for
294 * PING timeouts, not K/etc-line checks (thanks dianora!). Having it
295 * run once a second makes life a lot easier - when a new client connects
296 * and they need a ping in 4 seconds, if nextping was set to 20 seconds
297 * we end up waiting 20 seconds. This is stupid. :-)
298 * I will optimise (hah!) check_pings() once I've finished working on
299 * tidying up other network IO evilnesses.
300 * -- adrian
301 */
302
303 static void
304 check_pings(void *notused)
305 {
306 check_pings_list(&lclient_list);
307 check_pings_list(&serv_list);
308 check_unknowns_list(&unknown_list);
309 }
310
311 /*
312 * Check_pings_list()
313 *
314 * inputs - pointer to list to check
315 * output - NONE
316 * side effects -
317 */
318 static void
319 check_pings_list(rb_dlink_list * list)
320 {
321 char scratch[32]; /* way too generous but... */
322 struct Client *client_p; /* current local client_p being examined */
323 int ping = 0; /* ping time value from client */
324 rb_dlink_node *ptr, *next_ptr;
325
326 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, list->head)
327 {
328 client_p = ptr->data;
329
330 if(!MyConnect(client_p) || IsDead(client_p))
331 continue;
332
333 ping = get_client_ping(client_p);
334
335 if(ping < (rb_current_time() - client_p->localClient->lasttime))
336 {
337 /*
338 * If the client/server hasnt talked to us in 2*ping seconds
339 * and it has a ping time, then close its connection.
340 */
341 if(((rb_current_time() - client_p->localClient->lasttime) >= (2 * ping)
342 && (client_p->flags & FLAGS_PINGSENT)))
343 {
344 if(IsServer(client_p))
345 {
346 sendto_realops_snomask(SNO_GENERAL, L_ALL,
347 "No response from %s, closing link",
348 client_p->name);
349 ilog(L_SERVER,
350 "No response from %s, closing link",
351 log_client_name(client_p, HIDE_IP));
352 }
353 (void) rb_snprintf(scratch, sizeof(scratch),
354 "Ping timeout: %d seconds",
355 (int) (rb_current_time() - client_p->localClient->lasttime));
356
357 exit_client(client_p, client_p, &me, scratch);
358 continue;
359 }
360 else if((client_p->flags & FLAGS_PINGSENT) == 0)
361 {
362 /*
363 * if we havent PINGed the connection and we havent
364 * heard from it in a while, PING it to make sure
365 * it is still alive.
366 */
367 client_p->flags |= FLAGS_PINGSENT;
368 /* not nice but does the job */
369 client_p->localClient->lasttime = rb_current_time() - ping;
370 sendto_one(client_p, "PING :%s", me.name);
371 }
372 }
373 /* ping_timeout: */
374
375 }
376 }
377
378 /*
379 * check_unknowns_list
380 *
381 * inputs - pointer to list of unknown clients
382 * output - NONE
383 * side effects - unknown clients get marked for termination after n seconds
384 */
385 static void
386 check_unknowns_list(rb_dlink_list * list)
387 {
388 rb_dlink_node *ptr, *next_ptr;
389 struct Client *client_p;
390 int timeout;
391
392 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, list->head)
393 {
394 client_p = ptr->data;
395
396 if(IsDead(client_p) || IsClosing(client_p))
397 continue;
398
399 /* still has DNSbls to validate against */
400 if(client_p->preClient != NULL &&
401 rb_dlink_list_length(&client_p->preClient->dnsbl_queries) > 0)
402 continue;
403
404 /*
405 * Check UNKNOWN connections - if they have been in this state
406 * for > 30s, close them.
407 */
408
409 timeout = IsAnyServer(client_p) ? ConfigFileEntry.connect_timeout : 30;
410 if((rb_current_time() - client_p->localClient->firsttime) > timeout)
411 {
412 if(IsAnyServer(client_p))
413 {
414 sendto_realops_snomask(SNO_GENERAL, is_remote_connect(client_p) ? L_NETWIDE : L_ALL,
415 "No response from %s, closing link",
416 client_p->name);
417 ilog(L_SERVER,
418 "No response from %s, closing link",
419 log_client_name(client_p, HIDE_IP));
420 }
421 exit_client(client_p, client_p, &me, "Connection timed out");
422 }
423 }
424 }
425
426 static void
427 notify_banned_client(struct Client *client_p, struct ConfItem *aconf, int ban)
428 {
429 static const char conn_closed[] = "Connection closed";
430 static const char d_lined[] = "D-lined";
431 static const char k_lined[] = "K-lined";
432 const char *reason = NULL;
433 const char *exit_reason = conn_closed;
434
435 if(ConfigFileEntry.kline_with_reason)
436 {
437 reason = get_user_ban_reason(aconf);
438 exit_reason = reason;
439 }
440 else
441 {
442 reason = aconf->status == D_LINED ? d_lined : k_lined;
443 }
444
445 if(ban == D_LINED && !IsPerson(client_p))
446 sendto_one(client_p, "NOTICE DLINE :*** You have been D-lined");
447 else
448 sendto_one(client_p, form_str(ERR_YOUREBANNEDCREEP),
449 me.name, client_p->name, reason);
450
451 exit_client(client_p, client_p, &me,
452 EmptyString(ConfigFileEntry.kline_reason) ? exit_reason :
453 ConfigFileEntry.kline_reason);
454 }
455
456 /*
457 * check_banned_lines
458 * inputs - NONE
459 * output - NONE
460 * side effects - Check all connections for a pending k/dline against the
461 * client, exit the client if found.
462 */
463 void
464 check_banned_lines(void)
465 {
466 check_dlines();
467 check_klines();
468 check_xlines();
469 }
470
471 /* check_klines_event()
472 *
473 * inputs -
474 * outputs -
475 * side effects - check_klines() is called, kline_queued unset
476 */
477 void
478 check_klines_event(void *unused)
479 {
480 kline_queued = 0;
481 check_klines();
482 }
483
484 /* check_klines
485 *
486 * inputs -
487 * outputs -
488 * side effects - all clients will be checked for klines
489 */
490 void
491 check_klines(void)
492 {
493 struct Client *client_p;
494 struct ConfItem *aconf;
495 rb_dlink_node *ptr;
496 rb_dlink_node *next_ptr;
497
498 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, lclient_list.head)
499 {
500 client_p = ptr->data;
501
502 if(IsMe(client_p) || !IsPerson(client_p))
503 continue;
504
505 if((aconf = find_kline(client_p)) != NULL)
506 {
507 if(IsExemptKline(client_p))
508 {
509 sendto_realops_snomask(SNO_GENERAL, L_ALL,
510 "KLINE over-ruled for %s, client is kline_exempt [%s@%s]",
511 get_client_name(client_p, HIDE_IP),
512 aconf->user, aconf->host);
513 continue;
514 }
515
516 sendto_realops_snomask(SNO_GENERAL, L_ALL,
517 "KLINE active for %s",
518 get_client_name(client_p, HIDE_IP));
519
520 notify_banned_client(client_p, aconf, K_LINED);
521 continue;
522 }
523 }
524 }
525
526 /* check_dlines()
527 *
528 * inputs -
529 * outputs -
530 * side effects - all clients will be checked for dlines
531 */
532 void
533 check_dlines(void)
534 {
535 struct Client *client_p;
536 struct ConfItem *aconf;
537 rb_dlink_node *ptr;
538 rb_dlink_node *next_ptr;
539
540 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, lclient_list.head)
541 {
542 client_p = ptr->data;
543
544 if(IsMe(client_p))
545 continue;
546
547 if((aconf = find_dline((struct sockaddr *)&client_p->localClient->ip,client_p->localClient->ip.ss_family)) != NULL)
548 {
549 if(aconf->status & CONF_EXEMPTDLINE)
550 continue;
551
552 sendto_realops_snomask(SNO_GENERAL, L_ALL,
553 "DLINE active for %s",
554 get_client_name(client_p, HIDE_IP));
555
556 notify_banned_client(client_p, aconf, D_LINED);
557 continue;
558 }
559 }
560
561 /* dlines need to be checked against unknowns too */
562 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, unknown_list.head)
563 {
564 client_p = ptr->data;
565
566 if((aconf = find_dline((struct sockaddr *)&client_p->localClient->ip,client_p->localClient->ip.ss_family)) != NULL)
567 {
568 if(aconf->status & CONF_EXEMPTDLINE)
569 continue;
570
571 notify_banned_client(client_p, aconf, D_LINED);
572 }
573 }
574 }
575
576 /* check_xlines
577 *
578 * inputs -
579 * outputs -
580 * side effects - all clients will be checked for xlines
581 */
582 void
583 check_xlines(void)
584 {
585 struct Client *client_p;
586 struct ConfItem *aconf;
587 rb_dlink_node *ptr;
588 rb_dlink_node *next_ptr;
589
590 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, lclient_list.head)
591 {
592 client_p = ptr->data;
593
594 if(IsMe(client_p) || !IsPerson(client_p))
595 continue;
596
597 if((aconf = find_xline(client_p->info, 1)) != NULL)
598 {
599 if(IsExemptKline(client_p))
600 {
601 sendto_realops_snomask(SNO_GENERAL, L_ALL,
602 "XLINE over-ruled for %s, client is kline_exempt [%s]",
603 get_client_name(client_p, HIDE_IP),
604 aconf->host);
605 continue;
606 }
607
608 sendto_realops_snomask(SNO_GENERAL, L_ALL, "XLINE active for %s",
609 get_client_name(client_p, HIDE_IP));
610
611 (void) exit_client(client_p, client_p, &me, "Bad user info");
612 continue;
613 }
614 }
615 }
616
617 /* resv_nick_fnc
618 *
619 * inputs - resv, reason, time
620 * outputs - NONE
621 * side effects - all local clients matching resv will be FNC'd
622 */
623 void
624 resv_nick_fnc(const char *mask, const char *reason, int temp_time)
625 {
626 struct Client *client_p, *target_p;
627 rb_dlink_node *ptr;
628 rb_dlink_node *next_ptr;
629 char *nick;
630 char note[NICKLEN+10];
631
632 if (!ConfigFileEntry.resv_fnc)
633 return;
634
635 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, lclient_list.head)
636 {
637 client_p = ptr->data;
638
639 if(IsMe(client_p) || !IsPerson(client_p) || IsExemptResv(client_p))
640 continue;
641
642 /* Skip users that already have UID nicks. */
643 if(IsDigit(client_p->name[0]))
644 continue;
645
646 if(match_esc(mask, client_p->name))
647 {
648 nick = client_p->id;
649
650 /* Tell opers. */
651 sendto_realops_snomask(SNO_GENERAL, L_ALL,
652 "RESV forced nick change for %s!%s@%s to %s; nick matched [%s] (%s)",
653 client_p->name, client_p->username, client_p->host, nick, mask, reason);
654
655 sendto_realops_snomask(SNO_NCHANGE, L_ALL,
656 "Nick change: From %s to %s [%s@%s]",
657 client_p->name, nick, client_p->username, client_p->host);
658
659 /* Tell the user. */
660 if (temp_time > 0)
661 {
662 sendto_one_notice(client_p,
663 ":*** Nick %s is temporarily unavailable on this server.",
664 client_p->name);
665 }
666 else
667 {
668 sendto_one_notice(client_p,
669 ":*** Nick %s is no longer available on this server.",
670 client_p->name);
671 }
672
673 /* Do all of the nick-changing gymnastics. */
674 client_p->tsinfo = rb_current_time();
675 add_history(client_p, 1);
676
677 monitor_signoff(client_p);
678
679 invalidate_bancache_user(client_p);
680
681 sendto_common_channels_local(client_p, NOCAPS, NOCAPS, ":%s!%s@%s NICK :%s",
682 client_p->name, client_p->username, client_p->host, nick);
683 sendto_server(client_p, NULL, CAP_TS6, NOCAPS, ":%s NICK %s :%ld",
684 use_id(client_p), nick, (long) client_p->tsinfo);
685
686 del_from_client_hash(client_p->name, client_p);
687 rb_strlcpy(client_p->name, nick, sizeof(client_p->name));
688 add_to_client_hash(nick, client_p);
689
690 monitor_signon(client_p);
691
692 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, client_p->on_allow_list.head)
693 {
694 target_p = ptr->data;
695 rb_dlinkFindDestroy(client_p, &target_p->localClient->allow_list);
696 rb_dlinkDestroy(ptr, &client_p->on_allow_list);
697 }
698
699 rb_snprintf(note, sizeof(note), "Nick: %s", nick);
700 rb_note(client_p->localClient->F, note);
701 }
702 }
703 }
704
705 /*
706 * update_client_exit_stats
707 *
708 * input - pointer to client
709 * output - NONE
710 * side effects -
711 */
712 static void
713 update_client_exit_stats(struct Client *client_p)
714 {
715 if(IsServer(client_p))
716 {
717 sendto_realops_snomask(SNO_EXTERNAL, L_ALL,
718 "Server %s split from %s",
719 client_p->name, client_p->servptr->name);
720 if(HasSentEob(client_p))
721 eob_count--;
722 }
723 else if(IsClient(client_p))
724 {
725 --Count.total;
726 if(IsOper(client_p))
727 --Count.oper;
728 if(IsInvisible(client_p))
729 --Count.invisi;
730 }
731
732 if(splitchecking && !splitmode)
733 check_splitmode(NULL);
734 }
735
736 /*
737 * release_client_state
738 *
739 * input - pointer to client to release
740 * output - NONE
741 * side effects -
742 */
743 static void
744 release_client_state(struct Client *client_p)
745 {
746 if(client_p->user != NULL)
747 {
748 free_user(client_p->user, client_p); /* try this here */
749 }
750 if(client_p->serv)
751 {
752 if(client_p->serv->user != NULL)
753 free_user(client_p->serv->user, client_p);
754 if(client_p->serv->fullcaps)
755 rb_free(client_p->serv->fullcaps);
756 rb_free(client_p->serv);
757 }
758 }
759
760 /*
761 * remove_client_from_list
762 * inputs - point to client to remove
763 * output - NONE
764 * side effects - taken the code from ExitOneClient() for this
765 * and placed it here. - avalon
766 */
767 static void
768 remove_client_from_list(struct Client *client_p)
769 {
770 s_assert(NULL != client_p);
771
772 if(client_p == NULL)
773 return;
774
775 /* A client made with make_client()
776 * is on the unknown_list until removed.
777 * If it =does= happen to exit before its removed from that list
778 * and its =not= on the global_client_list, it will core here.
779 * short circuit that case now -db
780 */
781 if(client_p->node.prev == NULL && client_p->node.next == NULL)
782 return;
783
784 rb_dlinkDelete(&client_p->node, &global_client_list);
785
786 update_client_exit_stats(client_p);
787 }
788
789
790 /* clean_nick()
791 *
792 * input - nickname to check, flag for nick from local client
793 * output - 0 if erroneous, else 1
794 * side effects -
795 */
796 int
797 clean_nick(const char *nick, int loc_client)
798 {
799 int len = 0;
800
801 /* nicks cant start with a digit or -, and must have a length */
802 if(*nick == '-' || *nick == '\0')
803 return 0;
804
805 if(loc_client && IsDigit(*nick))
806 return 0;
807
808 for(; *nick; nick++)
809 {
810 len++;
811 if(!IsNickChar(*nick))
812 return 0;
813 }
814
815 /* nicklen is +1 */
816 if(len >= NICKLEN && (unsigned int)len >= ConfigFileEntry.nicklen)
817 return 0;
818
819 return 1;
820 }
821
822 /*
823 * find_person - find person by (nick)name.
824 * inputs - pointer to name
825 * output - return client pointer
826 * side effects -
827 */
828 struct Client *
829 find_person(const char *name)
830 {
831 struct Client *c2ptr;
832
833 c2ptr = find_client(name);
834
835 if(c2ptr && IsPerson(c2ptr))
836 return (c2ptr);
837 return (NULL);
838 }
839
840 struct Client *
841 find_named_person(const char *name)
842 {
843 struct Client *c2ptr;
844
845 c2ptr = find_named_client(name);
846
847 if(c2ptr && IsPerson(c2ptr))
848 return (c2ptr);
849 return (NULL);
850 }
851
852
853 /*
854 * find_chasing - find the client structure for a nick name (user)
855 * using history mechanism if necessary. If the client is not found,
856 * an error message (NO SUCH NICK) is generated. If the client was found
857 * through the history, chasing will be 1 and otherwise 0.
858 */
859 struct Client *
860 find_chasing(struct Client *source_p, const char *user, int *chasing)
861 {
862 struct Client *who;
863
864 if(MyClient(source_p))
865 who = find_named_person(user);
866 else
867 who = find_person(user);
868
869 if(chasing)
870 *chasing = 0;
871
872 if(who || IsDigit(*user))
873 return who;
874
875 if(!(who = get_history(user, (long) KILLCHASETIMELIMIT)))
876 {
877 sendto_one_numeric(source_p, ERR_NOSUCHNICK,
878 form_str(ERR_NOSUCHNICK), user);
879 return (NULL);
880 }
881 if(chasing)
882 *chasing = 1;
883 return who;
884 }
885
886 /*
887 * get_client_name - Return the name of the client
888 * for various tracking and
889 * admin purposes. The main purpose of this function is to
890 * return the "socket host" name of the client, if that
891 * differs from the advertised name (other than case).
892 * But, this can be used to any client structure.
893 *
894 * NOTE 1:
895 * Watch out the allocation of "nbuf", if either source_p->name
896 * or source_p->sockhost gets changed into pointers instead of
897 * directly allocated within the structure...
898 *
899 * NOTE 2:
900 * Function return either a pointer to the structure (source_p) or
901 * to internal buffer (nbuf). *NEVER* use the returned pointer
902 * to modify what it points!!!
903 */
904
905 const char *
906 get_client_name(struct Client *client, int showip)
907 {
908 static char nbuf[HOSTLEN * 2 + USERLEN + 5];
909
910 s_assert(NULL != client);
911 if(client == NULL)
912 return NULL;
913
914 if(MyConnect(client))
915 {
916 if(!irccmp(client->name, client->host))
917 return client->name;
918
919 if(ConfigFileEntry.hide_spoof_ips &&
920 showip == SHOW_IP && IsIPSpoof(client))
921 showip = MASK_IP;
922 if(IsAnyServer(client))
923 showip = MASK_IP;
924
925 /* And finally, let's get the host information, ip or name */
926 switch (showip)
927 {
928 case SHOW_IP:
929 rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
930 client->name, client->username,
931 client->sockhost);
932 break;
933 case MASK_IP:
934 rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@255.255.255.255]",
935 client->name, client->username);
936 break;
937 default:
938 rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
939 client->name, client->username, client->host);
940 }
941 return nbuf;
942 }
943
944 /* As pointed out by Adel Mezibra
945 * Neph|l|m@EFnet. Was missing a return here.
946 */
947 return client->name;
948 }
949
950 /* log_client_name()
951 *
952 * This version is the same as get_client_name, but doesnt contain the
953 * code that will hide IPs always. This should be used for logfiles.
954 */
955 const char *
956 log_client_name(struct Client *target_p, int showip)
957 {
958 static char nbuf[HOSTLEN * 2 + USERLEN + 5];
959
960 if(target_p == NULL)
961 return NULL;
962
963 if(MyConnect(target_p))
964 {
965 if(irccmp(target_p->name, target_p->host) == 0)
966 return target_p->name;
967
968 switch (showip)
969 {
970 case SHOW_IP:
971 rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]", target_p->name,
972 target_p->username, target_p->sockhost);
973 break;
974
975 default:
976 rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]", target_p->name,
977 target_p->username, target_p->host);
978 }
979
980 return nbuf;
981 }
982
983 return target_p->name;
984 }
985
986 /* is_remote_connect - Returns whether a server was /connect'ed by a remote
987 * oper (send notices netwide) */
988 int
989 is_remote_connect(struct Client *client_p)
990 {
991 struct Client *oper;
992
993 if (client_p->serv == NULL)
994 return FALSE;
995 oper = find_named_person(client_p->serv->by);
996 return oper != NULL && IsOper(oper) && !MyConnect(oper);
997 }
998
999 static void
1000 free_exited_clients(void *unused)
1001 {
1002 rb_dlink_node *ptr, *next;
1003 struct Client *target_p;
1004
1005 RB_DLINK_FOREACH_SAFE(ptr, next, dead_list.head)
1006 {
1007 target_p = ptr->data;
1008
1009 #ifdef DEBUG_EXITED_CLIENTS
1010 {
1011 struct abort_client *abt;
1012 rb_dlink_node *aptr;
1013 int found = 0;
1014
1015 RB_DLINK_FOREACH(aptr, abort_list.head)
1016 {
1017 abt = aptr->data;
1018 if(abt->client == target_p)
1019 {
1020 s_assert(0);
1021 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1022 "On abort_list: %s stat: %u flags: %u/%u handler: %c",
1023 target_p->name, (unsigned int) target_p->status,
1024 target_p->flags, target_p->flags2, target_p->handler);
1025 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1026 "Please report this to the charybdis developers!");
1027 found++;
1028 }
1029 }
1030
1031 if(found)
1032 {
1033 rb_dlinkDestroy(ptr, &dead_list);
1034 continue;
1035 }
1036 }
1037 #endif
1038
1039 if(ptr->data == NULL)
1040 {
1041 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1042 "Warning: null client on dead_list!");
1043 rb_dlinkDestroy(ptr, &dead_list);
1044 continue;
1045 }
1046 release_client_state(target_p);
1047 free_client(target_p);
1048 rb_dlinkDestroy(ptr, &dead_list);
1049 }
1050
1051 #ifdef DEBUG_EXITED_CLIENTS
1052 RB_DLINK_FOREACH_SAFE(ptr, next, dead_remote_list.head)
1053 {
1054 target_p = ptr->data;
1055
1056 if(ptr->data == NULL)
1057 {
1058 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1059 "Warning: null client on dead_list!");
1060 rb_dlinkDestroy(ptr, &dead_list);
1061 continue;
1062 }
1063 release_client_state(target_p);
1064 free_client(target_p);
1065 rb_dlinkDestroy(ptr, &dead_remote_list);
1066 }
1067 #endif
1068
1069 }
1070
1071 /*
1072 ** Remove all clients that depend on source_p; assumes all (S)QUITs have
1073 ** already been sent. we make sure to exit a server's dependent clients
1074 ** and servers before the server itself; exit_one_client takes care of
1075 ** actually removing things off llists. tweaked from +CSr31 -orabidoo
1076 */
1077 /*
1078 * added sanity test code.... source_p->serv might be NULL...
1079 */
1080 static void
1081 recurse_remove_clients(struct Client *source_p, const char *comment)
1082 {
1083 struct Client *target_p;
1084 rb_dlink_node *ptr, *ptr_next;
1085
1086 if(IsMe(source_p))
1087 return;
1088
1089 if(source_p->serv == NULL) /* oooops. uh this is actually a major bug */
1090 return;
1091
1092 /* this is very ugly, but it saves cpu :P */
1093 if(ConfigFileEntry.nick_delay > 0)
1094 {
1095 RB_DLINK_FOREACH_SAFE(ptr, ptr_next, source_p->serv->users.head)
1096 {
1097 target_p = ptr->data;
1098 target_p->flags |= FLAGS_KILLED;
1099 add_nd_entry(target_p->name);
1100
1101 if(!IsDead(target_p) && !IsClosing(target_p))
1102 exit_remote_client(NULL, target_p, &me, comment);
1103 }
1104 }
1105 else
1106 {
1107 RB_DLINK_FOREACH_SAFE(ptr, ptr_next, source_p->serv->users.head)
1108 {
1109 target_p = ptr->data;
1110 target_p->flags |= FLAGS_KILLED;
1111
1112 if(!IsDead(target_p) && !IsClosing(target_p))
1113 exit_remote_client(NULL, target_p, &me, comment);
1114 }
1115 }
1116
1117 RB_DLINK_FOREACH_SAFE(ptr, ptr_next, source_p->serv->servers.head)
1118 {
1119 target_p = ptr->data;
1120 recurse_remove_clients(target_p, comment);
1121 qs_server(NULL, target_p, &me, comment);
1122 }
1123 }
1124
1125 /*
1126 ** Remove *everything* that depends on source_p, from all lists, and sending
1127 ** all necessary SQUITs. source_p itself is still on the lists,
1128 ** and its SQUITs have been sent except for the upstream one -orabidoo
1129 */
1130 static void
1131 remove_dependents(struct Client *client_p,
1132 struct Client *source_p,
1133 struct Client *from, const char *comment, const char *comment1)
1134 {
1135 struct Client *to;
1136 rb_dlink_node *ptr, *next;
1137
1138 RB_DLINK_FOREACH_SAFE(ptr, next, serv_list.head)
1139 {
1140 to = ptr->data;
1141
1142 if(IsMe(to) || to == source_p->from || to == client_p)
1143 continue;
1144
1145 sendto_one(to, "SQUIT %s :%s", get_id(source_p, to), comment);
1146 }
1147
1148 recurse_remove_clients(source_p, comment1);
1149 }
1150
1151 void
1152 exit_aborted_clients(void *unused)
1153 {
1154 struct abort_client *abt;
1155 rb_dlink_node *ptr, *next;
1156 RB_DLINK_FOREACH_SAFE(ptr, next, abort_list.head)
1157 {
1158 abt = ptr->data;
1159
1160 #ifdef DEBUG_EXITED_CLIENTS
1161 {
1162 if(rb_dlinkFind(abt->client, &dead_list))
1163 {
1164 s_assert(0);
1165 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1166 "On dead_list: %s stat: %u flags: %u/%u handler: %c",
1167 abt->client->name, (unsigned int) abt->client->status,
1168 abt->client->flags, abt->client->flags2, abt->client->handler);
1169 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1170 "Please report this to the charybdis developers!");
1171 continue;
1172 }
1173 }
1174 #endif
1175
1176 s_assert(*((unsigned long*)abt->client) != 0xdeadbeef); /* This is lame but its a debug thing */
1177 rb_dlinkDelete(ptr, &abort_list);
1178
1179 if(IsAnyServer(abt->client))
1180 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1181 "Closing link to %s: %s",
1182 abt->client->name, abt->notice);
1183
1184 /* its no longer on abort list - we *must* remove
1185 * FLAGS_CLOSING otherwise exit_client() will not run --fl
1186 */
1187 abt->client->flags &= ~FLAGS_CLOSING;
1188 exit_client(abt->client, abt->client, &me, abt->notice);
1189 rb_free(abt);
1190 }
1191 }
1192
1193
1194 /*
1195 * dead_link - Adds client to a list of clients that need an exit_client()
1196 *
1197 */
1198 void
1199 dead_link(struct Client *client_p, int sendqex)
1200 {
1201 struct abort_client *abt;
1202
1203 s_assert(!IsMe(client_p));
1204 if(IsDead(client_p) || IsClosing(client_p) || IsMe(client_p))
1205 return;
1206
1207 abt = (struct abort_client *) rb_malloc(sizeof(struct abort_client));
1208
1209 if(sendqex)
1210 rb_strlcpy(abt->notice, "Max SendQ exceeded", sizeof(abt->notice));
1211 else
1212 rb_snprintf(abt->notice, sizeof(abt->notice), "Write error: %s", strerror(errno));
1213
1214 abt->client = client_p;
1215 SetIOError(client_p);
1216 SetDead(client_p);
1217 SetClosing(client_p);
1218 rb_dlinkAdd(abt, &abt->node, &abort_list);
1219 }
1220
1221
1222 /* This does the remove of the user from channels..local or remote */
1223 static inline void
1224 exit_generic_client(struct Client *client_p, struct Client *source_p, struct Client *from,
1225 const char *comment)
1226 {
1227 rb_dlink_node *ptr, *next_ptr;
1228
1229 if(IsOper(source_p))
1230 rb_dlinkFindDestroy(source_p, &oper_list);
1231
1232 sendto_common_channels_local(source_p, NOCAPS, NOCAPS, ":%s!%s@%s QUIT :%s",
1233 source_p->name,
1234 source_p->username, source_p->host, comment);
1235
1236 remove_user_from_channels(source_p);
1237
1238 /* Should not be in any channels now */
1239 s_assert(source_p->user->channel.head == NULL);
1240
1241 /* Clean up invitefield */
1242 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, source_p->user->invited.head)
1243 {
1244 del_invite(ptr->data, source_p);
1245 }
1246
1247 /* Clean up allow lists */
1248 del_all_accepts(source_p);
1249
1250 add_history(source_p, 0);
1251 off_history(source_p);
1252
1253 monitor_signoff(source_p);
1254
1255 if(has_id(source_p))
1256 del_from_id_hash(source_p->id, source_p);
1257
1258 del_from_hostname_hash(source_p->orighost, source_p);
1259 del_from_client_hash(source_p->name, source_p);
1260 remove_client_from_list(source_p);
1261 }
1262
1263 /*
1264 * Assumes IsPerson(source_p) && !MyConnect(source_p)
1265 */
1266
1267 static int
1268 exit_remote_client(struct Client *client_p, struct Client *source_p, struct Client *from,
1269 const char *comment)
1270 {
1271 exit_generic_client(client_p, source_p, from, comment);
1272
1273 if(source_p->servptr && source_p->servptr->serv)
1274 {
1275 rb_dlinkDelete(&source_p->lnode, &source_p->servptr->serv->users);
1276 }
1277
1278 if((source_p->flags & FLAGS_KILLED) == 0)
1279 {
1280 sendto_server(client_p, NULL, CAP_TS6, NOCAPS,
1281 ":%s QUIT :%s", use_id(source_p), comment);
1282 }
1283
1284 SetDead(source_p);
1285 #ifdef DEBUG_EXITED_CLIENTS
1286 rb_dlinkAddAlloc(source_p, &dead_remote_list);
1287 #else
1288 rb_dlinkAddAlloc(source_p, &dead_list);
1289 #endif
1290 return(CLIENT_EXITED);
1291 }
1292
1293 /*
1294 * This assumes IsUnknown(source_p) == TRUE and MyConnect(source_p) == TRUE
1295 */
1296
1297 static int
1298 exit_unknown_client(struct Client *client_p, struct Client *source_p, struct Client *from,
1299 const char *comment)
1300 {
1301 delete_auth_queries(source_p);
1302 abort_blacklist_queries(source_p);
1303 if (source_p->localClient->dnsquery)
1304 {
1305 delete_resolver_queries(source_p->localClient->dnsquery);
1306 rb_free(source_p->localClient->dnsquery);
1307 }
1308 rb_dlinkDelete(&source_p->localClient->tnode, &unknown_list);
1309
1310 if(!IsIOError(source_p))
1311 sendto_one(source_p, "ERROR :Closing Link: %s (%s)",
1312 source_p->user != NULL ? source_p->host : "127.0.0.1",
1313 comment);
1314
1315 close_connection(source_p);
1316
1317 if(has_id(source_p))
1318 del_from_id_hash(source_p->id, source_p);
1319
1320 del_from_hostname_hash(source_p->host, source_p);
1321 del_from_client_hash(source_p->name, source_p);
1322 remove_client_from_list(source_p);
1323 SetDead(source_p);
1324 rb_dlinkAddAlloc(source_p, &dead_list);
1325
1326 /* Note that we don't need to add unknowns to the dead_list */
1327 return(CLIENT_EXITED);
1328 }
1329
1330 static int
1331 exit_remote_server(struct Client *client_p, struct Client *source_p, struct Client *from,
1332 const char *comment)
1333 {
1334 static char comment1[(HOSTLEN*2)+2];
1335 static char newcomment[BUFSIZE];
1336 struct Client *target_p;
1337
1338 if(ConfigServerHide.flatten_links)
1339 strcpy(comment1, "*.net *.split");
1340 else
1341 {
1342 strcpy(comment1, source_p->servptr->name);
1343 strcat(comment1, " ");
1344 strcat(comment1, source_p->name);
1345 }
1346 if (IsPerson(from))
1347 rb_snprintf(newcomment, sizeof(newcomment), "by %s: %s",
1348 from->name, comment);
1349
1350 if(source_p->serv != NULL)
1351 remove_dependents(client_p, source_p, from, IsPerson(from) ? newcomment : comment, comment1);
1352
1353 if(source_p->servptr && source_p->servptr->serv)
1354 rb_dlinkDelete(&source_p->lnode, &source_p->servptr->serv->servers);
1355 else
1356 s_assert(0);
1357
1358 rb_dlinkFindDestroy(source_p, &global_serv_list);
1359 target_p = source_p->from;
1360
1361 if(target_p != NULL && IsServer(target_p) && target_p != client_p &&
1362 !IsMe(target_p) && (source_p->flags & FLAGS_KILLED) == 0)
1363 {
1364 sendto_one(target_p, ":%s SQUIT %s :%s",
1365 get_id(from, target_p), get_id(source_p, target_p),
1366 comment);
1367 }
1368
1369 if(has_id(source_p))
1370 del_from_id_hash(source_p->id, source_p);
1371
1372 del_from_client_hash(source_p->name, source_p);
1373 remove_client_from_list(source_p);
1374 scache_split(source_p->serv->nameinfo);
1375
1376 SetDead(source_p);
1377 #ifdef DEBUG_EXITED_CLIENTS
1378 rb_dlinkAddAlloc(source_p, &dead_remote_list);
1379 #else
1380 rb_dlinkAddAlloc(source_p, &dead_list);
1381 #endif
1382 return 0;
1383 }
1384
1385 static int
1386 qs_server(struct Client *client_p, struct Client *source_p, struct Client *from,
1387 const char *comment)
1388 {
1389 if(source_p->servptr && source_p->servptr->serv)
1390 rb_dlinkDelete(&source_p->lnode, &source_p->servptr->serv->servers);
1391 else
1392 s_assert(0);
1393
1394 rb_dlinkFindDestroy(source_p, &global_serv_list);
1395
1396 if(has_id(source_p))
1397 del_from_id_hash(source_p->id, source_p);
1398
1399 del_from_client_hash(source_p->name, source_p);
1400 remove_client_from_list(source_p);
1401 scache_split(source_p->serv->nameinfo);
1402
1403 SetDead(source_p);
1404 rb_dlinkAddAlloc(source_p, &dead_list);
1405 return 0;
1406 }
1407
1408 static int
1409 exit_local_server(struct Client *client_p, struct Client *source_p, struct Client *from,
1410 const char *comment)
1411 {
1412 static char comment1[(HOSTLEN*2)+2];
1413 static char newcomment[BUFSIZE];
1414 unsigned int sendk, recvk;
1415
1416 rb_dlinkDelete(&source_p->localClient->tnode, &serv_list);
1417 rb_dlinkFindDestroy(source_p, &global_serv_list);
1418
1419 sendk = source_p->localClient->sendK;
1420 recvk = source_p->localClient->receiveK;
1421
1422 /* Always show source here, so the server notices show
1423 * which side initiated the split -- jilles
1424 */
1425 rb_snprintf(newcomment, sizeof(newcomment), "by %s: %s",
1426 from == source_p ? me.name : from->name, comment);
1427 if (!IsIOError(source_p))
1428 sendto_one(source_p, "SQUIT %s :%s", use_id(source_p),
1429 newcomment);
1430 if(client_p != NULL && source_p != client_p && !IsIOError(source_p))
1431 {
1432 sendto_one(source_p, "ERROR :Closing Link: 127.0.0.1 %s (%s)",
1433 source_p->name, comment);
1434 }
1435
1436 if(source_p->servptr && source_p->servptr->serv)
1437 rb_dlinkDelete(&source_p->lnode, &source_p->servptr->serv->servers);
1438 else
1439 s_assert(0);
1440
1441
1442 close_connection(source_p);
1443
1444 if(ConfigServerHide.flatten_links)
1445 strcpy(comment1, "*.net *.split");
1446 else
1447 {
1448 strcpy(comment1, source_p->servptr->name);
1449 strcat(comment1, " ");
1450 strcat(comment1, source_p->name);
1451 }
1452
1453 if(source_p->serv != NULL)
1454 remove_dependents(client_p, source_p, from, IsPerson(from) ? newcomment : comment, comment1);
1455
1456 sendto_realops_snomask(SNO_GENERAL, L_ALL, "%s was connected"
1457 " for %ld seconds. %d/%d sendK/recvK.",
1458 source_p->name, (long) rb_current_time() - source_p->localClient->firsttime, sendk, recvk);
1459
1460 ilog(L_SERVER, "%s was connected for %ld seconds. %d/%d sendK/recvK.",
1461 source_p->name, (long) rb_current_time() - source_p->localClient->firsttime, sendk, recvk);
1462
1463 if(has_id(source_p))
1464 del_from_id_hash(source_p->id, source_p);
1465
1466 del_from_client_hash(source_p->name, source_p);
1467 remove_client_from_list(source_p);
1468 scache_split(source_p->serv->nameinfo);
1469
1470 SetDead(source_p);
1471 rb_dlinkAddAlloc(source_p, &dead_list);
1472 return 0;
1473 }
1474
1475
1476 /*
1477 * This assumes IsPerson(source_p) == TRUE && MyConnect(source_p) == TRUE
1478 */
1479
1480 static int
1481 exit_local_client(struct Client *client_p, struct Client *source_p, struct Client *from,
1482 const char *comment)
1483 {
1484 unsigned long on_for;
1485 char tbuf[26];
1486
1487 exit_generic_client(client_p, source_p, from, comment);
1488 clear_monitor(source_p);
1489
1490 s_assert(IsPerson(source_p));
1491 rb_dlinkDelete(&source_p->localClient->tnode, &lclient_list);
1492 rb_dlinkDelete(&source_p->lnode, &me.serv->users);
1493
1494 if(IsOper(source_p))
1495 rb_dlinkFindDestroy(source_p, &local_oper_list);
1496
1497 sendto_realops_snomask(SNO_CCONN, L_ALL,
1498 "Client exiting: %s (%s@%s) [%s] [%s]",
1499 source_p->name,
1500 source_p->username, source_p->host, comment,
1501 show_ip(NULL, source_p) ? source_p->sockhost : "255.255.255.255");
1502
1503 sendto_realops_snomask(SNO_CCONNEXT, L_ALL,
1504 "CLIEXIT %s %s %s %s 0 %s",
1505 source_p->name, source_p->username, source_p->host,
1506 show_ip(NULL, source_p) ? source_p->sockhost : "255.255.255.255",
1507 comment);
1508
1509 on_for = rb_current_time() - source_p->localClient->firsttime;
1510
1511 ilog(L_USER, "%s (%3lu:%02lu:%02lu): %s!%s@%s %s %d/%d",
1512 rb_ctime(rb_current_time(), tbuf, sizeof(tbuf)), on_for / 3600,
1513 (on_for % 3600) / 60, on_for % 60,
1514 source_p->name, source_p->username, source_p->host,
1515 source_p->sockhost,
1516 source_p->localClient->sendK, source_p->localClient->receiveK);
1517
1518 sendto_one(source_p, "ERROR :Closing Link: %s (%s)", source_p->host, comment);
1519 close_connection(source_p);
1520
1521 if((source_p->flags & FLAGS_KILLED) == 0)
1522 {
1523 sendto_server(client_p, NULL, CAP_TS6, NOCAPS,
1524 ":%s QUIT :%s", use_id(source_p), comment);
1525 }
1526
1527 SetDead(source_p);
1528 rb_dlinkAddAlloc(source_p, &dead_list);
1529 return(CLIENT_EXITED);
1530 }
1531
1532
1533 /*
1534 ** exit_client - This is old "m_bye". Name changed, because this is not a
1535 ** protocol function, but a general server utility function.
1536 **
1537 ** This function exits a client of *any* type (user, server, etc)
1538 ** from this server. Also, this generates all necessary prototol
1539 ** messages that this exit may cause.
1540 **
1541 ** 1) If the client is a local client, then this implicitly
1542 ** exits all other clients depending on this connection (e.g.
1543 ** remote clients having 'from'-field that points to this.
1544 **
1545 ** 2) If the client is a remote client, then only this is exited.
1546 **
1547 ** For convenience, this function returns a suitable value for
1548 ** m_function return value:
1549 **
1550 ** CLIENT_EXITED if (client_p == source_p)
1551 ** 0 if (client_p != source_p)
1552 */
1553 int
1554 exit_client(struct Client *client_p, /* The local client originating the
1555 * exit or NULL, if this exit is
1556 * generated by this server for
1557 * internal reasons.
1558 * This will not get any of the
1559 * generated messages. */
1560 struct Client *source_p, /* Client exiting */
1561 struct Client *from, /* Client firing off this Exit,
1562 * never NULL! */
1563 const char *comment /* Reason for the exit */
1564 )
1565 {
1566 hook_data_client_exit hdata;
1567 if(IsClosing(source_p))
1568 return -1;
1569
1570 /* note, this HAS to be here, when we exit a client we attempt to
1571 * send them data, if this generates a write error we must *not* add
1572 * them to the abort list --fl
1573 */
1574 SetClosing(source_p);
1575
1576 hdata.local_link = client_p;
1577 hdata.target = source_p;
1578 hdata.from = from;
1579 hdata.comment = comment;
1580 call_hook(h_client_exit, &hdata);
1581
1582 if(MyConnect(source_p))
1583 {
1584 /* Local clients of various types */
1585 if(IsPerson(source_p))
1586 return exit_local_client(client_p, source_p, from, comment);
1587 else if(IsServer(source_p))
1588 return exit_local_server(client_p, source_p, from, comment);
1589 /* IsUnknown || IsConnecting || IsHandShake */
1590 else if(!IsReject(source_p))
1591 return exit_unknown_client(client_p, source_p, from, comment);
1592 }
1593 else
1594 {
1595 /* Remotes */
1596 if(IsPerson(source_p))
1597 return exit_remote_client(client_p, source_p, from, comment);
1598 else if(IsServer(source_p))
1599 return exit_remote_server(client_p, source_p, from, comment);
1600 }
1601
1602 return -1;
1603 }
1604
1605 /*
1606 * Count up local client memory
1607 */
1608
1609 /* XXX one common Client list now */
1610 void
1611 count_local_client_memory(size_t * count, size_t * local_client_memory_used)
1612 {
1613 size_t lusage;
1614 rb_bh_usage(lclient_heap, count, NULL, &lusage, NULL);
1615 *local_client_memory_used = lusage + (*count * (sizeof(void *) + sizeof(struct Client)));
1616 }
1617
1618 /*
1619 * Count up remote client memory
1620 */
1621 void
1622 count_remote_client_memory(size_t * count, size_t * remote_client_memory_used)
1623 {
1624 size_t lcount, rcount;
1625 rb_bh_usage(lclient_heap, &lcount, NULL, NULL, NULL);
1626 rb_bh_usage(client_heap, &rcount, NULL, NULL, NULL);
1627 *count = rcount - lcount;
1628 *remote_client_memory_used = *count * (sizeof(void *) + sizeof(struct Client));
1629 }
1630
1631
1632 /*
1633 * accept processing, this adds a form of "caller ID" to ircd
1634 *
1635 * If a client puts themselves into "caller ID only" mode,
1636 * only clients that match a client pointer they have put on
1637 * the accept list will be allowed to message them.
1638 *
1639 * [ source.on_allow_list ] -> [ target1 ] -> [ target2 ]
1640 *
1641 * [target.allow_list] -> [ source1 ] -> [source2 ]
1642 *
1643 * i.e. a target will have a link list of source pointers it will allow
1644 * each source client then has a back pointer pointing back
1645 * to the client that has it on its accept list.
1646 * This allows for exit_one_client to remove these now bogus entries
1647 * from any client having an accept on them.
1648 */
1649 /*
1650 * del_all_accepts
1651 *
1652 * inputs - pointer to exiting client
1653 * output - NONE
1654 * side effects - Walk through given clients allow_list and on_allow_list
1655 * remove all references to this client
1656 */
1657 void
1658 del_all_accepts(struct Client *client_p)
1659 {
1660 rb_dlink_node *ptr;
1661 rb_dlink_node *next_ptr;
1662 struct Client *target_p;
1663
1664 if(MyClient(client_p) && client_p->localClient->allow_list.head)
1665 {
1666 /* clear this clients accept list, and remove them from
1667 * everyones on_accept_list
1668 */
1669 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, client_p->localClient->allow_list.head)
1670 {
1671 target_p = ptr->data;
1672 rb_dlinkFindDestroy(client_p, &target_p->on_allow_list);
1673 rb_dlinkDestroy(ptr, &client_p->localClient->allow_list);
1674 }
1675 }
1676
1677 /* remove this client from everyones accept list */
1678 RB_DLINK_FOREACH_SAFE(ptr, next_ptr, client_p->on_allow_list.head)
1679 {
1680 target_p = ptr->data;
1681 rb_dlinkFindDestroy(client_p, &target_p->localClient->allow_list);
1682 rb_dlinkDestroy(ptr, &client_p->on_allow_list);
1683 }
1684 }
1685
1686 /*
1687 * show_ip() - asks if the true IP should be shown when source is
1688 * asking for info about target
1689 *
1690 * Inputs - source_p who is asking
1691 * - target_p who do we want the info on
1692 * Output - returns 1 if clear IP can be shown, otherwise 0
1693 * Side Effects - none
1694 */
1695
1696 int
1697 show_ip(struct Client *source_p, struct Client *target_p)
1698 {
1699 if(IsAnyServer(target_p))
1700 {
1701 return 0;
1702 }
1703 else if(IsIPSpoof(target_p))
1704 {
1705 /* source == NULL indicates message is being sent
1706 * to local opers.
1707 */
1708 if(!ConfigFileEntry.hide_spoof_ips &&
1709 (source_p == NULL || MyOper(source_p)))
1710 return 1;
1711 return 0;
1712 }
1713 else if(IsDynSpoof(target_p) && (source_p != NULL && !IsOper(source_p)))
1714 return 0;
1715 else
1716 return 1;
1717 }
1718
1719 int
1720 show_ip_conf(struct ConfItem *aconf, struct Client *source_p)
1721 {
1722 if(IsConfDoSpoofIp(aconf))
1723 {
1724 if(!ConfigFileEntry.hide_spoof_ips && MyOper(source_p))
1725 return 1;
1726
1727 return 0;
1728 }
1729 else
1730 return 1;
1731 }
1732
1733 int
1734 show_ip_whowas(struct Whowas *whowas, struct Client *source_p)
1735 {
1736 if(whowas->flags & WHOWAS_IP_SPOOFING)
1737 if(ConfigFileEntry.hide_spoof_ips || !MyOper(source_p))
1738 return 0;
1739 if(whowas->flags & WHOWAS_DYNSPOOF)
1740 if(!IsOper(source_p))
1741 return 0;
1742 return 1;
1743 }
1744
1745 /*
1746 * make_user
1747 *
1748 * inputs - pointer to client struct
1749 * output - pointer to struct User
1750 * side effects - add's an User information block to a client
1751 * if it was not previously allocated.
1752 */
1753 struct User *
1754 make_user(struct Client *client_p)
1755 {
1756 struct User *user;
1757
1758 user = client_p->user;
1759 if(!user)
1760 {
1761 user = (struct User *) rb_bh_alloc(user_heap);
1762 user->refcnt = 1;
1763 client_p->user = user;
1764 }
1765 return user;
1766 }
1767
1768 /*
1769 * make_server
1770 *
1771 * inputs - pointer to client struct
1772 * output - pointer to server_t
1773 * side effects - add's an Server information block to a client
1774 * if it was not previously allocated.
1775 */
1776 struct Server *
1777 make_server(struct Client *client_p)
1778 {
1779 struct Server *serv = client_p->serv;
1780
1781 if(!serv)
1782 {
1783 serv = (struct Server *) rb_malloc(sizeof(struct Server));
1784 client_p->serv = serv;
1785 }
1786 return client_p->serv;
1787 }
1788
1789 /*
1790 * free_user
1791 *
1792 * inputs - pointer to user struct
1793 * - pointer to client struct
1794 * output - none
1795 * side effects - Decrease user reference count by one and release block,
1796 * if count reaches 0
1797 */
1798 void
1799 free_user(struct User *user, struct Client *client_p)
1800 {
1801 free_away(client_p);
1802
1803 if(--user->refcnt <= 0)
1804 {
1805 if(user->away)
1806 rb_free((char *) user->away);
1807 /*
1808 * sanity check
1809 */
1810 if(user->refcnt < 0 || user->invited.head || user->channel.head)
1811 {
1812 sendto_realops_snomask(SNO_GENERAL, L_ALL,
1813 "* %#lx user (%s!%s@%s) %#lx %#lx %#lx %lu %d *",
1814 (unsigned long) client_p,
1815 client_p ? client_p->
1816 name : "<noname>",
1817 client_p->username,
1818 client_p->host,
1819 (unsigned long) user,
1820 (unsigned long) user->invited.head,
1821 (unsigned long) user->channel.head,
1822 rb_dlink_list_length(&user->channel),
1823 user->refcnt);
1824 s_assert(!user->refcnt);
1825 s_assert(!user->invited.head);
1826 s_assert(!user->channel.head);
1827 }
1828
1829 rb_bh_free(user_heap, user);
1830 }
1831 }
1832
1833 void
1834 allocate_away(struct Client *client_p)
1835 {
1836 if(client_p->user->away == NULL)
1837 client_p->user->away = rb_bh_alloc(away_heap);
1838 }
1839
1840
1841 void
1842 free_away(struct Client *client_p)
1843 {
1844 if(client_p->user != NULL && client_p->user->away != NULL) {
1845 rb_bh_free(away_heap, client_p->user->away);
1846 client_p->user->away = NULL;
1847 }
1848 }
1849
1850 void
1851 init_uid(void)
1852 {
1853 int i;
1854
1855 for(i = 0; i < 3; i++)
1856 current_uid[i] = me.id[i];
1857
1858 for(i = 3; i < 9; i++)
1859 current_uid[i] = 'A';
1860
1861 current_uid[9] = '\0';
1862 }
1863
1864
1865 char *
1866 generate_uid(void)
1867 {
1868 int i;
1869
1870 for(i = 8; i > 3; i--)
1871 {
1872 if(current_uid[i] == 'Z')
1873 {
1874 current_uid[i] = '0';
1875 return current_uid;
1876 }
1877 else if(current_uid[i] != '9')
1878 {
1879 current_uid[i]++;
1880 return current_uid;
1881 }
1882 else
1883 current_uid[i] = 'A';
1884 }
1885
1886 /* if this next if() triggers, we're fucked. */
1887 if(current_uid[3] == 'Z')
1888 {
1889 current_uid[i] = 'A';
1890 s_assert(0);
1891 }
1892 else
1893 current_uid[i]++;
1894
1895 return current_uid;
1896 }
1897
1898 /*
1899 * close_connection
1900 * Close the physical connection. This function must make
1901 * MyConnect(client_p) == FALSE, and set client_p->from == NULL.
1902 */
1903 void
1904 close_connection(struct Client *client_p)
1905 {
1906 s_assert(client_p != NULL);
1907 if(client_p == NULL)
1908 return;
1909
1910 s_assert(MyConnect(client_p));
1911 if(!MyConnect(client_p))
1912 return;
1913
1914 if(IsServer(client_p))
1915 {
1916 struct server_conf *server_p;
1917
1918 ServerStats.is_sv++;
1919 ServerStats.is_sbs += client_p->localClient->sendB;
1920 ServerStats.is_sbr += client_p->localClient->receiveB;
1921 ServerStats.is_sti += (unsigned long long)(rb_current_time() - client_p->localClient->firsttime);
1922
1923 /*
1924 * If the connection has been up for a long amount of time, schedule
1925 * a 'quick' reconnect, else reset the next-connect cycle.
1926 */
1927 if((server_p = find_server_conf(client_p->name)) != NULL)
1928 {
1929 /*
1930 * Reschedule a faster reconnect, if this was a automatically
1931 * connected configuration entry. (Note that if we have had
1932 * a rehash in between, the status has been changed to
1933 * CONF_ILLEGAL). But only do this if it was a "good" link.
1934 */
1935 server_p->hold = time(NULL);
1936 server_p->hold +=
1937 (server_p->hold - client_p->localClient->lasttime >
1938 HANGONGOODLINK) ? HANGONRETRYDELAY : ConFreq(server_p->class);
1939 }
1940
1941 }
1942 else if(IsClient(client_p))
1943 {
1944 ServerStats.is_cl++;
1945 ServerStats.is_cbs += client_p->localClient->sendB;
1946 ServerStats.is_cbr += client_p->localClient->receiveB;
1947 ServerStats.is_cti += (unsigned long long)(rb_current_time() - client_p->localClient->firsttime);
1948 }
1949 else
1950 ServerStats.is_ni++;
1951
1952 if(client_p->localClient->F != NULL)
1953 {
1954 /* attempt to flush any pending dbufs. Evil, but .. -- adrian */
1955 if(!IsIOError(client_p))
1956 send_queued(client_p);
1957
1958 del_from_cli_connid_hash(client_p);
1959 rb_close(client_p->localClient->F);
1960 client_p->localClient->F = NULL;
1961 }
1962
1963 rb_linebuf_donebuf(&client_p->localClient->buf_sendq);
1964 rb_linebuf_donebuf(&client_p->localClient->buf_recvq);
1965 detach_conf(client_p);
1966
1967 /* XXX shouldnt really be done here. */
1968 detach_server_conf(client_p);
1969
1970 client_p->from = NULL; /* ...this should catch them! >:) --msa */
1971 ClearMyConnect(client_p);
1972 SetIOError(client_p);
1973 }
1974
1975
1976
1977 void
1978 error_exit_client(struct Client *client_p, int error)
1979 {
1980 /*
1981 * ...hmm, with non-blocking sockets we might get
1982 * here from quite valid reasons, although.. why
1983 * would select report "data available" when there
1984 * wasn't... so, this must be an error anyway... --msa
1985 * actually, EOF occurs when read() returns 0 and
1986 * in due course, select() returns that fd as ready
1987 * for reading even though it ends up being an EOF. -avalon
1988 */
1989 char errmsg[255];
1990 int current_error = rb_get_sockerr(client_p->localClient->F);
1991
1992 SetIOError(client_p);
1993
1994 if(IsServer(client_p) || IsHandshake(client_p))
1995 {
1996 if(error == 0)
1997 {
1998 sendto_realops_snomask(SNO_GENERAL, is_remote_connect(client_p) && !IsServer(client_p) ? L_NETWIDE : L_ALL,
1999 "Server %s closed the connection",
2000 client_p->name);
2001
2002 ilog(L_SERVER, "Server %s closed the connection",
2003 log_client_name(client_p, SHOW_IP));
2004 }
2005 else
2006 {
2007 sendto_realops_snomask(SNO_GENERAL, is_remote_connect(client_p) && !IsServer(client_p) ? L_NETWIDE : L_ALL,
2008 "Lost connection to %s: %s",
2009 client_p->name, strerror(current_error));
2010 ilog(L_SERVER, "Lost connection to %s: %s",
2011 log_client_name(client_p, SHOW_IP), strerror(current_error));
2012 }
2013 }
2014
2015 if(error == 0)
2016 rb_strlcpy(errmsg, "Remote host closed the connection", sizeof(errmsg));
2017 else
2018 rb_snprintf(errmsg, sizeof(errmsg), "Read error: %s", strerror(current_error));
2019
2020 exit_client(client_p, client_p, &me, errmsg);
2021 }