ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/trunk/src/server.c
Revision: 8310
Committed: Wed Feb 28 16:46:13 2018 UTC (7 years, 5 months ago) by michael
Content type: text/x-csrc
File size: 24123 byte(s)
Log Message:
- Clean up remaining sizeof() to sizeof(variable)

File Contents

# Content
1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 1997-2018 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
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
19 * USA
20 */
21
22 /*! \file s_serv.c
23 * \brief Server related functions.
24 * \version $Id$
25 */
26
27 #include "stdinc.h"
28 #include "list.h"
29 #include "client.h"
30 #include "event.h"
31 #include "hash.h"
32 #include "irc_string.h"
33 #include "ircd.h"
34 #include "ircd_defs.h"
35 #include "s_bsd.h"
36 #include "packet.h"
37 #include "conf.h"
38 #include "server.h"
39 #include "server_capab.h"
40 #include "log.h"
41 #include "send.h"
42 #include "memory.h"
43 #include "parse.h"
44
45
46 dlink_list flatten_links;
47 static void serv_connect_callback(fde_t *, int, void *);
48
49
50 /*
51 * write_links_file
52 *
53 * inputs - void pointer which is not used
54 * output - NONE
55 * side effects - called from an event, write out list of linked servers
56 * but in no particular order.
57 */
58 void
59 write_links_file(void *unused)
60 {
61 FILE *file = NULL;
62 dlink_node *node, *node_next;
63 char buff[IRCD_BUFSIZE] = "";
64
65 if (EmptyString(ConfigServerHide.flatten_links_file))
66 return;
67
68 if ((file = fopen(ConfigServerHide.flatten_links_file, "w")) == NULL)
69 {
70 ilog(LOG_TYPE_IRCD, "Couldn't open \"%s\": %s", ConfigServerHide.flatten_links_file,
71 strerror(errno));
72 return;
73 }
74
75 DLINK_FOREACH_SAFE(node, node_next, flatten_links.head)
76 {
77 dlinkDelete(node, &flatten_links);
78 xfree(node->data);
79 free_dlink_node(node);
80 }
81
82 DLINK_FOREACH(node, global_server_list.head)
83 {
84 const struct Client *target_p = node->data;
85
86 /*
87 * Skip hidden servers, aswell as ourselves, since we already send
88 * ourselves in /links
89 */
90 if (IsHidden(target_p) || IsMe(target_p))
91 continue;
92
93 if (HasFlag(target_p, FLAGS_SERVICE) && ConfigServerHide.hide_services)
94 continue;
95
96 /*
97 * Attempt to format the file in such a way it follows the usual links output
98 * ie "servername uplink :hops info"
99 * Mostly for aesthetic reasons - makes it look pretty in mIRC ;)
100 * - madmax
101 */
102 snprintf(buff, sizeof(buff), "%s %s :1 %s", target_p->name,
103 me.name, target_p->info);
104 dlinkAddTail(xstrdup(buff), make_dlink_node(), &flatten_links);
105 snprintf(buff, sizeof(buff), "%s %s :1 %s\n", target_p->name,
106 me.name, target_p->info);
107
108 fputs(buff, file);
109 }
110
111 fclose(file);
112 }
113
114 void
115 read_links_file(void)
116 {
117 FILE *file = NULL;
118 char *p = NULL;
119 char buff[IRCD_BUFSIZE] = "";
120
121 if (EmptyString(ConfigServerHide.flatten_links_file))
122 return;
123
124 if ((file = fopen(ConfigServerHide.flatten_links_file, "r")) == NULL)
125 {
126 ilog(LOG_TYPE_IRCD, "Couldn't open \"%s\": %s", ConfigServerHide.flatten_links_file,
127 strerror(errno));
128 return;
129 }
130
131 while (fgets(buff, sizeof(buff), file))
132 {
133 if ((p = strchr(buff, '\n')))
134 *p = '\0';
135
136 dlinkAddTail(xstrdup(buff), make_dlink_node(), &flatten_links);
137 }
138
139 fclose(file);
140 }
141
142 /* server_hunt()
143 * Do the basic thing in delivering the message (command)
144 * across the relays to the specific server (server) for
145 * actions.
146 *
147 * Note: The command is a format string and *MUST* be
148 * of prefixed style (e.g. ":%s COMMAND %s ...").
149 * Command can have only max 8 parameters.
150 *
151 * server parv[server] is the parameter identifying the
152 * target server.
153 *
154 * *WARNING*
155 * parv[server] is replaced with the pointer to the
156 * real servername from the matched client (I'm lazy
157 * now --msa).
158 *
159 * returns: (see #defines)
160 */
161 const struct server_hunt *
162 server_hunt(struct Client *source_p, const char *command,
163 const int server, const int parc, char *parv[])
164 {
165 static struct server_hunt hunt;
166 struct server_hunt *const h = &hunt;
167 dlink_node *node;
168
169 /* Assume it's me, if no server */
170 if (parc <= server || EmptyString(parv[server]))
171 {
172 h->target_p = &me;
173 h->ret = HUNTED_ISME;
174 return h;
175 }
176
177 if ((h->target_p = find_person(source_p, parv[server])) == NULL)
178 h->target_p = hash_find_server(parv[server]);
179
180 /*
181 * These are to pickup matches that would cause the following
182 * message to go in the wrong direction while doing quick fast
183 * non-matching lookups.
184 */
185 if (h->target_p)
186 if (h->target_p->from == source_p->from && !MyConnect(h->target_p))
187 h->target_p = NULL;
188
189 if (!h->target_p && has_wildcards(parv[server]))
190 {
191 DLINK_FOREACH(node, global_server_list.head)
192 {
193 struct Client *tmp = node->data;
194
195 assert(IsMe(tmp) || IsServer(tmp));
196 if (!match(parv[server], tmp->name))
197 {
198 if (tmp->from == source_p->from && !MyConnect(tmp))
199 continue;
200
201 h->target_p = tmp;
202 break;
203 }
204 }
205
206 if (!h->target_p)
207 {
208 DLINK_FOREACH(node, global_client_list.head)
209 {
210 struct Client *tmp = node->data;
211
212 assert(IsClient(tmp));
213 if (!match(parv[server], tmp->name))
214 {
215 if (tmp->from == source_p->from && !MyConnect(tmp))
216 continue;
217
218 h->target_p = tmp;
219 break;
220 }
221 }
222 }
223 }
224
225 if (h->target_p)
226 {
227 assert(IsMe(h->target_p) || IsServer(h->target_p) || IsClient(h->target_p));
228 if (IsMe(h->target_p) || MyClient(h->target_p))
229 {
230 h->ret = HUNTED_ISME;
231 return h;
232 }
233
234 parv[server] = h->target_p->id;
235 sendto_one(h->target_p, command, source_p->id,
236 parv[1], parv[2], parv[3], parv[4],
237 parv[5], parv[6], parv[7], parv[8]);
238 h->ret = HUNTED_PASS;
239 return h;
240 }
241
242 sendto_one_numeric(source_p, &me, ERR_NOSUCHSERVER, parv[server]);
243 h->ret = HUNTED_NOSUCH;
244 return h;
245 }
246
247 /* try_connections()
248 *
249 * inputs - void pointer which is not used
250 * output - NONE
251 * side effects -
252 * scan through configuration and try new connections.
253 * Returns the calendar time when the next call to this
254 * function should be made latest. (No harm done if this
255 * is called earlier or later...)
256 */
257 void
258 try_connections(void *unused)
259 {
260 dlink_node *node;
261
262 if (GlobalSetOptions.autoconn == 0)
263 return;
264
265 DLINK_FOREACH(node, connect_items.head)
266 {
267 struct MaskItem *conf = node->data;
268
269 assert(conf->type == CONF_SERVER);
270 assert(conf->class);
271
272 /* Also when already connecting! (update holdtimes) --SRB */
273 if (!conf->port || !IsConfAllowAutoConn(conf))
274 continue;
275
276 /*
277 * Skip this entry if the use of it is still on hold until
278 * future. Otherwise handle this entry (and set it on hold
279 * until next time). Will reset only hold times, if already
280 * made one successfull connection... [this algorithm is
281 * a bit fuzzy... -- msa >;) ]
282 */
283 if (conf->until > CurrentTime)
284 continue;
285
286 conf->until = CurrentTime + conf->class->con_freq;
287
288 /*
289 * Found a CONNECT config with port specified, scan clients
290 * and see if this server is already connected?
291 */
292 if (hash_find_server(conf->name))
293 continue;
294
295 if (conf->class->ref_count < conf->class->max_total)
296 {
297 /* Move this entry to the end of the list, if not already last */
298 if (node->next)
299 {
300 dlinkDelete(node, &connect_items);
301 dlinkAddTail(conf, &conf->node, &connect_items);
302 }
303
304 if (find_servconn_in_progress(conf->name))
305 return;
306
307 /*
308 * We used to only print this if serv_connect() actually
309 * succeeded, but since comm_tcp_connect() can call the callback
310 * immediately if there is an error, we were getting error messages
311 * in the wrong order. SO, we just print out the activated line,
312 * and let serv_connect() / serv_connect_callback() print an
313 * error afterwards if it fails.
314 * -- adrian
315 */
316 if (ConfigServerHide.hide_server_ips)
317 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
318 "Connection to %s activated.",
319 conf->name);
320 else
321 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
322 "Connection to %s[%s] activated.",
323 conf->name, conf->host);
324
325 serv_connect(conf, NULL);
326 /* We connect only one at time... */
327 return;
328 }
329 }
330 }
331
332 int
333 valid_servname(const char *name)
334 {
335 unsigned int dots = 0;
336 const char *p = name;
337
338 for (; *p; ++p)
339 {
340 if (!IsServChar(*p))
341 return 0;
342
343 if (*p == '.')
344 ++dots;
345 }
346
347 return dots && (p - name) <= HOSTLEN;
348 }
349
350 /* make_server()
351 *
352 * inputs - pointer to client struct
353 * output - pointer to struct Server
354 * side effects - add's an Server information block to a client
355 * if it was not previously allocated.
356 */
357 struct Server *
358 make_server(struct Client *client_p)
359 {
360 if (client_p->serv == NULL)
361 client_p->serv = xcalloc(sizeof(*client_p->serv));
362
363 return client_p->serv;
364 }
365
366 /* New server connection code
367 * Based upon the stuff floating about in s_bsd.c
368 * -- adrian
369 */
370
371 /* serv_connect() - initiate a server connection
372 *
373 * inputs - pointer to conf
374 * - pointer to client doing the connect
375 * output -
376 * side effects -
377 *
378 * This code initiates a connection to a server. It first checks to make
379 * sure the given server exists. If this is the case, it creates a socket,
380 * creates a client, saves the socket information in the client, and
381 * initiates a connection to the server through comm_connect_tcp(). The
382 * completion of this goes through serv_completed_connection().
383 *
384 * We return 1 if the connection is attempted, since we don't know whether
385 * it suceeded or not, and 0 if it fails in here somewhere.
386 */
387 int
388 serv_connect(struct MaskItem *conf, struct Client *by)
389 {
390 struct Client *client_p = NULL;
391 char buf[HOSTIPLEN + 1] = "";
392
393 /* conversion structs */
394 struct sockaddr_in *v4;
395
396 /* Make sure conf is useful */
397 assert(conf);
398
399 getnameinfo((const struct sockaddr *)&conf->addr, conf->addr.ss_len,
400 buf, sizeof(buf), NULL, 0, NI_NUMERICHOST);
401 ilog(LOG_TYPE_IRCD, "Connect to %s[%s] @%s", conf->name, conf->host,
402 buf);
403
404 /* Still processing a DNS lookup? -> exit */
405 if (conf->dns_pending)
406 {
407 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
408 "Error connecting to %s: DNS lookup for connect{} in progress.",
409 conf->name);
410 return 0;
411 }
412
413 if (conf->dns_failed)
414 {
415 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
416 "Error connecting to %s: DNS lookup for connect{} failed.",
417 conf->name);
418 return 0;
419 }
420
421 /*
422 * Make sure this server isn't already connected.
423 * Note: conf should ALWAYS be a valid connect {} block
424 */
425 if ((client_p = hash_find_server(conf->name)))
426 {
427 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
428 "Server %s already present from %s",
429 conf->name, client_get_name(client_p, SHOW_IP));
430 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
431 "Server %s already present from %s",
432 conf->name, client_get_name(client_p, MASK_IP));
433 if (by && IsClient(by) && !MyClient(by))
434 sendto_one_notice(by, &me, ":Server %s already present from %s",
435 conf->name, client_get_name(client_p, MASK_IP));
436 return 0;
437 }
438
439 /* Create a local client */
440 client_p = client_make(NULL);
441
442 /* Copy in the server, hostname, fd */
443 strlcpy(client_p->name, conf->name, sizeof(client_p->name));
444 strlcpy(client_p->host, conf->host, sizeof(client_p->host));
445
446 /* We already converted the ip once, so lets use it - stu */
447 strlcpy(client_p->sockhost, buf, sizeof(client_p->sockhost));
448
449 /* Create a socket for the server connection */
450 if (comm_open(&client_p->connection->fd, conf->addr.ss.ss_family, SOCK_STREAM, 0, NULL) < 0)
451 {
452 /* Eek, failure to create the socket */
453 report_error(L_ALL, "opening stream socket to %s: %s", conf->name, errno);
454
455 SetDead(client_p);
456 exit_client(client_p, "Connection failed");
457 return 0;
458 }
459
460 /* Server names are always guaranteed under HOSTLEN chars */
461 fd_note(&client_p->connection->fd, "Server: %s", client_p->name);
462
463 /*
464 * Attach config entries to client here rather than in serv_connect_callback().
465 * This to avoid null pointer references.
466 */
467 if (!attach_connect_block(client_p, conf->name, conf->host))
468 {
469 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
470 "Host %s is not enabled for connecting: no connect {} block",
471 conf->name);
472 if (by && IsClient(by) && !MyClient(by))
473 sendto_one_notice(by, &me, ":Connect to host %s failed: no connect {} block", client_p->name);
474
475 SetDead(client_p);
476 exit_client(client_p, "Connection failed");
477 return 0;
478 }
479
480 /*
481 * At this point we have a connection in progress and a connect {} block
482 * attached to the client, the socket info should be saved in the client
483 * and it should either be resolved or have a valid address.
484 *
485 * The socket has been connected or connect is in progress.
486 */
487 make_server(client_p);
488
489 if (by && IsClient(by))
490 strlcpy(client_p->serv->by, by->name, sizeof(client_p->serv->by));
491 else
492 strlcpy(client_p->serv->by, "AutoConn.", sizeof(client_p->serv->by));
493
494 SetConnecting(client_p);
495 client_p->connection->aftype = conf->aftype;
496
497 /* Now, initiate the connection */
498 /* XXX assume that a non 0 type means a specific bind address
499 * for this connect.
500 */
501 switch (conf->aftype)
502 {
503 case AF_INET:
504 v4 = (struct sockaddr_in*)&conf->bind;
505
506 if (v4->sin_addr.s_addr)
507 {
508 struct irc_ssaddr ipn;
509
510 memset(&ipn, 0, sizeof(ipn));
511 ipn.ss.ss_family = AF_INET;
512 ipn.ss_port = 0;
513 memcpy(&ipn, &conf->bind, sizeof(ipn));
514
515 comm_connect_tcp(&client_p->connection->fd, conf->host, conf->port,
516 (struct sockaddr *)&ipn, ipn.ss_len,
517 serv_connect_callback, client_p, conf->aftype,
518 CONNECTTIMEOUT);
519 }
520 else if (ConfigServerInfo.specific_ipv4_vhost)
521 {
522 struct irc_ssaddr ipn;
523
524 memset(&ipn, 0, sizeof(ipn));
525 ipn.ss.ss_family = AF_INET;
526 ipn.ss_port = 0;
527 memcpy(&ipn, &ConfigServerInfo.ip, sizeof(ipn));
528
529 comm_connect_tcp(&client_p->connection->fd, conf->host, conf->port,
530 (struct sockaddr *)&ipn, ipn.ss_len,
531 serv_connect_callback, client_p, conf->aftype,
532 CONNECTTIMEOUT);
533 }
534 else
535 comm_connect_tcp(&client_p->connection->fd, conf->host, conf->port,
536 NULL, 0, serv_connect_callback, client_p, conf->aftype,
537 CONNECTTIMEOUT);
538 break;
539 case AF_INET6:
540 {
541 struct irc_ssaddr ipn;
542 struct sockaddr_in6 *v6;
543 struct sockaddr_in6 *v6conf;
544
545 memset(&ipn, 0, sizeof(ipn));
546 v6conf = (struct sockaddr_in6 *)&conf->bind;
547 v6 = (struct sockaddr_in6 *)&ipn;
548
549 if (memcmp(&v6conf->sin6_addr, &v6->sin6_addr, sizeof(struct in6_addr)))
550 {
551 memcpy(&ipn, &conf->bind, sizeof(ipn));
552 ipn.ss.ss_family = AF_INET6;
553 ipn.ss_port = 0;
554
555 comm_connect_tcp(&client_p->connection->fd,
556 conf->host, conf->port,
557 (struct sockaddr *)&ipn, ipn.ss_len,
558 serv_connect_callback, client_p,
559 conf->aftype, CONNECTTIMEOUT);
560 }
561 else if (ConfigServerInfo.specific_ipv6_vhost)
562 {
563 memcpy(&ipn, &ConfigServerInfo.ip6, sizeof(ipn));
564 ipn.ss.ss_family = AF_INET6;
565 ipn.ss_port = 0;
566
567 comm_connect_tcp(&client_p->connection->fd,
568 conf->host, conf->port,
569 (struct sockaddr *)&ipn, ipn.ss_len,
570 serv_connect_callback, client_p,
571 conf->aftype, CONNECTTIMEOUT);
572 }
573 else
574 comm_connect_tcp(&client_p->connection->fd,
575 conf->host, conf->port,
576 NULL, 0, serv_connect_callback, client_p,
577 conf->aftype, CONNECTTIMEOUT);
578 }
579 }
580
581 return 1;
582 }
583
584 static void
585 finish_ssl_server_handshake(struct Client *client_p)
586 {
587 const struct MaskItem *conf = find_conf_name(&client_p->connection->confs,
588 client_p->name, CONF_SERVER);
589 if (!conf)
590 {
591 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
592 "Lost connect{} block for %s", client_get_name(client_p, SHOW_IP));
593 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
594 "Lost connect{} block for %s", client_get_name(client_p, MASK_IP));
595
596 exit_client(client_p, "Lost connect{} block");
597 return;
598 }
599
600 sendto_one(client_p, "PASS %s TS %u %s", conf->spasswd, TS_CURRENT, me.id);
601
602 sendto_one(client_p, "CAPAB :%s", capab_get(NULL));
603
604 sendto_one(client_p, "SERVER %s 1 :%s%s",
605 me.name, ConfigServerHide.hidden ? "(H) " : "",
606 me.info);
607
608 /*
609 * If we've been marked dead because a send failed, just exit
610 * here now and save everyone the trouble of us ever existing.
611 */
612 if (IsDead(client_p))
613 {
614 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
615 "%s went dead during handshake", client_get_name(client_p, SHOW_IP));
616 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
617 "%s went dead during handshake", client_get_name(client_p, MASK_IP));
618 return;
619 }
620
621 /* don't move to serv_list yet -- we haven't sent a burst! */
622 /* If we get here, we're ok, so lets start reading some data */
623 comm_setselect(&client_p->connection->fd, COMM_SELECT_READ, read_packet, client_p, 0);
624 }
625
626 static void
627 ssl_server_handshake(fde_t *fd, void *data)
628 {
629 struct Client *client_p = data;
630 const char *sslerr = NULL;
631
632 tls_handshake_status_t ret = tls_handshake(&client_p->connection->fd.ssl, TLS_ROLE_CLIENT, &sslerr);
633 if (ret != TLS_HANDSHAKE_DONE)
634 {
635 if ((CurrentTime - client_p->connection->firsttime) > CONNECTTIMEOUT)
636 {
637 exit_client(client_p, "Timeout during TLS handshake");
638 return;
639 }
640
641 switch (ret)
642 {
643 case TLS_HANDSHAKE_WANT_WRITE:
644 comm_setselect(&client_p->connection->fd, COMM_SELECT_WRITE,
645 ssl_server_handshake, client_p, CONNECTTIMEOUT);
646 return;
647 case TLS_HANDSHAKE_WANT_READ:
648 comm_setselect(&client_p->connection->fd, COMM_SELECT_READ,
649 ssl_server_handshake, client_p, CONNECTTIMEOUT);
650 return;
651 default:
652 {
653 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
654 "Error connecting to %s: %s", client_p->name,
655 sslerr ? sslerr : "unknown TLS error");
656 exit_client(client_p, "Error during TLS handshake");
657 return;
658 }
659 }
660 }
661
662 comm_settimeout(&client_p->connection->fd, 0, NULL, NULL);
663
664 if (!tls_verify_cert(&client_p->connection->fd.ssl, ConfigServerInfo.message_digest_algorithm, &client_p->certfp))
665 ilog(LOG_TYPE_IRCD, "Server %s!%s@%s gave bad TLS client certificate",
666 client_p->name, client_p->username, client_p->host);
667
668 finish_ssl_server_handshake(client_p);
669 }
670
671 static void
672 ssl_connect_init(struct Client *client_p, const struct MaskItem *conf, fde_t *fd)
673 {
674 if (!tls_new(&client_p->connection->fd.ssl, fd->fd, TLS_ROLE_CLIENT))
675 {
676 SetDead(client_p);
677 exit_client(client_p, "TLS context initialization failed");
678 return;
679 }
680
681 if (!EmptyString(conf->cipher_list))
682 tls_set_ciphers(&client_p->connection->fd.ssl, conf->cipher_list);
683
684 ssl_server_handshake(NULL, client_p);
685 }
686
687 /* serv_connect_callback() - complete a server connection.
688 *
689 * This routine is called after the server connection attempt has
690 * completed. If unsucessful, an error is sent to ops and the client
691 * is closed. If sucessful, it goes through the initialisation/check
692 * procedures, the capabilities are sent, and the socket is then
693 * marked for reading.
694 */
695 static void
696 serv_connect_callback(fde_t *fd, int status, void *data)
697 {
698 struct Client *const client_p = data;
699
700 /* First, make sure it's a real client! */
701 assert(client_p);
702 assert(&client_p->connection->fd == fd);
703
704 /* Next, for backward purposes, record the ip of the server */
705 memcpy(&client_p->connection->ip, &fd->connect.hostaddr, sizeof(client_p->connection->ip));
706
707 /* Check the status */
708 if (status != COMM_OK)
709 {
710 /* We have an error, so report it and quit */
711 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
712 "Error connecting to %s: %s",
713 client_get_name(client_p, SHOW_IP), comm_errstr(status));
714 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
715 "Error connecting to %s: %s",
716 client_get_name(client_p, MASK_IP), comm_errstr(status));
717
718 /*
719 * If a fd goes bad, call dead_link() the socket is no
720 * longer valid for reading or writing.
721 */
722 dead_link_on_write(client_p, 0);
723 return;
724 }
725
726 /* COMM_OK, so continue the connection procedure */
727 /* Get the connect {} block */
728 const struct MaskItem *conf = find_conf_name(&client_p->connection->confs,
729 client_p->name, CONF_SERVER);
730 if (!conf)
731 {
732 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
733 "Lost connect{} block for %s", client_get_name(client_p, SHOW_IP));
734 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
735 "Lost connect{} block for %s", client_get_name(client_p, MASK_IP));
736
737 exit_client(client_p, "Lost connect{} block");
738 return;
739 }
740
741 /* Next, send the initial handshake */
742 SetHandshake(client_p);
743
744 if (IsConfSSL(conf))
745 {
746 ssl_connect_init(client_p, conf, fd);
747 return;
748 }
749
750 sendto_one(client_p, "PASS %s TS %u %s", conf->spasswd, TS_CURRENT, me.id);
751
752 sendto_one(client_p, "CAPAB :%s", capab_get(NULL));
753
754 sendto_one(client_p, "SERVER %s 1 :%s%s", me.name,
755 ConfigServerHide.hidden ? "(H) " : "", me.info);
756
757 /*
758 * If we've been marked dead because a send failed, just exit
759 * here now and save everyone the trouble of us ever existing.
760 */
761 if (IsDead(client_p))
762 {
763 sendto_realops_flags(UMODE_SERVNOTICE, L_ADMIN, SEND_NOTICE,
764 "%s went dead during handshake", client_get_name(client_p, SHOW_IP));
765 sendto_realops_flags(UMODE_SERVNOTICE, L_OPER, SEND_NOTICE,
766 "%s went dead during handshake", client_get_name(client_p, MASK_IP));
767 return;
768 }
769
770 /* don't move to serv_list yet -- we haven't sent a burst! */
771 /* If we get here, we're ok, so lets start reading some data */
772 comm_setselect(fd, COMM_SELECT_READ, read_packet, client_p, 0);
773 }
774
775 struct Client *
776 find_servconn_in_progress(const char *name)
777 {
778 dlink_node *ptr;
779
780 DLINK_FOREACH(ptr, unknown_list.head)
781 {
782 struct Client *cptr = ptr->data;
783
784 if (cptr->name[0])
785 if (!irccmp(name, cptr->name))
786 return cptr;
787 }
788
789 return NULL;
790 }

Properties

Name Value
svn:eol-style native
svn:keywords Id