newio/src/send.c

/*
 *  ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd).
 *  send.c: Functions for sending messages.
 *
 *  Copyright (C) 2002 by the past and present ircd coders, and others.
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
 *  USA
 *
 *  $Id$
 */

#include "stdinc.h"
#include "list.h"
#include "send.h"
#include "channel.h"
#include "client.h"
#include "msgq.h"
#include "irc_string.h"
#include "ircd.h"
#include "numeric.h"
#include "s_bsd.h"
#include "s_serv.h"
#include "conf.h"
#include "log.h"
#include "memory.h"
#include "packet.h"
#include "xsnprintf.h"


static uint64_t current_serial = 0;
/** Linked list of all connections with data queued to send. */
static struct Connection *send_queues;


/*
 * dead_link
 *
 * An error has been detected. The link *must* be closed,
 * but *cannot* call ExitClient (m_bye) from here.
 * Instead, mark it with FLAGS_DEADSOCKET. This should
 * generate ExitClient from the main loop.
 *
 * If 'notice' is not NULL, it is assumed to be a format
 * for a message to local opers. It can contain only one
 * '%s', which will be replaced by the sockhost field of
 * the failing link.
 *
 * Also, the notice is skipped for "uninteresting" cases,
 * like Persons and yet unknown connections...
 */
/** Mark a client as dead, even if they are not the current message source.
 * This is done by setting the DEADSOCKET flag on the user and letting the
 * main loop perform the actual exit logic.
 * @param[in,out] to Client being killed.
 * @param[in] notice Message for local opers.
 */
static void
dead_link(struct Client *to, const char *notice)
{
  AddFlag(to, FLAGS_DEADSOCKET);

  /*
   * If because of BUFFERPOOL problem then clean dbuf's now so that
   * notices don't hurt operators below.
   */
  DBufClear(&to->localClient->recvQ);
  MsgQClear(&to->localClient->sendQ);
  client_drop_sendq(to->localClient);

  /*
   * Keep a copy of the last comment, for later use...
   */
  strlcpy(to->info, notice, sizeof(to->info));

  if (!IsClient(to) && !IsUnknown(to) && !HasFlag(to, FLAGS_CLOSING))
    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE, "%s for %s",
                         to->info, to->name);
}

/** Test whether we can send to a client.
 * @param[in] to Client we want to send to.
 * @return Non-zero if we can send to the client.
 */
static int
can_send(struct Client *to)
{
  assert(to);
  return (IsDead(to) || IsMe(to) || s_fd(&to->localClient->socket) == -1) ? 0 : 1;
}

/*
 * flush_connections
 *
 * Used to empty all output buffers for all connections. Should only
 * be called once per scan of connections. There should be a select in
 * here perhaps but that means either forcing a timeout or doing a poll.
 * When flushing, all we do is empty the obuffer array for each local
 * client and try to send it. if we cant send it, it goes into the sendQ
 * -avalon
 */
/** Flush data queued for one or all connections.
 * @param[in] client_p Client to flush (if NULL, do all).
 */
void
flush_connections(struct Client *client_p)
{
  if (client_p)
    send_queued(client_p);
  else
  {
    struct Connection *con = send_queues;
    for (; con; con = con->con_next)
    {
      assert(MsgQLength(&con->sendQ) > 0);
      send_queued(con->client_p);
    }
  }
}

/*
 * send_queued
 *
 * This function is called from the main select-loop (or whatever)
 * when there is a chance that some output would be possible. This
 * attempts to empty the send queue as far as possible...
 */
/** Attempt to send data queued for a client.
 * @param[in] to Client to send data to.
 */
void
send_queued(struct Client *to)
{
  assert(to);
  assert(to->localClient);

  if (HasFlag(to, FLAGS_BLOCKED) || !can_send(to))
    return;  /* Don't bother */

  while (MsgQLength(&to->localClient->sendQ) > 0)
  {
    unsigned int len;

    if ((len = deliver_it(to, &to->localClient->sendQ)))
    {
      msgq_delete(&to->localClient->sendQ, len);
      to->localClient->lastsq = MsgQLength(&to->localClient->sendQ) / 1024;

      if (HasFlag(to, FLAGS_BLOCKED))
      {
        update_write(to);
        return;
      }
    }
    else
    {
      if (IsDead(to))
      {
        char tmp[IRCD_BUFSIZE];

        snprintf(tmp, sizeof(tmp), "Write error: %s",
                 (strerror(to->localClient->error)) ?
                 (strerror(to->localClient->error)) :
                 "Unknown error" );
        dead_link(to, tmp);
      }

      return;
    }
  }

  /* Ok, sendq is now empty... */
  client_drop_sendq(to->localClient);
  update_write(to);
}

