34 lines
834 B
C
34 lines
834 B
C
/*
|
|
* Copyright (c) 2012, ETH Zurich.
|
|
* All rights reserved.
|
|
*
|
|
* This file is distributed under the terms in the attached LICENSE file.
|
|
* If you do not find this file, copies can be found by writing to:
|
|
* ETH Zurich D-INFK, Haldeneggsteig 4, CH-8092 Zurich. Attn: Systems Group.
|
|
*/
|
|
|
|
#ifndef CAPQUEUE_H
|
|
#define CAPQUEUE_H
|
|
|
|
#include <stdbool.h>
|
|
#include <aos/event_queue.h>
|
|
|
|
struct capqueue_queue {
|
|
struct event_queue queues[2];
|
|
struct event_queue_node queue_end;
|
|
bool on_first, running, retrigger;
|
|
};
|
|
|
|
static inline void
|
|
capqueue_wait(struct capqueue_queue *q, struct event_queue_node *qn,
|
|
struct event_closure event)
|
|
{
|
|
event_queue_add(&q->queues[!q->on_first], qn, event);
|
|
}
|
|
|
|
void capqueue_notify(struct capqueue_queue *q);
|
|
|
|
void capqueue_init(struct capqueue_queue *q, struct waitset *ws);
|
|
|
|
#endif
|