3 * Copyright 2007 Free Software Foundation, Inc.
5 * This file is part of GNU Radio
7 * GNU Radio 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 * GNU Radio 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 along
18 * with this program; if not, write to the Free Software Foundation, Inc.,
19 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
25 #include <mb_msg_queue.h>
26 #include <mb_message.h>
28 // FIXME turn this into a template so we can use it for the runq of mblocks too
30 mb_msg_queue::mb_msg_queue()
34 mb_msg_queue::~mb_msg_queue()
39 mb_msg_queue::insert(mb_message_sptr msg)
41 // omni_mutex_lock l(d_mutex); FIXME
43 mb_pri_t q = mb_pri_clamp(msg->priority());
45 if (d_queue[q].empty_p()){
46 d_queue[q].tail = d_queue[q].head = msg;
47 msg->d_next.reset(); //msg->d_next = 0;
50 d_queue[q].tail->d_next = msg;
51 d_queue[q].tail = msg;
52 msg->d_next.reset(); // msg->d_next = 0;
54 // FIXME set bit in bitmap
58 mb_msg_queue::get_highest_pri_msg()
60 // omni_mutex_lock l(d_mutex); FIXME
62 // FIXME use bitmap and ffz to find best queue in O(1)
64 for (mb_pri_t q = 0; q <= MB_PRI_WORST; q++){
66 if (!d_queue[q].empty_p()){
67 mb_message_sptr msg = d_queue[q].head;
68 d_queue[q].head = msg->d_next;
69 if (d_queue[q].head == 0){
70 d_queue[q].tail.reset(); // d_queue[q].tail = 0;
71 // FIXME clear bit in bitmap
74 msg->d_next.reset(); // msg->d_next = 0;
79 return mb_message_sptr(); // equivalent of a zero pointer