/** Try to send a buffer to a client, queueing it if needed.
 * @param[in,out] to Client to send message to.
 * @param[in] buf Message to send.
 * @param[in] prio If non-zero, send as high priority.
 */
void
send_buffer(struct Client *to, struct MsgBuf *buf, const int prio)
{
  assert(to);
  assert(buf);

  if (to->from)
    to = to->from;

  if (!can_send(to))
    /*
     * This socket has already been marked as dead
     */
    return;

  if (MsgQLength(&to->localClient->sendQ) > get_sendq(&to->localClient->confs))
  {
    if (IsServer(to))
      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
                           "Max SendQ limit exceeded for %s: %u > %u",
                           get_client_name(to, HIDE_IP),
                           MsgQLength(&to->localClient->sendQ),
                           get_sendq(&to->localClient->confs));
    dead_link(to, "Max sendQ exceeded");
    return;
  }

  msgq_add(&to->localClient->sendQ, buf, prio);
  client_add_sendq(to->localClient, &send_queues);
  update_write(to);

  /*
   * Update statistics. The following is slightly incorrect
   * because it counts messages even if queued, but bytes
   * only really sent. Queued bytes get updated in SendQueued.
   */
  ++to->localClient->send.messages;
  ++me.localClient->send.messages;

  /*
   * This little bit is to stop the sendQ from growing too large when
   * there is no need for it to. Thus we call send_queued() every time
   * 2k has been added to the queue since the last non-fatal write.
   * Also stops us from deliberately building a large sendQ and then
   * trying to flood that link with data (possible during the net
   * relinking done by servers with a large load).
   */
  if (MsgQLength(&to->localClient->sendQ) / 1024 > to->localClient->lastsq)
    send_queued(to);
}

/* send_message_remote()
 *
 * inputs       - pointer to client from message is being sent
 *              - pointer to client to send to
 *              - pointer to preformatted buffer
 *              - length of input buffer
 * output       - none
 * side effects - Despite the function name, this only sends to directly
 *                connected clients.
 * 
 */
static void
send_buffer_remote(struct Client *to, struct Client *from,
                   struct MsgBuf *buf, const int prio)
{
  if (!MyConnect(to))
  {
    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
                         "server send message to %s [%s] dropped from %s(Not local server)",
                         to->name, to->from->name, from->name);
    return;
  }

  /* Optimize by checking if (from && to) before everything */
  /* we set to->from up there.. */

  if (!MyClient(from) && IsClient(to) && (to == from->from))
  {
    if (IsServer(from))
    {
      sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
                           "Send message to %s [%s] dropped from %s(Fake Dir)",
                           to->name, to->from->name, from->name);
      return;
    }

    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
                         "Ghosted: %s[%s@%s] from %s[%s@%s] (%s)",
                         to->name, to->username, to->host,
                         from->name, from->username, from->host,
                         to->from->name);

    sendto_server(NULL, CAP_TS6, NOCAPS,
                  ":%s KILL %s :%s (%s[%s@%s] Ghosted %s)",
                  me.id, to->name, me.name, to->name,
                  to->username, to->host, to->from->name);
    sendto_server(NULL, NOCAPS, CAP_TS6,
                  ":%s KILL %s :%s (%s[%s@%s] Ghosted %s)",
                  me.name, to->name, me.name, to->name,
                  to->username, to->host, to->from->name);

    AddFlag(to, FLAGS_KILLED);

    if (IsClient(from))
      sendto_one(from, form_str(ERR_GHOSTEDCLIENT),
                 me.name, from->name, to->name, to->username,
                 to->host, to->from);

    exit_client(NULL, to, &me, "Ghosted client");
    return;
  } 

  send_buffer(to, buf, prio);
}

/* sendto_one()
 *
 * inputs       - pointer to destination client
 *              - var args message
 * output       - NONE
 * side effects - send message to single client
 */
