- extra tests to distinguish errno problems from P::X::Q:A bugs,

[poe-xs-queue-array.git] / queue.h

#ifndef XSQUEUE_H\r
#define XSQUEUE_H\r
\r
typedef unsigned pq_id_t;\r
typedef double pq_priority_t;\r
\r
/* an entry in the queue */\r
typedef struct {\r
  pq_priority_t priority;\r
  pq_id_t id;\r
  SV *payload;\r
} pq_entry;\r
\r
typedef struct poe_queue_tag poe_queue;\r
\r
extern poe_queue *pq_create(void);\r
extern void\r
pq_delete(poe_queue *pq);\r
extern int\r
pq_enqueue(poe_queue *pq, pq_priority_t priority, SV *payload);\r
extern int\r
pq_get_item_count(poe_queue *pq);\r
extern int\r
pq_dequeue_next(poe_queue *pq, pq_priority_t *priority, pq_id_t *id, SV **payload);\r
extern int\r
pq_get_next_priority(poe_queue *pq, pq_priority_t *priority);\r
extern int\r
pq_remove_item(poe_queue *pq, pq_id_t id, SV *filter, pq_entry *removed);\r
extern int\r
pq_remove_items(poe_queue *pq, SV *filter, int max_count, pq_entry **entries);\r
extern int\r
pq_set_priority(poe_queue *pq, pq_id_t id, SV *filter, pq_priority_t new_priority);\r
extern int\r
pq_adjust_priority(poe_queue *pq, pq_id_t id, SV *filter, double delta, pq_priority_t *priority);\r
extern int\r
pq_peek_items(poe_queue *pq, SV *filter, int max_count, pq_entry **items);\r
extern void pq_dump(poe_queue *pq);\r
extern void pq_verify(poe_queue *pq);\r
\r
extern void\r
pq__set_errno_queue(int value);\r
\r
#endif\r