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
34
35
36
|
#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 char frag_cnt;
unsigned short cnt;
ecp_sts_t abstime;
ecp_sts_t timeout;
ecp_timer_retry_t retry;
void *param;
} 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, void *param);
void *ecp_timer_get_param(ECPTimerItem *ti);
int ecp_timer_push(ECPTimerItem *ti);
void ecp_timer_pop(struct ECPConnection *conn, unsigned char mtype, ecp_seq_t seq, unsigned char frag_cnt, unsigned char frag_tot);
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, void *param);
|