From d580fc0e00bf4b7acd3f9ee3345fad32223b40db Mon Sep 17 00:00:00 2001 From: Uros Majstorovic Date: Fri, 21 Jul 2017 00:33:35 +0200 Subject: send ring buffer implementation; not done --- code/core/rbuf.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'code/core/rbuf.c') diff --git a/code/core/rbuf.c b/code/core/rbuf.c index 54843fa..d6c9c6e 100644 --- a/code/core/rbuf.c +++ b/code/core/rbuf.c @@ -4,7 +4,11 @@ int ecp_rbuf_init(ECPRBuffer *rbuf, ECPRBMessage *msg, unsigned int msg_size) { rbuf->msg = msg; - rbuf->msg_size = msg_size; + if (msg_size) { + rbuf->msg_size = msg_size; + } else { + rbuf->msg_size = ECP_RBUF_SEQ_HALF; + } return ECP_OK; } @@ -20,6 +24,8 @@ int ecp_rbuf_msg_idx(ECPRBuffer *rbuf, ecp_seq_t seq) { ssize_t ecp_rbuf_msg_store(ECPRBuffer *rbuf, ecp_seq_t seq, unsigned char *msg, size_t msg_size, unsigned char test_flags, unsigned char set_flags) { int idx = ecp_rbuf_msg_idx(rbuf, seq); if (idx < 0) return idx; + + if (rbuf->msg == NULL) return 0; if (test_flags && (test_flags & rbuf->msg[idx].flags)) return ECP_ERR_RBUF_FLAG; memcpy(rbuf->msg[idx].msg, msg, msg_size); -- cgit v1.2.3