ViewVC Help
View File | Revision Log | Show Annotations | View Changeset | Root Listing
root/svn/ircd-hybrid/branches/8.2.x/src/send.c
Revision: 8035
Committed: Fri Mar 17 17:49:11 2017 UTC (7 years ago) by michael
Content type: text/x-csrc
File size: 23261 byte(s)
Log Message:
- send.c: replace IsDefunct() test in sendto_wallops_flags(), and sendto_realops_flags() with just IsDead()

File Contents

# Content
1 /*
2 * ircd-hybrid: an advanced, lightweight Internet Relay Chat Daemon (ircd)
3 *
4 * Copyright (c) 1997-2017 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 send.c
23 * \brief Functions for sending messages.
24 * \version $Id$
25 */
26
27 #include "stdinc.h"
28 #include "list.h"
29 #include "send.h"
30 #include "channel.h"
31 #include "client.h"
32 #include "dbuf.h"
33 #include "irc_string.h"
34 #include "ircd.h"
35 #include "s_bsd.h"
36 #include "server.h"
37 #include "conf_class.h"
38 #include "log.h"
39
40
41 static uintmax_t current_serial;
42
43
44 /* send_format()
45 *
46 * inputs
47 * - buffer
48 * - format pattern to use
49 * - var args
50 * output - number of bytes formatted output
51 * side effects - modifies sendbuf
52 */
53 static void
54 send_format(struct dbuf_block *buffer, const char *pattern, va_list args)
55 {
56 /*
57 * from rfc1459
58 *
59 * IRC messages are always lines of characters terminated with a CR-LF
60 * (Carriage Return - Line Feed) pair, and these messages shall not
61 * exceed 512 characters in length, counting all characters
62 * including the trailing CR-LF.
63 * Thus, there are 510 characters maximum allowed
64 * for the command and its parameters. There is no provision for
65 * continuation message lines. See section 7 for more details about
66 * current implementations.
67 */
68 dbuf_put_args(buffer, pattern, args);
69
70 if (buffer->size > IRCD_BUFSIZE - 2)
71 buffer->size = IRCD_BUFSIZE - 2;
72
73 buffer->data[buffer->size++] = '\r';
74 buffer->data[buffer->size++] = '\n';
75 }
76
77 /*
78 ** send_message
79 ** Internal utility which appends given buffer to the sockets
80 ** sendq.
81 */
82 static void
83 send_message(struct Client *to, struct dbuf_block *buf)
84 {
85 assert(!IsMe(to));
86 assert(to != &me);
87 assert(MyConnect(to));
88
89 if (dbuf_length(&to->connection->buf_sendq) + buf->size > get_sendq(&to->connection->confs))
90 {
91 if (IsServer(to))
92 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
93 "Max SendQ limit exceeded for %s: %zu > %u",
94 client_get_name(to, HIDE_IP),
95 (dbuf_length(&to->connection->buf_sendq) + buf->size),
96 get_sendq(&to->connection->confs));
97
98 if (IsClient(to))
99 AddFlag(to, FLAGS_SENDQEX);
100
101 dead_link_on_write(to, 0);
102 return;
103 }
104
105 dbuf_add(&to->connection->buf_sendq, buf);
106
107 /*
108 * Update statistics. The following is slightly incorrect because
109 * it counts messages even if queued, but bytes only really sent.
110 * Queued bytes get updated in send_queued_write().
111 */
112 ++to->connection->send.messages;
113 ++me.connection->send.messages;
114
115 send_queued_write(to);
116 }
117
118 /* send_message_remote()
119 *
120 * inputs - pointer to client from message is being sent
121 * - pointer to client to send to
122 * - pointer to buffer
123 * output - none
124 * side effects - Despite the function name, this only sends to directly
125 * connected clients.
126 *
127 */
128 static void
129 send_message_remote(struct Client *to, const struct Client *from, struct dbuf_block *buf)
130 {
131 assert(MyConnect(to));
132 assert(IsServer(to));
133 assert(!IsMe(to));
134 assert(to->from == to);
135
136 if (to == from->from)
137 {
138 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE,
139 "Send message to %s dropped from %s (Fake Dir)",
140 to->name, from->name);
141 return;
142 }
143
144 send_message(to, buf);
145 }
146
147 /*
148 ** sendq_unblocked
149 ** Called when a socket is ready for writing.
150 */
151 void
152 sendq_unblocked(fde_t *fd, void *data)
153 {
154 struct Client *const client_p = data;
155 assert(fd == &client_p->connection->fd);
156
157 DelFlag(client_p, FLAGS_BLOCKED);
158 send_queued_write(client_p);
159 }
160
161 /*
162 ** send_queued_write
163 ** This is called when there is a chance that some output would
164 ** be possible. This attempts to empty the send queue as far as
165 ** possible, and then if any data is left, a write is rescheduled.
166 */
167 void
168 send_queued_write(struct Client *to)
169 {
170 int retlen = 0;
171 int want_read = 0;
172
173 /*
174 ** Once socket is marked dead, we cannot start writing to it,
175 ** even if the error is removed...
176 */
177 if (IsDead(to) || HasFlag(to, FLAGS_BLOCKED))
178 return; /* no use calling send() now */
179
180 /* Next, lets try to write some data */
181 if (dbuf_length(&to->connection->buf_sendq))
182 {
183 do
184 {
185 const struct dbuf_block *first = to->connection->buf_sendq.blocks.head->data;
186
187 if (tls_isusing(&to->connection->fd.ssl))
188 {
189 retlen = tls_write(&to->connection->fd.ssl, first->data + to->connection->buf_sendq.pos,
190 first->size - to->connection->buf_sendq.pos, &want_read);
191
192 if (want_read)
193 return; /* Retry later, don't register for write events */
194 }
195 else
196 retlen = send(to->connection->fd.fd, first->data + to->connection->buf_sendq.pos,
197 first->size - to->connection->buf_sendq.pos, 0);
198
199 if (retlen <= 0)
200 break;
201
202 dbuf_delete(&to->connection->buf_sendq, retlen);
203
204 /* We have some data written .. update counters */
205 to->connection->send.bytes += retlen;
206 me.connection->send.bytes += retlen;
207 } while (dbuf_length(&to->connection->buf_sendq));
208
209 if (retlen < 0 && ignoreErrno(errno))
210 {
211 AddFlag(to, FLAGS_BLOCKED);
212
213 /* we have a non-fatal error, reschedule a write */
214 comm_setselect(&to->connection->fd, COMM_SELECT_WRITE, sendq_unblocked, to, 0);
215 }
216 else if (retlen <= 0)
217 {
218 dead_link_on_write(to, errno);
219 return;
220 }
221 }
222 }
223
224 /* send_queued_all()
225 *
226 * input - NONE
227 * output - NONE
228 * side effects - try to flush sendq of each client
229 */
230 void
231 send_queued_all(void)
232 {
233 dlink_node *node = NULL;
234
235 /* Servers are processed first, mainly because this can generate
236 * a notice to opers, which is to be delivered by this function.
237 */
238 DLINK_FOREACH(node, local_server_list.head)
239 send_queued_write(node->data);
240
241 DLINK_FOREACH(node, unknown_list.head)
242 send_queued_write(node->data);
243
244 DLINK_FOREACH(node, local_client_list.head)
245 send_queued_write(node->data);
246
247 /* NOTE: This can still put clients on aborted_list; unfortunately,
248 * exit_aborted_clients takes precedence over send_queued_all,
249 * because exiting clients can generate server/oper traffic.
250 * The easiest approach is dealing with aborted clients in the next I/O lap.
251 * -adx
252 */
253 }
254
255 /* sendto_one()
256 *
257 * inputs - pointer to destination client
258 * - var args message
259 * output - NONE
260 * side effects - send message to single client
261 */
262 void
263 sendto_one(struct Client *to, const char *pattern, ...)
264 {
265 va_list args;
266
267 if (IsDead(to->from))
268 return; /* This socket has already been marked as dead */
269
270 va_start(args, pattern);
271
272 struct dbuf_block *buffer = dbuf_alloc();
273 send_format(buffer, pattern, args);
274
275 va_end(args);
276
277 send_message(to->from, buffer);
278
279 dbuf_ref_free(buffer);
280 }
281
282 void
283 sendto_one_numeric(struct Client *to, const struct Client *from, enum irc_numerics numeric, ...)
284 {
285 va_list args;
286 const char *numstr = NULL;
287
288 if (IsDead(to->from))
289 return;
290
291 const char *dest = ID_or_name(to, to);
292 if (EmptyString(dest))
293 dest = "*";
294
295 struct dbuf_block *buffer = dbuf_alloc();
296 dbuf_put_fmt(buffer, ":%s %03d %s ", ID_or_name(from, to), numeric & ~SND_EXPLICIT, dest);
297
298 va_start(args, numeric);
299
300 if (numeric & SND_EXPLICIT)
301 numstr = va_arg(args, const char *);
302 else
303 numstr = numeric_form(numeric);
304
305 send_format(buffer, numstr, args);
306 va_end(args);
307
308 send_message(to->from, buffer);
309
310 dbuf_ref_free(buffer);
311 }
312
313 void
314 sendto_one_notice(struct Client *to, const struct Client *from, const char *pattern, ...)
315 {
316 va_list args;
317
318 if (IsDead(to->from))
319 return;
320
321 const char *dest = ID_or_name(to, to);
322 if (EmptyString(dest))
323 dest = "*";
324
325 struct dbuf_block *buffer = dbuf_alloc();
326 dbuf_put_fmt(buffer, ":%s NOTICE %s ", ID_or_name(from, to), dest);
327
328 va_start(args, pattern);
329 send_format(buffer, pattern, args);
330 va_end(args);
331
332 send_message(to->from, buffer);
333
334 dbuf_ref_free(buffer);
335 }
336
337 /* sendto_channel_butone()
338 *
339 * inputs - pointer to client(server) to NOT send message to
340 * - pointer to client that is sending this message
341 * - pointer to channel being sent to
342 * - vargs message
343 * output - NONE
344 * side effects - message as given is sent to given channel members.
345 *
346 * WARNING - +D clients are ignored
347 */
348 void
349 sendto_channel_butone(struct Client *one, const struct Client *from,
350 struct Channel *chptr, unsigned int type,
351 const char *pattern, ...)
352 {
353 va_list alocal, aremote;
354 struct dbuf_block *local_buf, *remote_buf;
355 dlink_node *node = NULL;
356
357 local_buf = dbuf_alloc(), remote_buf = dbuf_alloc();
358
359 if (IsClient(from))
360 dbuf_put_fmt(local_buf, ":%s!%s@%s ", from->name, from->username, from->host);
361 else
362 dbuf_put_fmt(local_buf, ":%s ", from->name);
363
364 dbuf_put_fmt(remote_buf, ":%s ", from->id);
365
366 va_start(alocal, pattern);
367 va_start(aremote, pattern);
368 send_format(local_buf, pattern, alocal);
369 send_format(remote_buf, pattern, aremote);
370
371 va_end(aremote);
372 va_end(alocal);
373
374 ++current_serial;
375
376 DLINK_FOREACH(node, chptr->members.head)
377 {
378 struct Membership *member = node->data;
379 struct Client *target_p = member->client_p;
380
381 assert(IsClient(target_p));
382
383 if (IsDefunct(target_p->from))
384 continue;
385
386 if (one && (target_p->from == one->from))
387 continue;
388
389 if (type && (member->flags & type) == 0)
390 continue;
391
392 if (HasUMode(target_p, UMODE_DEAF))
393 continue;
394
395 if (MyConnect(target_p))
396 send_message(target_p, local_buf);
397 else if (target_p->from->connection->serial != current_serial)
398 send_message_remote(target_p->from, from, remote_buf);
399
400 target_p->from->connection->serial = current_serial;
401 }
402
403 dbuf_ref_free(local_buf);
404 dbuf_ref_free(remote_buf);
405 }
406
407 /* sendto_server()
408 *
409 * inputs - pointer to client to NOT send to
410 * - pointer to channel
411 * - caps or'd together which must ALL be present
412 * - caps or'd together which must ALL NOT be present
413 * - printf style format string
414 * - args to format string
415 * output - NONE
416 * side effects - Send a message to all connected servers, except the
417 * client 'one' (if non-NULL), as long as the servers
418 * support ALL capabs in 'caps', and NO capabs in 'nocaps'.
419 *
420 * This function was written in an attempt to merge together the other
421 * billion sendto_*serv*() functions, which sprung up with capabs,
422 * lazylinks, uids, etc.
423 * -davidt
424 */
425 void
426 sendto_server(const struct Client *one,
427 const unsigned int caps,
428 const unsigned int nocaps,
429 const char *format, ...)
430 {
431 va_list args;
432 dlink_node *node;
433
434 va_start(args, format);
435
436 struct dbuf_block *buffer = dbuf_alloc();
437 send_format(buffer, format, args);
438
439 va_end(args);
440
441 DLINK_FOREACH(node, local_server_list.head)
442 {
443 struct Client *client_p = node->data;
444
445 /* If dead already skip */
446 if (IsDead(client_p))
447 continue;
448
449 /* check against 'one' */
450 if (one && (client_p == one->from))
451 continue;
452
453 /* check we have required capabs */
454 if ((client_p->connection->caps & caps) != caps)
455 continue;
456
457 /* check we don't have any forbidden capabs */
458 if ((client_p->connection->caps & nocaps))
459 continue;
460
461 send_message(client_p, buffer);
462 }
463
464 dbuf_ref_free(buffer);
465 }
466
467 /* sendto_common_channels_local()
468 *
469 * inputs - pointer to client
470 * - pattern to send
471 * output - NONE
472 * side effects - Sends a message to all people on local server who are
473 * in same channel with user.
474 * used by m_nick.c and exit_one_client.
475 */
476 void
477 sendto_common_channels_local(struct Client *user, int touser, unsigned int poscap,
478 unsigned int negcap, const char *pattern, ...)
479 {
480 va_list args;
481 dlink_node *uptr;
482 dlink_node *cptr;
483 struct Channel *chptr;
484 struct Membership *member;
485 struct Client *target_p;
486 struct dbuf_block *buffer = dbuf_alloc();
487
488 va_start(args, pattern);
489 send_format(buffer, pattern, args);
490 va_end(args);
491
492 ++current_serial;
493
494 DLINK_FOREACH(cptr, user->channel.head)
495 {
496 chptr = ((struct Membership *)cptr->data)->chptr;
497
498 DLINK_FOREACH(uptr, chptr->locmembers.head)
499 {
500 member = uptr->data;
501 target_p = member->client_p;
502
503 if (target_p == user || IsDefunct(target_p) ||
504 target_p->connection->serial == current_serial)
505 continue;
506
507 if (poscap && HasCap(target_p, poscap) != poscap)
508 continue;
509
510 if (negcap && HasCap(target_p, negcap))
511 continue;
512
513 target_p->connection->serial = current_serial;
514 send_message(target_p, buffer);
515 }
516 }
517
518 if (touser && MyConnect(user) && !IsDead(user) &&
519 user->connection->serial != current_serial)
520 if (HasCap(user, poscap) == poscap)
521 send_message(user, buffer);
522
523 dbuf_ref_free(buffer);
524 }
525
526 /*! \brief Send a message to members of a channel that are locally connected to this server.
527 * \param one Client to skip; can be NULL
528 * \param chptr Destination channel
529 * \param status Channel member status flags clients must have
530 * \param poscap Positive client capabilities flags (CAP)
531 * \param negcap Negative client capabilities flags (CAP)
532 * \param pattern Format string for command arguments
533 */
534 void
535 sendto_channel_local(const struct Client *one, struct Channel *chptr, unsigned int status,
536 unsigned int poscap, unsigned int negcap, const char *pattern, ...)
537 {
538 va_list args;
539 dlink_node *node = NULL;
540 struct dbuf_block *buffer = dbuf_alloc();
541
542 va_start(args, pattern);
543 send_format(buffer, pattern, args);
544 va_end(args);
545
546 DLINK_FOREACH(node, chptr->locmembers.head)
547 {
548 struct Membership *member = node->data;
549 struct Client *target_p = member->client_p;
550
551 if (IsDefunct(target_p))
552 continue;
553
554 if (one && target_p == one->from)
555 continue;
556
557 if (status && (member->flags & status) == 0)
558 continue;
559
560 if (poscap && HasCap(target_p, poscap) != poscap)
561 continue;
562
563 if (negcap && HasCap(target_p, negcap))
564 continue;
565
566 send_message(target_p, buffer);
567 }
568
569 dbuf_ref_free(buffer);
570 }
571
572 /*
573 ** match_it() and sendto_match_butone() ARE only used
574 ** to send a msg to all ppl on servers/hosts that match a specified mask
575 ** (used for enhanced PRIVMSGs) for opers
576 **
577 ** addition -- Armin, 8jun90 (gruner@informatik.tu-muenchen.de)
578 **
579 */
580
581 /* match_it()
582 *
583 * inputs - client pointer to match on
584 * - actual mask to match
585 * - what to match on, HOST or SERVER
586 * output - 1 or 0 if match or not
587 * side effects - NONE
588 */
589 static int
590 match_it(const struct Client *one, const char *mask, unsigned int what)
591 {
592 if (what == MATCH_HOST)
593 return !match(mask, one->host);
594
595 return !match(mask, one->servptr->name);
596 }
597
598 /* sendto_match_butone()
599 *
600 * Send to all clients which match the mask in a way defined on 'what';
601 * either by user hostname or user servername.
602 *
603 * ugh. ONLY used by m_message.c to send an "oper magic" message. ugh.
604 */
605 void
606 sendto_match_butone(const struct Client *one, const struct Client *from,
607 const char *mask, int what, const char *pattern, ...)
608 {
609 va_list alocal, aremote;
610 dlink_node *node = NULL;
611 struct dbuf_block *local_buf, *remote_buf;
612
613 local_buf = dbuf_alloc(), remote_buf = dbuf_alloc();
614
615 dbuf_put_fmt(local_buf, ":%s!%s@%s ", from->name, from->username, from->host);
616 dbuf_put_fmt(remote_buf, ":%s ", from->id);
617
618 va_start(alocal, pattern);
619 va_start(aremote, pattern);
620 send_format(local_buf, pattern, alocal);
621 send_format(remote_buf, pattern, aremote);
622 va_end(aremote);
623 va_end(alocal);
624
625 /* scan the local clients */
626 DLINK_FOREACH(node, local_client_list.head)
627 {
628 struct Client *client_p = node->data;
629
630 if ((!one || client_p != one->from) && !IsDefunct(client_p) &&
631 match_it(client_p, mask, what))
632 send_message(client_p, local_buf);
633 }
634
635 /* Now scan servers */
636 DLINK_FOREACH(node, local_server_list.head)
637 {
638 struct Client *client_p = node->data;
639
640 /*
641 * The old code looped through every client on the
642 * network for each server to check if the
643 * server (client_p) has at least 1 client matching
644 * the mask, using something like:
645 *
646 * for (target_p = GlobalClientList; target_p; target_p = target_p->next)
647 * if (IsRegisteredUser(target_p) &&
648 * match_it(target_p, mask, what) &&
649 * (target_p->from == client_p))
650 * vsendto_prefix_one(client_p, from, pattern, args);
651 *
652 * That way, we wouldn't send the message to
653 * a server who didn't have a matching client.
654 * However, on a network such as EFNet, that
655 * code would have looped through about 50
656 * servers, and in each loop, loop through
657 * about 50k clients as well, calling match()
658 * in each nested loop. That is a very bad
659 * thing cpu wise - just send the message
660 * to every connected server and let that
661 * server deal with it.
662 * -wnder
663 */
664 if ((!one || client_p != one->from) && !IsDefunct(client_p))
665 send_message_remote(client_p, from, remote_buf);
666 }
667
668 dbuf_ref_free(local_buf);
669 dbuf_ref_free(remote_buf);
670 }
671
672 /* sendto_match_servs()
673 *
674 * inputs - source client
675 * - mask to send to
676 * - capab needed
677 * - data
678 * outputs - none
679 * side effects - data sent to servers matching with capab
680 */
681 void
682 sendto_match_servs(const struct Client *source_p, const char *mask, unsigned int cap,
683 const char *pattern, ...)
684 {
685 va_list args;
686 dlink_node *node = NULL;
687 struct dbuf_block *buffer = dbuf_alloc();
688
689 dbuf_put_fmt(buffer, ":%s ", source_p->id);
690 va_start(args, pattern);
691 send_format(buffer, pattern, args);
692 va_end(args);
693
694 ++current_serial;
695
696 DLINK_FOREACH(node, global_server_list.head)
697 {
698 struct Client *target_p = node->data;
699
700 /* Do not attempt to send to ourselves, or the source */
701 if (IsMe(target_p) || target_p->from == source_p->from)
702 continue;
703
704 if (target_p->from->connection->serial == current_serial)
705 continue;
706
707 if (match(mask, target_p->name))
708 continue;
709
710 if (cap && IsCapable(target_p->from, cap) != cap)
711 continue;
712
713 target_p->from->connection->serial = current_serial;
714 send_message_remote(target_p->from, source_p, buffer);
715 }
716
717 dbuf_ref_free(buffer);
718 }
719
720 /* sendto_anywhere()
721 *
722 * inputs - pointer to dest client
723 * - pointer to from client
724 * - varags
725 * output - NONE
726 * side effects - less efficient than sendto_remote and sendto_one
727 * but useful when one does not know where target "lives"
728 */
729 void
730 sendto_anywhere(struct Client *to, const struct Client *from,
731 const char *command,
732 const char *pattern, ...)
733 {
734 va_list args;
735
736 if (IsDead(to->from))
737 return;
738
739 struct dbuf_block *buffer = dbuf_alloc();
740 if (MyClient(to) && IsClient(from))
741 dbuf_put_fmt(buffer, ":%s!%s@%s %s %s ", from->name, from->username,
742 from->host, command, to->name);
743 else
744 dbuf_put_fmt(buffer, ":%s %s %s ", ID_or_name(from, to),
745 command, ID_or_name(to, to));
746
747 va_start(args, pattern);
748 send_format(buffer, pattern, args);
749 va_end(args);
750
751 if (MyConnect(to))
752 send_message(to, buffer);
753 else
754 send_message_remote(to->from, from, buffer);
755
756 dbuf_ref_free(buffer);
757 }
758
759 /* sendto_realops_flags()
760 *
761 * inputs - flag types of messages to show to real opers
762 * - flag indicating opers/admins
763 * - var args input message
764 * output - NONE
765 * side effects - Send to *local* ops only but NOT +s nonopers.
766 */
767 void
768 sendto_realops_flags(unsigned int flags, int level, int type, const char *pattern, ...)
769 {
770 const char *ntype = "???";
771 dlink_node *node;
772 va_list args;
773
774 switch (type)
775 {
776 case SEND_NOTICE:
777 ntype = "Notice";
778 break;
779 case SEND_GLOBAL:
780 ntype = "Global";
781 break;
782 case SEND_LOCOPS:
783 ntype = "LocOps";
784 break;
785 default:
786 assert(0);
787 }
788
789 struct dbuf_block *buffer = dbuf_alloc();
790 dbuf_put_fmt(buffer, ":%s NOTICE * :*** %s -- ", me.name, ntype);
791
792 va_start(args, pattern);
793 send_format(buffer, pattern, args);
794 va_end(args);
795
796 DLINK_FOREACH(node, oper_list.head)
797 {
798 struct Client *client_p = node->data;
799 assert(HasUMode(client_p, UMODE_OPER));
800
801 /*
802 * If we're sending it to opers and they're an admin, skip.
803 * If we're sending it to admins, and they're not, skip.
804 */
805 if (((level == L_ADMIN) && !HasUMode(client_p, UMODE_ADMIN)) ||
806 ((level == L_OPER) && HasUMode(client_p, UMODE_ADMIN)))
807 continue;
808
809 if (HasUMode(client_p, flags) && !IsDead(client_p))
810 send_message(client_p, buffer);
811 }
812
813 dbuf_ref_free(buffer);
814 }
815
816 /* ts_warn()
817 *
818 * inputs - var args message
819 * output - NONE
820 * side effects - Call sendto_realops_flags, with some flood checking
821 * (at most 5 warnings every 5 seconds)
822 */
823 void
824 sendto_realops_flags_ratelimited(uintmax_t *rate, const char *pattern, ...)
825 {
826 va_list args;
827 char buffer[IRCD_BUFSIZE] = "";
828
829 if ((CurrentTime - *rate) < 20)
830 return;
831
832 *rate = CurrentTime;
833
834 va_start(args, pattern);
835 vsnprintf(buffer, sizeof(buffer), pattern, args);
836 va_end(args);
837
838 sendto_realops_flags(UMODE_SERVNOTICE, L_ALL, SEND_NOTICE, "%s", buffer);
839 ilog(LOG_TYPE_IRCD, "%s", buffer);
840 }
841
842 /* sendto_wallops_flags()
843 *
844 * inputs - flag types of messages to show to real opers
845 * - client sending request
846 * - var args input message
847 * output - NONE
848 * side effects - Send a wallops to local opers
849 */
850 void
851 sendto_wallops_flags(unsigned int flags, const struct Client *source_p,
852 const char *pattern, ...)
853 {
854 dlink_node *node = NULL;
855 va_list args;
856 struct dbuf_block *buffer = dbuf_alloc();
857
858 if (IsClient(source_p))
859 dbuf_put_fmt(buffer, ":%s!%s@%s WALLOPS :", source_p->name, source_p->username, source_p->host);
860 else
861 dbuf_put_fmt(buffer, ":%s WALLOPS :", source_p->name);
862
863 va_start(args, pattern);
864 send_format(buffer, pattern, args);
865 va_end(args);
866
867 DLINK_FOREACH(node, oper_list.head)
868 {
869 struct Client *client_p = node->data;
870 assert(client_p->umodes & UMODE_OPER);
871
872 if (HasUMode(client_p, flags) && !IsDead(client_p))
873 send_message(client_p, buffer);
874 }
875
876 dbuf_ref_free(buffer);
877 }

Properties

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