1 #ifndef INCLUDED_msgq_h
2 #define INCLUDED_msgq_h
4 * IRC - Internet Relay Chat, include/msgq.h
5 * Copyright (C) 2000 Kevin L. Mitchell <klmitch@mit.edu>
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; either version 2, or (at your option)
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
17 * You should have received a copy of the GNU General Public License
18 * along with this program; if not, write to the Free Software
19 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
23 #ifndef INCLUDED_ircd_defs_h
24 #include "ircd_defs.h" /* BUFSIZE */
26 #ifndef INCLUDED_sys_types_h
27 #include <sys/types.h>
28 #define INCLUDED_sys_types_h
30 #ifndef INCLUDED_stdarg_h
32 #define INCLUDED_stdarg_h
45 * These should be considered read-only
47 extern struct MsgCounts msgBufCounts; /* resource count for struct MsgBuf */
48 extern struct MsgCounts msgCounts; /* resource count for struct Msg */
54 struct Msg *head; /* First Msg in queue list */
55 struct Msg *tail; /* Last Msg in queue list */
59 unsigned int length; /* Current number of bytes stored */
60 unsigned int count; /* Current number of messages stored */
61 struct MsgQList queue; /* Normal Msg queue */
62 struct MsgQList prio; /* Priority Msg queue */
66 * MsgQLength - Returns the current number of bytes stored in the buffer.
68 #define MsgQLength(mq) ((mq)->length)
71 * MsgQCount - Returns the current number of messages stored in the buffer
73 #define MsgQCount(mq) ((mq)->count)
76 * MsgQClear - Scratch the current content of the buffer.
77 * Release all allocated buffers and make it empty.
79 #define MsgQClear(mq) msgq_delete((mq), MsgQLength(mq))
84 extern void msgq_init(struct MsgQ *mq);
85 extern void msgq_delete(struct MsgQ *mq, unsigned int length);
86 extern int msgq_mapiov(const struct MsgQ *mq, struct iovec *iov, int count,
88 extern struct MsgBuf *msgq_make(struct Client *dest, const char *format, ...);
89 extern struct MsgBuf *msgq_vmake(struct Client *dest, const char *format,
91 extern void msgq_append(struct Client *dest, struct MsgBuf *mb,
92 const char *format, ...);
93 extern void msgq_clean(struct MsgBuf *mb);
94 extern void msgq_add(struct MsgQ *mq, struct MsgBuf *mb, int prio);
95 extern void msgq_count_memory(size_t *msg_alloc, size_t *msg_used,
96 size_t *msgbuf_alloc, size_t *msgbuf_used);
97 extern unsigned int msgq_bufleft(struct MsgBuf *mb);
99 #endif /* INCLUDED_msgq_h */