split.patch

   1 work in progress
   2 Add split functionality into ircd
   3 Add /split command
   4 Add /stats S/split (make /STATS s/S case sensitive, s spoofhosts)
   5 Add feature SPLIT
   6 Add split.c split.h m_split.c
   7
   8 NOTE: feature SPLIT is default enabled as that is just easier when working on this patch.
   9
  10 diff -r 88fea3d419e4 doc/api/log.txt
  11 --- a/doc/api/log.txt   Thu Jan 29 14:02:57 2009 +0100
  12 +++ b/doc/api/log.txt   Thu Jan 29 19:59:36 2009 +0100
  13 @@ -41,7 +41,7 @@
  14
  15  <enum>
  16  enum LogSys {
  17 -  LS_SYSTEM, LS_CONFIG, LS_OPERMODE, LS_GLINE, LS_JUPE, LS_WHO, LS_NETWORK,
  18 +  LS_SYSTEM, LS_CONFIG, LS_OPERMODE, LS_GLINE, LS_JUPE, LS_SPLIT, LS_WHO, LS_NETWORK,
  19    LS_OPERKILL, LS_SERVKILL, LS_USER, LS_OPER, LS_RESOLVER, LS_SOCKET,
  20    LS_DEBUG, LS_OLDLOG,
  21    LS_LAST_SYSTEM
  22 diff -r 88fea3d419e4 include/handlers.h
  23 --- a/include/handlers.h        Thu Jan 29 14:02:57 2009 +0100
  24 +++ b/include/handlers.h        Thu Jan 29 19:59:36 2009 +0100
  25 @@ -139,6 +139,7 @@
  26  extern int m_registered(struct Client*, struct Client*, int, char*[]);
  27  extern int m_sethost(struct Client*, struct Client*, int, char*[]);
  28  extern int m_silence(struct Client*, struct Client*, int, char*[]);
  29 +extern int m_split(struct Client*, struct Client*, int, char*[]);
  30  extern int m_stats(struct Client*, struct Client*, int, char*[]);
  31  extern int m_time(struct Client*, struct Client*, int, char*[]);
  32  extern int m_topic(struct Client*, struct Client*, int, char*[]);
  33 @@ -179,6 +180,7 @@
  34  extern int mo_rping(struct Client*, struct Client*, int, char*[]);
  35  extern int mo_set(struct Client*, struct Client*, int, char*[]);
  36  extern int mo_settime(struct Client*, struct Client*, int, char*[]);
  37 +extern int mo_split(struct Client*, struct Client*, int, char*[]);
  38  extern int mo_squit(struct Client*, struct Client*, int, char*[]);
  39  extern int mo_stats(struct Client*, struct Client*, int, char*[]);
  40  extern int mo_trace(struct Client*, struct Client*, int, char*[]);
  41 @@ -234,6 +236,7 @@
  42  extern int ms_sethost(struct Client*, struct Client*, int, char*[]);
  43  extern int ms_settime(struct Client*, struct Client*, int, char*[]);
  44  extern int ms_silence(struct Client*, struct Client*, int, char*[]);
  45 +extern int ms_split(struct Client*, struct Client*, int, char*[]);
  46  extern int ms_squit(struct Client*, struct Client*, int, char*[]);
  47  extern int ms_stats(struct Client*, struct Client*, int, char*[]);
  48  extern int ms_topic(struct Client*, struct Client*, int, char*[]);
  49 diff -r 88fea3d419e4 include/ircd_features.h
  50 --- a/include/ircd_features.h   Thu Jan 29 14:02:57 2009 +0100
  51 +++ b/include/ircd_features.h   Thu Jan 29 19:59:36 2009 +0100
  52 @@ -112,6 +112,10 @@
  53    FEAT_SETHOST_USER,
  54    FEAT_SETHOST_AUTO,
  55
  56 +  /* SPLIT */
  57 +  FEAT_SPLIT,
  58 +  FEAT_SPLIT_AUTO_EXPIRE,
  59 +
  60    /* HEAD_IN_SAND Features */
  61    FEAT_HIS_SNOTICES,
  62    FEAT_HIS_SNOTICES_OPER_ONLY,
  63 @@ -139,6 +143,7 @@
  64    FEAT_HIS_STATS_q,
  65    FEAT_HIS_STATS_R,
  66    FEAT_HIS_STATS_r,
  67 +  FEAT_HIS_STATS_S,
  68    FEAT_HIS_STATS_s,
  69    FEAT_HIS_STATS_t,
  70    FEAT_HIS_STATS_T,
  71 diff -r 88fea3d419e4 include/ircd_log.h
  72 --- a/include/ircd_log.h        Thu Jan 29 14:02:57 2009 +0100
  73 +++ b/include/ircd_log.h        Thu Jan 29 19:59:36 2009 +0100
  74 @@ -55,6 +55,7 @@
  75    LS_OPERMODE,   /**< Uses of OPMODE, CLEARMODE< etc. */
  76    LS_GLINE,      /**< Adding, (de-)activating or removing GLINEs. */
  77    LS_JUPE,       /**< Adding, (de-)activating or removing JUPEs. */
  78 +  LS_SPLIT,      /**< Adding, (de-)activating or removing SPLITs. */
  79    LS_WHO,        /**< Use of extended WHO privileges. */
  80    LS_NETWORK,    /**< New server connections. */
  81    LS_OPERKILL,   /**< Kills by IRC operators. */
  82 diff -r 88fea3d419e4 include/msg.h
  83 --- a/include/msg.h     Thu Jan 29 14:02:57 2009 +0100
  84 +++ b/include/msg.h     Thu Jan 29 19:59:36 2009 +0100
  85 @@ -336,6 +336,10 @@
  86  #define TOK_JUPE                "JU"
  87  #define CMD_JUPE               MSG_JUPE, TOK_JUPE
  88
  89 +#define MSG_SPLIT                "SPLIT"          /* SPLIT */
  90 +#define TOK_SPLIT                "SP"
  91 +#define CMD_SPLIT              MSG_SPLIT, TOK_SPLIT
  92 +
  93  #define MSG_OPMODE              "OPMODE"        /* OPMO */
  94  #define TOK_OPMODE              "OM"
  95  #define CMD_OPMODE             MSG_OPMODE, TOK_OPMODE
  96 diff -r 88fea3d419e4 include/numeric.h
  97 --- a/include/numeric.h Thu Jan 29 14:02:57 2009 +0100
  98 +++ b/include/numeric.h Thu Jan 29 19:59:36 2009 +0100
  99 @@ -118,6 +118,7 @@
 100  #define RPL_STATSALINE       226        /* Hybrid, Undernet */
 101  #define RPL_STATSWELCOME     227        /* QuakeNet extension */
 102  #define RPL_STATSQLINE       228        /* Undernet extension */
 103 +#define RPL_STATSSPLIT       229        /* QuakeNet extension */
 104  #define RPL_STATSHEADER      230        /* QuakeNet extension */
 105
 106  /*      RPL_SERVICEINFO      231       unused */
 107 @@ -179,6 +180,8 @@
 108  #define RPL_STATSDLINE       275        /* Undernet extension */
 109  #define RPL_STATSRLINE       276        /* Undernet extension */
 110
 111 +#define RPL_SPLITLIST        278        /* QuakeNet extension */
 112 +#define RPL_ENDOFSPLITLIST   279        /* QuakeNet extension */
 113  #define RPL_GLIST            280        /* Undernet extension */
 114  #define RPL_ENDOFGLIST       281        /* Undernet extension */
 115  #define RPL_JUPELIST         282        /* Undernet extension - jupe -Kev */
 116 @@ -449,6 +452,7 @@
 117
 118  #define ERR_NOSUCHWELCOME    509        /* QuakeNet extension */
 119
 120 +#define ERR_NOSUCHSPLIT      510        /* QuakeNet extension */
 121  #define ERR_SILELISTFULL     511        /* Undernet extension */
 122  /*      ERR_NOTIFYFULL       512           aircd */
 123  /*     ERR_TOOMANYWATCH     512           Numeric List: Dalnet */
 124 diff -r 88fea3d419e4 include/split.h
 125 --- /dev/null   Thu Jan 01 00:00:00 1970 +0000
 126 +++ b/include/split.h   Thu Jan 29 19:59:36 2009 +0100
 127 @@ -0,0 +1,110 @@
 128 +#ifndef INCLUDED_split_h
 129 +#define INCLUDED_split_h
 130 +/*
 131 + * IRC - Internet Relay Chat, include/split.h
 132 + * Copyright (C) 1990 Jarkko Oikarinen and
 133 + *                    University of Oulu, Computing Center
 134 + * Copyright (C) 2000 Kevin L. Mitchell <klmitch@mit.edu>
 135 + *
 136 + * This program is free software; you can redistribute it and/or modify
 137 + * it under the terms of the GNU General Public License as published by
 138 + * the Free Software Foundation; either version 2, or (at your option)
 139 + * any later version.
 140 + *
 141 + * This program is distributed in the hope that it will be useful,
 142 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
 143 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 144 + * GNU General Public License for more details.
 145 + *
 146 + * You should have received a copy of the GNU General Public License
 147 + * along with this program; if not, write to the Free Software
 148 + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 149 + */
 150 +/** @file
 151 + * @brief  Interface and declarations for split server handling.
 152 + */
 153 +#ifndef INCLUDED_sys_types_h
 154 +#include <sys/types.h>
 155 +#define INCLUDED_sys_types_h
 156 +#endif
 157 +
 158 +
 159 +struct Client;
 160 +struct StatDesc;
 161 +
 162 +#define SPLIT_MAX_EXPIRE   2419200   /**< Maximum split expiration time (4 weeks).
 163 +                                       *  that an operator can use in /SPLIT
 164 +                                       */
 165 +#define SPLIT_MAX_DRIFT    600       /**< Maximum drift in seconds allowed in lastmod
 166 +                                       *  timestamp
 167 +                                       *  when greater correct and throw warning
 168 +                                       */
 169 +
 170 +/* Describes a SPLIT server entry. */
 171 +struct Split {
 172 +  struct Split*   sp_next;     /**< Pointer to next Split. */
 173 +  struct Split**  sp_prev_p;   /**< Pointer to previous next pointer. */
 174 +  char*           sp_server;   /**< Name of server. */
 175 +  char*           sp_reason;   /**< Reason. */
 176 +  time_t          sp_creation; /**< TODO: Creation time. What are we using this for then? */
 177 +  time_t          sp_expire;   /**< Expiration time. */
 178 +  time_t          sp_lastmod;  /**< Last modification time. */
 179 +  time_t          sp_lifetime; /**< Life time. */
 180 +  unsigned int    sp_flags;    /**< Status flags. */
 181 +};
 182 +
 183 +/** Split state flags. */
 184 +#define SPLIT_ACTIVE       0x01  /**< Split is active. */
 185 +#define SPLIT_REMOVING   0x02  /**< Split is being force removed (instead of deactivated). */
 186 +#define SPLIT_BURST      0x04  /**< Split is for a server that is in progress of linking,
 187 +                                    and will be destroyed at the end of burst */
 188 +
 189 +/* Actions to perform on a SPLIT. */
 190 +enum SplitAction {
 191 +  SPLIT_ACTIVATE,    /**< SPLIT should be activated. */
 192 +  SPLIT_DEACTIVATE,  /**< SPLIT should be deactivated. */
 193 +  SPLIT_MODIFY,      /**< SPLIT should be modified. */
 194 +  SPLIT_REMOVE       /**< SPLIT should be removed. */
 195 +};
 196 +
 197 +/* Split update flags. */
 198 +#define SPLIT_EXPIRE     0x01  /**< Expiration time update. */
 199 +#define SPLIT_LIFETIME   0x02  /**< Record lifetime update. */
 200 +#define SPLIT_REASON     0x04  /**< Reason update. */
 201 +#define SPLIT_MODIFY     0x08  /**< No state change. */
 202 +
 203 +/* mask for Split update flags. */
 204 +#define SPLIT_UPDATE (SPLIT_EXPIRE | SPLIT_LIFETIME | SPLIT_REASON)
 205 +
 206 +/* test whether a split entry is active. */
 207 +#define SplitIsActive(s)      ((s)->sp_flags & SPLIT_ACTIVE)
 208 +/* test whether a split entry is marked for forced removal. */
 209 +#define SplitIsRemoving(s)    ((s)->sp_flags & SPLIT_REMOVING)
 210 +/* test whether a split entry is part of a netmerge. */
 211 +#define SplitIsBurst(s)       ((s)->sp_flags & SPLIT_BURST)
 212 +
 213 +extern int split_add(struct Client *cptr, struct Client *sptr,
 214 +  char *server, const char *reason,
 215 +  time_t creation, time_t expire, time_t lastmod, time_t lifetime,
 216 +  unsigned int flags);
 217 +extern int split_modify(struct Client *cptr, struct Client *sptr,
 218 +  struct Split *split, enum SplitAction action, const char *reason,
 219 +  time_t creation, time_t expire, time_t lastmod, time_t lifetime,
 220 +  unsigned int flags);
 221 +extern int split_remove(struct Client *cptr, struct Client *sptr,
 222 +  struct Split *split, const char *reason);
 223 +
 224 +extern struct Split* split_find(char *server);
 225 +extern void split_free(struct Split *split);
 226 +extern int split_expire(struct Split* split);
 227 +extern void split_burst(struct Client *cptr);
 228 +extern int split_resend(struct Client *cptr, struct Split *split);
 229 +extern int split_list(struct Client *sptr, char *server);
 230 +extern void split_newserver(struct Client *acptr);
 231 +extern int split_netmerge(struct Client *sptr);
 232 +extern int split_netbreak(struct Client *victim, const char *reason);
 233 +extern void split_conf();
 234 +extern void split_stats(struct Client *sptr, const struct StatDesc *sd, char *param);
 235 +extern int split_memory_count(size_t *sp_size);
 236 +
 237 +#endif /* INCLUDED_split_h */
 238 diff -r 88fea3d419e4 ircd/Makefile.in
 239 --- a/ircd/Makefile.in  Thu Jan 29 14:02:57 2009 +0100
 240 +++ b/ircd/Makefile.in  Thu Jan 29 19:59:36 2009 +0100
 241 @@ -173,6 +173,7 @@
 242         m_sethost.c \
 243         m_settime.c \
 244         m_silence.c \
 245 +       m_split.c \
 246         m_squit.c \
 247         m_stats.c \
 248         m_time.c \
 249 @@ -213,6 +214,7 @@
 250         s_stats.c \
 251         s_user.c \
 252         send.c \
 253 +       split.c \
 254         uping.c \
 255         userload.c \
 256         welcome.c \
 257 @@ -1054,6 +1056,15 @@
 258    ../include/ircd_chattr.h ../include/list.h ../include/msg.h \
 259    ../include/numeric.h ../include/numnicks.h ../include/s_user.h \
 260    ../include/send.h ../include/struct.h
 261 +m_split.o: m_split.c ../config.h ../include/client.h ../include/ircd_defs.h \
 262 +  ../include/dbuf.h ../include/msgq.h ../include/ircd_events.h \
 263 +  ../config.h ../include/ircd_handler.h ../include/res.h \
 264 +  ../include/capab.h ../include/split.h ../include/hash.h \
 265 +  ../include/ircd.h ../include/struct.h ../include/ircd_features.h \
 266 +  ../include/ircd_log.h ../include/ircd_reply.h ../include/ircd_string.h \
 267 +  ../include/ircd_chattr.h ../include/match.h ../include/msg.h \
 268 +  ../include/numeric.h ../include/numnicks.h ../include/s_conf.h \
 269 +  ../include/client.h ../include/s_misc.h ../include/send.h
 270  m_squit.o: m_squit.c ../config.h ../include/client.h \
 271    ../include/ircd_defs.h ../include/dbuf.h ../include/msgq.h \
 272    ../include/ircd_events.h ../config.h ../include/ircd_handler.h \
 273 @@ -1332,6 +1343,7 @@
 274    ../include/msgq.h ../include/numeric.h ../include/numnicks.h \
 275    ../include/res.h ../include/s_bsd.h ../include/s_conf.h \
 276    ../include/s_user.h ../include/s_stats.h ../include/send.h \
 277 +  ../include/split.h \
 278    ../include/struct.h ../include/sys.h ../include/whowas.h
 279  s_err.o: s_err.c ../config.h ../include/numeric.h ../include/ircd_log.h \
 280    ../include/s_debug.h ../config.h ../include/ircd_defs.h
 281 @@ -1417,6 +1429,16 @@
 282    ../include/msg.h ../include/numnicks.h ../include/parse.h \
 283    ../include/s_bsd.h ../include/s_debug.h ../include/s_misc.h \
 284    ../include/s_user.h ../include/struct.h ../include/sys.h
 285 +split.o: split.c ../config.h ../include/split.h ../include/client.h \
 286 +  ../include/ircd_defs.h ../include/dbuf.h ../include/msgq.h \
 287 +  ../include/ircd_events.h ../config.h ../include/ircd_handler.h \
 288 +  ../include/res.h ../include/capab.h ../include/hash.h ../include/ircd.h \
 289 +  ../include/struct.h ../include/ircd_alloc.h ../include/ircd_features.h \
 290 +  ../include/ircd_log.h ../include/ircd_reply.h ../include/ircd_string.h \
 291 +  ../include/ircd_chattr.h ../include/match.h ../include/msg.h \
 292 +  ../include/numeric.h ../include/numnicks.h ../include/s_bsd.h \
 293 +  ../include/s_misc.h ../include/send.h ../include/struct.h \
 294 +  ../include/sys.h
 295  uping.o: uping.c ../config.h ../include/uping.h ../include/ircd_defs.h \
 296    ../include/ircd_events.h ../config.h ../include/res.h \
 297    ../include/client.h ../include/dbuf.h ../include/msgq.h \
 298 diff -r 88fea3d419e4 ircd/ircd.c
 299 --- a/ircd/ircd.c       Thu Jan 29 14:02:57 2009 +0100
 300 +++ b/ircd/ircd.c       Thu Jan 29 19:59:36 2009 +0100
 301 @@ -55,6 +55,7 @@
 302  #include "s_misc.h"
 303  #include "s_stats.h"
 304  #include "send.h"
 305 +#include "split.h"
 306  #include "sys.h"
 307  #include "uping.h"
 308  #include "userload.h"
 309 @@ -763,6 +764,9 @@
 310    Debug((DEBUG_NOTICE, "Server ready..."));
 311    log_write(LS_SYSTEM, L_NOTICE, 0, "Server Ready");
 312
 313 +  /* create SPLITs */
 314 +  split_conf();
 315 +
 316    event_loop();
 317
 318    return 0;
 319 diff -r 88fea3d419e4 ircd/ircd_features.c
 320 --- a/ircd/ircd_features.c      Thu Jan 29 14:02:57 2009 +0100
 321 +++ b/ircd/ircd_features.c      Thu Jan 29 19:59:36 2009 +0100
 322 @@ -366,6 +366,10 @@
 323    F_B(SETHOST_USER, 0, 0, 0),
 324    F_B(SETHOST_AUTO, 0, 0, 0),
 325
 326 +  /* SPLIT */
 327 +  F_B(SPLIT, 0, 1, 0),
 328 +  F_I(SPLIT_AUTO_EXPIRE, 0, 604800, 0),
 329 +
 330    /* HEAD_IN_SAND Features */
 331    F_B(HIS_SNOTICES, 0, 1, 0),
 332    F_B(HIS_SNOTICES_OPER_ONLY, 0, 1, 0),
 333 @@ -393,6 +397,7 @@
 334    F_B(HIS_STATS_q, 0, 1, 0),
 335    F_B(HIS_STATS_R, 0, 1, 0),
 336    F_B(HIS_STATS_r, 0, 1, 0),
 337 +  F_B(HIS_STATS_S, 0, 1, 0),
 338    F_B(HIS_STATS_s, 0, 1, 0),
 339    F_B(HIS_STATS_t, 0, 1, 0),
 340    F_B(HIS_STATS_T, 0, 1, 0),
 341 diff -r 88fea3d419e4 ircd/ircd_log.c
 342 --- a/ircd/ircd_log.c   Thu Jan 29 14:02:57 2009 +0100
 343 +++ b/ircd/ircd_log.c   Thu Jan 29 19:59:36 2009 +0100
 344 @@ -154,6 +154,7 @@
 345    S(OPERMODE, -1, SNO_HACK4),
 346    S(GLINE, -1, SNO_GLINE),
 347    S(JUPE, -1, SNO_NETWORK),
 348 +  S(SPLIT, -1, SNO_NETWORK),
 349    S(WHO, -1, 0),
 350    S(NETWORK, -1, SNO_NETWORK),
 351    S(OPERKILL, -1, 0),
 352 diff -r 88fea3d419e4 ircd/m_endburst.c
 353 --- a/ircd/m_endburst.c Thu Jan 29 14:02:57 2009 +0100
 354 +++ b/ircd/m_endburst.c Thu Jan 29 19:59:36 2009 +0100
 355 @@ -85,6 +85,7 @@
 356  #include "client.h"
 357  #include "hash.h"
 358  #include "ircd.h"
 359 +#include "ircd_features.h"
 360  #include "ircd_log.h"
 361  #include "ircd_reply.h"
 362  #include "ircd_string.h"
 363 @@ -92,6 +93,7 @@
 364  #include "numeric.h"
 365  #include "numnicks.h"
 366  #include "send.h"
 367 +#include "split.h"
 368
 369  /* #include <assert.h> -- Now using assert in ircd_log.h */
 370
 371 @@ -125,6 +127,7 @@
 372  int ms_end_of_burst(struct Client* cptr, struct Client* sptr, int parc, char* parv[])
 373  {
 374    struct Channel *chan, *next_chan;
 375 +  int split;
 376
 377    assert(0 != cptr);
 378    assert(0 != sptr);
 379 @@ -135,6 +138,10 @@
 380    dump_map(sptr, "*", 0, report_new_links, 0);
 381    sendto_opmask_butone(0, SNO_NETWORK, "Completed net.burst from %C.",
 382         sptr);
 383 +  /* cleanup SPLITs, but only bother ops when FEAT_SPLIT is enabled. */
 384 +  split = split_netmerge(sptr);
 385 +  if (feature_bool(FEAT_SPLIT))
 386 +    sendto_opmask_butone(0, SNO_NETWORK, "Removed %d SPLIT entries.", split);
 387    if (MyConnect(sptr))
 388      sendcmdto_one(&me, CMD_END_OF_BURST_ACK, sptr, "");
 389
 390 diff -r 88fea3d419e4 ircd/m_reburst.c
 391 --- a/ircd/m_reburst.c  Thu Jan 29 14:02:57 2009 +0100
 392 +++ b/ircd/m_reburst.c  Thu Jan 29 19:59:36 2009 +0100
 393 @@ -102,6 +102,7 @@
 394  #include "ircd_snprintf.h"
 395  #include "gline.h"
 396  #include "jupe.h"
 397 +#include "split.h"
 398
 399  /* #include <assert.h> -- Now using assert in ircd_log.h */
 400  #include <stdlib.h>
 401 @@ -130,6 +131,10 @@
 402      case 'J':
 403        jupe_burst(sptr);
 404        break;
 405 +    case 's':
 406 +    case 'S':
 407 +      split_burst(sptr);
 408 +      break;
 409      default:
 410        break;
 411    }
 412 diff -r 88fea3d419e4 ircd/m_server.c
 413 --- a/ircd/m_server.c   Thu Jan 29 14:02:57 2009 +0100
 414 +++ b/ircd/m_server.c   Thu Jan 29 19:59:36 2009 +0100
 415 @@ -47,6 +47,7 @@
 416  #include "s_misc.h"
 417  #include "s_serv.h"
 418  #include "send.h"
 419 +#include "split.h"
 420  #include "userload.h"
 421
 422  /* #include <assert.h> -- Now using assert in ircd_log.h */
 423 @@ -764,6 +765,9 @@
 424        sendto_opmask_butone(0, SNO_NETWORK, "Net junction: %s %s",
 425                             cli_name(sptr), cli_name(acptr));
 426    }
 427 +  /* new server - mark SPLIT for this server */
 428 +  split_newserver(acptr);
 429 +
 430    /*
 431     * Old sendto_serv_but_one() call removed because we now need to send
 432     * different names to different servers (domain name matching).
 433 diff -r 88fea3d419e4 ircd/m_split.c
 434 --- /dev/null   Thu Jan 01 00:00:00 1970 +0000
 435 +++ b/ircd/m_split.c    Thu Jan 29 19:59:36 2009 +0100
 436 @@ -0,0 +1,392 @@
 437 +/*
 438 + * IRC - Internet Relay Chat, ircd/m_split.c
 439 + * Copyright (C) 1990 Jarkko Oikarinen and
 440 + *                    University of Oulu, Computing Center
 441 + * Copyright (C) 2000 Kevin L. Mitchell <klmitch@mit.edu>
 442 + *
 443 + * See file AUTHORS in IRC package for additional names of
 444 + * the programmers.
 445 + *
 446 + * This program is free software; you can redistribute it and/or modify
 447 + * it under the terms of the GNU General Public License as published by
 448 + * the Free Software Foundation; either version 1, or (at your option)
 449 + * any later version.
 450 + *
 451 + * This program is distributed in the hope that it will be useful,
 452 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
 453 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 454 + * GNU General Public License for more details.
 455 + *
 456 + * You should have received a copy of the GNU General Public License
 457 + * along with this program; if not, write to the Free Software
 458 + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 459 + *
 460 + */
 461 +
 462 +/*
 463 + * m_functions execute protocol messages on this server:
 464 + *
 465 + *    cptr    is always NON-NULL, pointing to a *LOCAL* client
 466 + *            structure (with an open socket connected!). This
 467 + *            identifies the physical socket where the message
 468 + *            originated (or which caused the m_function to be
 469 + *            executed--some m_functions may call others...).
 470 + *
 471 + *    sptr    is the source of the message, defined by the
 472 + *            prefix part of the message if present. If not
 473 + *            or prefix not found, then sptr==cptr.
 474 + *
 475 + *            (!IsServer(cptr)) => (cptr == sptr), because
 476 + *            prefixes are taken *only* from servers...
 477 + *
 478 + *            (IsServer(cptr))
 479 + *                    (sptr == cptr) => the message didn't
 480 + *                    have the prefix.
 481 + *
 482 + *                    (sptr != cptr && IsServer(sptr) means
 483 + *                    the prefix specified servername. (?)
 484 + *
 485 + *                    (sptr != cptr && !IsServer(sptr) means
 486 + *                    that message originated from a remote
 487 + *                    user (not local).
 488 + *
 489 + *            combining
 490 + *
 491 + *            (!IsServer(sptr)) means that, sptr can safely
 492 + *            taken as defining the target structure of the
 493 + *            message in this server.
 494 + *
 495 + *    *Always* true (if 'parse' and others are working correct):
 496 + *
 497 + *    1)      sptr->from == cptr  (note: cptr->from == cptr)
 498 + *
 499 + *    2)      MyConnect(sptr) <=> sptr == cptr (e.g. sptr
 500 + *            *cannot* be a local connection, unless it's
 501 + *            actually cptr!). [MyConnect(x) should probably
 502 + *            be defined as (x == x->from) --msa ]
 503 + *
 504 + *    parc    number of variable parameter strings (if zero,
 505 + *            parv is allowed to be NULL)
 506 + *
 507 + *    parv    a NULL terminated list of parameter pointers,
 508 + *
 509 + *                    parv[0], sender (prefix string), if not present
 510 + *                            this points to an empty string.
 511 + *                    parv[1]...parv[parc-1]
 512 + *                            pointers to additional parameters
 513 + *                    parv[parc] == NULL, *always*
 514 + *
 515 + *            note:   it is guaranteed that parv[0]..parv[parc-1] are all
 516 + *                    non-NULL pointers.
 517 + */
 518 +#include "config.h"
 519 +
 520 +#include "client.h"
 521 +#include "split.h"
 522 +#include "hash.h"
 523 +#include "ircd.h"
 524 +#include "ircd_features.h"
 525 +#include "ircd_log.h"
 526 +#include "ircd_reply.h"
 527 +#include "ircd_string.h"
 528 +#include "match.h"
 529 +#include "msg.h"
 530 +#include "numeric.h"
 531 +#include "numnicks.h"
 532 +#include "s_conf.h"
 533 +#include "s_debug.h"
 534 +#include "s_misc.h"
 535 +#include "send.h"
 536 +
 537 +/* #include <assert.h> -- Now using assert in ircd_log.h */
 538 +#include <stdlib.h>
 539 +#include <string.h>
 540 +
 541 +/*
 542 + * ms_split - server message handler
 543 + *
 544 + * parv[0] = Send prefix
 545 + * parv[1] = (+|-)<server name>
 546 + * parv[2] = Creation time
 547 + * parv[3] = Expiration time
 548 + * parv[4] = Last modification time
 549 + * parv[5] = Life time
 550 + * parv[6] = Comment
 551 + *
 552 + */
 553 +int ms_split(struct Client* cptr, struct Client* sptr, int parc, char* parv[])
 554 +{
 555 +  struct Client *acptr = 0;
 556 +  struct Split *asplit = 0;
 557 +  unsigned int flags = 0;
 558 +  enum SplitAction action = SPLIT_MODIFY;
 559 +  time_t creation = 0, expire = 0, lastmod = 0, lifetime = 0;
 560 +  char *server;
 561 +  const char *reason = "No reason";
 562 +
 563 +  /* reason is optional - for lazy services, we always send it */
 564 +  if (parc < 5)
 565 +    return need_more_params(sptr, "SPLIT");
 566 +
 567 +  /* server param */
 568 +  server = parv[1];
 569 +
 570 +  /* check for ! prefix - force removing */
 571 +  if (*server == '!') {
 572 +    server++;
 573 +    action = SPLIT_REMOVE;
 574 +  }
 575 +
 576 +  /* check for + and - prefix */
 577 +  switch (*server) {
 578 +    case '+':
 579 +    if (action != SPLIT_REMOVE)
 580 +      action = SPLIT_ACTIVATE;
 581 +    server++;
 582 +    break;
 583 +
 584 +    case '-':
 585 +    if (action != SPLIT_REMOVE)
 586 +      action = SPLIT_DEACTIVATE;
 587 +    server++;
 588 +    break;
 589 +  }
 590 +
 591 +  /* Next, try to find the split entry... */
 592 +  asplit = split_find(server);
 593 +
 594 +  /* We now have all the pieces to tell us what we've got; let's put
 595 +   * it all together and convert the rest of the arguments.
 596 +   */
 597 +
 598 +  /* cannot modify a split entry that does not exist - remap to activate */
 599 +  if (!asplit && action == SPLIT_MODIFY)
 600 +    action = SPLIT_ACTIVATE;
 601 +
 602 +  /* set all flags for modification */
 603 +  if (asplit && action != SPLIT_REMOVE)
 604 +    flags = SPLIT_UPDATE;
 605 +
 606 +  /* set the things we need */
 607 +  creation = atoi(parv[2]);
 608 +  expire = atoi(parv[3]);
 609 +  lastmod = atoi(parv[4]);
 610 +  lifetime = atoi(parv[5]);
 611 +
 612 +  /* got a reason too */
 613 +  if (parc > 5)
 614 +    reason = parv[parc - 1];
 615 +  else
 616 +    flags &= ~SPLIT_REASON;
 617 +
 618 +  /* debug */
 619 +  Debug((DEBUG_DEBUG, "I have a SPLIT I am acting upon now; "
 620 +    "server %s, action %s, creation %Tu, expire %Tu, "
 621 +    "lastmod %Tu, lifetime %Tu, reason: %s; split %s!", server,
 622 +         action == SPLIT_REMOVE ? "!-" :
 623 +          (action == SPLIT_ACTIVATE ? "+" :
 624 +           (action == SPLIT_DEACTIVATE ? "-" : "(MODIFY)")),
 625 +        creation, expire, lastmod, lifetime, reason,
 626 +        asplit ? "EXISTS" : "does not exist"));
 627 +
 628 +  /* modify or remove an existing SPLIT */
 629 +  if (asplit) {
 630 +    if (action == SPLIT_REMOVE)
 631 +      return split_remove(cptr, sptr, asplit, reason);
 632 +    return split_modify(cptr, sptr, asplit, action, reason, creation, expire,
 633 +                       lastmod, lifetime, flags);
 634 +  }
 635 +
 636 +  /* desynch or cross - we do not have it so we cannot remove it */
 637 +  /* TODO: manually propagate the message ?
 638 +   *
 639 +   * but if we do not have it, can our downlinks have it?
 640 +   *   they could if my oper force removed it earlier, and then my downlinks linked
 641 +   *     no, then they would have bursted it again to us.. argh
 642 +   */
 643 +  if (!asplit && action == SPLIT_REMOVE)
 644 +    return 0;
 645 +
 646 +  /* this should not happen */
 647 +  assert(action != SPLIT_MODIFY);
 648 +  assert(action != SPLIT_REMOVE);
 649 +
 650 +  /* create a new SPLIT */
 651 +  return split_add(cptr, sptr, server, reason, creation, expire, lastmod, lifetime,
 652 +    action == SPLIT_ACTIVATE ? SPLIT_ACTIVE : 0);
 653 +}
 654 +
 655 +
 656 +/*
 657 + * mo_split - oper message handler
 658 + *
 659 + * Local listing: 1 or 2 params
 660 + * parv[0] = Send prefix
 661 + * parv[1] = [Server or mask to match]
 662 + *
 663 + * Add or modify entry: 3, 4 or 5 params (3 is * then)
 664 + * parv[0] = Send prefix
 665 + * parv[1] = [+|-]<server name>
 666 + * parv[2] = [Expiration offset] (required for new)
 667 + * parv[3] = [Comment] (required for new)
 668 + *
 669 + */
 670 +int mo_split(struct Client* cptr, struct Client* sptr, int parc, char* parv[])
 671 +{
 672 +  struct Client *acptr = 0;
 673 +  struct Split *asplit = 0;
 674 +  unsigned int flags = 0;
 675 +  enum SplitAction action = SPLIT_MODIFY;
 676 +  time_t expire = 0, lastmod = TStime(), creation = TStime();
 677 +  char *server, *end;
 678 +  const char *reason = NULL;
 679 +
 680 +  /* listing */
 681 +  if (parc < 2) {
 682 +    if (!HasPriv(sptr, PRIV_ROUTEINFO))
 683 +      return send_reply(sptr, ERR_NOPRIVILEGES);
 684 +    else
 685 +      return split_list(sptr, 0);
 686 +  }
 687 +
 688 +  /* set server */
 689 +  server = parv[1];
 690 +
 691 +  /* ! prefix - force removal */
 692 +  if (*server == '!') {
 693 +    server++;
 694 +    action = SPLIT_REMOVE;
 695 +  }
 696 +
 697 +  /* handle + and - */
 698 +  switch (*server) {
 699 +    case '+':
 700 +    if (action != SPLIT_REMOVE)
 701 +      action = SPLIT_ACTIVATE;
 702 +    server++;
 703 +    break;
 704 +
 705 +    case '-':
 706 +    if (action != SPLIT_REMOVE)
 707 +      action = SPLIT_DEACTIVATE;
 708 +    server++;
 709 +    break;
 710 +  }
 711 +
 712 +  /* user wants listing */
 713 +  if (action == SPLIT_MODIFY && parc == 2)
 714 +    return split_list(sptr, server);
 715 +
 716 +  /* if we have an expire, this must be it */
 717 +  if (parc > 2)
 718 +    expire = strtol(parv[2], &end, 10);
 719 +
 720 +  /* got reason and expire */
 721 +  if (parc > 3) {
 722 +    flags |= SPLIT_EXPIRE;
 723 +    flags |= SPLIT_REASON;
 724 +  }
 725 +  /* got reason or expire */
 726 +  else if (parc > 2) {
 727 +    if (*end != '\0')
 728 +      flags |= SPLIT_REASON;
 729 +    else
 730 +      flags |= SPLIT_EXPIRE;
 731 +  }
 732 +
 733 +  /* set reason */
 734 +  if (flags & SPLIT_REASON) {
 735 +    reason = parv[parc - 1];
 736 +    /* ignore empty reason */
 737 +    if (EmptyString(reason))
 738 +      flags &= ~SPLIT_REASON;
 739 +  }
 740 +
 741 +  /* bad expire */
 742 +  if (flags & SPLIT_EXPIRE && *end != '\0')
 743 +    return send_reply(sptr, SND_EXPLICIT | ERR_BADEXPIRE, "%s :Bad expire time", parv[2]);
 744 +
 745 +  /* require a reason for forced removal */
 746 +  if (!(flags & SPLIT_REASON) && action == SPLIT_REMOVE)
 747 +    return need_more_params(sptr, "SPLIT");
 748 +
 749 +  /* we got expire */
 750 +  if (flags & SPLIT_EXPIRE) {
 751 +    if (expire == 0) /* dummy value 0 given, no change to expire */
 752 +      flags &= ~SPLIT_EXPIRE;
 753 +    else /* turn expire into timestamp */
 754 +      expire += TStime();
 755 +   }
 756 +
 757 +  /* TODO: but allow force removal when disabled? */
 758 +  /* check feature and privs */
 759 +  if (!feature_bool(FEAT_SPLIT))
 760 +    return send_reply(sptr, ERR_DISABLED, "SPLIT");
 761 +  /* TODO: create PRIV_SPLIT - need help there */
 762 +  else if (!HasPriv(sptr, PRIV_SERVERINFO))
 763 +    return send_reply(sptr, ERR_NOPRIVILEGES);
 764 +
 765 +  /* we have all we need - find the split */
 766 +  asplit = split_find(server);
 767 +
 768 +  /* SPLIT not found and thus we cannot:
 769 +   *   remove SPLIT we do not have
 770 +   *   add new SPLIT without expire and reason
 771 +   */
 772 +  if (!asplit &&
 773 +      ((action == SPLIT_REMOVE) ||
 774 +       (action == SPLIT_ACTIVATE && !reason) ||
 775 +       (action == SPLIT_DEACTIVATE && !reason) ||
 776 +       (action == SPLIT_MODIFY && !reason)))
 777 +    return send_reply(sptr, ERR_NOSUCHSPLIT, server);
 778 +
 779 +  /* cannot modify a split entry that does not exist - remap to activate */
 780 +  if (!asplit && action == SPLIT_MODIFY)
 781 +    action = SPLIT_ACTIVATE;
 782 +
 783 +  /* debug */
 784 +  Debug((DEBUG_DEBUG, "I have a SPLIT I am acting upon now; "
 785 +    "server %s, action %s, expire %Tu, "
 786 +    "reason: %s; split %s!  (fields present: %s %s)", server,
 787 +    action == SPLIT_REMOVE ? "!-" :
 788 +     (action == SPLIT_ACTIVATE ? "+" :
 789 +      (action == SPLIT_DEACTIVATE ? "-" : "(MODIFY)")),
 790 +    expire, reason, asplit ? "EXISTS" : "does not exist",
 791 +    flags & SPLIT_EXPIRE ? "expire" : "",
 792 +    flags & SPLIT_REASON ? "reason" : ""));
 793 +
 794 +  /* modify or remove an existing SPLIT */
 795 +  if (asplit) {
 796 +    if (action == SPLIT_REMOVE)
 797 +      return split_remove(cptr, sptr, asplit, reason);
 798 +    return split_modify(cptr, sptr, asplit, action, reason,
 799 +      asplit->sp_creation, expire, lastmod, asplit->sp_lifetime, flags);
 800 +  }
 801 +
 802 +  /* this should not happen */
 803 +  assert(action != SPLIT_MODIFY);
 804 +  assert(action != SPLIT_REMOVE);
 805 +
 806 +  /* create a new SPLIT */
 807 +  return split_add(cptr, sptr, server, reason,
 808 +    creation, expire, lastmod, expire,
 809 +    flags | ((action == SPLIT_ACTIVATE) ? SPLIT_ACTIVE : 0));
 810 +}
 811 +
 812 +/*
 813 + * m_split - user message handler
 814 + *
 815 + * parv[0] = Send prefix
 816 + * parv[1] = [<server name>]
 817 + *
 818 + */
 819 +int m_split(struct Client* cptr, struct Client* sptr, int parc, char* parv[])
 820 +{
 821 +  /* TODO: this is not used at all at the moment
 822 +   * create a FEAT_HIS_SPLIT ?
 823 +   */
 824 +  if (parc < 2)
 825 +    return split_list(sptr, 0);
 826 +
 827 +  return split_list(sptr, parv[1]);
 828 +}
 829 diff -r 88fea3d419e4 ircd/parse.c
 830 --- a/ircd/parse.c      Thu Jan 29 14:02:57 2009 +0100
 831 +++ b/ircd/parse.c      Thu Jan 29 19:59:36 2009 +0100
 832 @@ -506,6 +506,13 @@
 833      { m_unregistered, m_not_oper, ms_jupe, mo_jupe, m_ignore, mh_jupe }
 834    },
 835    {
 836 +    MSG_SPLIT,
 837 +    TOK_SPLIT,
 838 +    0, MAXPARA, MFLG_SLOW, 0, NULL,
 839 +    /* UNREG, CLIENT, SERVER, OPER, SERVICE, HELP */
 840 +    { m_unregistered, m_not_oper, ms_split, mo_split, m_ignore, mh_nohelp }
 841 +   },
 842 +  {
 843      MSG_OPMODE,
 844      TOK_OPMODE,
 845      0, MAXPARA, MFLG_SLOW, 0, NULL,
 846 diff -r 88fea3d419e4 ircd/s_conf.c
 847 --- a/ircd/s_conf.c     Thu Jan 29 14:02:57 2009 +0100
 848 +++ b/ircd/s_conf.c     Thu Jan 29 19:59:36 2009 +0100
 849 @@ -53,6 +53,7 @@
 850  #include "s_debug.h"
 851  #include "s_misc.h"
 852  #include "send.h"
 853 +#include "split.h"
 854  #include "struct.h"
 855  #include "sys.h"
 856
 857 @@ -1005,6 +1006,7 @@
 858    }
 859
 860    attach_conf_uworld(&me);
 861 +  split_conf();
 862
 863    return ret;
 864  }
 865 diff -r 88fea3d419e4 ircd/s_debug.c
 866 --- a/ircd/s_debug.c    Thu Jan 29 14:02:57 2009 +0100
 867 +++ b/ircd/s_debug.c    Thu Jan 29 19:59:36 2009 +0100
 868 @@ -48,6 +48,7 @@
 869  #include "s_user.h"
 870  #include "s_stats.h"
 871  #include "send.h"
 872 +#include "split.h"
 873  #include "struct.h"
 874  #include "sys.h"
 875  #include "whowas.h"
 876 @@ -231,7 +232,8 @@
 877        aw = 0,                   /* aways set */
 878        wwa = 0,                  /* whowas aways */
 879        gl = 0,                   /* glines */
 880 -      ju = 0;                   /* jupes */
 881 +      ju = 0,                   /* jupes */
 882 +      sp = 0;                   /* splits */
 883
 884    size_t chm = 0,               /* memory used by channels */
 885        chbm = 0,                 /* memory used by channel bans */
 886 @@ -244,6 +246,7 @@
 887        wwm = 0,                  /* whowas array memory used */
 888        glm = 0,                  /* memory used by glines */
 889        jum = 0,                  /* memory used by jupes */
 890 +      spm = 0,                  /* memory used by splits */
 891        com = 0,                  /* memory used by conf lines */
 892        dbufs_allocated = 0,      /* memory used by dbufs */
 893        dbufs_used = 0,           /* memory used by dbufs */
 894 @@ -348,8 +351,9 @@
 895
 896    gl = gline_memory_count(&glm);
 897    ju = jupe_memory_count(&jum);
 898 +  sp = split_memory_count(&spm);
 899    send_reply(cptr, SND_EXPLICIT | RPL_STATSDEBUG,
 900 -            ":Glines %d(%zu) Jupes %d(%zu)", gl, glm, ju, jum);
 901 +            ":Glines %d(%zu) Jupes %d(%zu) Splits %d(%zu)", gl, glm, ju, jum, sp, spm);
 902
 903    send_reply(cptr, SND_EXPLICIT | RPL_STATSDEBUG,
 904              ":Hash: client %d(%zu), chan is the same", HASHSIZE,
 905 diff -r 88fea3d419e4 ircd/s_err.c
 906 --- a/ircd/s_err.c      Thu Jan 29 14:02:57 2009 +0100
 907 +++ b/ircd/s_err.c      Thu Jan 29 19:59:36 2009 +0100
 908 @@ -490,7 +490,7 @@
 909  /* 228 */
 910    { RPL_STATSQLINE, "Q %s :%s", "228" },
 911  /* 229 */
 912 -  { 0 },
 913 +  { RPL_STATSSPLIT, "S %s %d %d %d %d %c :%s", "229" },
 914  /* 230 */
 915    { RPL_STATSHEADER, 0, "230" },
 916  /* 231 */
 917 @@ -588,9 +588,9 @@
 918  /* 277 */
 919    { 0 },
 920  /* 278 */
 921 -  { 0 },
 922 +  { RPL_SPLITLIST, "%s %Tu %Tu %Tu %Tu %c :%s", "278" },
 923  /* 279 */
 924 -  { 0 },
 925 +  { RPL_ENDOFSPLITLIST, ":End of Split List", "279" },
 926  /* 280 */
 927    { RPL_GLIST, "%s%s%s%s%s %Tu %Tu %Tu %s %s%s%c :%s", "280" },
 928  /* 281 */
 929 @@ -1052,7 +1052,7 @@
 930  /* 509 */
 931    { ERR_NOSUCHWELCOME, "%s :No such welcome", "509" },
 932  /* 510 */
 933 -  { 0 },
 934 +  { ERR_NOSUCHSPLIT, "%s :No such split", "510" },
 935  /* 511 */
 936    { ERR_SILELISTFULL, "%s :Your silence list is full", "511" },
 937  /* 512 */
 938 diff -r 88fea3d419e4 ircd/s_misc.c
 939 --- a/ircd/s_misc.c     Thu Jan 29 14:02:57 2009 +0100
 940 +++ b/ircd/s_misc.c     Thu Jan 29 19:59:36 2009 +0100
 941 @@ -53,6 +53,7 @@
 942  #include "s_stats.h"
 943  #include "s_user.h"
 944  #include "send.h"
 945 +#include "split.h"
 946  #include "struct.h"
 947  #include "sys.h"
 948  #include "uping.h"
 949 @@ -391,6 +392,7 @@
 950    time_t on_for;
 951
 952    char comment1[HOSTLEN + HOSTLEN + 2];
 953 +  char splitreason[BUFSIZE];
 954    assert(killer);
 955    if (MyConnect(victim))
 956    {
 957 @@ -497,6 +499,15 @@
 958      sendto_opmask_butone(0, SNO_NETWORK, "Net break: %C %C (%s)",
 959                          cli_serv(victim)->up, victim, comment);
 960      dump_map(victim, "*", 0, report_lost_links, 0);
 961 +    if (feature_bool(FEAT_SPLIT)) {
 962 +      /* TODO: remote & local SQUIT ? servername oper is on? */
 963 +      ircd_snprintf(0, splitreason, sizeof(splitreason),
 964 +        "Net break: %C %C (%s%s%s%s)", cli_serv(victim)->up, victim,
 965 +        IsUser(killer) ? "SQUIT by " : "", IsUser(killer) ? cli_name(killer) : "",
 966 +        IsUser(killer) ? ": " : "", comment);
 967 +      sendto_opmask_butone(0, SNO_NETWORK, "Created %d SPLIT entries.",
 968 +          split_netbreak(victim, splitreason));
 969 +    }
 970    }
 971
 972    /*
 973 diff -r 88fea3d419e4 ircd/s_serv.c
 974 --- a/ircd/s_serv.c     Thu Jan 29 14:02:57 2009 +0100
 975 +++ b/ircd/s_serv.c     Thu Jan 29 19:59:36 2009 +0100
 976 @@ -54,6 +54,7 @@
 977  #include "s_misc.h"
 978  #include "s_user.h"
 979  #include "send.h"
 980 +#include "split.h"
 981  #include "struct.h"
 982  #include "sys.h"
 983  #include "userload.h"
 984 @@ -197,6 +198,7 @@
 985     */
 986    gline_burst(cptr);
 987    jupe_burst(cptr);
 988 +  split_burst(cptr);
 989    welcome_burst(cptr);
 990
 991    /*
 992 diff -r 88fea3d419e4 ircd/s_stats.c
 993 --- a/ircd/s_stats.c    Thu Jan 29 14:02:57 2009 +0100
 994 +++ b/ircd/s_stats.c    Thu Jan 29 19:59:36 2009 +0100
 995 @@ -52,6 +52,7 @@
 996  #include "s_stats.h"
 997  #include "s_user.h"
 998  #include "send.h"
 999 +#include "split.h"
1000  #include "struct.h"
1001  #include "userload.h"
1002  #include "welcome.h"
1003 @@ -669,7 +670,10 @@
1004      send_usage, 0,
1005      "System resource usage (Debug only)." },
1006  #endif
1007 -  { 's', "spoofhosts", (STAT_FLAG_OPERFEAT | STAT_FLAG_VARPARAM), FEAT_HIS_STATS_s,
1008 +  { 'S', "splits", (STAT_FLAG_OPERFEAT | STAT_FLAG_VARPARAM | STAT_FLAG_CASESENS), FEAT_HIS_STATS_S,
1009 +    split_stats, 0,
1010 +    "Server SPLITs information."},
1011 +  { 's', "spoofhosts", (STAT_FLAG_OPERFEAT | STAT_FLAG_VARPARAM | STAT_FLAG_CASESENS), FEAT_HIS_STATS_s,
1012      stats_sline, 0,
1013      "Spoofed hosts information." },
1014    { 'T', "motds", (STAT_FLAG_OPERFEAT | STAT_FLAG_CASESENS), FEAT_HIS_STATS_T,
1015 diff -r 88fea3d419e4 ircd/split.c
1016 --- /dev/null   Thu Jan 01 00:00:00 1970 +0000
1017 +++ b/ircd/split.c      Thu Jan 29 19:59:36 2009 +0100
1018 @@ -0,0 +1,873 @@
1019 +/*
1020 + * IRC - Internet Relay Chat, ircd/split.c
1021 + * Copyright (C) 1990 Jarkko Oikarinen and
1022 + *                    University of Oulu, Finland
1023 + * Copyright (C) 2000 Kevin L. Mitchell <klmitch@mit.edu>
1024 + *
1025 + * This program is free software; you can redistribute it and/or modify
1026 + * it under the terms of the GNU General Public License as published by
1027 + * the Free Software Foundation; either version 1, or (at your option)
1028 + * any later version.
1029 + *
1030 + * This program is distributed in the hope that it will be useful,
1031 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
1032 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
1033 + * GNU General Public License for more details.
1034 + *
1035 + * You should have received a copy of the GNU General Public License
1036 + * along with this program; if not, write to the Free Software
1037 + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
1038 + */
1039 +/** @file
1040 + * @brief Implementation of split server handling functions.
1041 + */
1042 +#include "config.h"
1043 +
1044 +#include "split.h"
1045 +#include "client.h"
1046 +#include "hash.h"
1047 +#include "ircd.h"
1048 +#include "ircd_alloc.h"
1049 +#include "ircd_features.h"
1050 +#include "ircd_log.h"
1051 +#include "ircd_reply.h"
1052 +#include "ircd_string.h"
1053 +#include "list.h"
1054 +#include "match.h"
1055 +#include "msg.h"
1056 +#include "numeric.h"
1057 +#include "numnicks.h"
1058 +#include "s_conf.h"
1059 +#include "s_bsd.h"
1060 +#include "s_debug.h"
1061 +#include "s_misc.h"
1062 +#include "send.h"
1063 +#include "struct.h"
1064 +#include "sys.h"    /* FALSE bleah */
1065 +
1066 +/* #include <assert.h> -- Now using assert in ircd_log.h */
1067 +#include <string.h>
1068 +
1069 +/** List of split entries. */
1070 +static struct Split *GlobalSplitList = 0;
1071 +
1072 +/** Allocate a new Split entry with the given parameters.
1073 + * @param[in] server Server name for split entry.
1074 + * @param[in] reason Reason for the split entry.
1075 + * @param[in] creation Creation time for split entry.
1076 + * @param[in] expire Expiration time for split entry.
1077 + * @param[in] lastmod Last modification time for split entry.
1078 + * @param[in] lifetime Life time for split entry.
1079 + * @param[in] flags Flags to set for the split entry.
1080 + */
1081 +static struct Split *
1082 +split_make(char *server, const char *reason,
1083 +  time_t creation, time_t expire, time_t lastmod, time_t lifetime,
1084 +  unsigned int flags)
1085 +{
1086 +  struct Split *asplit;
1087 +  char sp_server[HOSTLEN+1];
1088 +  char sp_reason[TOPICLEN+1];
1089 +
1090 +  /* alloc memory */
1091 +  asplit = (struct Split*) MyMalloc(sizeof(struct Split));
1092 +
1093 +  /* we should have it now */
1094 +  assert(0 != asplit);
1095 +
1096 +  memset(asplit, 0, sizeof(*asplit));
1097 +  ircd_strncpy(sp_server, server, HOSTLEN);
1098 +  DupString(asplit->sp_server, sp_server);
1099 +  /* TODO: prefix the reason here with the opername/ID? */
1100 +  ircd_strncpy(sp_reason, reason, TOPICLEN);
1101 +  DupString(asplit->sp_reason, sp_reason);
1102 +  asplit->sp_creation = creation;
1103 +  asplit->sp_expire = expire;
1104 +  asplit->sp_lastmod = lastmod;
1105 +  asplit->sp_lifetime = lifetime;
1106 +  /* set split flags - only save SPLIT_ACTIVE */
1107 +  asplit->sp_flags = flags & SPLIT_ACTIVE;
1108 +
1109 +  /* link it into the list */
1110 +  asplit->sp_next = GlobalSplitList;
1111 +  asplit->sp_prev_p = &GlobalSplitList;
1112 +  if (GlobalSplitList)
1113 +    GlobalSplitList->sp_prev_p = &asplit->sp_next;
1114 +  GlobalSplitList = asplit;
1115 +
1116 +  return asplit;
1117 +}
1118 +
1119 +/** Forward a split entry to another server.
1120 + * @param[in] cptr Local client that sent us the split entry.
1121 + * @param[in] sptr Originator of the split entry.
1122 + * @param[in] split Split entry to forward.
1123 + * @param[in] reason Reason to send upstream (used by split_remove)
1124 + */
1125 +static void
1126 +split_propagate(struct Client *cptr, struct Client *sptr,
1127 +  struct Split *split, const char *reason)
1128 +{
1129 +  sendcmdto_serv_butone(sptr, CMD_SPLIT, cptr, "%s%c%s %Tu %Tu %Tu %Tu :%s",
1130 +    SplitIsRemoving(split) ? "!" : "",
1131 +    SplitIsActive(split) && !SplitIsRemoving(split) ? '+' : '-', /* always !- not !+ */
1132 +    split->sp_server, split->sp_creation, split->sp_expire,
1133 +    split->sp_lastmod, split->sp_lifetime,
1134 +    EmptyString(reason) ? split->sp_reason : reason);
1135 +}
1136 +
1137 +/** Add a new server split entry.
1138 + * @param[in] cptr Local client that sent us the split entry.
1139 + * @param[in] sptr Originator of the split entry.
1140 + * @param[in] server Server name to split entry.
1141 + * @param[in] reason Reason for the split entry.
1142 + * @param[in] expire Expiration timestamp.
1143 + * @param[in] lastmod Last modification timestamp.
1144 + * @param[in] flags Flags to set on the split entry.
1145 + * @return Zero
1146 + */
1147 +int
1148 +split_add(struct Client *cptr, struct Client *sptr, char *server, const char *reason,
1149 +        time_t creation, time_t expire, time_t lastmod, time_t lifetime,
1150 +        unsigned int flags)
1151 +{
1152 +
1153 +  struct Split *split;
1154 +  char noreason[BUFSIZE];
1155 +  static time_t rate;
1156 +
1157 +  assert(NULL != cptr);
1158 +  assert(NULL != sptr);
1159 +  assert(NULL != server);
1160 +
1161 +  /* debug */
1162 +  Debug((DEBUG_DEBUG, "split_add(\"%s\", \"%s\", \"%s\", \"%s\", %Tu, %Tu, %Tu, "
1163 +        "%Tu, 0x%04x)", cli_name(cptr), cli_name(sptr), server, reason,
1164 +        creation, expire, lastmod, lifetime, flags));
1165 +
1166 +  /* not adding SPLIT for server that is linked
1167 +   *   if sptr is my user throw error
1168 +   *   otherwise ignore - SERVER and SPLIT messages can cross,
1169 +   *   or a server is bursting and it will see our end and destroy the SPLITs
1170 +   */
1171 +  if (FindServer(server)) {
1172 +    if (MyUser(sptr))
1173 +      sendcmdto_one(&me, CMD_NOTICE, sptr,
1174 +        "%C :SPLIT: Cannot add SPLIT %s - server is linked.", sptr, server);
1175 +    return 0;
1176 +  }
1177 +
1178 +  /*
1179 +   * You cannot set a negative (or zero) duration, nor can you set an
1180 +   * duration greater than SPLIT_MAX_EXPIRE.
1181 +   */
1182 +  if (expire - TStime() <= 0 || expire - TStime() > SPLIT_MAX_EXPIRE) {
1183 +    if (MyUser(sptr))
1184 +      return send_reply(cptr, ERR_BADEXPIRE, expire - TStime());
1185 +    if (lifetime <= TStime()) /* no point going further */
1186 +      /* CHECK: sptr may have the wrong idea about the nettime?
1187 +       * or we could be wrong?
1188 +       * perhaps raise some sort of warning to ops
1189 +       */
1190 +      return 0;
1191 +  }
1192 +
1193 +  /* empty reason */
1194 +  if (EmptyString(reason))
1195 +    ircd_snprintf(0, noreason, sizeof(noreason), "%C gave no reason.", sptr);
1196 +
1197 +  /* lastmod is more than SPLIT_MAX_DRIFT seconds ahead of our idea of time
1198 +   *   correct and warn ops
1199 +   */
1200 +  if (lastmod - TStime() > SPLIT_MAX_DRIFT) {
1201 +    sendto_opmask_butone_ratelimited(0, SNO_NETWORK, &rate,
1202 +      "Possible timestamp drift from %C; lastmod in SPLIT message is %is ahead of time",
1203 +      IsServer(sptr) ? sptr : cli_user(sptr)->server, lastmod - TStime());
1204 +    lastmod = TStime() + SPLIT_MAX_DRIFT;
1205 +  }
1206 +
1207 +  /* make the split entry */
1208 +  split = split_make(server, EmptyString(reason) ? noreason : reason,
1209 +             creation, expire, lastmod, lifetime, flags);
1210 +
1211 +  /* got to have it now */
1212 +  assert(split);
1213 +
1214 +  /* inform ops */
1215 +  sendto_opmask_butone(0, SNO_NETWORK, "%s adding%sSPLIT for %s, expiring at %Tu: %s",
1216 +    (feature_bool(FEAT_HIS_SNOTICES) || IsServer(sptr)) ?
1217 +      get_client_name_and_opername(sptr) : cli_name((cli_user(sptr))->server),
1218 +    SplitIsActive(split) ? " " : " deactivated ",
1219 +    split->sp_server, split->sp_expire, split->sp_reason);
1220 +
1221 +  /* log it */
1222 +  log_write(LS_SPLIT, L_INFO, LOG_NOSNOTICE,
1223 +    "%#C adding%sSPLIT for %s, expiring at %Tu: %s",
1224 +    sptr, SplitIsActive(split) ? " " : " deactivated ",
1225 +    split->sp_server, split->sp_expire, split->sp_reason);
1226 +
1227 +  /* and propagate it */
1228 +  split_propagate(cptr, sptr, split, NULL);
1229 +
1230 +  return 0;
1231 +}
1232 +
1233 +
1234 +/** Modify a split entry.
1235 + * @param[in] cptr Client that sent us the split modification.
1236 + * @param[in] sptr Client that originated the split modification.
1237 + * @param[in] split Split entry being modified.
1238 + * @param[in] action Resultant status of the SPLIT.
1239 + * @param[in] reason Reason.
1240 + * @param[in] expire Expiration time.
1241 + * @param[in] lastmod Last modification time.
1242 + * @param[in] lifetime Lifetime.
1243 + * @param[in] flags Bitwise combination of SPLIT_* flags.
1244 + * @return Zero.
1245 + */
1246 +int
1247 +split_modify(struct Client *cptr, struct Client *sptr, struct Split *split,
1248 +  enum SplitAction action, const char *reason,
1249 +  time_t creation, time_t expire, time_t lastmod, time_t lifetime,
1250 +  unsigned int flags)
1251 +{
1252 +  char buf[BUFSIZE];
1253 +  char sp_reason[TOPICLEN+1];
1254 +  int pos = 0;
1255 +  static time_t rate;
1256 +
1257 +  assert(NULL != cptr);
1258 +  assert(NULL != sptr);
1259 +  assert(NULL != split);
1260 +
1261 +  /* debug */
1262 +  Debug((DEBUG_DEBUG, "split_modify(cptr \"%s\", sptr \"%s\", split \"%s\", reason \"%s\","
1263 +    " action %d, creation %Tu, expire %Tu, lastmod %Tu, lifetime %Tu, flags 0x%04x)",
1264 +    cli_name(cptr), cli_name(sptr), split->sp_server, reason, action,
1265 +        creation, expire, lastmod, lifetime, flags));
1266 +
1267 +  /* not modifying SPLIT for server that is linked
1268 +   *   if sptr is my user throw error
1269 +   *   otherwise ignore - SERVER and SPLIT messages can cross.
1270 +   *
1271 +   * note: we cleanup SPLIT entries at end of burst,
1272 +   *       and not when a server is introduced.
1273 +   *       so between net junction and end of burst,
1274 +   *       we can get SPLITs for a linked server.
1275 +   *       also more than one server can be bursting at a time.
1276 +   */
1277 +  if (FindServer(split->sp_server)) {
1278 +    if (MyUser(sptr))
1279 +      sendcmdto_one(&me, CMD_NOTICE, sptr,
1280 +        "%C :SPLIT: Cannot modify SPLIT %s - server is linked.", sptr, split->sp_server);
1281 +
1282 +    /* SPLIT is not for a server part of a netmerge - free it */
1283 +    if (!SplitIsBurst(split))
1284 +      split_free(split);
1285 +    return 0;
1286 +  }
1287 +
1288 +  /* check lastmod */
1289 +  /* check if my oper modifies the SPLIT
1290 +   * in which case use the greater of lastmod and split->sp_lastmod+1
1291 +   *
1292 +   * because if the lastmod of the split is in the future (greater than TStime())
1293 +   * my oper cannot modify it when we use TStime() as lastmod
1294 +   * therefore use split->sp_lastmod+1 - ugly hack, but the only way in that situation
1295 +   * to modify it, apart from force removing it first..
1296 +   */
1297 +  if (MyUser(sptr))
1298 +    lastmod = IRCD_MAX(lastmod, split->sp_lastmod + 1);
1299 +  /* we have a more recent version */
1300 +  if (split->sp_lastmod > lastmod) {
1301 +    /* middle of a burst, it will resync on its own */
1302 +    if (IsBurstOrBurstAck(cptr))
1303 +      return 0;
1304 +    /* resync the server */
1305 +    return split_resend(cptr, split);
1306 +  /* same version */
1307 +  } else if (split->sp_lastmod == lastmod)
1308 +     return 0;
1309 +
1310 +  /* lastmod is more than SPLIT_MAX_DRIFT seconds ahead of our idea of time
1311 +   *   correct and warn ops
1312 +   *
1313 +   *   not in case it is my oper
1314 +   *   we use the lastmod of either TStime() or the lastmod we have plus 1 second
1315 +   *   see above
1316 +   */
1317 +  if (lastmod - TStime() > SPLIT_MAX_DRIFT && !MyUser(sptr)) {
1318 +    sendto_opmask_butone_ratelimited(0, SNO_NETWORK, &rate,
1319 +      "Possible timestamp drift from %C; lastmod in SPLIT message is %is ahead of time",
1320 +      IsServer(sptr) ? sptr : cli_user(sptr)->server, lastmod - TStime());
1321 +    lastmod = TStime() + SPLIT_MAX_DRIFT;
1322 +  }
1323 +
1324 +  /* we got here so there is a change of some sort */
1325 +
1326 +  /* check out the expiration time */
1327 +  if (flags & SPLIT_EXPIRE) {
1328 +    if (expire != split->sp_expire) {
1329 +      /* bad expiration time */
1330 +      if (MyUser(sptr) && (expire < TStime() || expire - TStime() > SPLIT_MAX_EXPIRE))
1331 +        return send_reply(sptr, ERR_BADEXPIRE, expire - TStime());
1332 +      /* expire timestamp is in the past, so remap to deactivate */
1333 +      if (expire < TStime() && action == SPLIT_ACTIVATE)
1334 +        action = SPLIT_DEACTIVATE;
1335 +    } else
1336 +      flags &= ~SPLIT_EXPIRE;
1337 +  }
1338 +
1339 +  /* check out lifetime */
1340 +  if (!(flags & SPLIT_LIFETIME) || !lifetime)
1341 +    lifetime = split->sp_lifetime; /* use Split lifetime */
1342 +
1343 +  /* raise lifetime when required */
1344 +  lifetime = IRCD_MAX(lifetime, expire);
1345 +
1346 +  /* SPLIT already expired with this lifetime */
1347 +  if (lifetime - TStime() <= 0)
1348 +    return 0;
1349 +
1350 +  /* check if lifetime needs to be updated */
1351 +  if (lifetime > split->sp_lifetime)
1352 +    flags |= SPLIT_LIFETIME;
1353 +  else {
1354 +    flags &= ~SPLIT_LIFETIME;
1355 +    lifetime = 0;
1356 +  }
1357 +
1358 +  /* no changes to the reason - empty or the same */
1359 +  if ((flags & SPLIT_REASON) &&
1360 +      (EmptyString(reason) || !ircd_strcmp(split->sp_reason, reason)))
1361 +    flags &= ~SPLIT_REASON;
1362 +
1363 +  /* no status change
1364 +   *  activate but split is active
1365 +   *  deactivate but split is deactivated
1366 +   *  expire timestamp is in the past so it should be deactivated
1367 +   *    and cannot be activated anymore
1368 +   */
1369 +  if ((action == SPLIT_ACTIVATE && SplitIsActive(split)) ||
1370 +      (action == SPLIT_DEACTIVATE && !SplitIsActive(split)) ||
1371 +      (IRCD_MAX(split->sp_expire, expire) <= TStime()))
1372 +    action = SPLIT_MODIFY;
1373 +
1374 +  /* debug */
1375 +  Debug((DEBUG_DEBUG,  "About to perform changes; flags 0x%04x, action %s",
1376 +        flags, action == SPLIT_ACTIVATE ? "SPLIT_ACTIVATE" :
1377 +        (action == SPLIT_DEACTIVATE ? "SPLIT_DEACTIVATE" :
1378 +     (action == SPLIT_MODIFY ? "SPLIT_MODIFY" : "<UNKNOWN>"))));
1379 +
1380 +  /* nothing to change at all */
1381 +  if (!(flags & SPLIT_UPDATE) && action == SPLIT_MODIFY) {
1382 +    if (MyUser(sptr))
1383 +      sendcmdto_one(&me, CMD_NOTICE, sptr,
1384 +        "%C :SPLIT: Cannot modify SPLIT %s - nothing to change.", sptr, split->sp_server);
1385 +    return 0;
1386 +  }
1387 +
1388 +  /* update lastmod */
1389 +  split->sp_lastmod = lastmod;
1390 +
1391 +  /* update status */
1392 +  switch (action) {
1393 +
1394 +  /* activating split entry */
1395 +  case SPLIT_ACTIVATE:
1396 +    split->sp_flags |= SPLIT_ACTIVE;
1397 +    pos += ircd_snprintf(0, buf, sizeof(buf), " activating SPLIT");
1398 +    break;
1399 +
1400 +  /* deactivating split entry */
1401 +  case SPLIT_DEACTIVATE:
1402 +    split->sp_flags &= ~SPLIT_ACTIVE;
1403 +    pos += ircd_snprintf(0, buf, sizeof(buf), " deactivating SPLIT");
1404 +    break;
1405 +
1406 +  /* no change to activity status */
1407 +  case SPLIT_MODIFY:
1408 +    break;
1409 +  }
1410 +
1411 +
1412 +  /* update expire */
1413 +  if (flags & SPLIT_EXPIRE) {
1414 +    split->sp_expire = expire;
1415 +    if (pos < BUFSIZE)
1416 +      pos += ircd_snprintf(0, buf + pos, sizeof(buf) - pos,
1417 +               "%s%s changing expiration time to %Tu",
1418 +               pos ? ";" : "",
1419 +               pos && !(flags & (SPLIT_LIFETIME | SPLIT_REASON)) ?
1420 +               " and" : "", expire);
1421 +  }
1422 +
1423 +  /* update lifetime */
1424 +  if (flags & SPLIT_LIFETIME) {
1425 +    split->sp_lifetime = lifetime;
1426 +    if (pos < BUFSIZE)
1427 +      pos += ircd_snprintf(0, buf + pos, sizeof(buf) - pos,
1428 +               "%s%s extending record lifetime to %Tu",
1429 +               pos ? ";" : "", pos && !(flags & SPLIT_REASON) ?
1430 +               " and" : "", lifetime);
1431 +  }
1432 +
1433 +  /* update reason */
1434 +  if (flags & SPLIT_REASON) {
1435 +    MyFree(split->sp_reason);
1436 +    ircd_strncpy(sp_reason, reason, TOPICLEN);
1437 +    DupString(split->sp_reason, sp_reason);
1438 +    if (pos < BUFSIZE)
1439 +      pos += ircd_snprintf(0, buf + pos, sizeof(buf) - pos,
1440 +               "%s%s changing reason to \"%s\"",
1441 +               pos ? ";" : "", pos ? " and" : "", sp_reason);
1442 +  }
1443 +
1444 +  /* inform ops */
1445 +  sendto_opmask_butone(0, SNO_NETWORK, "%s modifying SPLIT for %s:%s",
1446 +    (feature_bool(FEAT_HIS_SNOTICES) || IsServer(sptr)) ?
1447 +      get_client_name_and_opername(sptr) : cli_name((cli_user(sptr))->server),
1448 +    split->sp_server, buf);
1449 +
1450 +  /* log it */
1451 +  log_write(LS_SPLIT, L_INFO, LOG_NOSNOTICE,
1452 +    "%#C modifying SPLIT for %s:%s",
1453 +    sptr, split->sp_server, buf);
1454 +
1455 +  /* and propagate it */
1456 +  split_propagate(cptr, sptr, split, NULL);
1457 +
1458 +  return 0;
1459 +}
1460 +
1461 +
1462 +/** Remove a split entry.
1463 + * @param[in] cptr Local client that sent us the split entry.
1464 + * @param[in] sptr Originator of the split entry.
1465 + * @param[in] split Split entry to remove.
1466 + * @param[in] reason  Reason for removing this split entry.
1467 + * @return Zero.
1468 + */
1469 +int
1470 +split_remove(struct Client *cptr, struct Client *sptr, struct Split *split, const char *reason)
1471 +{
1472 +  unsigned int saveflags = 0;
1473 +
1474 +  assert(NULL != split);
1475 +  assert(NULL != cptr);
1476 +  assert(NULL != sptr);
1477 +
1478 +  /* debug */
1479 +  Debug((DEBUG_DEBUG, "split_remove(\"%s\", \"%s\", \"%s\", \"%s\")",
1480 +    cli_name(cptr), cli_name(sptr), split->sp_server, reason));
1481 +
1482 +  /* deactivate entry and mark it for removal (used in split_propagate) */
1483 +  split->sp_flags |= SPLIT_REMOVING;
1484 +  split->sp_flags &= ~SPLIT_ACTIVE;
1485 +
1486 +  /* inform ops */
1487 +  sendto_opmask_butone(0, SNO_NETWORK, "%s removing SPLIT for %s, expiring at %Tu: %s (%s)",
1488 +    (feature_bool(FEAT_HIS_SNOTICES) || IsServer(sptr)) ?
1489 +      get_client_name_and_opername(sptr) : cli_name((cli_user(sptr))->server),
1490 +    split->sp_server, split->sp_expire, split->sp_reason, reason);
1491 +
1492 +  /* log it */
1493 +  log_write(LS_SPLIT, L_INFO, LOG_NOSNOTICE,
1494 +    "%#C removing SPLIT for %s, expiring at %Tu: %s (%s)",
1495 +    sptr, split->sp_server, split->sp_expire, split->sp_reason, reason);
1496 +
1497 +  /* propagate it */
1498 +  split_propagate(cptr, sptr, split, reason);
1499 +
1500 +  /* destroy it */
1501 +  split_free(split);
1502 +
1503 +  return 0;
1504 +}
1505 +
1506 +
1507 +/** Find a split entry by name.
1508 + * @param[in] server Split entry name to search for.
1509 + * @return Matching split entry (or NULL if none match).
1510 + */
1511 +struct Split *
1512 +split_find(char *server)
1513 +{
1514 +  struct Split* split;
1515 +  struct Split* ssplit;
1516 +
1517 +  /* go over SPLITs */
1518 +  for (split = GlobalSplitList; split; split = ssplit) {
1519 +    ssplit = split->sp_next;
1520 +
1521 +    /* expire any that need expiring */
1522 +    if (split_expire(split))
1523 +      split_free(split);
1524 +
1525 +   /* found it */
1526 +    else if (0 == ircd_strcmp(server, split->sp_server))
1527 +      return split;
1528 +  }
1529 +
1530 +  /* nothing found */
1531 +  return NULL;
1532 +}
1533 +
1534 +/** Unlink and free an unused split entry.
1535 + * @param[in] split Server split entry to free.
1536 + */
1537 +void
1538 +split_free(struct Split* split)
1539 +{
1540 +  assert(NULL != split);
1541 +
1542 +  /* squeeze this split entry out */
1543 +  *split->sp_prev_p = split->sp_next;
1544 +  if (split->sp_next)
1545 +    split->sp_next->sp_prev_p = split->sp_prev_p;
1546 +
1547 +  /* and free up the memory */
1548 +  MyFree(split->sp_server);
1549 +  MyFree(split->sp_reason);
1550 +  MyFree(split);
1551 +}
1552 +
1553 +
1554 +/** Check whether a split entry has past its life time.
1555 + *   when entry is active and past expire time, but not life time, deactivate it
1556 + * @param[in] split Server split entry to check.
1557 + * @return 1 when entry can be free'd, 0 otherwise.
1558 + */
1559 +int
1560 +split_expire(struct Split* split)
1561 +{
1562 +  assert(NULL != split);
1563 +
1564 +  /* TODO: also check if the server in SPLIT entry is linked atm? */
1565 +  /* past lifetime */
1566 +  if (split->sp_lifetime <= TStime())
1567 +    return 1;
1568 +
1569 +  /* past expire time, deactivate entry if it is active */
1570 +  if ((split->sp_expire <= TStime()) && SplitIsActive(split))
1571 +    split->sp_flags &= ~SPLIT_ACTIVE;
1572 +
1573 +  return 0;
1574 +}
1575 +
1576 +/** Send the full list of split entries to \a cptr.
1577 + * @param[in] cptr Local server to send split entries to.
1578 + */
1579 +void
1580 +split_burst(struct Client *cptr)
1581 +{
1582 +  struct Split *split;
1583 +  struct Split *ssplit;
1584 +
1585 +  assert(NULL != cptr);
1586 +
1587 +  /* go over SPLITs */
1588 +  for (split = GlobalSplitList; split; split = ssplit) {
1589 +    ssplit = split->sp_next;
1590 +
1591 +    /* expire any that need expiring */
1592 +    if (split_expire(split)) {
1593 +      split_free(split);
1594 +      continue;
1595 +    }
1596 +
1597 +    /* if we have an entry for cptr, dont send it - but do not free here yet
1598 +     *   free it at end of burst, to get the correct count for SPLITs removed.
1599 +     */
1600 +    if (ircd_strcmp(split->sp_server, cli_name(cptr)) == 0)
1601 +      continue;
1602 +
1603 +    /* send it */
1604 +    sendcmdto_one(&me, CMD_SPLIT, cptr, "%c%s %Tu %Tu %Tu %Tu :%s",
1605 +      SplitIsActive(split) ? '+' : '-', split->sp_server,
1606 +      split->sp_creation, split->sp_expire,
1607 +      split->sp_lastmod, split->sp_lifetime,
1608 +      split->sp_reason);
1609 +  }
1610 +}
1611 +
1612 +/** Forward a split to another server.
1613 + * @param[in] cptr Server to send split entries to.
1614 + * @param[in] split Split to forward.
1615 + * @return Zero.
1616 + */
1617 +int
1618 +split_resend(struct Client *cptr, struct Split *split)
1619 +{
1620 +  sendcmdto_one(&me, CMD_SPLIT, cptr, "%c%s %Tu %Tu %Tu %Tu :%s",
1621 +    SplitIsActive(split) ? '+' : '-', split->sp_server,
1622 +    split->sp_creation, split->sp_expire,
1623 +    split->sp_lastmod, split->sp_lifetime,
1624 +    split->sp_reason);
1625 +
1626 +  return 0;
1627 +}
1628 +
1629 +/** List split entries to a client.
1630 + * @param[in] sptr Client searching for split entries.
1631 + * @param[in] server Name of split entry to search for (if NULL, list all).
1632 + * @return Zero.
1633 + */
1634 +int
1635 +split_list(struct Client *sptr, char *server)
1636 +{
1637 +  struct Split *split;
1638 +  int count = 0;
1639 +
1640 +  assert(NULL != sptr);
1641 +
1642 +  /* go through SPLITs */
1643 +  for (split = GlobalSplitList; split; split = split->sp_next) {
1644 +
1645 +    /* expire any that need expiring */
1646 +    if (split_expire(split)) {
1647 +      split_free(split);
1648 +      continue;
1649 +    }
1650 +
1651 +    /* server given and does not match */
1652 +    if (server && match(server, split->sp_server))
1653 +      continue;
1654 +
1655 +    /* got one */
1656 +    count++;
1657 +    send_reply(sptr, RPL_SPLITLIST, split->sp_server,
1658 +      split->sp_creation, split->sp_expire, split->sp_lastmod, split->sp_lifetime,
1659 +      SplitIsActive(split) ? '+' : '-', split->sp_reason);
1660 +  }
1661 +
1662 +  /* server given and nothing found */
1663 +  if (server && !count)
1664 +    return send_reply(sptr, ERR_NOSUCHSPLIT, server);
1665 +
1666 +  /* end of splitlist information */
1667 +  return send_reply(sptr, RPL_ENDOFSPLITLIST);
1668 +}
1669 +
1670 +
1671 +/** Mark SPLIT for new server with SPLIT_BURST
1672 + * @param[in] acptr Server introduced to the network
1673 + */
1674 +void
1675 +split_newserver(struct Client *acptr)
1676 +{
1677 +  struct Split *split;
1678 +
1679 +  assert(NULL != acptr);
1680 +
1681 +  /* debug */
1682 +  Debug((DEBUG_DEBUG, "split_newserver(\"%s\")", cli_name(acptr)));
1683 +
1684 +  /* mark the SPLIT with SPLIT_BURST
1685 +   *  so we know this SPLIT is marked for removal already
1686 +   *  but not remove it just yet to get the correct count
1687 +   *  of SPLITs removed at the end of burst.
1688 +   *
1689 +   *  also we need the SPLIT in case the net breaks again
1690 +   *  before end of burst?
1691 +   */
1692 +  if ((split = split_find(cli_name(acptr))))
1693 +    split->sp_flags |= SPLIT_BURST;
1694 +}
1695 +
1696 +
1697 +/** Auto destroy SPLITs for servers gained in a netmerge
1698 + * @param[in] sptr Server that has linked to the network
1699 + * @return Number of destroyed SPLITs
1700 + */
1701 +int
1702 +split_netmerge(struct Client *sptr)
1703 +{
1704 +  struct DLink *lp;
1705 +  struct Split *split;
1706 +  int count = 0;
1707 +
1708 +  assert(NULL != sptr);
1709 +
1710 +  /* debug */
1711 +  Debug((DEBUG_DEBUG, "split_netmerge(\"%s\")", cli_name(sptr)));
1712 +
1713 +  /* find the SPLIT for this server */
1714 +  if ((split = split_find(cli_name(sptr)))) {
1715 +    split_free(split);
1716 +    count++;
1717 +  }
1718 +
1719 +  /* go over its downlinks */
1720 +  for (lp = cli_serv(sptr)->down; lp; lp = lp->next)
1721 +    count += split_netmerge(lp->value.cptr);
1722 +
1723 +  /* return the number of SPLITs removed */
1724 +  return count;
1725 +}
1726 +
1727 +
1728 +/** Auto create SPLITs for servers lost in a netbreak
1729 + * @param[in] victim Server that lost link to network
1730 + * @param[in] reason Reason to add to SPLITs
1731 + * @return Number of created SPLITs
1732 + */
1733 +int
1734 +split_netbreak(struct Client *victim, const char *reason)
1735 +{
1736 +  struct DLink *lp;
1737 +  struct Split *split;
1738 +  int count = 0;
1739 +  time_t creation = TStime(), expire = TStime() + feature_int(FEAT_SPLIT_AUTO_EXPIRE),
1740 +    lastmod = TStime(), lifetime = expire;
1741 +  unsigned int flags = SPLIT_ACTIVE;
1742 +
1743 +  assert(NULL != victim);
1744 +
1745 +  /* debug */
1746 +  Debug((DEBUG_DEBUG, "split_netbreak(\"%s\", \"%s\")", cli_name(victim), reason));
1747 +
1748 +  /* bad auto expire value */
1749 +  if (feature_int(FEAT_SPLIT_AUTO_EXPIRE) <= 0)
1750 +    return 0;
1751 +
1752 +  /* TODO: what if we do have a SPLIT for this server?
1753 +   * we remove splits in end of burst
1754 +   * and if the netbreaks again before that
1755 +   * free the SPLIT and create a new one?
1756 +   * or simply update lastmod/lifetime/reason but leave the status?
1757 +   */
1758 +  /* find the SPLIT for this server */
1759 +  if (!(split = split_find(cli_name(victim)))) {
1760 +    split_make(cli_name(victim), reason, creation, expire, lastmod, lifetime, flags);
1761 +    count++;
1762 +  } else
1763 +    /* clear the burst flag for it */
1764 +    split->sp_flags &= SPLIT_BURST;
1765 +
1766 +  /* go over its downlinks */
1767 +  for (lp = cli_serv(victim)->down; lp; lp = lp->next)
1768 +    count += split_netbreak(lp->value.cptr, reason);
1769 +
1770 +  /* return the number of SPLITs created */
1771 +  return count;
1772 +}
1773 +
1774 +
1775 +/** Auto create SPLITs for servers we have a Connect Block for
1776 + *
1777 + */
1778 +void
1779 +split_conf()
1780 +{
1781 +  struct ConfItem *conf;
1782 +  struct Split *split;
1783 +  time_t creation = TStime(), expire = TStime() + feature_int(FEAT_SPLIT_AUTO_EXPIRE),
1784 +    lastmod = TStime(), lifetime = expire;
1785 +  unsigned int flags = SPLIT_ACTIVE;
1786 +  char reason[BUFSIZE];
1787 +
1788 +  /* debug */
1789 +  Debug((DEBUG_DEBUG, "split_conf()"));
1790 +
1791 +  /* we are not set to generate SPLITs */
1792 +  if (!feature_bool(FEAT_SPLIT))
1793 +    return;
1794 +
1795 +  /* TODO: log this problem? */
1796 +  /* bad auto expire value */
1797 +  if (feature_int(FEAT_SPLIT_AUTO_EXPIRE) <= 0)
1798 +    return;
1799 +
1800 +  ircd_snprintf(0, reason, sizeof(reason),
1801 +    "Generated upon loading conf file on %C", &me);
1802 +
1803 +  /* go over the conf contents */
1804 +  for (conf = GlobalConfList; conf; conf = conf->next) {
1805 +
1806 +    /* not a Connect Block */
1807 +    if (CONF_SERVER != conf->status)
1808 +      continue;
1809 +
1810 +    /* server is linked */
1811 +    if (FindServer(conf->name))
1812 +      continue;
1813 +
1814 +    /* we have a SPLIT for this server already */
1815 +    if (split_find(conf->name))
1816 +      continue;
1817 +
1818 +    /* TODO: use SNO_OLDSNO here?
1819 +     * just like nickcollisions on local users go there?
1820 +     * or at least change the source / message format?
1821 +     * /REHASH goes to SNO_OLDSNO? so this too?
1822 +     * if oper did rehash, add his name here?
1823 +     */
1824 +    /* inform ops */
1825 +    sendto_opmask_butone(0, SNO_NETWORK, "%C adding SPLIT for %s, expiring at %Tu: %s",
1826 +      &me, conf->name, expire, reason);
1827 +
1828 +    /* log it */
1829 +    log_write(LS_SPLIT, L_INFO, LOG_NOSNOTICE,
1830 +      "%C adding SPLIT for %s, expiring at %Tu: %s",
1831 +      &me, conf->name, expire, reason);
1832 +
1833 +    /* make the split entry */
1834 +    split = split_make(conf->name, reason, creation, expire, lastmod, lifetime, flags);
1835 +
1836 +    /* got to have it now */
1837 +    assert(split);
1838 +
1839 +    /* and propagate it */
1840 +    split_propagate(&me, &me, split, NULL);
1841 +  }
1842 +}
1843 +
1844 +
1845 +/** Statistics callback to list SPLITs.
1846 + * @param[in] sptr Client requesting statistics.
1847 + * @param[in] sd Stats descriptor for request (ignored).
1848 + * @param[in] param Extra parameter from user (ignored).
1849 + */
1850 +void
1851 +split_stats(struct Client *sptr, const struct StatDesc *sd, char *param)
1852 +{
1853 +  struct Split *split;
1854 +
1855 +  /* send header so the client knows what we are showing */
1856 +  send_reply(sptr, SND_EXPLICIT | RPL_STATSHEADER,
1857 +    "S Server Creation Expire Lastmod Lifetime Status :Reason");
1858 +
1859 +  /* go over SPLIT entries */
1860 +  for (split = GlobalSplitList; split; split = split->sp_next) {
1861 +
1862 +    /* does not match */
1863 +    if (param && match(param, split->sp_server))
1864 +      continue;
1865 +
1866 +    /* send it */
1867 +    send_reply(sptr, RPL_STATSSPLIT, split->sp_server,
1868 +      split->sp_creation, split->sp_expire, split->sp_lastmod, split->sp_lifetime,
1869 +      SplitIsActive(split) ? '+' : '-', split->sp_reason);
1870 +  }
1871 +}
1872 +
1873 +
1874 +/** Count split entries and memory used by them.
1875 + * @param[out] sp_size Receives total number of bytes allocated for split entries.
1876 + * @return Number of split entries currently allocated.
1877 + */
1878 +int
1879 +split_memory_count(size_t *sp_size)
1880 +{
1881 +  struct Split *split;
1882 +  unsigned int sp = 0;
1883 +
1884 +  for (split = GlobalSplitList; split; split = split->sp_next) {
1885 +    sp++;
1886 +    *sp_size += sizeof(struct Split);
1887 +    *sp_size += split->sp_server ? (strlen(split->sp_server) + 1) : 0;
1888 +    *sp_size += split->sp_reason ? (strlen(split->sp_reason) + 1) : 0;
1889 +  }
1890 +  return sp;
1891 +}