diff options
author | Harald Welte <laforge@gnumonks.org> | 2010-05-28 09:44:26 +0200 |
---|---|---|
committer | Harald Welte <laforge@gnumonks.org> | 2010-05-28 09:44:26 +0200 |
commit | bf51438a8aeaa67076e209587b83cafe6c4fa4d2 (patch) | |
tree | 23ccc827f6ad1a3fddd97fe66ed9b45342ea8df0 /libosmocore/src/write_queue.c | |
parent | 900aeaf41539a0577f33b501b2cc0c525ce4ce34 (diff) |
remove libosmocore from openbsc.git
The idea was great, but it never really worked in reality...
Diffstat (limited to 'libosmocore/src/write_queue.c')
-rw-r--r-- | libosmocore/src/write_queue.c | 88 |
1 files changed, 0 insertions, 88 deletions
diff --git a/libosmocore/src/write_queue.c b/libosmocore/src/write_queue.c deleted file mode 100644 index 618a8c0b3..000000000 --- a/libosmocore/src/write_queue.c +++ /dev/null @@ -1,88 +0,0 @@ -/* 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. - * - */ - -#include <osmocore/write_queue.h> - -int write_queue_bfd_cb(struct bsc_fd *fd, unsigned int what) -{ - struct write_queue *queue; - - queue = container_of(fd, struct write_queue, bfd); - - if (what & BSC_FD_READ) - queue->read_cb(fd); - - if (what & BSC_FD_EXCEPT) - queue->except_cb(fd); - - if (what & BSC_FD_WRITE) { - struct msgb *msg; - - fd->when &= ~BSC_FD_WRITE; - msg = msgb_dequeue(&queue->msg_queue); - if (!msg) - return -1; - - --queue->current_length; - queue->write_cb(fd, msg); - msgb_free(msg); - - if (!llist_empty(&queue->msg_queue)) - fd->when |= BSC_FD_WRITE; - } - - return 0; -} - -void write_queue_init(struct write_queue *queue, int max_length) -{ - queue->max_length = max_length; - queue->current_length = 0; - queue->read_cb = NULL; - queue->write_cb = NULL; - queue->bfd.cb = write_queue_bfd_cb; - INIT_LLIST_HEAD(&queue->msg_queue); -} - -int write_queue_enqueue(struct write_queue *queue, struct msgb *data) -{ -// if (queue->current_length + 1 >= queue->max_length) -// LOGP(DMSC, LOGL_ERROR, "The queue is full. Dropping not yet implemented.\n"); - - ++queue->current_length; - msgb_enqueue(&queue->msg_queue, data); - queue->bfd.when |= BSC_FD_WRITE; - - return 0; -} - -void write_queue_clear(struct write_queue *queue) -{ - while (!llist_empty(&queue->msg_queue)) { - struct msgb *msg = msgb_dequeue(&queue->msg_queue); - msgb_free(msg); - } - - queue->current_length = 0; - queue->bfd.when &= ~BSC_FD_WRITE; -} |