ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/client.c
(Generate patch)

Comparing:
ircd-hybrid-8/src/client.c (file contents), Revision 1247 by michael, Sat Oct 1 07:54:24 2011 UTC vs.
ircd-hybrid/trunk/src/client.c (file contents), Revision 2583 by michael, Wed Nov 20 23:01:19 2013 UTC

# Line 36 | Line 36
36   #include "packet.h"
37   #include "s_auth.h"
38   #include "s_bsd.h"
39 < #include "s_conf.h"
40 < #include "s_log.h"
39 > #include "conf.h"
40 > #include "log.h"
41   #include "s_misc.h"
42   #include "s_serv.h"
43   #include "send.h"
# Line 45 | Line 45
45   #include "s_user.h"
46   #include "dbuf.h"
47   #include "memory.h"
48 + #include "mempool.h"
49   #include "hostmask.h"
49 #include "balloc.h"
50   #include "listener.h"
51   #include "irc_res.h"
52   #include "userhost.h"
53   #include "watch.h"
54 + #include "rng_mt.h"
55  
56   dlink_list listing_client_list = { NULL, NULL, 0 };
57   /* Pointer to beginning of Client list */
# Line 64 | Line 65 | dlink_list oper_list = {NULL, NULL, 0};
65  
66   static EVH check_pings;
67  
68 < static BlockHeap *client_heap  = NULL;
69 < static BlockHeap *lclient_heap = NULL;
68 > static mp_pool_t *client_pool  = NULL;
69 > static mp_pool_t *lclient_pool = NULL;
70  
71   static dlink_list dead_list  = { NULL, NULL, 0};
72   static dlink_list abort_list = { NULL, NULL, 0};
# Line 74 | Line 75 | static dlink_node *eac_next;  /* next ab
75  
76   static void check_pings_list(dlink_list *);
77   static void check_unknowns_list(void);
78 < static void ban_them(struct Client *, struct ConfItem *);
78 > static void ban_them(struct Client *, struct MaskItem *);
79  
80  
81 < /* init_client()
81 > /* client_init()
82   *
83   * inputs       - NONE
84   * output       - NONE
85   * side effects - initialize client free memory
86   */
87   void
88 < init_client(void)
88 > client_init(void)
89   {
90    /* start off the check ping event ..  -- adrian
91     * Every 30 seconds is plenty -- db
92     */
93 <  client_heap = BlockHeapCreate("client", sizeof(struct Client), CLIENT_HEAP_SIZE);
94 <  lclient_heap = BlockHeapCreate("local client", sizeof(struct LocalUser), LCLIENT_HEAP_SIZE);
93 >  client_pool = mp_pool_new(sizeof(struct Client), MP_CHUNK_SIZE_CLIENT);
94 >  lclient_pool = mp_pool_new(sizeof(struct LocalUser), MP_CHUNK_SIZE_LCLIENT);
95    eventAdd("check_pings", check_pings, NULL, 5);
96   }
97  
# Line 112 | Line 113 | init_client(void)
113   struct Client *
114   make_client(struct Client *from)
115   {
116 <  struct Client *client_p = BlockHeapAlloc(client_heap);
116 >  struct Client *client_p = mp_pool_get(client_pool);
117 >
118 >  memset(client_p, 0, sizeof(*client_p));
119  
120    if (from == NULL)
121    {
122      client_p->from                      = client_p; /* 'from' of local client is self! */
123 <    client_p->localClient               = BlockHeapAlloc(lclient_heap);
123 >    client_p->localClient               = mp_pool_get(lclient_pool);
124 >
125 >    memset(client_p->localClient, 0, sizeof(*client_p->localClient));
126 >
127      client_p->localClient->since        = CurrentTime;
128      client_p->localClient->lasttime     = CurrentTime;
129      client_p->localClient->firsttime    = CurrentTime;
# Line 129 | Line 135 | make_client(struct Client *from)
135    else
136      client_p->from = from; /* 'from' of local client is self! */
137  
138 +  client_p->idhnext = client_p;
139    client_p->hnext  = client_p;
140    client_p->status = STAT_UNKNOWN;
141    strcpy(client_p->username, "unknown");
142 +  strcpy(client_p->svid, "0");
143  
144    return client_p;
145   }
# Line 149 | Line 157 | free_client(struct Client *client_p)
157    assert(client_p != NULL);
158    assert(client_p != &me);
159    assert(client_p->hnext == client_p);
160 +  assert(client_p->idhnext == client_p);
161    assert(client_p->channel.head == NULL);
162    assert(dlink_list_length(&client_p->channel) == 0);
163 +  assert(dlink_list_length(&client_p->whowas) == 0);
164 +  assert(!IsServer(client_p) || (IsServer(client_p) && client_p->serv));
165  
155  MyFree(client_p->away);
166    MyFree(client_p->serv);
167 +  MyFree(client_p->certfp);
168  
169    if (MyConnect(client_p))
170    {
171      assert(client_p->localClient->invited.head == NULL);
172      assert(dlink_list_length(&client_p->localClient->invited) == 0);
173 +    assert(dlink_list_length(&client_p->localClient->watches) == 0);
174      assert(IsClosing(client_p) && IsDead(client_p));
175  
176      MyFree(client_p->localClient->response);
# Line 171 | Line 183 | free_client(struct Client *client_p)
183      {
184        assert(0 < client_p->localClient->listener->ref_count);
185        if (0 == --client_p->localClient->listener->ref_count &&
186 <          !client_p->localClient->listener->active)
186 >          !client_p->localClient->listener->active)
187          free_listener(client_p->localClient->listener);
188      }
189  
190      dbuf_clear(&client_p->localClient->buf_recvq);
191      dbuf_clear(&client_p->localClient->buf_sendq);
192  
193 <    BlockHeapFree(lclient_heap, client_p->localClient);
193 >    mp_pool_release(client_p->localClient);
194    }
195  
196 <  BlockHeapFree(client_heap, client_p);
196 >  mp_pool_release(client_p);
197   }
198  
199   /*
# Line 190 | Line 202 | free_client(struct Client *client_p)
202   *
203   * inputs       - NOT USED (from event)
204   * output       - next time_t when check_pings() should be called again
205 < * side effects -
205 > * side effects -
206   *
207   *
208   * A PING can be sent to clients as necessary.
# Line 212 | Line 224 | free_client(struct Client *client_p)
224  
225   static void
226   check_pings(void *notused)
227 < {              
227 > {
228    check_pings_list(&local_client_list);
229    check_pings_list(&serv_list);
230    check_unknowns_list();
# Line 222 | Line 234 | check_pings(void *notused)
234   *
235   * inputs       - pointer to list to check
236   * output       - NONE
237 < * side effects -
237 > * side effects -
238   */
239   static void
240   check_pings_list(dlink_list *list)
241   {
242    char scratch[32];        /* way too generous but... */
243 <  struct Client *client_p; /* current local client_p being examined */
244 <  int ping, pingwarn;      /* ping time value from client */
233 <  dlink_node *ptr, *next_ptr;
243 >  int ping = 0;      /* ping time value from client */
244 >  dlink_node *ptr = NULL, *next_ptr = NULL;
245  
246    DLINK_FOREACH_SAFE(ptr, next_ptr, list->head)
247    {
248 <    client_p = ptr->data;
248 >    struct Client *client_p = ptr->data;
249  
250      /*
251      ** Note: No need to notify opers here. It's
# Line 243 | Line 254 | check_pings_list(dlink_list *list)
254      if (IsDead(client_p))
255      {
256        /* Ignore it, its been exited already */
246      continue;
247    }
248
249    if (client_p->localClient->reject_delay > 0)
250    {
251      if (client_p->localClient->reject_delay <= CurrentTime)
252        exit_client(client_p, &me, "Rejected");
257        continue;
258      }
259  
260      if (!IsRegistered(client_p))
261 <      ping = CONNECTTIMEOUT, pingwarn = 0;
261 >      ping = CONNECTTIMEOUT;
262      else
263 <      ping = get_client_ping(client_p, &pingwarn);
263 >      ping = get_client_ping(&client_p->localClient->confs);
264  
265      if (ping < CurrentTime - client_p->localClient->lasttime)
266      {
267        if (!IsPingSent(client_p))
268        {
269 <        /*
270 <         * if we havent PINGed the connection and we havent
271 <         * heard from it in a while, PING it to make sure
272 <         * it is still alive.
273 <         */
274 <        SetPingSent(client_p);
275 <        ClearPingWarning(client_p);
276 <        client_p->localClient->lasttime = CurrentTime - ping;
273 <        sendto_one(client_p, "PING :%s", ID_or_name(&me, client_p));
269 >        /*
270 >         * if we havent PINGed the connection and we havent
271 >         * heard from it in a while, PING it to make sure
272 >         * it is still alive.
273 >         */
274 >        SetPingSent(client_p);
275 >        client_p->localClient->lasttime = CurrentTime - ping;
276 >        sendto_one(client_p, "PING :%s", ID_or_name(&me, client_p));
277        }
278        else
279        {
# Line 281 | Line 284 | check_pings_list(dlink_list *list)
284             * and it has a ping time, then close its connection.
285             */
286            if (IsServer(client_p) || IsHandshake(client_p))
287 <          {
288 <            sendto_realops_flags(UMODE_ALL, L_ADMIN,
289 <                                 "No response from %s, closing link",
290 <                                 get_client_name(client_p, HIDE_IP));
291 <            sendto_realops_flags(UMODE_ALL, L_OPER,
292 <                                 "No response from %s, closing link",
293 <                                 get_client_name(client_p, MASK_IP));
294 <            ilog(LOG_TYPE_IRCD, "No response from %s, closing link",
295 <                 get_client_name(client_p, HIDE_IP));
296 <          }
287 >          {
288 >            sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
289 >                                 "No response from %s, closing link",
290 >                                 get_client_name(client_p, HIDE_IP));
291 >            sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
292 >                                 "No response from %s, closing link",
293 >                                 get_client_name(client_p, MASK_IP));
294 >            ilog(LOG_TYPE_IRCD, "No response from %s, closing link",
295 >                 get_client_name(client_p, HIDE_IP));
296 >          }
297  
298            snprintf(scratch, sizeof(scratch), "Ping timeout: %d seconds",
299                     (int)(CurrentTime - client_p->localClient->lasttime));
300            exit_client(client_p, &me, scratch);
301          }
299        else if (!IsPingWarning(client_p) && pingwarn > 0 &&
300                 (IsServer(client_p) || IsHandshake(client_p)) &&
301                 CurrentTime - client_p->localClient->lasttime >= ping + pingwarn)
302        {
303          /*
304           * If the server hasn't replied in pingwarn seconds after sending
305           * the PING, notify the opers so that they are aware of the problem.
306           */
307          SetPingWarning(client_p);
308          sendto_realops_flags(UMODE_ALL, L_ADMIN,
309                               "Warning, no response from %s in %d seconds",
310                               get_client_name(client_p, HIDE_IP), pingwarn);
311          sendto_realops_flags(UMODE_ALL, L_OPER,
312                               "Warning, no response from %s in %d seconds",
313                               get_client_name(client_p, MASK_IP), pingwarn);
314          ilog(LOG_TYPE_IRCD, "No response from %s in %d seconds",
315               get_client_name(client_p, HIDE_IP), pingwarn);
316        }
302        }
303      }
304    }
# Line 334 | Line 319 | check_unknowns_list(void)
319    {
320      struct Client *client_p = ptr->data;
321  
337    if (client_p->localClient->reject_delay > 0)
338    {
339      if (client_p->localClient->reject_delay <= CurrentTime)
340        exit_client(client_p, &me, "Rejected");
341      continue;
342    }
343
322      /*
323       * Check UNKNOWN connections - if they have been in this state
324       * for > 30s, close them.
# Line 357 | Line 335 | check_unknowns_list(void)
335   * side effects - Check all connections for a pending kline against the
336   *                client, exit the client if a kline matches.
337   */
338 < void
338 > void
339   check_conf_klines(void)
340 < {              
340 > {
341    struct Client *client_p = NULL;       /* current local client_p being examined */
342 <  struct AccessItem *aconf = NULL;
365 <  struct ConfItem *conf = NULL;
342 >  struct MaskItem *conf = NULL;
343    dlink_node *ptr, *next_ptr;
344  
345    DLINK_FOREACH_SAFE(ptr, next_ptr, local_client_list.head)
# Line 374 | Line 351 | check_conf_klines(void)
351      if (IsDead(client_p) || !IsClient(client_p))
352        continue;
353  
354 <    /* if there is a returned struct ConfItem then kill it */
378 <    if ((aconf = find_dline_conf(&client_p->localClient->ip,
354 >    if ((conf = find_dline_conf(&client_p->localClient->ip,
355                                    client_p->localClient->aftype)) != NULL)
356      {
357 <      if (aconf->status & CONF_EXEMPTDLINE)
358 <        continue;
357 >      if (conf->type == CONF_EXEMPT)
358 >        continue;
359  
384      conf = unmap_conf_item(aconf);
360        ban_them(client_p, conf);
361        continue; /* and go examine next fd/client_p */
362      }
363  
364 <    if (ConfigFileEntry.glines && (aconf = find_gline(client_p)))
364 >    if (ConfigFileEntry.glines)
365      {
366 +      if (!(conf = find_conf_by_address(client_p->host, &client_p->localClient->ip,
367 +                                        CONF_GLINE, client_p->localClient->aftype,
368 +                                        client_p->username, NULL, 1)))
369 +        continue;
370 +
371        if (IsExemptKline(client_p) ||
372            IsExemptGline(client_p))
373        {
374 <        sendto_realops_flags(UMODE_ALL, L_ALL,
374 >        sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
375                               "GLINE over-ruled for %s, client is %sline_exempt",
376                               get_client_name(client_p, HIDE_IP), IsExemptKline(client_p) ? "k" : "g");
377          continue;
378        }
379  
400      conf = unmap_conf_item(aconf);
380        ban_them(client_p, conf);
381 <      /* and go examine next fd/client_p */    
381 >      /* and go examine next fd/client_p */
382        continue;
383 <    }
383 >    }
384  
385 <    if ((aconf = find_kill(client_p)) != NULL)
385 >    if ((conf = find_conf_by_address(client_p->host, &client_p->localClient->ip,
386 >                                     CONF_KLINE, client_p->localClient->aftype,
387 >                                     client_p->username, NULL, 1)) != NULL)
388      {
408
409      /* if there is a returned struct AccessItem.. then kill it */
389        if (IsExemptKline(client_p))
390        {
391 <        sendto_realops_flags(UMODE_ALL, L_ALL,
391 >        sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
392                               "KLINE over-ruled for %s, client is kline_exempt",
393                               get_client_name(client_p, HIDE_IP));
394          continue;
395        }
396  
418      conf = unmap_conf_item(aconf);
397        ban_them(client_p, conf);
398 <      continue;
398 >      continue;
399      }
400  
401 <    /* if there is a returned struct MatchItem then kill it */
402 <    if ((conf = find_matching_name_conf(XLINE_TYPE,  client_p->info,
425 <                                        NULL, NULL, 0)) != NULL ||
426 <        (conf = find_matching_name_conf(RXLINE_TYPE, client_p->info,
427 <                                        NULL, NULL, 0)) != NULL)
401 >    if ((conf = find_matching_name_conf(CONF_XLINE,  client_p->info,
402 >                                        NULL, NULL, 0)))
403      {
404        ban_them(client_p, conf);
405        continue;
# Line 436 | Line 411 | check_conf_klines(void)
411    {
412      client_p = ptr->data;
413  
414 <    if ((aconf = find_dline_conf(&client_p->localClient->ip,
415 <                                  client_p->localClient->aftype)))
414 >    if ((conf = find_dline_conf(&client_p->localClient->ip,
415 >                                 client_p->localClient->aftype)))
416      {
417 <      if (aconf->status & CONF_EXEMPTDLINE)
417 >      if (conf->type == CONF_EXEMPT)
418          continue;
419  
420        exit_client(client_p, &me, "D-lined");
# Line 451 | Line 426 | check_conf_klines(void)
426   * ban_them
427   *
428   * inputs       - pointer to client to ban
429 < *              - pointer to ConfItem
429 > *              - pointer to MaskItem
430   * output       - NONE
431   * side effects - given client_p is banned
432   */
433   static void
434 < ban_them(struct Client *client_p, struct ConfItem *conf)
434 > ban_them(struct Client *client_p, struct MaskItem *conf)
435   {
436 <  const char *user_reason = NULL;       /* What is sent to user */
462 <  const char *channel_reason = NULL;    /* What is sent to channel */
463 <  struct AccessItem *aconf = NULL;
464 <  struct MatchItem *xconf = NULL;
436 >  const char *user_reason = NULL;  /* What is sent to user */
437    const char *type_string = NULL;
438    const char dline_string[] = "D-line";
439    const char kline_string[] = "K-line";
# Line 470 | Line 442 | ban_them(struct Client *client_p, struct
442  
443    switch (conf->type)
444    {
445 <    case RKLINE_TYPE:
474 <    case KLINE_TYPE:
445 >    case CONF_KLINE:
446        type_string = kline_string;
476      aconf = map_to_conf(conf);
447        break;
448 <    case DLINE_TYPE:
448 >    case CONF_DLINE:
449        type_string = dline_string;
480      aconf = map_to_conf(conf);
450        break;
451 <    case GLINE_TYPE:
451 >    case CONF_GLINE:
452        type_string = gline_string;
484      aconf = map_to_conf(conf);
453        break;
454 <    case RXLINE_TYPE:
487 <    case XLINE_TYPE:
454 >    case CONF_XLINE:
455        type_string = xline_string;
456 <      xconf = map_to_conf(conf);
490 <      ++xconf->count;
456 >      ++conf->count;
457        break;
458      default:
459        assert(0);
460        break;
461    }
462  
463 <  if (ConfigFileEntry.kline_with_reason)
498 <  {
499 <    if (aconf != NULL)
500 <      user_reason = aconf->reason ? aconf->reason : type_string;
501 <    if (xconf != NULL)
502 <      user_reason = xconf->reason ? xconf->reason : type_string;
503 <  }
504 <  else
505 <    user_reason = type_string;
506 <
507 <  if (ConfigFileEntry.kline_reason != NULL)
508 <    channel_reason = ConfigFileEntry.kline_reason;
509 <  else
510 <    channel_reason = user_reason;
463 >  user_reason = conf->reason ? conf->reason : type_string;
464  
465 <  sendto_realops_flags(UMODE_ALL, L_ALL, "%s active for %s",
465 >  sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE, "%s active for %s",
466                         type_string, get_client_name(client_p, HIDE_IP));
467  
468    if (IsClient(client_p))
469      sendto_one(client_p, form_str(ERR_YOUREBANNEDCREEP),
470 <               me.name, client_p->name, user_reason);
470 >               me.name, client_p->name, user_reason);
471  
472 <  exit_client(client_p, &me, channel_reason);
472 >  exit_client(client_p, &me, user_reason);
473   }
474  
475   /* update_client_exit_stats()
476   *
477   * input        - pointer to client
478   * output       - NONE
479 < * side effects -
479 > * side effects -
480   */
481   static void
482   update_client_exit_stats(struct Client *client_p)
# Line 538 | Line 491 | update_client_exit_stats(struct Client *
491        --Count.invisi;
492    }
493    else if (IsServer(client_p))
494 <    sendto_realops_flags(UMODE_EXTERNAL, L_ALL, "Server %s split from %s",
494 >    sendto_realops_flags(UMODE_EXTERNAL, L_ALL, SEND_NOTICE,
495 >                         "Server %s split from %s",
496                           client_p->name, client_p->servptr->name);
497  
498    if (splitchecking && !splitmode)
# Line 551 | Line 505 | update_client_exit_stats(struct Client *
505   * output       - return client pointer
506   * side effects - find person by (nick)name
507   */
554 /* XXX - ugly wrapper */
508   struct Client *
509   find_person(const struct Client *client_p, const char *name)
510   {
511 <  struct Client *c2ptr;
511 >  struct Client *target_p = NULL;
512  
513    if (IsDigit(*name))
514    {
515 <    if ((c2ptr = hash_find_id(name)) != NULL)
516 <    {
517 <      /* invisible users shall not be found by UID guessing */
565 <      if (HasUMode(c2ptr, UMODE_INVISIBLE) && !IsServer(client_p))
566 <        c2ptr = NULL;
567 <    }
515 >    if ((target_p = hash_find_id(name)) != NULL)
516 >      if (!IsServer(client_p) && !HasFlag(client_p, FLAGS_SERVICE))
517 >        target_p = NULL;
518    }
519    else
520 <    c2ptr = hash_find_client(name);
520 >    target_p = hash_find_client(name);
521  
522 <  return ((c2ptr != NULL && IsClient(c2ptr)) ? c2ptr : NULL);
522 >  return (target_p && IsClient(target_p)) ? target_p : NULL;
523   }
524  
525   /*
526 < * find_chasing - find the client structure for a nick name (user)
527 < *      using history mechanism if necessary. If the client is not found,
526 > * find_chasing - find the client structure for a nick name (name)
527 > *      using history mechanism if necessary. If the client is not found,
528   *      an error message (NO SUCH NICK) is generated. If the client was found
529   *      through the history, chasing will be 1 and otherwise 0.
530   */
531   struct Client *
532 < find_chasing(struct Client *client_p, struct Client *source_p, const char *user, int *chasing)
532 > find_chasing(struct Client *source_p, const char *name, int *const chasing)
533   {
534 <  struct Client *who = find_person(client_p, user);
534 >  struct Client *who = find_person(source_p->from, name);
535  
536    if (chasing)
537      *chasing = 0;
# Line 589 | Line 539 | find_chasing(struct Client *client_p, st
539    if (who)
540      return who;
541  
542 <  if (IsDigit(*user))
542 >  if (IsDigit(*name))
543      return NULL;
544  
545 <  if ((who = get_history(user,
546 <                        (time_t)ConfigFileEntry.kill_chase_time_limit))
547 <                         == NULL)
545 >  if ((who = whowas_get_history(name,
546 >                         (time_t)ConfigFileEntry.kill_chase_time_limit))
547 >                         == NULL)
548    {
549      sendto_one(source_p, form_str(ERR_NOSUCHNICK),
550 <               me.name, source_p->name, user);
550 >               me.name, source_p->name, name);
551      return NULL;
552    }
553  
# Line 626 | Line 576 | find_chasing(struct Client *client_p, st
576   *        to modify what it points!!!
577   */
578   const char *
579 < get_client_name(const struct Client *client, int showip)
579 > get_client_name(const struct Client *client, enum addr_mask_type type)
580   {
581    static char nbuf[HOSTLEN * 2 + USERLEN + 5];
582  
583    assert(client != NULL);
584  
585 <  if (irccmp(client->name, client->host) == 0)
585 >  if (!MyConnect(client))
586      return client->name;
587  
588 <  if (ConfigServerHide.hide_server_ips)
589 <    if (IsServer(client) || IsConnecting(client) || IsHandshake(client))
590 <      showip = MASK_IP;
588 >  if (IsServer(client) || IsConnecting(client) || IsHandshake(client))
589 >  {
590 >    if (!irccmp(client->name, client->host))
591 >      return client->name;
592 >    else if (ConfigServerHide.hide_server_ips)
593 >      type = MASK_IP;
594 >  }
595  
596    if (ConfigFileEntry.hide_spoof_ips)
597 <    if (showip == SHOW_IP && IsIPSpoof(client))
598 <      showip = MASK_IP;
597 >    if (type == SHOW_IP && IsIPSpoof(client))
598 >      type = MASK_IP;
599  
600    /* And finally, let's get the host information, ip or name */
601 <  switch (showip)
601 >  switch (type)
602    {
603      case SHOW_IP:
604 <      if (MyConnect(client))
605 <      {
606 <        snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
607 <                 client->name,
654 <                 client->username, client->sockhost);
655 <        break;
656 <      }
604 >      snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
605 >               client->name,
606 >               client->username, client->sockhost);
607 >      break;
608      case MASK_IP:
609 <      snprintf(nbuf, sizeof(nbuf), "%s[%s@255.255.255.255]",
610 <               client->name, client->username);
609 >      if (client->localClient->aftype == AF_INET)
610 >        snprintf(nbuf, sizeof(nbuf), "%s[%s@255.255.255.255]",
611 >                 client->name, client->username);
612 >      else
613 >        snprintf(nbuf, sizeof(nbuf), "%s[%s@ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff]",
614 >                 client->name, client->username);
615        break;
616      default:
617        snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
# Line 671 | Line 626 | void
626   free_exited_clients(void)
627   {
628    dlink_node *ptr = NULL, *next = NULL;
629 <  
629 >
630    DLINK_FOREACH_SAFE(ptr, next, dead_list.head)
631    {
632      free_client(ptr->data);
# Line 704 | Line 659 | exit_one_client(struct Client *source_p,
659       * that the client can show the "**signoff" message).
660       * (Note: The notice is to the local clients *only*)
661       */
662 <    sendto_common_channels_local(source_p, 0, ":%s!%s@%s QUIT :%s",
662 >    sendto_common_channels_local(source_p, 0, 0, ":%s!%s@%s QUIT :%s",
663                                   source_p->name, source_p->username,
664                                   source_p->host, quitmsg);
665      DLINK_FOREACH_SAFE(lp, next_lp, source_p->channel.head)
666        remove_user_from_channel(lp->data);
667  
668 <    add_history(source_p, 0);
669 <    off_history(source_p);
668 >    whowas_add_history(source_p, 0);
669 >    whowas_off_history(source_p);
670  
671      watch_check_hash(source_p, RPL_LOGOFF);
672  
# Line 774 | Line 729 | recurse_send_quits(struct Client *origin
729   {
730    dlink_node *ptr, *next;
731    struct Client *target_p;
777  int hidden = match(me.name, source_p->name); /* XXX */
732  
733    assert(to != source_p);  /* should be already removed from serv_list */
734  
735    /* If this server can handle quit storm (QS) removal
736     * of dependents, just send the SQUIT
783   *
784   * Always check *all* dependent servers if some of them are
785   * hidden behind fakename. If so, send out the QUITs -adx
737     */
738 <  if (hidden || !IsCapable(to, CAP_QS))
738 >  if (!IsCapable(to, CAP_QS))
739      DLINK_FOREACH_SAFE(ptr, next, source_p->serv->client_list.head)
740      {
741        target_p = ptr->data;
# Line 795 | Line 746 | recurse_send_quits(struct Client *origin
746      recurse_send_quits(original_source_p, ptr->data, from, to,
747                         comment, splitstr);
748  
749 <  if (!hidden && ((source_p == original_source_p && to != from) ||
750 <                  !IsCapable(to, CAP_QS)))
749 >  if ((source_p == original_source_p && to != from) ||
750 >                  !IsCapable(to, CAP_QS))
751    {
752      /* don't use a prefix here - we have to be 100% sure the message
753       * will be accepted without Unknown prefix etc.. */
# Line 804 | Line 755 | recurse_send_quits(struct Client *origin
755    }
756   }
757  
758 < /*
758 > /*
759   * Remove all clients that depend on source_p; assumes all (S)QUITs have
760 < * already been sent.  we make sure to exit a server's dependent clients
761 < * and servers before the server itself; exit_one_client takes care of
760 > * already been sent.  we make sure to exit a server's dependent clients
761 > * and servers before the server itself; exit_one_client takes care of
762   * actually removing things off llists.   tweaked from +CSr31  -orabidoo
763   */
764   static void
# Line 879 | Line 830 | exit_client(struct Client *source_p, str
830      if (IsIpHash(source_p))
831        remove_one_ip(&source_p->localClient->ip);
832  
833 <    if (source_p->localClient->auth)
883 <    {
884 <      delete_auth(source_p->localClient->auth);
885 <      source_p->localClient->auth = NULL;
886 <    }
833 >    delete_auth(&source_p->localClient->auth);
834  
835 <    /* This source_p could have status of one of STAT_UNKNOWN, STAT_CONNECTING
835 >    /*
836 >     * This source_p could have status of one of STAT_UNKNOWN, STAT_CONNECTING
837       * STAT_HANDSHAKE or STAT_UNKNOWN
838       * all of which are lumped together into unknown_list
839       *
# Line 904 | Line 852 | exit_client(struct Client *source_p, str
852        Count.local--;
853  
854        if (HasUMode(source_p, UMODE_OPER))
907      {
855          if ((m = dlinkFindDelete(&oper_list, source_p)) != NULL)
856            free_dlink_node(m);
910      }
857  
858        assert(dlinkFind(&local_client_list, source_p));
859        dlinkDelete(&source_p->localClient->lclient_node, &local_client_list);
# Line 916 | Line 862 | exit_client(struct Client *source_p, str
862          free_list_task(source_p->localClient->list_task, source_p);
863  
864        watch_del_watch_list(source_p);
865 <      sendto_realops_flags(UMODE_CCONN, L_ALL, "Client exiting: %s (%s@%s) [%s] [%s]",
865 >      sendto_realops_flags(UMODE_CCONN, L_ALL, SEND_NOTICE,
866 >                           "Client exiting: %s (%s@%s) [%s] [%s]",
867                             source_p->name, source_p->username, source_p->host, comment,
868                             ConfigFileEntry.hide_spoof_ips && IsIPSpoof(source_p) ?
869                             "255.255.255.255" : source_p->sockhost);
923      sendto_realops_flags(UMODE_CCONN_FULL, L_ALL, "CLIEXIT: %s %s %s %s 0 %s",
924                           source_p->name,
925                           source_p->username,
926                           source_p->host,
927                           ConfigFileEntry.hide_spoof_ips && IsIPSpoof(source_p) ?
928                           "255.255.255.255" : source_p->sockhost,
929                           comment);
870        ilog(LOG_TYPE_USER, "%s (%3u:%02u:%02u): %s!%s@%s %llu/%llu",
871             myctime(source_p->localClient->firsttime), (unsigned int)(on_for / 3600),
872             (unsigned int)((on_for % 3600)/60), (unsigned int)(on_for % 60),
# Line 934 | Line 874 | exit_client(struct Client *source_p, str
874             source_p->localClient->send.bytes>>10,
875             source_p->localClient->recv.bytes>>10);
876      }
877 <
938 <    /* As soon as a client is known to be a server of some sort
939 <     * it has to be put on the serv_list, or SJOIN's to this new server
940 <     * from the connect burst will not be seen.
941 <     * XXX - TBV.  This is not true. The only place where we put a server on
942 <     * serv_list is in server_estab right now after registration process.
943 <     * And only after this, a burst is sent to the remote server, i.e. we never
944 <     * send a burst to STAT_CONNECTING, or STAT_HANDSHAKE. This will need
945 <     * more investigation later on, but for now, it's not a problem after all.
946 <     */
947 <    if (IsServer(source_p) || IsConnecting(source_p) ||
948 <        IsHandshake(source_p))
877 >    else if (IsServer(source_p))
878      {
879 <      if (dlinkFind(&serv_list, source_p))
880 <      {
952 <        dlinkDelete(&source_p->localClient->lclient_node, &serv_list);
953 <        unset_chcap_usage_counts(source_p);
954 <      }
879 >      assert(Count.myserver > 0);
880 >      --Count.myserver;
881  
882 <      if (IsServer(source_p))
883 <        Count.myserver--;
882 >      assert(dlinkFind(&serv_list, source_p));
883 >      dlinkDelete(&source_p->localClient->lclient_node, &serv_list);
884 >      unset_chcap_usage_counts(source_p);
885      }
886  
887      if (!IsDead(source_p))
# Line 963 | Line 890 | exit_client(struct Client *source_p, str
890        {
891          /* for them, we are exiting the network */
892          sendto_one(source_p, ":%s SQUIT %s :%s",
893 <                   ID_or_name(from, source_p), me.name, comment);
893 >                   ID_or_name(from, source_p), me.name, comment);
894        }
895  
896        sendto_one(source_p, "ERROR :Closing Link: %s (%s)",
# Line 983 | Line 910 | exit_client(struct Client *source_p, str
910      */
911      close_connection(source_p);
912    }
913 +  else if (IsClient(source_p) && HasFlag(source_p->servptr, FLAGS_EOB))
914 +    sendto_realops_flags(UMODE_FARCONNECT, L_ALL, SEND_NOTICE,
915 +                         "Client exiting at %s: %s (%s@%s) [%s]",
916 +                         source_p->servptr->name, source_p->name,
917 +                         source_p->username, source_p->host, comment);
918  
919    if (IsServer(source_p))
920    {
# Line 993 | Line 925 | exit_client(struct Client *source_p, str
925  
926      if (ConfigServerHide.hide_servers)
927        /*
928 <       * Set netsplit message to "*.net *.split" to still show
928 >       * Set netsplit message to "*.net *.split" to still show
929         * that its a split, but hide the servers splitting
930         */
931        strcpy(splitstr, "*.net *.split");
# Line 1005 | Line 937 | exit_client(struct Client *source_p, str
937  
938      if (source_p->servptr == &me)
939      {
940 <      sendto_realops_flags(UMODE_ALL, L_ALL,
940 >      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
941                             "%s was connected for %d seconds.  %llu/%llu sendK/recvK.",
942                             source_p->name, (int)(CurrentTime - source_p->localClient->firsttime),
943                             source_p->localClient->send.bytes >> 10,
944                             source_p->localClient->recv.bytes >> 10);
945        ilog(LOG_TYPE_IRCD, "%s was connected for %d seconds.  %llu/%llu sendK/recvK.",
946 <           source_p->name, (int)(CurrentTime - source_p->localClient->firsttime),
946 >           source_p->name, (int)(CurrentTime - source_p->localClient->firsttime),
947             source_p->localClient->send.bytes >> 10,
948             source_p->localClient->recv.bytes >> 10);
949      }
950    }
951    else if (IsClient(source_p) && !HasFlag(source_p, FLAGS_KILLED))
952    {
953 <    sendto_server(from->from, NULL, CAP_TS6, NOCAPS,
953 >    sendto_server(from->from, CAP_TS6, NOCAPS,
954                    ":%s QUIT :%s", ID(source_p), comment);
955 <    sendto_server(from->from, NULL, NOCAPS, CAP_TS6,
955 >    sendto_server(from->from, NOCAPS, CAP_TS6,
956                    ":%s QUIT :%s", source_p->name, comment);
957    }
958  
# Line 1080 | Line 1012 | dead_link_on_read(struct Client *client_
1012    if (IsServer(client_p) || IsHandshake(client_p))
1013    {
1014      int connected = CurrentTime - client_p->localClient->firsttime;
1015 <      
1015 >
1016      if (error == 0)
1017      {
1018        /* Admins get the real IP */
1019 <      sendto_realops_flags(UMODE_ALL, L_ADMIN,
1020 <                           "Server %s closed the connection",
1021 <                           get_client_name(client_p, SHOW_IP));
1019 >      sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
1020 >                           "Server %s closed the connection",
1021 >                           get_client_name(client_p, SHOW_IP));
1022  
1023        /* Opers get a masked IP */
1024 <      sendto_realops_flags(UMODE_ALL, L_OPER,
1025 <                           "Server %s closed the connection",
1026 <                           get_client_name(client_p, MASK_IP));
1024 >      sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
1025 >                           "Server %s closed the connection",
1026 >                           get_client_name(client_p, MASK_IP));
1027  
1028        ilog(LOG_TYPE_IRCD, "Server %s closed the connection",
1029 <           get_client_name(client_p, SHOW_IP));
1029 >           get_client_name(client_p, SHOW_IP));
1030      }
1031      else
1032      {
1033        report_error(L_ADMIN, "Lost connection to %s: %s",
1034 <                   get_client_name(client_p, SHOW_IP), current_error);
1034 >                   get_client_name(client_p, SHOW_IP), current_error);
1035        report_error(L_OPER, "Lost connection to %s: %s",
1036 <                   get_client_name(client_p, MASK_IP), current_error);
1036 >                   get_client_name(client_p, MASK_IP), current_error);
1037      }
1038  
1039 <    sendto_realops_flags(UMODE_ALL, L_ALL,
1040 <                         "%s had been connected for %d day%s, %2d:%02d:%02d",
1041 <                         client_p->name, connected/86400,
1042 <                         (connected/86400 == 1) ? "" : "s",
1043 <                         (connected % 86400) / 3600, (connected % 3600) / 60,
1044 <                         connected % 60);
1039 >    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
1040 >                         "%s had been connected for %d day%s, %2d:%02d:%02d",
1041 >                         client_p->name, connected/86400,
1042 >                         (connected/86400 == 1) ? "" : "s",
1043 >                         (connected % 86400) / 3600, (connected % 3600) / 60,
1044 >                         connected % 60);
1045    }
1046  
1047    if (error == 0)
# Line 1136 | Line 1068 | exit_aborted_clients(void)
1068  
1069      if (target_p == NULL)
1070      {
1071 <      sendto_realops_flags(UMODE_ALL, L_ALL,
1071 >      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
1072                             "Warning: null client on abort_list!");
1073        dlinkDelete(ptr, &abort_list);
1074        free_dlink_node(ptr);
# Line 1150 | Line 1082 | exit_aborted_clients(void)
1082      else
1083        notice = "Write error: connection closed";
1084  
1085 <    exit_client(target_p, &me, notice);  
1085 >    exit_client(target_p, &me, notice);
1086      free_dlink_node(ptr);
1087    }
1088   }
# Line 1178 | Line 1110 | del_accept(struct split_nuh_item *accept
1110  
1111   struct split_nuh_item *
1112   find_accept(const char *nick, const char *user,
1113 <            const char *host, struct Client *client_p, int do_match)
1113 >            const char *host, struct Client *client_p,
1114 >            int (*cmpfunc)(const char *, const char *))
1115   {
1116    dlink_node *ptr = NULL;
1184  /* XXX We wouldn't need that if match() would return 0 on match */
1185  int (*cmpfunc)(const char *, const char *) = do_match ? match : irccmp;
1117  
1118    DLINK_FOREACH(ptr, client_p->localClient->acceptlist.head)
1119    {
1120      struct split_nuh_item *accept_p = ptr->data;
1121  
1122 <    if (cmpfunc(accept_p->nickptr, nick) == do_match &&
1123 <        cmpfunc(accept_p->userptr, user) == do_match &&
1124 <        cmpfunc(accept_p->hostptr, host) == do_match)
1122 >    if (!cmpfunc(accept_p->nickptr, nick) &&
1123 >        !cmpfunc(accept_p->userptr, user) &&
1124 >        !cmpfunc(accept_p->hostptr, host))
1125        return accept_p;
1126    }
1127  
# Line 1211 | Line 1142 | accept_message(struct Client *source,
1142    dlink_node *ptr = NULL;
1143  
1144    if (source == target || find_accept(source->name, source->username,
1145 <                                      source->host, target, 1))
1145 >                                      source->host, target, match))
1146      return 1;
1147  
1148    if (HasUMode(target, UMODE_SOFTCALLERID))
# Line 1236 | Line 1167 | del_all_accepts(struct Client *client_p)
1167    DLINK_FOREACH_SAFE(ptr, next_ptr, client_p->localClient->acceptlist.head)
1168      del_accept(ptr->data, client_p);
1169   }
1170 +
1171 + unsigned int
1172 + idle_time_get(const struct Client *source_p, const struct Client *target_p)
1173 + {
1174 +  unsigned int idle = 0;
1175 +  unsigned int min_idle = 0;
1176 +  unsigned int max_idle = 0;
1177 +  const struct ClassItem *class = get_class_ptr(&target_p->localClient->confs);
1178 +
1179 +  if (!(class->flags & CLASS_FLAGS_FAKE_IDLE) || target_p == source_p)
1180 +    return CurrentTime - target_p->localClient->last_privmsg;
1181 +  if (HasUMode(source_p, UMODE_OPER) &&
1182 +      !(class->flags & CLASS_FLAGS_HIDE_IDLE_FROM_OPERS))
1183 +    return CurrentTime - target_p->localClient->last_privmsg;
1184 +
1185 +  min_idle = class->min_idle;
1186 +  max_idle = class->max_idle;
1187 +
1188 +  if (min_idle == max_idle)
1189 +    return min_idle;
1190 +
1191 +  if (class->flags & CLASS_FLAGS_RANDOM_IDLE)
1192 +    idle = genrand_int32();
1193 +  else
1194 +    idle = CurrentTime - target_p->localClient->last_privmsg;
1195 +
1196 +  if (max_idle == 0)
1197 +    idle = 0;
1198 +  else
1199 +    idle %= max_idle;
1200 +
1201 +  if (idle < min_idle)
1202 +    idle = min_idle + (idle % (max_idle - min_idle));
1203 +
1204 +  return idle;
1205 + }

Diff Legend

Removed lines
+ Added lines
< Changed lines (old)
> Changed lines (new)