ecp/src/ecp/timer.h


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

#define ECP_MAX_TIMER       8

#define ECP_ERR_MAX_TIMER   -110

struct ECPTimerItem;

typedef ssize_t (*ecp_timer_retry_t) (struct ECPConnection *, struct ECPTimerItem *);

typedef struct ECPTimerItem {
    struct ECPConnection *conn;
    unsigned char mtype;
    unsigned short cnt;
    ecp_sts_t abstime;
    ecp_sts_t timeout;
    ecp_timer_retry_t retry;
} ECPTimerItem;

typedef struct ECPTimer {
    ECPTimerItem item[ECP_MAX_TIMER];
    short head;
#ifdef ECP_WITH_PTHREAD
    pthread_mutex_t mutex;
#endif
} ECPTimer;

int ecp_timer_create(ECPTimer *timer);
void ecp_timer_destroy(ECPTimer *timer);
void ecp_timer_item_init(ECPTimerItem *ti, struct ECPConnection *conn, unsigned char mtype, ecp_timer_retry_t retry_f, unsigned short cnt, ecp_sts_t timeout);
int ecp_timer_push(ECPTimerItem *ti);
void ecp_timer_pop(struct ECPConnection *conn, unsigned char mtype);
void ecp_timer_remove(struct ECPConnection *conn);
ecp_sts_t ecp_timer_exe(struct ECPSocket *sock);
ssize_t ecp_timer_send(struct ECPConnection *conn, ecp_timer_retry_t send_f, unsigned char mtype, unsigned short cnt, ecp_sts_t timeout);