void
sendto_one(struct Client *to, const char *pattern, ...)
{
  struct MsgBuf *mb;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(to, pattern, vl);
  va_end(vl);

  send_buffer(to, mb, 0);

  msgq_clean(mb);
}

/* sendto_channel_butone()
 *
 * inputs       - pointer to client(server) to NOT send message to
 *              - pointer to client that is sending this message
 *              - pointer to channel being sent to
 *              - vargs message
 * output       - NONE
 * side effects - message as given is sent to given channel members.
 *
 * WARNING - +D clients are ignored
 */
void
sendto_channel_butone(struct Client *one, struct Client *from,
                      struct Channel *chptr, unsigned int type,
                      const char *pattern, ...)
{
  struct VarData vd;
  struct MsgBuf *remote_mb = NULL;
  struct MsgBuf *local_mb = NULL;
  struct MsgBuf *uid_mb = NULL;
  dlink_node *ptr = NULL, *ptr_next = NULL;

  vd.vd_format = pattern;
  va_start(vd.vd_args, pattern);

  if (IsServer(from))
    local_mb = msgq_make(NULL, ":%s %v",&vd);

  else
    local_mb = msgq_make(NULL, ":%s!%s@%s %v",
                         from->name,
                         from->username, from->host, &vd);
  va_end(vd.vd_args);

  va_start(vd.vd_args, pattern);
  remote_mb = msgq_make(NULL, ":%s %v", from->name, &vd);
  va_end(vd.vd_args);

  va_start(vd.vd_args, pattern);
  uid_mb = msgq_make(NULL, ":%s %v", ID(from), &vd);
  va_end(vd.vd_args);


  ++current_serial;

  DLINK_FOREACH_SAFE(ptr, ptr_next, chptr->members.head)
  {
    struct Membership *ms = ptr->data;
    struct Client *target_p = ms->client_p;

    assert(IsClient(target_p));

    if (HasUMode(target_p, UMODE_DEAF) || target_p->from == one)
      continue;

    if (type != 0 && (ms->flags & type) == 0)
      continue;

    if (MyConnect(target_p))
    {
      if (target_p->localClient->serial != current_serial)
      {
        send_buffer(target_p, local_mb, 0);
        target_p->localClient->serial = current_serial;
      }
    }
    else
    {
      /* Now check whether a message has been sent to this
       * remote link already
       */
      if (target_p->from->localClient->serial != current_serial)
      {
        if (IsCapable(target_p->from, CAP_TS6))
          send_buffer_remote(target_p->from, from, uid_mb, 0);
        else
          send_buffer_remote(target_p->from, from, remote_mb, 0);
        target_p->from->localClient->serial = current_serial;
      }
    }
  }

  msgq_clean(local_mb);
  msgq_clean(remote_mb);
  msgq_clean(uid_mb);
}

/* sendto_server()
 * 
 * inputs       - pointer to client to NOT send to
 *              - pointer to channel
 *              - caps or'd together which must ALL be present
 *              - caps or'd together which must ALL NOT be present
 *              - printf style format string
 *              - args to format string
 * output       - NONE
 * side effects - Send a message to all connected servers, except the
 *                client 'one' (if non-NULL), as long as the servers
 *                support ALL capabs in 'caps', and NO capabs in 'nocaps'.
 *            
 * This function was written in an attempt to merge together the other
 * billion sendto_*serv*() functions, which sprung up with capabs,
 * lazylinks, uids, etc.
 * -davidt
 */
void 
sendto_server(struct Client *one,
              const unsigned int caps,
              const unsigned int nocaps,
              const char *pattern, ...)
{
  dlink_node *ptr = NULL;
  struct MsgBuf *mb = NULL;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(&me, pattern, vl);
  va_end(vl);

  DLINK_FOREACH(ptr, serv_list.head)
  {
    struct Client *client_p = ptr->data;

    /* check against 'one' */
    if (one != NULL && (client_p == one->from))
      continue;
    /* check we have required capabs */
    if ((client_p->localClient->caps & caps) != caps)
      continue;
    /* check we don't have any forbidden capabs */
    if ((client_p->localClient->caps & nocaps) != 0)
      continue;

    send_buffer(client_p, mb, 0);
  }

  msgq_clean(mb);
}

/* sendto_common_channels_local()
 *
 * inputs       - pointer to client
 *              - pattern to send
 * output       - NONE
 * side effects - Sends a message to all people on local server who are
 *                in same channel with user. 
 *                used by m_nick.c and exit_one_client.
 */
