diff options
Diffstat (limited to 'code/timer.h')
-rw-r--r-- | code/timer.h | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/code/timer.h b/code/timer.h new file mode 100644 index 0000000..dd9a2a8 --- /dev/null +++ b/code/timer.h @@ -0,0 +1,43 @@ +#define ECP_MAX_TIMER 8 + +#define ECP_ERR_MAX_TIMER -110 + +#include <stddef.h> + +#ifdef ECP_WITH_PTHREAD +#include <pthread.h> +#endif + +struct ECPConnection; +struct ECPSocket; +struct ECPTimerItem; + +typedef int ecp_timer_retry_t (struct ECPConnection *, struct ECPTimerItem *); + +typedef struct ECPTimerItem { + struct ECPConnection *conn; + unsigned char ptype; + unsigned short cnt; + unsigned int abstime; + unsigned int timeout; + ecp_timer_retry_t *retry; + unsigned char *pld; + size_t pld_size; +} 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); +int ecp_timer_item_init(ECPTimerItem *ti, struct ECPConnection *conn, unsigned char ptype, unsigned short cnt, unsigned int timeout); +int ecp_timer_push(struct ECPConnection *conn, ECPTimerItem *ti); +void ecp_timer_pop(struct ECPConnection *conn, unsigned char ptype); +void ecp_timer_remove(struct ECPConnection *conn); +unsigned int ecp_timer_exe(struct ECPSocket *sock); +int ecp_timer_send(struct ECPConnection *conn, ecp_timer_retry_t *send_f, unsigned char ptype, unsigned short cnt, unsigned int timeout);
\ No newline at end of file |