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

Comparing:
ircd-hybrid-8/src/s_serv.c (file contents), Revision 1306 by michael, Sat Mar 24 07:43:04 2012 UTC vs.
ircd-hybrid/trunk/src/server.c (file contents), Revision 4113 by michael, Tue Jul 1 16:02:52 2014 UTC

# Line 1 | Line 1
1   /*
2 < *  ircd-hybrid: an advanced Internet Relay Chat Daemon(ircd).
3 < *  s_serv.c: Server related functions.
2 > *  ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3   *
4 < *  Copyright (C) 2005 by the past and present ircd coders, and others.
4 > *  Copyright (c) 1997-2014 ircd-hybrid development team
5   *
6   *  This program is free software; you can redistribute it and/or modify
7   *  it under the terms of the GNU General Public License as published by
# Line 18 | Line 17
17   *  along with this program; if not, write to the Free Software
18   *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307
19   *  USA
20 < *
21 < *  $Id$
20 > */
21 >
22 > /*! \file s_serv.c
23 > * \brief Server related functions.
24 > * \version $Id$
25   */
26  
27   #include "stdinc.h"
# Line 28 | Line 30
30   #include "rsa.h"
31   #endif
32   #include "list.h"
31 #include "channel.h"
32 #include "channel_mode.h"
33   #include "client.h"
34 #include "dbuf.h"
34   #include "event.h"
36 #include "fdlist.h"
35   #include "hash.h"
36   #include "irc_string.h"
39 #include "sprintf_irc.h"
37   #include "ircd.h"
38   #include "ircd_defs.h"
39   #include "s_bsd.h"
40   #include "numeric.h"
41   #include "packet.h"
42 < #include "irc_res.h"
43 < #include "s_conf.h"
44 < #include "s_serv.h"
45 < #include "s_log.h"
49 < #include "s_misc.h"
50 < #include "s_user.h"
42 > #include "conf.h"
43 > #include "server.h"
44 > #include "log.h"
45 > #include "user.h"
46   #include "send.h"
47   #include "memory.h"
48 < #include "channel.h" /* chcap_usage_counts stuff...*/
48 > #include "channel.h"
49   #include "parse.h"
50  
51   #define MIN_CONN_FREQ 300
52  
53 + dlink_list flatten_links;
54   static dlink_list cap_list = { NULL, NULL, 0 };
59 static void server_burst(struct Client *);
60 static void burst_all(struct Client *);
61 static void send_tb(struct Client *client_p, struct Channel *chptr);
62
55   static CNCB serv_connect_callback;
56  
65 static void start_io(struct Client *);
66 static void burst_members(struct Client *, struct Channel *);
57  
58   /*
59   * write_links_file
# Line 74 | Line 64 | static void burst_members(struct Client
64   *                but in no particular order.
65   */
66   void
67 < write_links_file(void* notused)
67 > write_links_file(void *notused)
68   {
69 <  MessageFileLine *next_mptr = 0;
70 <  MessageFileLine *mptr = 0;
71 <  MessageFileLine *currentMessageLine = 0;
82 <  MessageFileLine *newMessageLine = 0;
83 <  MessageFile *MessageFileptr;
84 <  const char *p;
85 <  FBFILE *file;
86 <  char buff[512];
87 <  dlink_node *ptr;
69 >  FILE *file = NULL;
70 >  dlink_node *ptr = NULL, *ptr_next = NULL;
71 >  char buff[IRCD_BUFSIZE] = "";
72  
73 <  MessageFileptr = &ConfigFileEntry.linksfile;
90 <
91 <  if ((file = fbopen(MessageFileptr->fileName, "w")) == NULL)
73 >  if ((file = fopen(LIPATH, "w")) == NULL)
74      return;
75  
76 <  for (mptr = MessageFileptr->contentsOfFile; mptr; mptr = next_mptr)
76 >  DLINK_FOREACH_SAFE(ptr, ptr_next, flatten_links.head)
77    {
78 <    next_mptr = mptr->next;
79 <    MyFree(mptr);
78 >    dlinkDelete(ptr, &flatten_links);
79 >    MyFree(ptr->data);
80 >    free_dlink_node(ptr);
81    }
82  
100  MessageFileptr->contentsOfFile = NULL;
101  currentMessageLine             = NULL;
102
83    DLINK_FOREACH(ptr, global_serv_list.head)
84    {
85 <    size_t nbytes = 0;
106 <    struct Client *target_p = ptr->data;
85 >    const struct Client *target_p = ptr->data;
86  
87 <    /* skip ourselves, we send ourselves in /links */
88 <    if (IsMe(target_p))
87 >    /*
88 >     * Skip hidden servers, aswell as ourselves, since we already send
89 >     * ourselves in /links
90 >     */
91 >    if (IsHidden(target_p) || IsMe(target_p))
92        continue;
93  
94 <    /* skip hidden servers */
113 <    if (IsHidden(target_p) && !ConfigServerHide.disable_hidden)
94 >    if (HasFlag(target_p, FLAGS_SERVICE) && ConfigServerHide.hide_services)
95        continue;
96  
97 <    if (target_p->info[0])
98 <      p = target_p->info;
118 <    else
119 <      p = "(Unknown Location)";
120 <
121 <    newMessageLine = MyMalloc(sizeof(MessageFileLine));
122 <
123 <    /* Attempt to format the file in such a way it follows the usual links output
97 >    /*
98 >     * Attempt to format the file in such a way it follows the usual links output
99       * ie  "servername uplink :hops info"
100       * Mostly for aesthetic reasons - makes it look pretty in mIRC ;)
101       * - madmax
102       */
103 +    snprintf(buff, sizeof(buff), "%s %s :1 %s",   target_p->name,
104 +             me.name, target_p->info);
105 +    dlinkAddTail(xstrdup(buff), make_dlink_node(), &flatten_links);
106 +    snprintf(buff, sizeof(buff), "%s %s :1 %s\n", target_p->name,
107 +             me.name, target_p->info);
108  
109 <    /*
110 <     * For now, check this ircsprintf wont overflow - it shouldnt on a
131 <     * default config but it is configurable..
132 <     * This should be changed to an snprintf at some point, but I'm wanting to
133 <     * know if this is a cause of a bug - cryogen
134 <     */
135 <    assert(strlen(target_p->name) + strlen(me.name) + 6 + strlen(p) <=
136 <            MESSAGELINELEN);
137 <    ircsprintf(newMessageLine->line, "%s %s :1 %s",
138 <               target_p->name, me.name, p);
139 <    newMessageLine->next = NULL;
109 >    fputs(buff, file);
110 >  }
111  
112 <    if (MessageFileptr->contentsOfFile)
113 <    {
143 <      if (currentMessageLine)
144 <        currentMessageLine->next = newMessageLine;
145 <      currentMessageLine = newMessageLine;
146 <    }
147 <    else
148 <    {
149 <      MessageFileptr->contentsOfFile = newMessageLine;
150 <      currentMessageLine = newMessageLine;
151 <    }
112 >  fclose(file);
113 > }
114  
115 <    nbytes = ircsprintf(buff, "%s %s :1 %s\n", target_p->name, me.name, p);
116 <    fbputs(buff, file, nbytes);
115 > void
116 > read_links_file(void)
117 > {
118 >  FILE *file = NULL;
119 >  char *p = NULL;
120 >  char buff[IRCD_BUFSIZE] = "";
121 >
122 >  if ((file = fopen(LIPATH, "r")) == NULL)
123 >    return;
124 >
125 >  while (fgets(buff, sizeof(buff), file))
126 >  {
127 >    if ((p = strchr(buff, '\n')))
128 >      *p = '\0';
129 >
130 >    dlinkAddTail(xstrdup(buff), make_dlink_node(), &flatten_links);
131    }
132  
133 <  fbclose(file);
133 >  fclose(file);
134   }
135  
136   /* hunt_server()
# Line 177 | Line 153 | write_links_file(void* notused)
153   *      returns: (see #defines)
154   */
155   int
156 < hunt_server(struct Client *client_p, struct Client *source_p, const char *command,
157 <            int server, int parc, char *parv[])
156 > hunt_server(struct Client *source_p, const char *command,
157 >            const int server, const int parc, char *parv[])
158   {
159    struct Client *target_p = NULL;
160    struct Client *target_tmp = NULL;
161    dlink_node *ptr;
186  int wilds;
162  
163 <  /* Assume it's me, if no server
164 <   */
165 <  if (parc <= server || EmptyString(parv[server]) ||
166 <      match(me.name, parv[server]) ||
167 <      match(parv[server], me.name) ||
168 <      !strcmp(parv[server], me.id))
194 <    return(HUNTED_ISME);
163 >  /* Assume it's me, if no server */
164 >  if (parc <= server || EmptyString(parv[server]))
165 >    return HUNTED_ISME;
166 >
167 >  if (!strcmp(parv[server], me.id) || !match(parv[server], me.name))
168 >    return HUNTED_ISME;
169  
170    /* These are to pickup matches that would cause the following
171     * message to go in the wrong direction while doing quick fast
# Line 200 | Line 174 | hunt_server(struct Client *client_p, str
174    if (MyClient(source_p))
175      target_p = hash_find_client(parv[server]);
176    else
177 <    target_p = find_person(client_p, parv[server]);
177 >    target_p = find_person(source_p, parv[server]);
178  
179    if (target_p)
180      if (target_p->from == source_p->from && !MyConnect(target_p))
# Line 210 | Line 184 | hunt_server(struct Client *client_p, str
184      if (target_p->from == source_p->from && !MyConnect(target_p))
185        target_p = NULL;
186  
213  collapse(parv[server]);
214  wilds = (strchr(parv[server], '?') || strchr(parv[server], '*'));
215
187    /* Again, if there are no wild cards involved in the server
188     * name, use the hash lookup
189     */
190    if (target_p == NULL)
191    {
192 <    if (!wilds)
192 >    if (!has_wildcards(parv[server]))
193      {
194        if (!(target_p = hash_find_server(parv[server])))
195        {
196 <        sendto_one(source_p, form_str(ERR_NOSUCHSERVER),
197 <                   me.name, source_p->name, parv[server]);
227 <        return(HUNTED_NOSUCH);
196 >        sendto_one_numeric(source_p, &me, ERR_NOSUCHSERVER, parv[server]);
197 >        return HUNTED_NOSUCH;
198        }
199      }
200      else
# Line 233 | Line 203 | hunt_server(struct Client *client_p, str
203        {
204          target_tmp = ptr->data;
205  
206 <        if (match(parv[server], target_tmp->name))
206 >        if (!match(parv[server], target_tmp->name))
207          {
208            if (target_tmp->from == source_p->from && !MyConnect(target_tmp))
209              continue;
210            target_p = ptr->data;
211  
212 <          if (IsRegistered(target_p) && (target_p != client_p))
212 >          if (IsRegistered(target_p) && (target_p != source_p->from))
213              break;
214          }
215        }
216      }
217    }
218  
219 <  if (target_p != NULL)
219 >  if (target_p)
220    {
221 <    if(!IsRegistered(target_p))
221 >    if (!IsRegistered(target_p))
222      {
223 <      sendto_one(source_p, form_str(ERR_NOSUCHSERVER),
254 <                 me.name, source_p->name, parv[server]);
223 >      sendto_one_numeric(source_p, &me, ERR_NOSUCHSERVER, parv[server]);
224        return HUNTED_NOSUCH;
225      }
226  
227      if (IsMe(target_p) || MyClient(target_p))
228        return HUNTED_ISME;
229  
230 <    if (!match(target_p->name, parv[server]))
230 >    if (match(target_p->name, parv[server]))
231        parv[server] = target_p->name;
232  
233      /* This is a little kludgy but should work... */
234 <    if (IsClient(source_p) &&
266 <        ((MyConnect(target_p) && IsCapable(target_p, CAP_TS6)) ||
267 <         (!MyConnect(target_p) && IsCapable(target_p->from, CAP_TS6))))
268 <      parv[0] = ID(source_p);
269 <
270 <    sendto_one(target_p, command, parv[0],
234 >    sendto_one(target_p, command, ID_or_name(source_p, target_p),
235                 parv[1], parv[2], parv[3], parv[4],
236                 parv[5], parv[6], parv[7], parv[8]);
237 <    return(HUNTED_PASS);
238 <  }
237 >    return HUNTED_PASS;
238 >  }
239  
240 <  sendto_one(source_p, form_str(ERR_NOSUCHSERVER),
241 <             me.name, source_p->name, parv[server]);
278 <  return(HUNTED_NOSUCH);
240 >  sendto_one_numeric(source_p, &me, ERR_NOSUCHSERVER, parv[server]);
241 >  return HUNTED_NOSUCH;
242   }
243  
244   /* try_connections()
# Line 291 | Line 254 | hunt_server(struct Client *client_p, str
254   void
255   try_connections(void *unused)
256   {
257 <  dlink_node *ptr;
258 <  struct ConfItem *conf;
296 <  struct AccessItem *aconf;
297 <  struct ClassItem *cltmp;
298 <  int confrq;
257 >  dlink_node *ptr = NULL;
258 >  int confrq = 0;
259  
260    /* TODO: change this to set active flag to 0 when added to event! --Habeeb */
261    if (GlobalSetOptions.autoconn == 0)
# Line 303 | Line 263 | try_connections(void *unused)
263  
264    DLINK_FOREACH(ptr, server_items.head)
265    {
266 <    conf = ptr->data;
267 <    aconf = map_to_conf(conf);
266 >    struct MaskItem *conf = ptr->data;
267 >
268 >    assert(conf->type == CONF_SERVER);
269  
270 <    /* Also when already connecting! (update holdtimes) --SRB
270 >    /* Also when already connecting! (update holdtimes) --SRB
271       */
272 <    if (!(aconf->status & CONF_SERVER) || !aconf->port ||
312 <        !(IsConfAllowAutoConn(aconf)))
272 >    if (!conf->port ||!IsConfAllowAutoConn(conf))
273        continue;
274  
315    cltmp = map_to_conf(aconf->class_ptr);
275  
276      /* Skip this entry if the use of it is still on hold until
277       * future. Otherwise handle this entry (and set it on hold
# Line 320 | Line 279 | try_connections(void *unused)
279       * made one successfull connection... [this algorithm is
280       * a bit fuzzy... -- msa >;) ]
281       */
282 <    if (aconf->hold > CurrentTime)
282 >    if (conf->until > CurrentTime)
283        continue;
284  
285 <    if (cltmp == NULL)
286 <      confrq = DEFAULT_CONNECTFREQUENCY;
287 <    else
288 <    {
289 <      confrq = ConFreq(cltmp);
331 <      if (confrq < MIN_CONN_FREQ )
332 <        confrq = MIN_CONN_FREQ;
333 <    }
285 >    assert(conf->class);
286 >
287 >    confrq = conf->class->con_freq;
288 >    if (confrq < MIN_CONN_FREQ)
289 >      confrq = MIN_CONN_FREQ;
290  
291 <    aconf->hold = CurrentTime + confrq;
291 >    conf->until = CurrentTime + confrq;
292  
293 <    /* Found a CONNECT config with port specified, scan clients
293 >    /*
294 >     * Found a CONNECT config with port specified, scan clients
295       * and see if this server is already connected?
296       */
297 <    if (hash_find_server(conf->name) != NULL)
297 >    if (hash_find_server(conf->name))
298        continue;
299  
300 <    if (CurrUserCount(cltmp) < MaxTotal(cltmp))
300 >    if (conf->class->ref_count < conf->class->max_total)
301      {
302        /* Go to the end of the list, if not already last */
303 <      if (ptr->next != NULL)
303 >      if (ptr->next)
304        {
305          dlinkDelete(ptr, &server_items);
306          dlinkAddTail(conf, &conf->node, &server_items);
# Line 352 | Line 309 | try_connections(void *unused)
309        if (find_servconn_in_progress(conf->name))
310          return;
311  
312 <      /* We used to only print this if serv_connect() actually
312 >      /*
313 >       * We used to only print this if serv_connect() actually
314         * succeeded, but since comm_tcp_connect() can call the callback
315         * immediately if there is an error, we were getting error messages
316         * in the wrong order. SO, we just print out the activated line,
# Line 361 | Line 319 | try_connections(void *unused)
319         *   -- adrian
320         */
321        if (ConfigServerHide.hide_server_ips)
322 <        sendto_realops_flags(UMODE_ALL, L_ALL, "Connection to %s activated.",
322 >        sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
323 >                             "Connection to %s activated.",
324                               conf->name);
325        else
326 <        sendto_realops_flags(UMODE_ALL, L_ALL, "Connection to %s[%s] activated.",
327 <                             conf->name, aconf->host);
326 >        sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
327 >                             "Connection to %s[%s] activated.",
328 >                             conf->name, conf->host);
329  
330 <      serv_connect(aconf, NULL);
330 >      serv_connect(conf, NULL);
331        /* We connect only one at time... */
332        return;
333      }
# Line 377 | Line 337 | try_connections(void *unused)
337   int
338   valid_servname(const char *name)
339   {
340 <  unsigned int length = 0;
381 <  unsigned int dots   = 0;
340 >  unsigned int dots = 0;
341    const char *p = name;
342  
343    for (; *p; ++p)
# Line 386 | Line 345 | valid_servname(const char *name)
345      if (!IsServChar(*p))
346        return 0;
347  
389    ++length;
390
348      if (*p == '.')
349        ++dots;
350    }
351  
352 <  return dots != 0 && length <= HOSTLEN;
352 >  return dots && (p - name) <= HOSTLEN;
353   }
354  
355   int
356   check_server(const char *name, struct Client *client_p)
357   {
358    dlink_node *ptr;
359 <  struct ConfItem *conf           = NULL;
360 <  struct ConfItem *server_conf    = NULL;
404 <  struct AccessItem *server_aconf = NULL;
405 <  struct AccessItem *aconf        = NULL;
359 >  struct MaskItem *conf        = NULL;
360 >  struct MaskItem *server_conf = NULL;
361    int error = -1;
362  
363 <  assert(client_p != NULL);
409 <
410 <  if (client_p == NULL)
411 <    return(error);
412 <
413 <  if (strlen(name) > HOSTLEN)
414 <    return(-4);
363 >  assert(client_p);
364  
365    /* loop through looking for all possible connect items that might work */
366    DLINK_FOREACH(ptr, server_items.head)
367    {
368      conf = ptr->data;
420    aconf = map_to_conf(conf);
369  
370 <    if (!match(name, conf->name))
370 >    if (match(name, conf->name))
371        continue;
372  
373      error = -3;
374  
375      /* XXX: Fix me for IPv6                    */
376      /* XXX sockhost is the IPv4 ip as a string */
377 <    if (match(aconf->host, client_p->host) ||
378 <        match(aconf->host, client_p->sockhost))
377 >    if (!match(conf->host, client_p->host) ||
378 >        !match(conf->host, client_p->sockhost))
379      {
380        error = -2;
433      {
434        /* A NULL password is as good as a bad one */
435        if (EmptyString(client_p->localClient->passwd))
436          return(-2);
437
438        /* code in s_conf.c should not have allowed this to be NULL */
439        if (aconf->passwd == NULL)
440          return(-2);
381  
382 <        if (IsConfEncrypted(aconf))
383 <        {
384 <          if (strcmp(aconf->passwd,
385 <              (const char *)crypt(client_p->localClient->passwd,
386 <                                  aconf->passwd)) == 0)
387 <            server_conf = conf;
388 <        }
389 <        else
450 <        {
451 <          if (strcmp(aconf->passwd, client_p->localClient->passwd) == 0)
452 <            server_conf = conf;
453 <        }
454 <      }
382 >      if (!match_conf_password(client_p->localClient->passwd, conf))
383 >        return -2;
384 >
385 >      if (!EmptyString(conf->certfp))
386 >        if (EmptyString(client_p->certfp) || strcasecmp(client_p->certfp, conf->certfp))
387 >          return -4;
388 >
389 >      server_conf = conf;
390      }
391    }
392  
393    if (server_conf == NULL)
394 <    return(error);
394 >    return error;
395  
396    attach_conf(client_p, server_conf);
397  
463  /* Now find all leaf or hub config items for this server */
464  DLINK_FOREACH(ptr, hub_items.head)
465  {
466    conf = ptr->data;
467
468    if (!match(name, conf->name))
469      continue;
470    attach_conf(client_p, conf);
471  }
472
473  DLINK_FOREACH(ptr, leaf_items.head)
474  {
475    conf = ptr->data;
476
477    if (!match(name, conf->name))
478      continue;
479    attach_conf(client_p, conf);
480  }
481
482  server_aconf = map_to_conf(server_conf);
483
484  if (!IsConfTopicBurst(server_aconf))
485  {
486    ClearCap(client_p, CAP_TB);
487    ClearCap(client_p, CAP_TBURST);
488  }
398  
399 <  if (aconf != NULL)
399 >  if (server_conf)
400    {
401      struct sockaddr_in *v4;
402   #ifdef IPV6
403      struct sockaddr_in6 *v6;
404   #endif
405 <    switch (aconf->aftype)
405 >    switch (server_conf->aftype)
406      {
407   #ifdef IPV6
408 <      case AF_INET6:
409 <        v6 = (struct sockaddr_in6 *)&aconf->ipnum;
408 >      case AF_INET6:
409 >        v6 = (struct sockaddr_in6 *)&server_conf->addr;
410  
411          if (IN6_IS_ADDR_UNSPECIFIED(&v6->sin6_addr))
412 <          memcpy(&aconf->ipnum, &client_p->localClient->ip, sizeof(struct irc_ssaddr));
412 >          memcpy(&server_conf->addr, &client_p->localClient->ip, sizeof(struct irc_ssaddr));
413          break;
414   #endif
415        case AF_INET:
416 <        v4 = (struct sockaddr_in *)&aconf->ipnum;
416 >        v4 = (struct sockaddr_in *)&server_conf->addr;
417  
418          if (v4->sin_addr.s_addr == INADDR_NONE)
419 <          memcpy(&aconf->ipnum, &client_p->localClient->ip, sizeof(struct irc_ssaddr));
419 >          memcpy(&server_conf->addr, &client_p->localClient->ip, sizeof(struct irc_ssaddr));
420          break;
421      }
422    }
423  
424 <  return(0);
424 >  return 0;
425   }
426  
427   /* add_capability()
# Line 527 | Line 436 | check_server(const char *name, struct Cl
436   void
437   add_capability(const char *capab_name, int cap_flag, int add_to_default)
438   {
439 <  struct Capability *cap = MyMalloc(sizeof(*cap));
439 >  struct Capability *cap = MyCalloc(sizeof(*cap));
440  
441 <  DupString(cap->name, capab_name);
441 >  cap->name = xstrdup(capab_name);
442    cap->cap = cap_flag;
443    dlinkAdd(cap, &cap->node, &cap_list);
444  
# Line 546 | Line 455 | add_capability(const char *capab_name, i
455   int
456   delete_capability(const char *capab_name)
457   {
458 <  dlink_node *ptr;
550 <  dlink_node *next_ptr;
551 <  struct Capability *cap;
458 >  dlink_node *ptr = NULL, *ptr_next = NULL;
459  
460 <  DLINK_FOREACH_SAFE(ptr, next_ptr, cap_list.head)
460 >  DLINK_FOREACH_SAFE(ptr, ptr_next, cap_list.head)
461    {
462 <    cap = ptr->data;
462 >    struct Capability *cap = ptr->data;
463  
464 <    if (cap->cap != 0)
464 >    if (cap->cap)
465      {
466 <      if (irccmp(cap->name, capab_name) == 0)
466 >      if (!irccmp(cap->name, capab_name))
467        {
468 <        default_server_capabs &= ~(cap->cap);
469 <        dlinkDelete(ptr, &cap_list);
470 <        MyFree(cap->name);
471 <        cap->name = NULL;
565 <        MyFree(cap);
468 >        default_server_capabs &= ~(cap->cap);
469 >        dlinkDelete(ptr, &cap_list);
470 >        MyFree(cap->name);
471 >        MyFree(cap);
472        }
473      }
474    }
# Line 577 | Line 483 | delete_capability(const char *capab_name
483   * output       - 0 if not found CAPAB otherwise
484   * side effects - none
485   */
486 < int
486 > unsigned int
487   find_capability(const char *capab)
488   {
489    const dlink_node *ptr = NULL;
# Line 596 | Line 502 | find_capability(const char *capab)
502   /* send_capabilities()
503   *
504   * inputs       - Client pointer to send to
599 *              - Pointer to AccessItem (for crypt)
505   *              - int flag of capabilities that this server can send
506   * output       - NONE
507   * side effects - send the CAPAB line to a server  -orabidoo
508   *
509   */
510   void
511 < send_capabilities(struct Client *client_p, struct AccessItem *aconf,
607 <                  int cap_can_send)
511 > send_capabilities(struct Client *client_p, int cap_can_send)
512   {
513 <  struct Capability *cap=NULL;
514 <  char msgbuf[IRCD_BUFSIZE];
611 <  char *t;
612 <  int tl;
613 <  dlink_node *ptr;
614 <
615 <  t = msgbuf;
513 >  char buf[IRCD_BUFSIZE] = "";
514 >  const dlink_node *ptr = NULL;
515  
516    DLINK_FOREACH(ptr, cap_list.head)
517    {
518 <    cap = ptr->data;
518 >    const struct Capability *cap = ptr->data;
519  
520      if (cap->cap & (cap_can_send|default_server_capabs))
521      {
522 <      tl = ircsprintf(t, "%s ", cap->name);
523 <      t += tl;
522 >      strlcat(buf, cap->name, sizeof(buf));
523 >      if (ptr->next)
524 >        strlcat(buf, " ", sizeof(buf));
525      }
526    }
527  
528 <  *(t - 1) = '\0';
629 <  sendto_one(client_p, "CAPAB :%s", msgbuf);
630 < }
631 <
632 < /* sendnick_TS()
633 < *
634 < * inputs       - client (server) to send nick towards
635 < *          - client to send nick for
636 < * output       - NONE
637 < * side effects - NICK message is sent towards given client_p
638 < */
639 < void
640 < sendnick_TS(struct Client *client_p, struct Client *target_p)
641 < {
642 <  static char ubuf[12];
643 <
644 <  if (!IsClient(target_p))
645 <    return;
646 <
647 <  send_umode(NULL, target_p, 0, SEND_UMODES, ubuf);
648 <
649 <  if (ubuf[0] == '\0')
650 <  {
651 <    ubuf[0] = '+';
652 <    ubuf[1] = '\0';
653 <  }
654 <
655 <  /* XXX Both of these need to have a :me.name or :mySID!?!?! */
656 <  if (IsCapable(client_p, CAP_SVS))
657 <  {
658 <    if (HasID(target_p) && IsCapable(client_p, CAP_TS6))
659 <      sendto_one(client_p, ":%s UID %s %d %lu %s %s %s %s %s %lu :%s",
660 <                 target_p->servptr->id,
661 <                 target_p->name, target_p->hopcount + 1,
662 <                 (unsigned long) target_p->tsinfo,
663 <                 ubuf, target_p->username, target_p->host,
664 <                 (MyClient(target_p) && IsIPSpoof(target_p)) ?
665 <                 "0" : target_p->sockhost, target_p->id,
666 <                 (unsigned long)target_p->servicestamp, target_p->info);
667 <    else
668 <      sendto_one(client_p, "NICK %s %d %lu %s %s %s %s %lu :%s",
669 <                 target_p->name, target_p->hopcount + 1,
670 <                 (unsigned long) target_p->tsinfo,
671 <                 ubuf, target_p->username, target_p->host,
672 <                 target_p->servptr->name, (unsigned long)target_p->servicestamp,
673 <                 target_p->info);
674 <  }
675 <  else
676 <  {
677 <    if (HasID(target_p) && IsCapable(client_p, CAP_TS6))
678 <      sendto_one(client_p, ":%s UID %s %d %lu %s %s %s %s %s :%s",
679 <                 target_p->servptr->id,
680 <                 target_p->name, target_p->hopcount + 1,
681 <                 (unsigned long) target_p->tsinfo,
682 <                 ubuf, target_p->username, target_p->host,
683 <                 (MyClient(target_p) && IsIPSpoof(target_p)) ?
684 <                 "0" : target_p->sockhost, target_p->id, target_p->info);
685 <    else
686 <      sendto_one(client_p, "NICK %s %d %lu %s %s %s %s :%s",
687 <                 target_p->name, target_p->hopcount + 1,
688 <                 (unsigned long) target_p->tsinfo,
689 <                 ubuf, target_p->username, target_p->host,
690 <                 target_p->servptr->name, target_p->info);
691 <  }
692 <
693 <  if (IsConfAwayBurst((struct AccessItem *)map_to_conf(client_p->serv->sconf)))
694 <    if (!EmptyString(target_p->away))
695 <      sendto_one(client_p, ":%s AWAY :%s", target_p->name,
696 <                 target_p->away);
697 <
528 >  sendto_one(client_p, "CAPAB :%s", buf);
529   }
530  
531   /*
# Line 705 | Line 536 | sendnick_TS(struct Client *client_p, str
536   * side effects - build up string representing capabilities of server listed
537   */
538   const char *
539 < show_capabilities(struct Client *target_p)
539 > show_capabilities(const struct Client *target_p)
540   {
541 <  static char msgbuf[IRCD_BUFSIZE];
542 <  char *t = msgbuf;
712 <  dlink_node *ptr;
541 >  static char msgbuf[IRCD_BUFSIZE] = "";
542 >  const dlink_node *ptr = NULL;
543  
544 <  t += ircsprintf(msgbuf, "TS ");
544 >  strlcpy(msgbuf, "TS", sizeof(msgbuf));
545  
546    DLINK_FOREACH(ptr, cap_list.head)
547    {
548      const struct Capability *cap = ptr->data;
549  
550 <    if (IsCapable(target_p, cap->cap))
551 <      t += ircsprintf(t, "%s ", cap->name);
550 >    if (!IsCapable(target_p, cap->cap))
551 >      continue;
552 >
553 >    strlcat(msgbuf,       " ", sizeof(msgbuf));
554 >    strlcat(msgbuf, cap->name, sizeof(msgbuf));
555    }
556  
724  *(t - 1) = '\0';
557    return msgbuf;
558   }
559  
# Line 736 | Line 568 | struct Server *
568   make_server(struct Client *client_p)
569   {
570    if (client_p->serv == NULL)
571 <    client_p->serv = MyMalloc(sizeof(struct Server));
571 >    client_p->serv = MyCalloc(sizeof(struct Server));
572  
573    return client_p->serv;
574   }
575  
744 /* server_estab()
745 *
746 * inputs       - pointer to a struct Client
747 * output       -
748 * side effects -
749 */
750 void
751 server_estab(struct Client *client_p)
752 {
753  struct Client *target_p;
754  struct ConfItem *conf;
755  struct AccessItem *aconf=NULL;
756  char *host;
757  const char *inpath;
758  static char inpath_ip[HOSTLEN * 2 + USERLEN + 6];
759  dlink_node *ptr;
760 #ifdef HAVE_LIBCRYPTO
761  const COMP_METHOD *compression = NULL, *expansion = NULL;
762 #endif
763
764  assert(client_p != NULL);
765
766  strlcpy(inpath_ip, get_client_name(client_p, SHOW_IP), sizeof(inpath_ip));
767
768  inpath = get_client_name(client_p, MASK_IP); /* "refresh" inpath with host */
769  host   = client_p->name;
770
771  if ((conf = find_conf_name(&client_p->localClient->confs, host, SERVER_TYPE))
772      == NULL)
773  {
774    /* This shouldn't happen, better tell the ops... -A1kmm */
775    sendto_realops_flags(UMODE_ALL, L_ALL, "Warning: Lost connect{} block "
776                         "for server %s(this shouldn't happen)!", host);
777    exit_client(client_p, &me, "Lost connect{} block!");
778    return;
779  }
780
781  MyFree(client_p->localClient->passwd);
782  client_p->localClient->passwd = NULL;
783
784  /* Its got identd, since its a server */
785  SetGotId(client_p);
786
787  /* If there is something in the serv_list, it might be this
788   * connecting server..
789   */
790  if (!ServerInfo.hub && serv_list.head)  
791  {
792    if (client_p != serv_list.head->data || serv_list.head->next)
793    {
794      ++ServerStats.is_ref;
795      sendto_one(client_p, "ERROR :I'm a leaf not a hub");
796      exit_client(client_p, &me, "I'm a leaf");
797      return;
798    }
799  }
800
801  aconf = map_to_conf(conf);
802
803  if (IsUnknown(client_p))
804  {
805    /* jdc -- 1.  Use EmptyString(), not [0] index reference.
806     *        2.  Check aconf->spasswd, not aconf->passwd.
807     */
808    if (!EmptyString(aconf->spasswd))
809      sendto_one(client_p, "PASS %s TS %d %s",
810                 aconf->spasswd, TS_CURRENT, me.id);
811
812    /* Pass my info to the new server
813     *
814     * Pass on ZIP if supported
815     * Pass on TB if supported.
816     * - Dianora
817     */
818
819    send_capabilities(client_p, aconf,
820      (IsConfTopicBurst(aconf) ? CAP_TBURST|CAP_TB : 0));
821
822    sendto_one(client_p, "SERVER %s 1 :%s%s",
823               me.name, ConfigServerHide.hidden ? "(H) " : "", me.info);
824  }
825
826  sendto_one(client_p, "SVINFO %d %d 0 :%lu", TS_CURRENT, TS_MIN,
827             (unsigned long)CurrentTime);
828
829  /* assumption here is if they passed the correct TS version, they also passed an SID */
830  if (IsCapable(client_p, CAP_TS6))
831    hash_add_id(client_p);
832
833  /* XXX Does this ever happen? I don't think so -db */
834  detach_conf(client_p, OPER_TYPE);
835
836  /* *WARNING*
837  **    In the following code in place of plain server's
838  **    name we send what is returned by get_client_name
839  **    which may add the "sockhost" after the name. It's
840  **    *very* *important* that there is a SPACE between
841  **    the name and sockhost (if present). The receiving
842  **    server will start the information field from this
843  **    first blank and thus puts the sockhost into info.
844  **    ...a bit tricky, but you have been warned, besides
845  **    code is more neat this way...  --msa
846  */
847  client_p->servptr = &me;
848
849  if (IsClosing(client_p))
850    return;
851
852  SetServer(client_p);
853
854  /* Update the capability combination usage counts. -A1kmm */
855  set_chcap_usage_counts(client_p);
856
857  /* Some day, all these lists will be consolidated *sigh* */
858  dlinkAdd(client_p, &client_p->lnode, &me.serv->server_list);
859
860  assert(dlinkFind(&unknown_list, client_p));
861
862  dlink_move_node(&client_p->localClient->lclient_node,
863                  &unknown_list, &serv_list);
864
865  Count.myserver++;
866
867  dlinkAdd(client_p, make_dlink_node(), &global_serv_list);
868  hash_add_client(client_p);
869
870  /* doesnt duplicate client_p->serv if allocated this struct already */
871  make_server(client_p);
872
873  /* fixing eob timings.. -gnp */
874  client_p->localClient->firsttime = CurrentTime;
875
876  if (find_matching_name_conf(SERVICE_TYPE, client_p->name, NULL, NULL, 0))
877    AddFlag(client_p, FLAGS_SERVICE);
878
879  /* Show the real host/IP to admins */
880 #ifdef HAVE_LIBCRYPTO
881  if (client_p->localClient->fd.ssl)
882  {
883    compression = SSL_get_current_compression(client_p->localClient->fd.ssl);
884    expansion   = SSL_get_current_expansion(client_p->localClient->fd.ssl);
885
886    sendto_realops_flags(UMODE_ALL, L_ADMIN,
887                         "Link with %s established: [SSL: %s, Compression/Expansion method: %s/%s] (Capabilities: %s)",
888                         inpath_ip, ssl_get_cipher(client_p->localClient->fd.ssl),
889                         compression ? SSL_COMP_get_name(compression) : "NONE",
890                         expansion ? SSL_COMP_get_name(expansion) : "NONE",
891                         show_capabilities(client_p));
892    /* Now show the masked hostname/IP to opers */
893    sendto_realops_flags(UMODE_ALL, L_OPER,
894                         "Link with %s established: [SSL: %s, Compression/Expansion method: %s/%s] (Capabilities: %s)",
895                         inpath, ssl_get_cipher(client_p->localClient->fd.ssl),
896                         compression ? SSL_COMP_get_name(compression) : "NONE",
897                         expansion ? SSL_COMP_get_name(expansion) : "NONE",
898                         show_capabilities(client_p));
899    ilog(LOG_TYPE_IRCD, "Link with %s established: [SSL: %s, Compression/Expansion method: %s/%s] (Capabilities: %s)",
900         inpath_ip, ssl_get_cipher(client_p->localClient->fd.ssl),
901         compression ? SSL_COMP_get_name(compression) : "NONE",
902         expansion ? SSL_COMP_get_name(expansion) : "NONE",
903         show_capabilities(client_p));
904  }
905  else
906 #endif
907  {
908    sendto_realops_flags(UMODE_ALL, L_ADMIN,
909                         "Link with %s established: (Capabilities: %s)",
910                         inpath_ip,show_capabilities(client_p));
911    /* Now show the masked hostname/IP to opers */
912    sendto_realops_flags(UMODE_ALL, L_OPER,
913                         "Link with %s established: (Capabilities: %s)",
914                         inpath,show_capabilities(client_p));
915    ilog(LOG_TYPE_IRCD, "Link with %s established: (Capabilities: %s)",
916         inpath_ip, show_capabilities(client_p));
917  }
918
919  client_p->serv->sconf = conf;
920
921  fd_note(&client_p->localClient->fd, "Server: %s", client_p->name);
922
923  /* Old sendto_serv_but_one() call removed because we now
924  ** need to send different names to different servers
925  ** (domain name matching) Send new server to other servers.
926  */
927  DLINK_FOREACH(ptr, serv_list.head)
928  {
929    target_p = ptr->data;
930
931    if (target_p == client_p)
932      continue;
933
934    if (IsCapable(target_p, CAP_TS6) && HasID(client_p))
935      sendto_one(target_p, ":%s SID %s 2 %s :%s%s",
936                 me.id, client_p->name, client_p->id,
937                 IsHidden(client_p) ? "(H) " : "",
938                 client_p->info);
939    else
940      sendto_one(target_p,":%s SERVER %s 2 :%s%s",
941                 me.name, client_p->name,
942                 IsHidden(client_p) ? "(H) " : "",
943                 client_p->info);
944  }
945
946  /* Pass on my client information to the new server
947  **
948  ** First, pass only servers (idea is that if the link gets
949  ** cancelled beacause the server was already there,
950  ** there are no NICK's to be cancelled...). Of course,
951  ** if cancellation occurs, all this info is sent anyway,
952  ** and I guess the link dies when a read is attempted...? --msa
953  **
954  ** Note: Link cancellation to occur at this point means
955  ** that at least two servers from my fragment are building
956  ** up connection this other fragment at the same time, it's
957  ** a race condition, not the normal way of operation...
958  **
959  ** ALSO NOTE: using the get_client_name for server names--
960  **    see previous *WARNING*!!! (Also, original inpath
961  **    is destroyed...)
962  */
963
964  DLINK_FOREACH_PREV(ptr, global_serv_list.tail)
965  {
966    target_p = ptr->data;
967
968    /* target_p->from == target_p for target_p == client_p */
969    if (IsMe(target_p) || target_p->from == client_p)
970      continue;
971
972    if (IsCapable(client_p, CAP_TS6))
973    {
974      if (HasID(target_p))
975        sendto_one(client_p, ":%s SID %s %d %s :%s%s",
976                   ID(target_p->servptr), target_p->name, target_p->hopcount+1,
977                   target_p->id, IsHidden(target_p) ? "(H) " : "",
978                   target_p->info);
979      else  /* introducing non-ts6 server */
980        sendto_one(client_p, ":%s SERVER %s %d :%s%s",
981                   ID(target_p->servptr), target_p->name, target_p->hopcount+1,
982                   IsHidden(target_p) ? "(H) " : "", target_p->info);
983    }
984    else
985      sendto_one(client_p, ":%s SERVER %s %d :%s%s",
986                 target_p->servptr->name, target_p->name, target_p->hopcount+1,
987                 IsHidden(target_p) ? "(H) " : "", target_p->info);
988  }
989
990  server_burst(client_p);
991 }
992
993 /* server_burst()
994 *
995 * inputs       - struct Client pointer server
996 *              -
997 * output       - none
998 * side effects - send a server burst
999 * bugs         - still too long
1000 */
1001 static void
1002 server_burst(struct Client *client_p)
1003 {
1004  /* Send it in the shortened format with the TS, if
1005  ** it's a TS server; walk the list of channels, sending
1006  ** all the nicks that haven't been sent yet for each
1007  ** channel, then send the channel itself -- it's less
1008  ** obvious than sending all nicks first, but on the
1009  ** receiving side memory will be allocated more nicely
1010  ** saving a few seconds in the handling of a split
1011  ** -orabidoo
1012  */
1013
1014  burst_all(client_p);
1015
1016  /* EOB stuff is now in burst_all */
1017  /* Always send a PING after connect burst is done */
1018  sendto_one(client_p, "PING :%s", ID_or_name(&me, client_p));
1019 }
1020
1021 /* burst_all()
1022 *
1023 * inputs       - pointer to server to send burst to
1024 * output       - NONE
1025 * side effects - complete burst of channels/nicks is sent to client_p
1026 */
1027 static void
1028 burst_all(struct Client *client_p)
1029 {
1030  dlink_node *ptr = NULL;
1031
1032  DLINK_FOREACH(ptr, global_channel_list.head)
1033  {
1034    struct Channel *chptr = ptr->data;
1035
1036    if (dlink_list_length(&chptr->members) != 0)
1037    {
1038      burst_members(client_p, chptr);
1039      send_channel_modes(client_p, chptr);
1040
1041      if (IsCapable(client_p, CAP_TBURST) ||
1042          IsCapable(client_p, CAP_TB))
1043        send_tb(client_p, chptr);
1044    }
1045  }
1046
1047  /* also send out those that are not on any channel
1048   */
1049  DLINK_FOREACH(ptr, global_client_list.head)
1050  {
1051    struct Client *target_p = ptr->data;
1052
1053    if (!HasFlag(target_p, FLAGS_BURSTED) && target_p->from != client_p)
1054      sendnick_TS(client_p, target_p);
1055    
1056    DelFlag(target_p, FLAGS_BURSTED);
1057  }
1058
1059  /* We send the time we started the burst, and let the remote host determine an EOB time,
1060  ** as otherwise we end up sending a EOB of 0   Sending here means it gets sent last -- fl
1061  */
1062  /* Its simpler to just send EOB and use the time its been connected.. --fl_ */
1063  if (IsCapable(client_p, CAP_EOB))
1064    sendto_one(client_p, ":%s EOB", ID_or_name(&me, client_p));
1065 }
1066
1067 /*
1068 * send_tb
1069 *
1070 * inputs       - pointer to Client
1071 *              - pointer to channel
1072 * output       - NONE
1073 * side effects - Called on a server burst when
1074 *                server is CAP_TB|CAP_TBURST capable
1075 */
1076 static void
1077 send_tb(struct Client *client_p, struct Channel *chptr)
1078 {
1079  /*
1080   * We may also send an empty topic here, but only if topic_time isn't 0,
1081   * i.e. if we had a topic that got unset.  This is required for syncing
1082   * topics properly.
1083   *
1084   * Imagine the following scenario: Our downlink introduces a channel
1085   * to us with a TS that is equal to ours, but the channel topic on
1086   * their side got unset while the servers were in splitmode, which means
1087   * their 'topic' is newer.  They simply wanted to unset it, so we have to
1088   * deal with it in a more sophisticated fashion instead of just resetting
1089   * it to their old topic they had before.  Read m_tburst.c:ms_tburst
1090   * for further information   -Michael
1091   */
1092  if (chptr->topic_time != 0)
1093  {
1094    if (IsCapable(client_p, CAP_TBURST))
1095      sendto_one(client_p, ":%s TBURST %lu %s %lu %s :%s",
1096                 me.name, (unsigned long)chptr->channelts, chptr->chname,
1097                 (unsigned long)chptr->topic_time,
1098                 chptr->topic_info,
1099                 chptr->topic);
1100    else if (IsCapable(client_p, CAP_TB))
1101    {
1102      if (ConfigChannel.burst_topicwho)
1103      {
1104        sendto_one(client_p, ":%s TB %s %lu %s :%s",
1105                   me.name, chptr->chname,
1106                   (unsigned long)chptr->topic_time,
1107                   chptr->topic_info, chptr->topic);
1108      }
1109      else
1110      {
1111        sendto_one(client_p, ":%s TB %s %lu :%s",
1112                   me.name, chptr->chname,
1113                   (unsigned long)chptr->topic_time,
1114                   chptr->topic);
1115      }
1116    }
1117  }
1118 }
1119
1120 /* burst_members()
1121 *
1122 * inputs       - pointer to server to send members to
1123 *              - dlink_list pointer to membership list to send
1124 * output       - NONE
1125 * side effects -
1126 */
1127 static void
1128 burst_members(struct Client *client_p, struct Channel *chptr)
1129 {
1130  struct Client *target_p;
1131  struct Membership *ms;
1132  dlink_node *ptr;
1133
1134  DLINK_FOREACH(ptr, chptr->members.head)
1135  {
1136    ms       = ptr->data;
1137    target_p = ms->client_p;
1138
1139    if (!HasFlag(target_p, FLAGS_BURSTED))
1140    {
1141      AddFlag(target_p, FLAGS_BURSTED);
1142
1143      if (target_p->from != client_p)
1144        sendnick_TS(client_p, target_p);
1145    }
1146  }
1147 }
1148
576   /* New server connection code
577   * Based upon the stuff floating about in s_bsd.c
578   *   -- adrian
# Line 1153 | Line 580 | burst_members(struct Client *client_p, s
580  
581   /* serv_connect() - initiate a server connection
582   *
583 < * inputs       - pointer to conf
583 > * inputs       - pointer to conf
584   *              - pointer to client doing the connect
585   * output       -
586   * side effects -
# Line 1168 | Line 595 | burst_members(struct Client *client_p, s
595   * it suceeded or not, and 0 if it fails in here somewhere.
596   */
597   int
598 < serv_connect(struct AccessItem *aconf, struct Client *by)
598 > serv_connect(struct MaskItem *conf, struct Client *by)
599   {
600 <  struct ConfItem *conf;
601 <  struct Client *client_p;
1175 <  char buf[HOSTIPLEN];
600 >  struct Client *client_p = NULL;
601 >  char buf[HOSTIPLEN + 1] = "";
602  
603    /* conversion structs */
604    struct sockaddr_in *v4;
1179  /* Make sure aconf is useful */
1180  assert(aconf != NULL);
605  
606 <  if(aconf == NULL)
607 <    return (0);
606 >  /* Make sure conf is useful */
607 >  assert(conf);
608  
609 <  /* XXX should be passing struct ConfItem in the first place */
1186 <  conf = unmap_conf_item(aconf);
1187 <
1188 <  /* log */
1189 <  getnameinfo((struct sockaddr *)&aconf->ipnum, aconf->ipnum.ss_len,
609 >  getnameinfo((struct sockaddr *)&conf->addr, conf->addr.ss_len,
610                buf, sizeof(buf), NULL, 0, NI_NUMERICHOST);
611 <  ilog(LOG_TYPE_IRCD, "Connect to %s[%s] @%s", aconf->user, aconf->host,
611 >  ilog(LOG_TYPE_IRCD, "Connect to %s[%s] @%s", conf->name, conf->host,
612         buf);
613  
614    /* Still processing a DNS lookup? -> exit */
615 <  if (aconf->dns_pending)
615 >  if (conf->dns_pending)
616    {
617 <    sendto_realops_flags(UMODE_ALL, L_ALL,
617 >    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
618                           "Error connecting to %s: DNS lookup for connect{} in progress.",
619                           conf->name);
620 <    return (0);
620 >    return 0;
621    }
622  
623 <  if (aconf->dns_failed)
623 >  if (conf->dns_failed)
624    {
625 <    sendto_realops_flags(UMODE_ALL, L_ALL,
625 >    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
626                           "Error connecting to %s: DNS lookup for connect{} failed.",
627                           conf->name);
628 <    return (0);
628 >    return 0;
629    }
630  
631    /* Make sure this server isn't already connected
632 <   * Note: aconf should ALWAYS be a valid C: line
632 >   * Note: conf should ALWAYS be a valid C: line
633     */
634 <  if ((client_p = hash_find_server(conf->name)) != NULL)
635 <  {
636 <    sendto_realops_flags(UMODE_ALL, L_ADMIN,
637 <                         "Server %s already present from %s",
638 <                         conf->name, get_client_name(client_p, SHOW_IP));
639 <    sendto_realops_flags(UMODE_ALL, L_OPER,
640 <                         "Server %s already present from %s",
641 <                         conf->name, get_client_name(client_p, MASK_IP));
634 >  if ((client_p = hash_find_server(conf->name)))
635 >  {
636 >    sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
637 >                         "Server %s already present from %s",
638 >                         conf->name, get_client_name(client_p, SHOW_IP));
639 >    sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
640 >                         "Server %s already present from %s",
641 >                         conf->name, get_client_name(client_p, MASK_IP));
642      if (by && IsClient(by) && !MyClient(by))
643 <      sendto_one(by, ":%s NOTICE %s :Server %s already present from %s",
644 <                 me.name, by->name, conf->name,
645 <                 get_client_name(client_p, MASK_IP));
1226 <    return (0);
643 >      sendto_one_notice(by, &me, ":Server %s already present from %s",
644 >                        conf->name, get_client_name(client_p, MASK_IP));
645 >    return 0;
646    }
647 <    
647 >
648    /* Create a local client */
649    client_p = make_client(NULL);
650  
651    /* Copy in the server, hostname, fd */
652    strlcpy(client_p->name, conf->name, sizeof(client_p->name));
653 <  strlcpy(client_p->host, aconf->host, sizeof(client_p->host));
653 >  strlcpy(client_p->host, conf->host, sizeof(client_p->host));
654  
655    /* We already converted the ip once, so lets use it - stu */
656    strlcpy(client_p->sockhost, buf, sizeof(client_p->sockhost));
657  
658 <  /* create a socket for the server connection */
659 <  if (comm_open(&client_p->localClient->fd, aconf->ipnum.ss.ss_family,
1241 <                SOCK_STREAM, 0, NULL) < 0)
658 >  /* create a socket for the server connection */
659 >  if (comm_open(&client_p->localClient->fd, conf->addr.ss.ss_family, SOCK_STREAM, 0, NULL) < 0)
660    {
661      /* Eek, failure to create the socket */
662 <    report_error(L_ALL,
663 <                 "opening stream socket to %s: %s", conf->name, errno);
662 >    report_error(L_ALL, "opening stream socket to %s: %s", conf->name, errno);
663 >
664      SetDead(client_p);
665 <    exit_client(client_p, &me, "Connection failed");
666 <    return (0);
665 >    exit_client(client_p, "Connection failed");
666 >    return 0;
667    }
668  
669    /* servernames are always guaranteed under HOSTLEN chars */
# Line 1254 | Line 672 | serv_connect(struct AccessItem *aconf, s
672    /* Attach config entries to client here rather than in
673     * serv_connect_callback(). This to avoid null pointer references.
674     */
675 <  if (!attach_connect_block(client_p, conf->name, aconf->host))
675 >  if (!attach_connect_block(client_p, conf->name, conf->host))
676    {
677 <    sendto_realops_flags(UMODE_ALL, L_ALL,
678 <                         "Host %s is not enabled for connecting:no C/N-line",
679 <                         conf->name);
680 <    if (by && IsClient(by) && !MyClient(by))  
681 <      sendto_one(by, ":%s NOTICE %s :Connect to host %s failed.",
682 <                 me.name, by->name, client_p->name);
677 >    sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
678 >                         "Host %s is not enabled for connecting: no connect{} block",
679 >                         conf->name);
680 >    if (by && IsClient(by) && !MyClient(by))
681 >      sendto_one_notice(by, &me, ":Connect to host %s failed.", client_p->name);
682 >
683      SetDead(client_p);
684 <    exit_client(client_p, client_p, "Connection failed");
685 <    return (0);
684 >    exit_client(client_p, "Connection failed");
685 >    return 0;
686    }
687  
688    /* at this point we have a connection in progress and C/N lines
# Line 1282 | Line 700 | serv_connect(struct AccessItem *aconf, s
700  
701    SetConnecting(client_p);
702    dlinkAdd(client_p, &client_p->node, &global_client_list);
703 <  /* from def_fam */
704 <  client_p->localClient->aftype = aconf->aftype;
703 >
704 >  client_p->localClient->aftype = conf->aftype;
705  
706    /* Now, initiate the connection */
707 <  /* XXX assume that a non 0 type means a specific bind address
707 >  /* XXX assume that a non 0 type means a specific bind address
708     * for this connect.
709     */
710 <  switch (aconf->aftype)
710 >  switch (conf->aftype)
711    {
712      case AF_INET:
713 <      v4 = (struct sockaddr_in*)&aconf->my_ipnum;
714 <      if (v4->sin_addr.s_addr != 0)
713 >      v4 = (struct sockaddr_in*)&conf->bind;
714 >      if (v4->sin_addr.s_addr)
715        {
716          struct irc_ssaddr ipn;
717          memset(&ipn, 0, sizeof(struct irc_ssaddr));
718          ipn.ss.ss_family = AF_INET;
719          ipn.ss_port = 0;
720 <        memcpy(&ipn, &aconf->my_ipnum, sizeof(struct irc_ssaddr));
721 <        comm_connect_tcp(&client_p->localClient->fd, aconf->host, aconf->port,
722 <                         (struct sockaddr *)&ipn, ipn.ss_len,
723 <                         serv_connect_callback, client_p, aconf->aftype,
724 <                         CONNECTTIMEOUT);
720 >        memcpy(&ipn, &conf->bind, sizeof(struct irc_ssaddr));
721 >        comm_connect_tcp(&client_p->localClient->fd, conf->host, conf->port,
722 >                         (struct sockaddr *)&ipn, ipn.ss_len,
723 >                         serv_connect_callback, client_p, conf->aftype,
724 >                         CONNECTTIMEOUT);
725        }
726        else if (ServerInfo.specific_ipv4_vhost)
727        {
# Line 1312 | Line 730 | serv_connect(struct AccessItem *aconf, s
730          ipn.ss.ss_family = AF_INET;
731          ipn.ss_port = 0;
732          memcpy(&ipn, &ServerInfo.ip, sizeof(struct irc_ssaddr));
733 <        comm_connect_tcp(&client_p->localClient->fd, aconf->host, aconf->port,
733 >        comm_connect_tcp(&client_p->localClient->fd, conf->host, conf->port,
734                           (struct sockaddr *)&ipn, ipn.ss_len,
735 <                         serv_connect_callback, client_p, aconf->aftype,
736 <                         CONNECTTIMEOUT);
735 >                         serv_connect_callback, client_p, conf->aftype,
736 >                         CONNECTTIMEOUT);
737        }
738        else
739 <        comm_connect_tcp(&client_p->localClient->fd, aconf->host, aconf->port,
740 <                         NULL, 0, serv_connect_callback, client_p, aconf->aftype,
739 >        comm_connect_tcp(&client_p->localClient->fd, conf->host, conf->port,
740 >                         NULL, 0, serv_connect_callback, client_p, conf->aftype,
741                           CONNECTTIMEOUT);
742        break;
743   #ifdef IPV6
744      case AF_INET6:
745        {
746 <        struct irc_ssaddr ipn;
747 <        struct sockaddr_in6 *v6;
748 <        struct sockaddr_in6 *v6conf;
749 <
750 <        memset(&ipn, 0, sizeof(struct irc_ssaddr));
751 <        v6conf = (struct sockaddr_in6 *)&aconf->my_ipnum;
752 <        v6 = (struct sockaddr_in6 *)&ipn;
753 <
754 <        if (memcmp(&v6conf->sin6_addr, &v6->sin6_addr,
755 <                   sizeof(struct in6_addr)) != 0)
756 <        {
757 <          memcpy(&ipn, &aconf->my_ipnum, sizeof(struct irc_ssaddr));
758 <          ipn.ss.ss_family = AF_INET6;
759 <          ipn.ss_port = 0;
760 <          comm_connect_tcp(&client_p->localClient->fd,
761 <                           aconf->host, aconf->port,
762 <                           (struct sockaddr *)&ipn, ipn.ss_len,
763 <                           serv_connect_callback, client_p,
764 <                           aconf->aftype, CONNECTTIMEOUT);
765 <        }
1348 <        else if (ServerInfo.specific_ipv6_vhost)
746 >        struct irc_ssaddr ipn;
747 >        struct sockaddr_in6 *v6;
748 >        struct sockaddr_in6 *v6conf;
749 >
750 >        memset(&ipn, 0, sizeof(struct irc_ssaddr));
751 >        v6conf = (struct sockaddr_in6 *)&conf->bind;
752 >        v6 = (struct sockaddr_in6 *)&ipn;
753 >
754 >        if (memcmp(&v6conf->sin6_addr, &v6->sin6_addr, sizeof(struct in6_addr)))
755 >        {
756 >          memcpy(&ipn, &conf->bind, sizeof(struct irc_ssaddr));
757 >          ipn.ss.ss_family = AF_INET6;
758 >          ipn.ss_port = 0;
759 >          comm_connect_tcp(&client_p->localClient->fd,
760 >                           conf->host, conf->port,
761 >                           (struct sockaddr *)&ipn, ipn.ss_len,
762 >                           serv_connect_callback, client_p,
763 >                           conf->aftype, CONNECTTIMEOUT);
764 >        }
765 >        else if (ServerInfo.specific_ipv6_vhost)
766          {
767 <          memcpy(&ipn, &ServerInfo.ip6, sizeof(struct irc_ssaddr));
768 <          ipn.ss.ss_family = AF_INET6;
769 <          ipn.ss_port = 0;
770 <          comm_connect_tcp(&client_p->localClient->fd,
771 <                           aconf->host, aconf->port,
772 <                           (struct sockaddr *)&ipn, ipn.ss_len,
773 <                           serv_connect_callback, client_p,
774 <                           aconf->aftype, CONNECTTIMEOUT);
775 <        }
776 <        else
777 <          comm_connect_tcp(&client_p->localClient->fd,
778 <                           aconf->host, aconf->port,
779 <                           NULL, 0, serv_connect_callback, client_p,
780 <                           aconf->aftype, CONNECTTIMEOUT);
767 >          memcpy(&ipn, &ServerInfo.ip6, sizeof(struct irc_ssaddr));
768 >          ipn.ss.ss_family = AF_INET6;
769 >          ipn.ss_port = 0;
770 >          comm_connect_tcp(&client_p->localClient->fd,
771 >                           conf->host, conf->port,
772 >                           (struct sockaddr *)&ipn, ipn.ss_len,
773 >                           serv_connect_callback, client_p,
774 >                           conf->aftype, CONNECTTIMEOUT);
775 >        }
776 >        else
777 >          comm_connect_tcp(&client_p->localClient->fd,
778 >                           conf->host, conf->port,
779 >                           NULL, 0, serv_connect_callback, client_p,
780 >                           conf->aftype, CONNECTTIMEOUT);
781        }
782   #endif
783    }
784 <  return (1);
784 >  return 1;
785   }
786  
787   #ifdef HAVE_LIBCRYPTO
788   static void
789   finish_ssl_server_handshake(struct Client *client_p)
790   {
791 <  struct ConfItem *conf=NULL;
1375 <  struct AccessItem *aconf=NULL;
791 >  struct MaskItem *conf = NULL;
792  
793    conf = find_conf_name(&client_p->localClient->confs,
794 <                        client_p->name, SERVER_TYPE);
794 >                        client_p->name, CONF_SERVER);
795    if (conf == NULL)
796    {
797 <    sendto_realops_flags(UMODE_ALL, L_ADMIN,
797 >    sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
798                           "Lost connect{} block for %s", get_client_name(client_p, HIDE_IP));
799 <    sendto_realops_flags(UMODE_ALL, L_OPER,
799 >    sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
800                           "Lost connect{} block for %s", get_client_name(client_p, MASK_IP));
801  
802 <    exit_client(client_p, &me, "Lost connect{} block");
802 >    exit_client(client_p, "Lost connect{} block");
803      return;
804    }
805  
806 <  aconf = map_to_conf(conf);
806 >  sendto_one(client_p, "PASS %s TS %d %s", conf->spasswd, TS_CURRENT, me.id);
807  
808 <  /* jdc -- Check and send spasswd, not passwd. */
1393 <  if (!EmptyString(aconf->spasswd))
1394 <    sendto_one(client_p, "PASS %s TS %d %s",
1395 <               aconf->spasswd, TS_CURRENT, me.id);
1396 <
1397 <  send_capabilities(client_p, aconf,
1398 <                   (IsConfTopicBurst(aconf) ? CAP_TBURST|CAP_TB : 0));
808 >  send_capabilities(client_p, 0);
809  
810    sendto_one(client_p, "SERVER %s 1 :%s%s",
811               me.name, ConfigServerHide.hidden ? "(H) " : "",
# Line 1406 | Line 816 | finish_ssl_server_handshake(struct Clien
816     */
817    if (IsDead(client_p))
818    {
819 <      sendto_realops_flags(UMODE_ALL, L_ADMIN,
819 >      sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
820                             "%s[%s] went dead during handshake",
821                             client_p->name,
822                             client_p->host);
823 <      sendto_realops_flags(UMODE_ALL, L_OPER,
823 >      sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
824                             "%s went dead during handshake", client_p->name);
825        return;
826    }
# Line 1423 | Line 833 | finish_ssl_server_handshake(struct Clien
833   static void
834   ssl_server_handshake(fde_t *fd, struct Client *client_p)
835   {
836 <  int ret;
837 <  int err;
1428 <
1429 <  ret = SSL_connect(client_p->localClient->fd.ssl);
836 >  X509 *cert = NULL;
837 >  int ret = 0;
838  
839 <  if (ret <= 0)
839 >  if ((ret = SSL_connect(client_p->localClient->fd.ssl)) <= 0)
840    {
841 <    switch ((err = SSL_get_error(client_p->localClient->fd.ssl, ret)))
841 >    switch (SSL_get_error(client_p->localClient->fd.ssl, ret))
842      {
843        case SSL_ERROR_WANT_WRITE:
844          comm_setselect(&client_p->localClient->fd, COMM_SELECT_WRITE,
845 <            (PF *) ssl_server_handshake, client_p, 0);
845 >                       (PF *)ssl_server_handshake, client_p, 0);
846          return;
847        case SSL_ERROR_WANT_READ:
848          comm_setselect(&client_p->localClient->fd, COMM_SELECT_READ,
849 <            (PF *) ssl_server_handshake, client_p, 0);
849 >                       (PF *)ssl_server_handshake, client_p, 0);
850          return;
851        default:
852 <        exit_client(client_p, client_p, "Error during SSL handshake");
852 >      {
853 >        const char *sslerr = ERR_error_string(ERR_get_error(), NULL);
854 >        sendto_realops_flags(UMODE_ALL, L_ALL, SEND_NOTICE,
855 >                             "Error connecting to %s: %s", client_p->name,
856 >                             sslerr ? sslerr : "unknown SSL error");
857 >        exit_client(client_p, "Error during SSL handshake");
858          return;
859 +      }
860 +    }
861 +  }
862 +
863 +  if ((cert = SSL_get_peer_certificate(client_p->localClient->fd.ssl)))
864 +  {
865 +    int res = SSL_get_verify_result(client_p->localClient->fd.ssl);
866 +    char buf[EVP_MAX_MD_SIZE * 2 + 1] = "";
867 +    unsigned char md[EVP_MAX_MD_SIZE] = "";
868 +
869 +    if (res == X509_V_OK || res == X509_V_ERR_SELF_SIGNED_CERT_IN_CHAIN ||
870 +        res == X509_V_ERR_UNABLE_TO_VERIFY_LEAF_SIGNATURE ||
871 +        res == X509_V_ERR_DEPTH_ZERO_SELF_SIGNED_CERT)
872 +    {
873 +      unsigned int n = 0;
874 +
875 +      if (X509_digest(cert, EVP_sha256(), md, &n))
876 +      {
877 +        binary_to_hex(md, buf, n);
878 +        client_p->certfp = xstrdup(buf);
879 +      }
880      }
881 +    else
882 +      ilog(LOG_TYPE_IRCD, "Server %s!%s@%s gave bad SSL client certificate: %d",
883 +           client_p->name, client_p->username, client_p->host, res);
884 +    X509_free(cert);
885    }
886  
887    finish_ssl_server_handshake(client_p);
888   }
889  
890   static void
891 < ssl_connect_init(struct Client *client_p, struct AccessItem *aconf, fde_t *fd)
891 > ssl_connect_init(struct Client *client_p, struct MaskItem *conf, fde_t *fd)
892   {
893    if ((client_p->localClient->fd.ssl = SSL_new(ServerInfo.client_ctx)) == NULL)
894    {
895      ilog(LOG_TYPE_IRCD, "SSL_new() ERROR! -- %s",
896           ERR_error_string(ERR_get_error(), NULL));
897      SetDead(client_p);
898 <    exit_client(client_p, client_p, "SSL_new failed");
898 >    exit_client(client_p, "SSL_new failed");
899      return;
900    }
901  
902    SSL_set_fd(fd->ssl, fd->fd);
903  
904 <  if (!EmptyString(aconf->cipher_list))
905 <    SSL_set_cipher_list(client_p->localClient->fd.ssl, aconf->cipher_list);
904 >  if (!EmptyString(conf->cipher_list))
905 >    SSL_set_cipher_list(client_p->localClient->fd.ssl, conf->cipher_list);
906  
907    ssl_server_handshake(NULL, client_p);
908   }
909   #endif
910  
911   /* serv_connect_callback() - complete a server connection.
912 < *
912 > *
913   * This routine is called after the server connection attempt has
914   * completed. If unsucessful, an error is sent to ops and the client
915   * is closed. If sucessful, it goes through the initialisation/check
# Line 1482 | Line 920 | static void
920   serv_connect_callback(fde_t *fd, int status, void *data)
921   {
922    struct Client *client_p = data;
923 <  struct ConfItem *conf=NULL;
1486 <  struct AccessItem *aconf=NULL;
923 >  struct MaskItem *conf = NULL;
924  
925    /* First, make sure its a real client! */
926 <  assert(client_p != NULL);
926 >  assert(client_p);
927    assert(&client_p->localClient->fd == fd);
928  
929    /* Next, for backward purposes, record the ip of the server */
930    memcpy(&client_p->localClient->ip, &fd->connect.hostaddr,
931           sizeof(struct irc_ssaddr));
932 +
933    /* Check the status */
934    if (status != COMM_OK)
935    {
# Line 1499 | Line 937 | serv_connect_callback(fde_t *fd, int sta
937       * Admins get to see any IP, mere opers don't *sigh*
938       */
939       if (ConfigServerHide.hide_server_ips)
940 <       sendto_realops_flags(UMODE_ALL, L_ADMIN,
940 >       sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
941                              "Error connecting to %s: %s",
942                              client_p->name, comm_errstr(status));
943       else
944 <       sendto_realops_flags(UMODE_ALL, L_ADMIN,
945 <                            "Error connecting to %s[%s]: %s", client_p->name,
946 <                            client_p->host, comm_errstr(status));
947 <
948 <     sendto_realops_flags(UMODE_ALL, L_OPER,
949 <                          "Error connecting to %s: %s",
950 <                          client_p->name, comm_errstr(status));
944 >       sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
945 >                            "Error connecting to %s[%s]: %s", client_p->name,
946 >                            client_p->host, comm_errstr(status));
947 >
948 >     sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
949 >                          "Error connecting to %s: %s",
950 >                          client_p->name, comm_errstr(status));
951  
952       /* If a fd goes bad, call dead_link() the socket is no
953        * longer valid for reading or writing.
# Line 1521 | Line 959 | serv_connect_callback(fde_t *fd, int sta
959    /* COMM_OK, so continue the connection procedure */
960    /* Get the C/N lines */
961    conf = find_conf_name(&client_p->localClient->confs,
962 <                        client_p->name, SERVER_TYPE);
962 >                        client_p->name, CONF_SERVER);
963    if (conf == NULL)
964    {
965 <    sendto_realops_flags(UMODE_ALL, L_ADMIN,
966 <                         "Lost connect{} block for %s", get_client_name(client_p, HIDE_IP));
967 <    sendto_realops_flags(UMODE_ALL, L_OPER,
968 <                         "Lost connect{} block for %s", get_client_name(client_p, MASK_IP));
965 >    sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
966 >                         "Lost connect{} block for %s", get_client_name(client_p, HIDE_IP));
967 >    sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
968 >                         "Lost connect{} block for %s", get_client_name(client_p, MASK_IP));
969  
970 <    exit_client(client_p, &me, "Lost connect{} block");
970 >    exit_client(client_p, "Lost connect{} block");
971      return;
972    }
973  
1536  aconf = map_to_conf(conf);
974    /* Next, send the initial handshake */
975    SetHandshake(client_p);
976  
977   #ifdef HAVE_LIBCRYPTO
978 <  if (IsConfSSL(aconf))
978 >  if (IsConfSSL(conf))
979    {
980 <    ssl_connect_init(client_p, aconf, fd);
980 >    ssl_connect_init(client_p, conf, fd);
981      return;
982    }
983   #endif
984  
985 <  /* jdc -- Check and send spasswd, not passwd. */
1549 <  if (!EmptyString(aconf->spasswd))
1550 <    sendto_one(client_p, "PASS %s TS %d %s",
1551 <               aconf->spasswd, TS_CURRENT, me.id);
985 >  sendto_one(client_p, "PASS %s TS %d %s", conf->spasswd, TS_CURRENT, me.id);
986  
987 <  send_capabilities(client_p, aconf,
1554 <                   (IsConfTopicBurst(aconf) ? CAP_TBURST|CAP_TB : 0));
987 >  send_capabilities(client_p, 0);
988  
989 <  sendto_one(client_p, "SERVER %s 1 :%s%s",
990 <             me.name, ConfigServerHide.hidden ? "(H) " : "",
1558 <             me.info);
989 >  sendto_one(client_p, "SERVER %s 1 :%s%s", me.name,
990 >             ConfigServerHide.hidden ? "(H) " : "", me.info);
991  
992    /* If we've been marked dead because a send failed, just exit
993     * here now and save everyone the trouble of us ever existing.
994     */
995 <  if (IsDead(client_p))
995 >  if (IsDead(client_p))
996    {
997 <      sendto_realops_flags(UMODE_ALL, L_ADMIN,
998 <                           "%s[%s] went dead during handshake",
997 >      sendto_realops_flags(UMODE_ALL, L_ADMIN, SEND_NOTICE,
998 >                           "%s[%s] went dead during handshake",
999                             client_p->name,
1000 <                           client_p->host);
1001 <      sendto_realops_flags(UMODE_ALL, L_OPER,
1002 <                           "%s went dead during handshake", client_p->name);
1000 >                           client_p->host);
1001 >      sendto_realops_flags(UMODE_ALL, L_OPER, SEND_NOTICE,
1002 >                           "%s went dead during handshake", client_p->name);
1003        return;
1004    }
1005  
# Line 1587 | Line 1019 | find_servconn_in_progress(const char *na
1019      cptr = ptr->data;
1020  
1021      if (cptr && cptr->name[0])
1022 <      if (match(name, cptr->name))
1022 >      if (!match(name, cptr->name))
1023          return cptr;
1024    }
1025 <  
1025 >
1026    return NULL;
1027   }

Diff Legend

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