void
sendto_common_channels_local(struct Client *user, int touser, unsigned int cap,
                             const char *pattern, ...)
{
  dlink_node *uptr;
  dlink_node *cptr;
  struct Channel *chptr;
  struct Membership *ms;
  struct Client *target_p;
  struct MsgBuf *mb;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(NULL, pattern, vl);
  va_end(vl);

  ++current_serial;

  DLINK_FOREACH(cptr, user->channel.head)
  {
    chptr = ((struct Membership *) cptr->data)->chptr;
    assert(chptr != NULL);

    DLINK_FOREACH(uptr, chptr->members.head)
    {
      ms = uptr->data;
      target_p = ms->client_p;
      assert(target_p != NULL);

      if (!MyConnect(target_p) || target_p == user ||
          target_p->localClient->serial == current_serial)
        continue;

      if (HasCap(target_p, cap) != cap)
        continue;

      target_p->localClient->serial = current_serial;
      send_buffer(target_p, mb, 0);
    }
  }

  if (touser && MyConnect(user) &&
      user->localClient->serial != current_serial)
    if (HasCap(user, cap) == cap)
      send_buffer(user, mb, 0);
  msgq_clean(mb);
}

/* sendto_channel_local()
 *
 * inputs       - member status mask, e.g. CHFL_CHANOP | CHFL_VOICE
 *              - whether to ignore +D clients (YES/NO)
 *              - pointer to channel to send to
 *              - var args pattern
 * output       - NONE
 * side effects - Send a message to all members of a channel that are
 *                locally connected to this server.
 */
void
sendto_channel_local(int type, int nodeaf, struct Channel *chptr,
                     const char *pattern, ...)
{
  dlink_node *ptr;
  struct MsgBuf *mb;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(NULL, pattern, vl);
  va_end(vl);

  DLINK_FOREACH(ptr, chptr->members.head)
  {
    struct Membership *ms = ptr->data;

    if (type != 0 && (ms->flags & type) == 0)
      continue;

    if (!MyConnect(ms->client_p) ||
        (nodeaf && HasUMode(ms->client_p, UMODE_DEAF)))
      continue;

    send_buffer(ms->client_p, mb, 0);
  }

  msgq_clean(mb);
}

/* sendto_channel_local_butone()
 *
 * inputs       - pointer to client to NOT send message to
 *              - member status mask, e.g. CHFL_CHANOP | CHFL_VOICE
 *              - pointer to channel to send to
 *              - var args pattern
 * output       - NONE
 * side effects - Send a message to all members of a channel that are
 *                locally connected to this server except one.
 *
 * WARNING - +D clients are omitted
 */
void       
sendto_channel_local_butone(struct Client *one, int type, unsigned int cap,
                            struct Channel *chptr, const char *pattern, ...)
{
  struct Client *target_p;
  struct Membership *ms;
  dlink_node *ptr;
  struct MsgBuf *mb;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(NULL, pattern, vl);
  va_end(vl);

  DLINK_FOREACH(ptr, chptr->members.head)       
  {   
    ms = ptr->data;
    target_p = ms->client_p;

    if (type != 0 && (ms->flags & type) == 0)
      continue;

    if (!MyConnect(target_p) || target_p == one ||
        HasUMode(target_p, UMODE_DEAF))
      continue;

    if (HasCap(target_p, cap) != cap)
        continue;
    send_buffer(target_p, mb, 0);
  }

  msgq_clean(mb);
}


/* sendto_channel_remote()
 *
 * inputs       - Client not to send towards
 *              - Client from whom message is from
 *              - member status mask, e.g. CHFL_CHANOP | CHFL_VOICE
 *              - pointer to channel to send to
 *              - var args pattern
 * output       - NONE
 * side effects - Send a message to all members of a channel that are
 *                remote to this server.
 */
void
sendto_channel_remote(struct Client *one, struct Client *from, int type,
                      const unsigned int caps, const unsigned int nocaps,
                      struct Channel *chptr, const char *pattern, ...)
{
  dlink_node *ptr;
  struct Client *target_p;
  struct Membership *ms;

  struct MsgBuf *mb;
  va_list vl;

  va_start(vl, pattern);
  mb = msgq_vmake(&me, pattern, vl);
  va_end(vl);

