/* $Id$ */

#ifndef MICQ_MSG_QUEUE_H
#define MICQ_MSG_QUEUE_H

typedef void (Queuef)(Event *event);

struct Event_s
{
    Connection *conn;
    Event      *rel;
    UDWORD      type;
    UDWORD      seq;
    UDWORD      attempts;
    UDWORD      uin;
    time_t      due;
    Packet     *pak;
    Extra      *extra;
    Queuef     *callback;
    UBYTE       flags;
};

void        QueueInit         (Queue **queue);
Event      *QueueDequeueEvent (Event *event);
void        QueueEnqueue      (Event *event);
Event      *QueueEnqueueData  (Connection *conn, UDWORD type, UDWORD seq, time_t due,
                               Packet *pak, UDWORD uin, Extra *extra, Queuef *callback);
Event      *QueueDequeue      (Connection *conn, UDWORD type, UDWORD seq);
Event      *QueueDequeue2     (Connection *conn, UDWORD type, UDWORD seq, UDWORD uin);
void        QueueRetry        (Connection *conn, UDWORD type, UDWORD uin);
void        QueueCancel       (Connection *conn);

void        QueueRun  ();
Event      *QueuePeek ();
Event      *QueuePop  ();

void EventD (Event *event);

const char *QueueType   (UDWORD type);

#define QUEUE_PEER_RESEND   45
#define QUEUE_PEER_FILE     60
#define QUEUE_UDP_RESEND    43
#define QUEUE_TCP_RESEND    42
#define QUEUE_TYPE2_RESEND  41
#define QUEUE_TYPE2_RESEND_ACK 40
#define QUEUE_TCP_TIMEOUT   72
#define QUEUE_CON_TIMEOUT   77
#define QUEUE_TCP_RECEIVE   32
#define QUEUE_UDP_KEEPALIVE 23
#define QUEUE_SRV_KEEPALIVE 21
#define QUEUE_FLAP          34
#define QUEUE_REQUEST_ROSTER  90
#define QUEUE_REQUEST_META    91
#define QUEUE_ACKNOWLEDGE   80
#define QUEUE_TODO_EG       11
#define QUEUE_CACHE_MSG     100

#define QUEUE_FLAG_CONSIDERED     1 /* this event has been considered and won't
                                       be tried again in this queue run */

#endif /* MICQ_MSG_QUEUE_H */