blob: 2ac91733533bab8a67a1de6bdeb3d5bf49020d37 (
plain)
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
|
#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;
} 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, 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);
|