  ++current_serial;

  DLINK_FOREACH(ptr, chptr->members.head)
  {
    ms = ptr->data;
    target_p = ms->client_p;

    if (type != 0 && (ms->flags & type) == 0)
      continue;

    if (MyConnect(target_p))
      continue;
    target_p = target_p->from;

    if (target_p == one->from ||
        ((target_p->from->localClient->caps & caps) != caps) ||
        ((target_p->from->localClient->caps & nocaps) != 0))
      continue;
    if (target_p->from->localClient->serial != current_serial)
    {
      send_buffer(target_p, mb, 0);
      target_p->from->localClient->serial = current_serial;
    }
  } 

  msgq_clean(mb);
}

/*
 ** match_it() and sendto_match_butone() ARE only used
 ** to send a msg to all ppl on servers/hosts that match a specified mask
 ** (used for enhanced PRIVMSGs) for opers
 **
 ** addition -- Armin, 8jun90 (gruner@informatik.tu-muenchen.de)
 **
 */

/* match_it()
 *
 * inputs       - client pointer to match on
 *              - actual mask to match
 *              - what to match on, HOST or SERVER
 * output       - 1 or 0 if match or not
 * side effects - NONE
 */
static int
match_it(const struct Client *one, const char *mask, const int what)
{
  if (what == MATCH_HOST)
    return !match(mask, one->host);

  return !match(mask, one->servptr->name);
}

/* sendto_match_butone()
 *
 * Send to all clients which match the mask in a way defined on 'what';
 * either by user hostname or user servername.
 *
 * ugh. ONLY used by m_message.c to send an "oper magic" message. ugh.
 */
void
sendto_match_butone(struct Client *one, struct Client *from, const char *mask,
                    const int what, const char *pattern, ...)
{
  struct VarData vd;
  struct MsgBuf *user_mb = NULL;
  struct MsgBuf *serv_mb = NULL;
  dlink_node *ptr = NULL, *ptr_next = NULL;

  vd.vd_format = pattern;

  /* Build buffer to send to users */
  va_start(vd.vd_args, pattern);
  user_mb = msgq_make(NULL, ":%s!%s@%s %v",
                      from->name,
                      from->username, from->host, &vd);
  va_end(vd.vd_args);

  /* Build buffer to send to servers */
  va_start(vd.vd_args, pattern);
  serv_mb = msgq_make(&me, ":%s %v", from->name, &vd);
  va_end(vd.vd_args);

  /* scan the local clients */
  DLINK_FOREACH(ptr, local_client_list.head)
  {
    struct Client *client_p = ptr->data;

    if (client_p != one && match_it(client_p, mask, what))
      send_buffer(client_p, user_mb, 0);
  }

  /* Now scan servers */
  DLINK_FOREACH_SAFE(ptr, ptr_next, serv_list.head)
  {
    struct Client *client_p = ptr->data;

    /*
     * The old code looped through every client on the
     * network for each server to check if the
     * server (client_p) has at least 1 client matching
     * the mask, using something like:
     *
     * for (target_p = GlobalClientList; target_p; target_p = target_p->next)
     *        if (IsRegisteredUser(target_p) &&
     *                        match_it(target_p, mask, what) &&
     *                        (target_p->from == client_p))
     *   vsendto_prefix_one(client_p, from, pattern, args);
     *
     * That way, we wouldn't send the message to
     * a server who didn't have a matching client.
     * However, on a network such as EFNet, that
     * code would have looped through about 50
     * servers, and in each loop, loop through
     * about 50k clients as well, calling match()
     * in each nested loop. That is a very bad
     * thing cpu wise - just send the message
     * to every connected server and let that
     * server deal with it.
     * -wnder
     */
    if (client_p != one)
      send_buffer_remote(client_p, from, serv_mb, 0);
  }

  msgq_clean(user_mb);
  msgq_clean(serv_mb);
}

/* sendto_match_servs()
 *
 * inputs       - source client
 *              - mask to send to
 *              - capab needed
 *              - data
 * outputs      - none
 * side effects - data sent to servers matching with capab
 */
