diff options
author | Uros Majstorovic <majstor@majstor.org> | 2017-08-24 14:34:05 +0200 |
---|---|---|
committer | Uros Majstorovic <majstor@majstor.org> | 2017-08-24 14:34:05 +0200 |
commit | e800e8df9fbe633d09a534ae07eb361833572f1a (patch) | |
tree | 57a827276059da457c65c23c936843d42647664c /code/core/rbuf.h | |
parent | a3f0e09379759e4cfb79e1d5c7d7ac752728fe5f (diff) |
seq item implemented for sender
Diffstat (limited to 'code/core/rbuf.h')
-rw-r--r-- | code/core/rbuf.h | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/code/core/rbuf.h b/code/core/rbuf.h index a965755..d10370a 100644 --- a/code/core/rbuf.h +++ b/code/core/rbuf.h @@ -86,19 +86,11 @@ typedef struct ECPConnRBuffer { ECPRBSend *send; } ECPConnRBuffer; -typedef struct ECPRBInfo { - ecp_seq_t seq; - unsigned int idx; - unsigned char mtype; - unsigned char seq_force; -} ECPRBInfo; - int ecp_rbuf_init(ECPRBuffer *rbuf, ECPRBMessage *msg, unsigned int msg_size); int ecp_rbuf_start(ECPRBuffer *rbuf, ecp_seq_t seq); int ecp_rbuf_msg_idx(ECPRBuffer *rbuf, ecp_seq_t seq); ssize_t ecp_rbuf_msg_store(ECPRBuffer *rbuf, ecp_seq_t seq, int idx, unsigned char *msg, size_t msg_size, unsigned char test_flags, unsigned char set_flags); -int ecp_rbuf_info_init(ECPRBInfo *rbuf_info); ssize_t ecp_rbuf_pld_send(struct ECPConnection *conn, unsigned char *payload, size_t payload_size, ecp_seq_t seq); int ecp_rbuf_conn_create(struct ECPConnection *conn, ECPRBSend *buf_s, ECPRBMessage *msg_s, unsigned int msg_s_size, ECPRBRecv *buf_r, ECPRBMessage *msg_r, unsigned int msg_r_size); @@ -115,8 +107,8 @@ ssize_t ecp_rbuf_recv_store(struct ECPConnection *conn, ecp_seq_t seq, unsigned int ecp_rbuf_send_create(struct ECPConnection *conn, ECPRBSend *buf, ECPRBMessage *msg, unsigned int msg_size); void ecp_rbuf_send_destroy(struct ECPConnection *conn); int ecp_rbuf_send_start(struct ECPConnection *conn); -int ecp_rbuf_pkt_prep(ECPRBSend *buf, ecp_seq_t seq, unsigned char mtype, ECPRBInfo *rbuf_info); -ssize_t ecp_rbuf_pkt_send(ECPRBSend *buf, struct ECPSocket *sock, ECPNetAddr *addr, ECPTimerItem *ti, unsigned char *packet, size_t pkt_size, ECPRBInfo *rbuf_info); +int ecp_rbuf_pkt_prep(ECPRBSend *buf, struct ECPSeqItem *si); +ssize_t ecp_rbuf_pkt_send(ECPRBSend *buf, struct ECPSocket *sock, ECPNetAddr *addr, ECPTimerItem *ti, struct ECPSeqItem *si, unsigned char *packet, size_t pkt_size); ssize_t ecp_rbuf_handle_ack(struct ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, ssize_t size); ssize_t ecp_rbuf_handle_flush(struct ECPConnection *conn, ecp_seq_t seq, unsigned char mtype, unsigned char *msg, ssize_t size); |