hub/queue.h

Go to the documentation of this file.

#ifndef utu_queue_h
#define utu_queue_h

/*
 * Utu -- Saving The Internet With Hate
 *
 * Copyright (c) Zed A. Shaw 2005 (zedshaw@zedshaw.com)
 *
 * This file is modifiable/redistributable under the terms of the GNU
 * General Public License.
 *
 * You should have recieved a copy of the GNU General Public License along
 * with this program; see the file COPYING. If not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 0211-1307, USA.
 */



#include <myriad/sglib.h>
#include "protocol/message.h"

typedef struct MsgQueue {
  Message **messages;
  Rendez read_wait;
  int dead;

  size_t i;
  size_t j;
  size_t dim;
} MsgQueue;

MsgQueue *MsgQueue_create(size_t length);

#define MsgQueue_is_empty(Q) ((Q)->i == (Q)->j)

#define MsgQueue_is_full(Q) (((Q)->i)==(((Q)->j)+1)%((Q)->dim))

#define MsgQueue_get_first(Q) ((Q)->messages[(Q)->i])

Message *MsgQueue_first(MsgQueue *queue);

int MsgQueue_add(MsgQueue *q, Message *message);

int MsgQueue_delete(MsgQueue *q);

#define MsgQueue_mark_dead(Q) (Q)->dead = 1

#define MsgQueue_is_dead(Q) (Q)->dead

#define MsgQueue_wake_all(Q) taskwakeupall(&((Q)->read_wait))

#define MsgQueue_wait(Q) tasksleep(&(Q)->read_wait)

void MsgQueue_destroy(MsgQueue *q);

#define MsgQueue_clear(Q) if(Q) (Q)->i = (Q)->j = 0;

#endif

---