void
sendto_match_servs(struct Client *source_p, const char *mask, int cap,
                   const char *pattern, ...)
{
  va_list args;
  struct Client *target_p;
  dlink_node *ptr;
  char buffer[IRCD_BUFSIZE];
  int found = 0;

  va_start(args, pattern);
  vsnprintf(buffer, sizeof(buffer), pattern, args);
  va_end(args);

  ++current_serial;

  DLINK_FOREACH(ptr, global_serv_list.head)
  {
    target_p = ptr->data;

    /* Do not attempt to send to ourselves, or the source */
    if (IsMe(target_p) || target_p->from == source_p->from)
      continue;

    if (target_p->from->localClient->serial == current_serial)
      continue;

    if (!match(mask, target_p->name))
    {
      /*
       * if we set the serial here, then we'll never do a
       * match() again, if !IsCapable()
       */
      target_p->from->localClient->serial = current_serial;
      found++;

      if (!IsCapable(target_p->from, cap))
        continue;

      sendto_anywhere(target_p, source_p, "%s", buffer);
    }
  }
}

/* sendto_anywhere()
 *
 * inputs       - pointer to dest client
 *              - pointer to from client
 *              - varags
 * output       - NONE
 * side effects - less efficient than sendto_remote and sendto_one
 *                but useful when one does not know where target "lives"
 */
void
sendto_anywhere(struct Client *to, struct Client *from,
                const char *pattern, ...)
{
  char buffer[IRCD_BUFSIZE];
  struct VarData vd;
  struct MsgBuf *mb = NULL;
  struct Client *send_to = (to->from != NULL ? to->from : to);

  if (IsDead(send_to))
    return;

  if (MyClient(to))
  {
    if (IsServer(from))
    {
      if (IsCapable(to, CAP_TS6) && HasID(from))
        sprintf(buffer, ":%s", from->id);
      else
        sprintf(buffer, ":%s", from->name);
    }
    else
      sprintf(buffer, ":%s!%s@%s", from->name, from->username, from->host);
  }
  else
    sprintf(buffer, ":%s", ID_or_name(from, send_to));

  vd.vd_format = pattern;
  va_start(vd.vd_args, pattern);

  mb = msgq_make(NULL, "%s %v", buffer, &vd);
  va_end(vd.vd_args);

  if (MyClient(to))
    send_buffer(send_to, mb, 0);
  else
    send_buffer_remote(send_to, from, mb, 0);
  msgq_clean(mb);
}

/* sendto_realops_flags()
 *
 * inputs       - flag types of messages to show to real opers
 *              - flag indicating opers/admins
 *              - var args input message
 * output       - NONE
 * side effects - Send to *local* ops only but NOT +s nonopers.
 */
void
sendto_realops_flags(unsigned int flags, int level, int type, const char *pattern, ...)
{
  const char *ntype = NULL;
  dlink_node *ptr = NULL;
  char nbuf[IRCD_BUFSIZE];
  va_list args;

  va_start(args, pattern);
  vsnprintf(nbuf, sizeof(nbuf), pattern, args);
  va_end(args);

  switch (type)
  {
    case SEND_NOTICE:
      ntype = "Notice";
      break;
    case SEND_GLOBAL:
      ntype = "Global";
      break;
    case SEND_LOCOPS:
      ntype = "LocOps";
      break;
    default:
      assert(0);
  }

  DLINK_FOREACH(ptr, oper_list.head)
  {
    struct Client *client_p = ptr->data;
    assert(HasUMode(client_p, UMODE_OPER));

    /*
     * If we're sending it to opers and they're an admin, skip.
     * If we're sending it to admins, and they're not, skip.
     */
    if (((level == L_ADMIN) && !HasUMode(client_p, UMODE_ADMIN)) ||
        ((level == L_OPER) && HasUMode(client_p, UMODE_ADMIN)))
      continue;

    if (HasUMode(client_p, flags))
      sendto_one(client_p, ":%s NOTICE %s :*** %s -- %s",
                 me.name, client_p->name, ntype, nbuf);
  }
}

/* sendto_wallops_flags()
 *
 * inputs       - flag types of messages to show to real opers
 *              - client sending request
 *              - var args input message
 * output       - NONE
 * side effects - Send a wallops to local opers
 */
