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

Comparing:
ircd-hybrid-7.2/src/channel.c (file contents), Revision 885 by michael, Wed Oct 31 18:09:24 2007 UTC vs.
ircd-hybrid/trunk/src/channel.c (file contents), Revision 3145 by michael, Wed Mar 12 20:12:46 2014 UTC

# Line 1 | Line 1
1   /*
2 < *  ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd).
2 > *  ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3   *
4 < *  Copyright (C) 2002 by the past and present ircd coders, and others.
4 > *  Copyright (c) 1997-2014 ircd-hybrid development team
5   *
6   *  This program is free software; you can redistribute it and/or modify
7   *  it under the terms of the GNU General Public License as published by
# Line 25 | Line 25
25   */
26  
27   #include "stdinc.h"
28 < #include "tools.h"
28 > #include "list.h"
29   #include "channel.h"
30   #include "channel_mode.h"
31   #include "client.h"
32 #include "common.h"
32   #include "hash.h"
33 + #include "conf.h"
34   #include "hostmask.h"
35   #include "irc_string.h"
36 #include "sprintf_irc.h"
36   #include "ircd.h"
38 #include "list.h"
37   #include "numeric.h"
38 < #include "s_serv.h"             /* captab */
41 < #include "s_user.h"
38 > #include "s_serv.h"
39   #include "send.h"
43 #include "s_conf.h"             /* ConfigFileEntry, ConfigChannel */
40   #include "event.h"
41   #include "memory.h"
42 < #include "balloc.h"
42 > #include "mempool.h"
43 > #include "s_misc.h"
44 > #include "resv.h"
45  
48 struct config_channel_entry ConfigChannel;
46   dlink_list global_channel_list = { NULL, NULL, 0 };
47 < BlockHeap *ban_heap;    /*! \todo ban_heap shouldn't be a global var */
47 > mp_pool_t *ban_pool;    /*! \todo ban_pool shouldn't be a global var */
48  
49 < static BlockHeap *topic_heap = NULL;
50 < static BlockHeap *member_heap = NULL;
54 < static BlockHeap *channel_heap = NULL;
49 > static mp_pool_t *member_pool = NULL;
50 > static mp_pool_t *channel_pool = NULL;
51  
52   static char buf[IRCD_BUFSIZE];
57 static char modebuf[MODEBUFLEN];
58 static char parabuf[MODEBUFLEN];
53  
54  
55   /*! \brief Initializes the channel blockheap, adds known channel CAPAB
56   */
57   void
58 < init_channels(void)
58 > channel_init(void)
59   {
60    add_capability("EX", CAP_EX, 1);
61    add_capability("IE", CAP_IE, 1);
68  add_capability("CHW", CAP_CHW, 1);
62  
63 <  channel_heap = BlockHeapCreate("channel", sizeof(struct Channel), CHANNEL_HEAP_SIZE);
64 <  ban_heap = BlockHeapCreate("ban", sizeof(struct Ban), BAN_HEAP_SIZE);
65 <  topic_heap = BlockHeapCreate("topic", TOPICLEN+1 + USERHOST_REPLYLEN, TOPIC_HEAP_SIZE);
73 <  member_heap = BlockHeapCreate("member", sizeof(struct Membership), CHANNEL_HEAP_SIZE*2);
63 >  channel_pool = mp_pool_new(sizeof(struct Channel), MP_CHUNK_SIZE_CHANNEL);
64 >  ban_pool = mp_pool_new(sizeof(struct Ban), MP_CHUNK_SIZE_BAN);
65 >  member_pool = mp_pool_new(sizeof(struct Membership), MP_CHUNK_SIZE_MEMBER);
66   }
67  
68   /*! \brief adds a user to a channel by adding another link to the
# Line 107 | Line 99 | add_user_to_channel(struct Channel *chpt
99        if (!IsSetJoinFloodNoticed(chptr))
100        {
101          SetJoinFloodNoticed(chptr);
102 <        sendto_realops_flags(UMODE_BOTS, L_ALL,
102 >        sendto_realops_flags(UMODE_BOTS, L_ALL, SEND_NOTICE,
103                               "Possible Join Flooder %s on %s target: %s",
104                               get_client_name(who, HIDE_IP),
105                               who->servptr->name, chptr->chname);
# Line 117 | Line 109 | add_user_to_channel(struct Channel *chpt
109      chptr->last_join_time = CurrentTime;
110    }
111  
112 <  ms = BlockHeapAlloc(member_heap);
112 >  ms = mp_pool_get(member_pool);
113 >  memset(ms, 0, sizeof(*ms));
114 >
115    ms->client_p = who;
116    ms->chptr = chptr;
117    ms->flags = flags;
# Line 139 | Line 133 | remove_user_from_channel(struct Membersh
133    dlinkDelete(&member->channode, &chptr->members);
134    dlinkDelete(&member->usernode, &client_p->channel);
135  
136 <  BlockHeapFree(member_heap, member);
136 >  mp_pool_release(member);
137  
138 <  if (dlink_list_length(&chptr->members) == 0)
138 >  if (chptr->members.head == NULL)
139      destroy_channel(chptr);
140   }
141  
# Line 153 | Line 147 | remove_user_from_channel(struct Membersh
147   */
148   static void
149   send_members(struct Client *client_p, struct Channel *chptr,
150 <             char *lmodebuf, char *lparabuf)
150 >             char *modebuf, char *parabuf)
151   {
152 <  struct Membership *ms;
159 <  dlink_node *ptr;
152 >  const dlink_node *ptr = NULL;
153    int tlen;              /* length of text to append */
154    char *t, *start;       /* temp char pointer */
155  
156 <  start = t = buf + ircsprintf(buf, ":%s SJOIN %lu %s %s %s:",
157 <                               ID_or_name(&me, client_p),
158 <                               (unsigned long)chptr->channelts,
159 <                               chptr->chname, lmodebuf, lparabuf);
156 >  start = t = buf + snprintf(buf, sizeof(buf), ":%s SJOIN %lu %s %s %s:",
157 >                             ID_or_name(&me, client_p),
158 >                             (unsigned long)chptr->channelts,
159 >                             chptr->chname, modebuf, parabuf);
160  
161    DLINK_FOREACH(ptr, chptr->members.head)
162    {
163 <    ms = ptr->data;
163 >    const struct Membership *ms = ptr->data;
164  
165 <    tlen = strlen(IsCapable(client_p, CAP_TS6) ?
173 <      ID(ms->client_p) : ms->client_p->name) + 1;  /* nick + space */
165 >    tlen = strlen(ID(ms->client_p)) + 1;  /* nick + space */
166  
167      if (ms->flags & CHFL_CHANOP)
168        tlen++;
169   #ifdef HALFOPS
170 <    else if (ms->flags & CHFL_HALFOP)
170 >    if (ms->flags & CHFL_HALFOP)
171        tlen++;
172   #endif
173      if (ms->flags & CHFL_VOICE)
# Line 184 | Line 176 | send_members(struct Client *client_p, st
176      /* space will be converted into CR, but we also need space for LF..
177       * That's why we use '- 1' here
178       * -adx */
179 <    if (t + tlen - buf > sizeof(buf) - 1)
179 >    if (t + tlen - buf > IRCD_BUFSIZE - 1)
180      {
181        *(t - 1) = '\0';  /* kill the space and terminate the string */
182        sendto_one(client_p, "%s", buf);
183        t = start;
184      }
185  
186 <    if ((ms->flags & (CHFL_CHANOP | CHFL_HALFOP)))
187 <      *t++ = (!(ms->flags & CHFL_CHANOP) && IsCapable(client_p, CAP_HOPS)) ?
188 <        '%' : '@';
189 <    if ((ms->flags & CHFL_VOICE))
186 >    if (ms->flags & CHFL_CHANOP)
187 >      *t++ = '@';
188 >    if (ms->flags & CHFL_HALFOP)
189 >      *t++ = '%';
190 >    if (ms->flags & CHFL_VOICE)
191        *t++ = '+';
192  
193 <    if (IsCapable(client_p, CAP_TS6))
194 <      strcpy(t, ID(ms->client_p));
202 <    else
203 <      strcpy(t, ms->client_p->name);
193 >    strcpy(t, ID(ms->client_p));
194 >
195      t += strlen(t);
196      *t++ = ' ';
197    }
# Line 220 | Line 211 | send_members(struct Client *client_p, st
211   */
212   static void
213   send_mode_list(struct Client *client_p, struct Channel *chptr,
214 <               dlink_list *top, char flag)
214 >               const dlink_list *top, char flag)
215   {
216 <  int ts5 = !IsCapable(client_p, CAP_TS6);
226 <  dlink_node *lp;
227 <  struct Ban *banptr;
216 >  const dlink_node *lp = NULL;
217    char pbuf[IRCD_BUFSIZE];
218    int tlen, mlen, cur_len, count = 0;
219 <  char *mp = NULL, *pp = pbuf;
219 >  char *pp = pbuf;
220  
221    if (top == NULL || top->length == 0)
222      return;
223  
224 <  if (ts5)
225 <    mlen = ircsprintf(buf, ":%s MODE %s +", me.name, chptr->chname);
226 <  else
238 <    mlen = ircsprintf(buf, ":%s BMASK %lu %s %c :", me.id,
239 <                      (unsigned long)chptr->channelts, chptr->chname, flag);
240 <
241 <  /* MODE needs additional one byte for space between buf and pbuf */
242 <  cur_len = mlen + ts5;
243 <  mp = buf + mlen;
224 >  mlen = snprintf(buf, sizeof(buf), ":%s BMASK %lu %s %c :", me.id,
225 >                  (unsigned long)chptr->channelts, chptr->chname, flag);
226 >  cur_len = mlen;
227  
228    DLINK_FOREACH(lp, top->head)
229    {
230 <    banptr = lp->data;
230 >    const struct Ban *banptr = lp->data;
231  
232 <    /* must add another b/e/I letter if we use MODE */
250 <    tlen = banptr->len + 3 + ts5;
232 >    tlen = banptr->len + 3;
233  
234      /*
235       * send buffer and start over if we cannot fit another ban,
236       * or if the target is non-ts6 and we have too many modes in
237       * in this line.
238       */
239 <    if (cur_len + (tlen - 1) > IRCD_BUFSIZE - 2 ||
258 <        (!IsCapable(client_p, CAP_TS6) &&
259 <         (count >= MAXMODEPARAMS || pp - pbuf >= MODEBUFLEN)))
239 >    if (cur_len + (tlen - 1) > IRCD_BUFSIZE - 2)
240      {
241        *(pp - 1) = '\0';  /* get rid of trailing space on buffer */
242 <      sendto_one(client_p, "%s%s%s", buf, ts5 ? " " : "", pbuf);
242 >      sendto_one(client_p, "%s%s", buf, pbuf);
243  
244 <      cur_len = mlen + ts5;
265 <      mp = buf + mlen;
244 >      cur_len = mlen;
245        pp = pbuf;
246        count = 0;
247      }
248  
249      count++;
250 <    if (ts5)
251 <    {
273 <      *mp++ = flag;
274 <      *mp = '\0';
275 <    }
276 <
277 <    pp += ircsprintf(pp, "%s!%s@%s ", banptr->name, banptr->username,
278 <                     banptr->host);
250 >    pp += sprintf(pp, "%s!%s@%s ", banptr->name, banptr->user,
251 >                  banptr->host);
252      cur_len += tlen;
253    }
254  
255    *(pp - 1) = '\0';  /* get rid of trailing space on buffer */
256 <  sendto_one(client_p, "%s%s%s", buf, ts5 ? " " : "", pbuf);
256 >  sendto_one(client_p, "%s%s", buf, pbuf);
257   }
258  
259   /*! \brief send "client_p" a full list of the modes for channel chptr
# Line 290 | Line 263 | send_mode_list(struct Client *client_p,
263   void
264   send_channel_modes(struct Client *client_p, struct Channel *chptr)
265   {
266 <  if (chptr->chname[0] != '#')
267 <    return;
266 >  char modebuf[MODEBUFLEN] = "";
267 >  char parabuf[MODEBUFLEN] = "";
268  
296  *modebuf = *parabuf = '\0';
269    channel_modes(chptr, client_p, modebuf, parabuf);
270    send_members(client_p, chptr, modebuf, parabuf);
271  
272    send_mode_list(client_p, chptr, &chptr->banlist, 'b');
273 <
274 <  if (IsCapable(client_p, CAP_EX))
303 <    send_mode_list(client_p, chptr, &chptr->exceptlist, 'e');
304 <  if (IsCapable(client_p, CAP_IE))
305 <    send_mode_list(client_p, chptr, &chptr->invexlist, 'I');
273 >  send_mode_list(client_p, chptr, &chptr->exceptlist, 'e');
274 >  send_mode_list(client_p, chptr, &chptr->invexlist, 'I');
275   }
276  
277   /*! \brief check channel name for invalid characters
# Line 311 | Line 280 | send_channel_modes(struct Client *client
280   * \return 0 if invalid, 1 otherwise
281   */
282   int
283 < check_channel_name(const char *name, int local)
283 > check_channel_name(const char *name, const int local)
284   {
285    const char *p = name;
286 <  int max_length = local ? LOCAL_CHANNELLEN : CHANNELLEN;
286 >  const int max_length = local ? LOCAL_CHANNELLEN : CHANNELLEN;
287    assert(name != NULL);
288  
289    if (!IsChanPrefix(*p))
# Line 342 | Line 311 | remove_ban(struct Ban *bptr, dlink_list
311    dlinkDelete(&bptr->node, list);
312  
313    MyFree(bptr->name);
314 <  MyFree(bptr->username);
314 >  MyFree(bptr->user);
315    MyFree(bptr->host);
316    MyFree(bptr->who);
317  
318 <  BlockHeapFree(ban_heap, bptr);
318 >  mp_pool_release(bptr);
319   }
320  
321   /* free_channel_list()
# Line 378 | Line 347 | make_channel(const char *chname)
347  
348    assert(!EmptyString(chname));
349  
350 <  chptr = BlockHeapAlloc(channel_heap);
350 >  chptr = mp_pool_get(channel_pool);
351 >
352 >  memset(chptr, 0, sizeof(*chptr));
353  
354    /* doesn't hurt to set it here */
355    chptr->channelts = CurrentTime;
# Line 408 | Line 379 | destroy_channel(struct Channel *chptr)
379    free_channel_list(&chptr->exceptlist);
380    free_channel_list(&chptr->invexlist);
381  
411  /* Free the topic */
412  free_topic(chptr);
413
382    dlinkDelete(&chptr->node, &global_channel_list);
383    hash_del_channel(chptr);
384  
385 <  BlockHeapFree(channel_heap, chptr);
385 >  mp_pool_release(chptr);
386   }
387  
388   /*!
# Line 422 | Line 390 | destroy_channel(struct Channel *chptr)
390   * \return string pointer "=" if public, "@" if secret else "*"
391   */
392   static const char *
393 < channel_pub_or_secret(struct Channel *chptr)
393 > channel_pub_or_secret(const struct Channel *chptr)
394   {
395    if (SecretChannel(chptr))
396      return "@";
# Line 441 | Line 409 | void
409   channel_member_names(struct Client *source_p, struct Channel *chptr,
410                       int show_eon)
411   {
412 <  struct Client *target_p = NULL;
445 <  struct Membership *ms = NULL;
446 <  dlink_node *ptr = NULL;
412 >  const dlink_node *ptr = NULL;
413    char lbuf[IRCD_BUFSIZE + 1];
414    char *t = NULL, *start = NULL;
415    int tlen = 0;
416    int is_member = IsMember(source_p, chptr);
417 <  int multi_prefix = (source_p->localClient->cap_active & CAP_MULTI_PREFIX) != 0;
417 >  int multi_prefix = HasCap(source_p, CAP_MULTI_PREFIX) != 0;
418 >  int uhnames = HasCap(source_p, CAP_UHNAMES) != 0;
419  
420    if (PubChannel(chptr) || is_member)
421    {
422 <    t = lbuf + ircsprintf(lbuf, form_str(RPL_NAMREPLY),
423 <                          me.name, source_p->name,
424 <                          channel_pub_or_secret(chptr),
458 <                          chptr->chname);
422 >    t = lbuf + snprintf(lbuf, sizeof(lbuf), numeric_form(RPL_NAMREPLY),
423 >                        me.name, source_p->name,
424 >                        channel_pub_or_secret(chptr), chptr->chname);
425      start = t;
426  
427      DLINK_FOREACH(ptr, chptr->members.head)
428      {
429 <      ms       = ptr->data;
464 <      target_p = ms->client_p;
429 >      const struct Membership *ms = ptr->data;
430  
431 <      if (IsInvisible(target_p) && !is_member)
431 >      if (HasUMode(ms->client_p, UMODE_INVISIBLE) && !is_member)
432          continue;
433  
434 <      tlen = strlen(target_p->name) + 1;  /* nick + space */
434 >      if (!uhnames)
435 >        tlen = strlen(ms->client_p->name) + 1;  /* nick + space */
436 >      else
437 >        tlen = strlen(ms->client_p->name) + strlen(ms->client_p->username) +
438 >               strlen(ms->client_p->host) + 3;
439  
440        if (!multi_prefix)
441        {
# Line 490 | Line 459 | channel_member_names(struct Client *sour
459          t = start;
460        }
461  
462 <      t += ircsprintf(t, "%s%s ", get_member_status(ms, multi_prefix),
463 <                      target_p->name);
462 >      if (!uhnames)
463 >        t += sprintf(t, "%s%s ", get_member_status(ms, multi_prefix),
464 >                     ms->client_p->name);
465 >      else
466 >        t += sprintf(t, "%s%s!%s@%s ", get_member_status(ms, multi_prefix),
467 >                     ms->client_p->name, ms->client_p->username,
468 >                     ms->client_p->host);
469      }
470  
471      if (tlen != 0)
# Line 502 | Line 476 | channel_member_names(struct Client *sour
476    }
477  
478    if (show_eon)
479 <    sendto_one(source_p, form_str(RPL_ENDOFNAMES),
506 <               me.name, source_p->name, chptr->chname);
479 >    sendto_one_numeric(source_p, &me, RPL_ENDOFNAMES, chptr->chname);
480   }
481  
482   /*! \brief adds client to invite list
# Line 558 | Line 531 | del_invite(struct Channel *chptr, struct
531   * (like in get_client_name)
532   */
533   const char *
534 < get_member_status(const struct Membership *ms, int combine)
534 > get_member_status(const struct Membership *ms, const int combine)
535   {
536    static char buffer[4];
537 <  char *p = NULL;
565 <
566 <  if (ms == NULL)
567 <    return "";
568 <  p = buffer;
537 >  char *p = buffer;
538  
539    if (ms->flags & CHFL_CHANOP)
540    {
# Line 603 | Line 572 | find_bmask(const struct Client *who, con
572  
573    DLINK_FOREACH(ptr, list->head)
574    {
575 <    struct Ban *bp = ptr->data;
575 >    const struct Ban *bp = ptr->data;
576  
577 <    if (match(bp->name, who->name) && match(bp->username, who->username))
577 >    if (!match(bp->name, who->name) && !match(bp->user, who->username))
578      {
579        switch (bp->type)
580        {
581          case HM_HOST:
582 <          if (match(bp->host, who->host) || match(bp->host, who->sockhost))
582 >          if (!match(bp->host, who->host) || !match(bp->host, who->sockhost))
583              return 1;
584            break;
585          case HM_IPV4:
# Line 640 | Line 609 | find_bmask(const struct Client *who, con
609   * \return 0 if not banned, 1 otherwise
610   */
611   int
612 < is_banned(struct Channel *chptr, struct Client *who)
612 > is_banned(const struct Channel *chptr, const struct Client *who)
613   {
614    if (find_bmask(who, &chptr->banlist))
615 <    if (!ConfigChannel.use_except || !find_bmask(who, &chptr->exceptlist))
615 >    if (!find_bmask(who, &chptr->exceptlist))
616        return 1;
617  
618    return 0;
# Line 651 | Line 620 | is_banned(struct Channel *chptr, struct
620  
621   /*!
622   * \param source_p pointer to client attempting to join
623 < * \param chptr    pointer to channel
623 > * \param chptr    pointer to channel
624   * \param key      key sent by client attempting to join if present
625   * \return ERR_BANNEDFROMCHAN, ERR_INVITEONLYCHAN, ERR_CHANNELISFULL
626   *         or 0 if allowed to join.
# Line 659 | Line 628 | is_banned(struct Channel *chptr, struct
628   int
629   can_join(struct Client *source_p, struct Channel *chptr, const char *key)
630   {
631 <  if (is_banned(chptr, source_p))
632 <    return ERR_BANNEDFROMCHAN;
631 >  if ((chptr->mode.mode & MODE_SSLONLY) && !HasUMode(source_p, UMODE_SSL))
632 >    return ERR_SSLONLYCHAN;
633 >
634 >  if ((chptr->mode.mode & MODE_REGONLY) && !HasUMode(source_p, UMODE_REGISTERED))
635 >    return ERR_NEEDREGGEDNICK;
636 >
637 >  if ((chptr->mode.mode & MODE_OPERONLY) && !HasUMode(source_p, UMODE_OPER))
638 >    return ERR_OPERONLYCHAN;
639  
640    if (chptr->mode.mode & MODE_INVITEONLY)
641      if (!dlinkFind(&source_p->localClient->invited, chptr))
642 <      if (!ConfigChannel.use_invex || !find_bmask(source_p, &chptr->invexlist))
642 >      if (!find_bmask(source_p, &chptr->invexlist))
643          return ERR_INVITEONLYCHAN;
644  
645 <  if (chptr->mode.key[0] && (!key || irccmp(chptr->mode.key, key)))
645 >  if (chptr->mode.key[0] && (!key || strcmp(chptr->mode.key, key)))
646      return ERR_BADCHANNELKEY;
647  
648    if (chptr->mode.limit && dlink_list_length(&chptr->members) >=
649        chptr->mode.limit)
650      return ERR_CHANNELISFULL;
651  
652 +  if (is_banned(chptr, source_p))
653 +    return ERR_BANNEDFROMCHAN;
654 +
655    return 0;
656   }
657  
658   int
659 < has_member_flags(struct Membership *ms, unsigned int flags)
659 > has_member_flags(const struct Membership *ms, const unsigned int flags)
660   {
661    if (ms != NULL)
662      return ms->flags & flags;
# Line 693 | Line 671 | find_channel_link(struct Client *client_
671    if (!IsClient(client_p))
672      return NULL;
673  
674 <  DLINK_FOREACH(ptr, client_p->channel.head)
675 <    if (((struct Membership *)ptr->data)->chptr == chptr)
676 <      return (struct Membership *)ptr->data;
674 >  if (dlink_list_length(&chptr->members) < dlink_list_length(&client_p->channel))
675 >  {
676 >    DLINK_FOREACH(ptr, chptr->members.head)
677 >      if (((struct Membership *)ptr->data)->client_p == client_p)
678 >        return ptr->data;
679 >  }
680 >  else
681 >  {
682 >    DLINK_FOREACH(ptr, client_p->channel.head)
683 >      if (((struct Membership *)ptr->data)->chptr == chptr)
684 >        return ptr->data;
685 >  }
686  
687    return NULL;
688   }
689  
690 + /*
691 + * Basically the same functionality as in bahamut
692 + */
693 + static int
694 + msg_has_ctrls(const char *message)
695 + {
696 +  const unsigned char *p = (const unsigned char *)message;
697 +
698 +  for (; *p; ++p)
699 +  {
700 +    if (*p > 31 || *p == 1)
701 +      continue;
702 +
703 +    if (*p == 27)
704 +    {
705 +      if (*(p + 1) == '$' ||
706 +          *(p + 1) == '(')
707 +      {
708 +        ++p;
709 +        continue;
710 +      }
711 +    }
712 +
713 +    return 1;
714 +  }
715 +
716 +  return 0;
717 + }
718 +
719   /*!
720   * \param chptr    pointer to Channel struct
721   * \param source_p pointer to Client struct
722   * \param ms       pointer to Membership struct (can be NULL)
723   * \return CAN_SEND_OPV if op or voiced on channel\n
724   *         CAN_SEND_NONOP if can send to channel but is not an op\n
725 < *         CAN_SEND_NO if they cannot send to channel\n
725 > *         ERR_CANNOTSENDTOCHAN or ERR_NEEDREGGEDNICK if they cannot send to channel\n
726   */
727   int
728 < can_send(struct Channel *chptr, struct Client *source_p, struct Membership *ms)
728 > can_send(struct Channel *chptr, struct Client *source_p,
729 >         struct Membership *ms, const char *message)
730   {
731 <  if (IsServer(source_p))
731 >  struct MaskItem *conf = NULL;
732 >
733 >  if (IsServer(source_p) || HasFlag(source_p, FLAGS_SERVICE))
734      return CAN_SEND_OPV;
735  
736    if (MyClient(source_p) && !IsExemptResv(source_p))
737 <    if (!(IsOper(source_p) && ConfigFileEntry.oper_pass_resv))
738 <      if (!hash_find_resv(chptr->chname) == ConfigChannel.restrict_channels)
739 <        return CAN_SEND_NO;
740 <
741 <  if (ms != NULL || (ms = find_channel_link(source_p, chptr)))
742 <  {
737 >    if (!(HasUMode(source_p, UMODE_OPER) && ConfigFileEntry.oper_pass_resv))
738 >      if ((conf = match_find_resv(chptr->chname)) && !resv_find_exempt(source_p, conf))
739 >        return ERR_CANNOTSENDTOCHAN;
740 >
741 >  if ((chptr->mode.mode & MODE_NOCTRL) && msg_has_ctrls(message))
742 >    return ERR_NOCTRLSONCHAN;
743 >  if (ms || (ms = find_channel_link(source_p, chptr)))
744      if (ms->flags & (CHFL_CHANOP|CHFL_HALFOP|CHFL_VOICE))
745        return CAN_SEND_OPV;
746 +  if (!ms && (chptr->mode.mode & MODE_NOPRIVMSGS))
747 +    return ERR_CANNOTSENDTOCHAN;
748 +  if (chptr->mode.mode & MODE_MODERATED)
749 +    return ERR_CANNOTSENDTOCHAN;
750 +  if ((chptr->mode.mode & MODE_MODREG) && !HasUMode(source_p, UMODE_REGISTERED))
751 +    return ERR_NEEDREGGEDNICK;
752  
753 <    /* cache can send if quiet_on_ban and banned */
754 <    if (ConfigChannel.quiet_on_ban && MyClient(source_p))
753 >  /* cache can send if banned */
754 >  if (MyClient(source_p))
755 >  {
756 >    if (ms)
757      {
758        if (ms->flags & CHFL_BAN_SILENCED)
759 <        return CAN_SEND_NO;
759 >        return ERR_CANNOTSENDTOCHAN;
760  
761        if (!(ms->flags & CHFL_BAN_CHECKED))
762        {
763          if (is_banned(chptr, source_p))
764          {
765            ms->flags |= (CHFL_BAN_CHECKED|CHFL_BAN_SILENCED);
766 <          return CAN_SEND_NO;
766 >          return ERR_CANNOTSENDTOCHAN;
767          }
768  
769          ms->flags |= CHFL_BAN_CHECKED;
770        }
771      }
772 +    else if (is_banned(chptr, source_p))
773 +      return ERR_CANNOTSENDTOCHAN;
774    }
745  else if (chptr->mode.mode & MODE_NOPRIVMSGS)
746    return CAN_SEND_NO;
747
748  if (chptr->mode.mode & MODE_MODERATED)
749    return CAN_SEND_NO;
775  
776    return CAN_SEND_NONOP;
777   }
# Line 776 | Line 801 | check_spambot_warning(struct Client *sou
801      {
802        /* Its already known as a possible spambot */
803        if (name != NULL)
804 <        sendto_realops_flags(UMODE_BOTS, L_ALL,
804 >        sendto_realops_flags(UMODE_BOTS, L_ALL, SEND_NOTICE,
805                               "User %s (%s@%s) trying to join %s is a possible spambot",
806                               source_p->name, source_p->username,
807                               source_p->host, name);
808        else
809 <        sendto_realops_flags(UMODE_BOTS, L_ALL,
809 >        sendto_realops_flags(UMODE_BOTS, L_ALL, SEND_NOTICE,
810                               "User %s (%s@%s) is a possible spambot",
811                               source_p->name, source_p->username,
812                               source_p->host);
# Line 832 | Line 857 | check_splitmode(void *unused)
857      {
858        splitmode = 1;
859  
860 <      sendto_realops_flags(UMODE_ALL,L_ALL,
860 >      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
861                             "Network split, activating splitmode");
862        eventAddIsh("check_splitmode", check_splitmode, NULL, 10);
863      }
# Line 840 | Line 865 | check_splitmode(void *unused)
865      {
866        splitmode = 0;
867  
868 <      sendto_realops_flags(UMODE_ALL, L_ALL,
868 >      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
869                             "Network rejoined, deactivating splitmode");
870        eventDelete(check_splitmode, NULL);
871      }
872    }
873   }
874  
850 /*! \brief Allocates a new topic
851 * \param chptr Channel to allocate a new topic for
852 */
853 static void
854 allocate_topic(struct Channel *chptr)
855 {
856  void *ptr = NULL;
857
858  if (chptr == NULL)
859    return;
860
861  ptr = BlockHeapAlloc(topic_heap);  
862
863  /* Basically we allocate one large block for the topic and
864   * the topic info.  We then split it up into two and shove it
865   * in the chptr
866   */
867  chptr->topic       = ptr;
868  chptr->topic_info  = (char *)ptr + TOPICLEN+1;
869  *chptr->topic      = '\0';
870  *chptr->topic_info = '\0';
871 }
872
873 void
874 free_topic(struct Channel *chptr)
875 {
876  void *ptr = NULL;
877  assert(chptr);
878  if (chptr->topic == NULL)
879    return;
880
881  /*
882   * If you change allocate_topic you MUST change this as well
883   */
884  ptr = chptr->topic;
885  BlockHeapFree(topic_heap, ptr);    
886  chptr->topic      = NULL;
887  chptr->topic_info = NULL;
888 }
889
875   /*! \brief Sets the channel topic for chptr
876   * \param chptr      Pointer to struct Channel
877   * \param topic      The topic string
# Line 895 | Line 880 | free_topic(struct Channel *chptr)
880   */
881   void
882   set_channel_topic(struct Channel *chptr, const char *topic,
883 <                  const char *topic_info, time_t topicts)
883 >                  const char *topic_info, time_t topicts, int local)
884   {
885 <  if (!EmptyString(topic))
886 <  {
902 <    if (chptr->topic == NULL)
903 <      allocate_topic(chptr);
904 <
905 <    strlcpy(chptr->topic, topic, TOPICLEN+1);
906 <    strlcpy(chptr->topic_info, topic_info, USERHOST_REPLYLEN);
907 <    chptr->topic_time = topicts;
908 <  }
885 >  if (local)
886 >    strlcpy(chptr->topic, topic, IRCD_MIN(sizeof(chptr->topic), ServerInfo.max_topic_length + 1));
887    else
888 <  {
889 <    /*
890 <     * Do not reset chptr->topic_time here, it's required for
891 <     * bursting topics properly.
914 <     */
915 <    if (chptr->topic != NULL)
916 <      free_topic(chptr);
917 <  }
888 >    strlcpy(chptr->topic, topic, sizeof(chptr->topic));
889 >
890 >  strlcpy(chptr->topic_info, topic_info, sizeof(chptr->topic_info));
891 >  chptr->topic_time = topicts;
892   }

Diff Legend

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