From 8df932a7fd1aecc5660f8b5db0f8f652db3d9474 Mon Sep 17 00:00:00 2001 From: Holger Hans Peter Freyther Date: Fri, 26 Feb 2010 20:30:32 +0100 Subject: [write_queue] Add a generic write queue class The write queue can be a dropin replacement for the bsc_fd. It is featuring two callbacks. One for ready read and one for ready write. Whenever there is a message in the queue the write_queue will set the BSC_FD_WRITE flag and then call the write callback. It will make sure to delete the msgb after the write function has been called. This class is intended to be be used in the osmocom, layer2, bsc_msc_ip, bsc_hack and other applications. --- include/osmocore/Makefile.am | 2 +- include/osmocore/write_queue.h | 43 ++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 44 insertions(+), 1 deletion(-) create mode 100644 include/osmocore/write_queue.h (limited to 'include/osmocore') diff --git a/include/osmocore/Makefile.am b/include/osmocore/Makefile.am index 02117528..cc9db084 100644 --- a/include/osmocore/Makefile.am +++ b/include/osmocore/Makefile.am @@ -1,6 +1,6 @@ osmocore_HEADERS = signal.h linuxlist.h timer.h talloc.h msgb.h select.h \ tlv.h bitvec.h comp128.h statistics.h gsm_utils.h utils.h \ - gsmtap.h + gsmtap.h write_queue.h osmocoredir = $(includedir)/osmocore diff --git a/include/osmocore/write_queue.h b/include/osmocore/write_queue.h new file mode 100644 index 00000000..af3d44be --- /dev/null +++ b/include/osmocore/write_queue.h @@ -0,0 +1,43 @@ +/* Generic write queue implementation */ +/* + * (C) 2010 by Holger Hans Peter Freyther + * (C) 2010 by On-Waves + * + * All Rights Reserved + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + * + */ +#ifndef write_queue_h +#define write_queue_h + +#include "select.h" +#include "msgb.h" + +struct write_queue { + struct bsc_fd bfd; + unsigned int max_length; + unsigned int current_length; + + struct llist_head msg_queue; + + int (*read_cb)(struct bsc_fd *fd); + int (*write_cb)(struct bsc_fd *fd, struct msgb *msg); +}; + +void write_queue_init(struct write_queue *queue, int max_length); +int write_queue_enqueue(struct write_queue *queue, struct msgb *data); + +#endif -- cgit v1.2.3