void
sendto_wallops_flags(unsigned int flags, struct Client *source_p,
                     const char *pattern, ...)
{
  dlink_node *ptr = NULL;
  va_list args;
  char buffer[IRCD_BUFSIZE];
  int len;

  if (IsClient(source_p))
    len = sprintf(buffer, ":%s!%s@%s WALLOPS :",
                  source_p->name, source_p->username, source_p->host);
  else
    len = sprintf(buffer, ":%s WALLOPS :", source_p->name);

  va_start(args, pattern);
  snprintf(&buffer[len], sizeof(buffer) - len, pattern, args);
  va_end(args);

  DLINK_FOREACH(ptr, oper_list.head)
  {
    struct Client *client_p = ptr->data;
    assert(client_p->umodes & UMODE_OPER);

    if (HasUMode(client_p, flags))
      sendto_one(client_p, "%s", buffer);
  }
}

/* ts_warn()
 *
 * inputs       - var args message
 * output       - NONE
 * side effects - Call sendto_realops_flags, with some flood checking
 *                (at most 5 warnings every 5 seconds)
 */
void
ts_warn(const char *pattern, ...)
{
  va_list args;
  char buffer[IRCD_BUFSIZE];
  static time_t last = 0;
  static int warnings = 0;

  /*
   ** if we're running with TS_WARNINGS enabled and someone does
   ** something silly like (remotely) connecting a nonTS server,
   ** we'll get a ton of warnings, so we make sure we don't send
   ** more than 5 every 5 seconds.  -orabidoo
   */

  if (CurrentTime - last < 5)
  {
    if (++warnings > 5)
      return;
  }
  else
  {
    last = CurrentTime;
    warnings = 0;
  }

  va_start(args, pattern);
  vsnprintf(buffer, sizeof(buffer), pattern, args);
  va_end(args);

  sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE, "%s", buffer);
  ilog(LOG_TYPE_IRCD, "%s", buffer);
}

/* kill_client()
 *
 * inputs       - client to send kill towards
 *              - pointer to client to kill
 *              - reason for kill
 * output       - NONE
 * side effects - NONE
 */
void
kill_client(struct Client *client_p, struct Client *diedie,
            const char *pattern, ...)
{
  struct VarData vd;
  struct MsgBuf *mb = NULL;

  if (client_p->from != NULL)
    client_p = client_p->from;
  if (IsDead(client_p))
    return;

  vd.vd_format = pattern;
  va_start(vd.vd_args, pattern);

  mb = msgq_make(NULL, ":%s KILL %s :%v",
                 ID_or_name(&me, client_p->from),
                 ID_or_name(diedie, client_p), &vd);
  va_end(vd.vd_args);

  send_buffer(client_p, mb, 0);
  msgq_clean(mb);
}

/* kill_client_ll_serv_butone()
 *
 * inputs       - pointer to client to not send to
 *              - pointer to client to kill
 * output       - NONE
 * side effects - Send a KILL for the given client
 *                message to all connected servers
 *                except the client 'one'. Also deal with
 *                client being unknown to leaf, as in lazylink...
 */
void
kill_client_ll_serv_butone(struct Client *one, struct Client *source_p,
                           const char *pattern, ...)
{
  struct VarData vd;
  struct MsgBuf *uid_mb = NULL;
  struct MsgBuf *nick_mb = NULL;
  dlink_node *ptr = NULL;

  vd.vd_format = pattern;

  if (HasID(source_p))
  {
    va_start(vd.vd_args, pattern);
    uid_mb = msgq_make(NULL, ":%s KILL %s :%v", me.id, ID(source_p), &vd);
    va_end(vd.vd_args);
  }

  va_start(vd.vd_args, pattern);
  nick_mb = msgq_make(NULL, ":%s KILL %s :%v", me.name, source_p->name, &vd);
  va_end(vd.vd_args);

  DLINK_FOREACH(ptr, serv_list.head)
  {
    struct Client *client_p = ptr->data;

    if (one != NULL && (client_p == one->from))
      continue;
    if (IsDefunct(client_p))
      continue;

    if (uid_mb && IsCapable(client_p, CAP_TS6))
      send_buffer(client_p, uid_mb, 0);
    else
      send_buffer(client_p, nick_mb, 0);
  }

  if (uid_mb)
    msgq_clean(uid_mb);
  msgq_clean(nick_mb);
} 
Revision:	2437
Committed:	Sat Aug 3 16:23:22 2013 UTC (13 years ago) by michael
Content type:	text/x-csrc
File size:	28838 byte(s)
Log Message:	- Ficed conversion specifiers in some places