mirror of
https://github.com/emqx/neuron.git
synced 2026-10-28 22:59:34 +08:00
@@ -100,6 +100,16 @@ inline static uint8_t *neu_protocol_unpack_buf(neu_protocol_unpack_buf_t *buf,
|
||||
return buf->base + buf->offset - size;
|
||||
}
|
||||
|
||||
inline static uint8_t *
|
||||
neu_protocol_unpack_buf_get(neu_protocol_unpack_buf_t *buf, uint16_t size)
|
||||
{
|
||||
if (buf->size - buf->offset < size) {
|
||||
return NULL;
|
||||
}
|
||||
|
||||
return buf->base + buf->offset;
|
||||
}
|
||||
|
||||
inline static uint8_t *neu_protocol_pack_buf(neu_protocol_pack_buf_t *buf,
|
||||
uint16_t size)
|
||||
{
|
||||
@@ -118,6 +128,12 @@ neu_protocol_pack_buf_unused_size(neu_protocol_pack_buf_t *buf)
|
||||
return buf->offset;
|
||||
}
|
||||
|
||||
inline static uint16_t
|
||||
neu_protocol_pack_buf_used_size(neu_protocol_pack_buf_t *buf)
|
||||
{
|
||||
return buf->size - buf->offset;
|
||||
}
|
||||
|
||||
inline static uint16_t
|
||||
neu_protocol_unpack_buf_unused_size(neu_protocol_unpack_buf_t *buf)
|
||||
{
|
||||
|
||||
@@ -58,6 +58,8 @@ rules.append(mkdeb.FileMap("../include/neuron/utils/utlist.h",
|
||||
"/usr/local/include/neuron/utils/"))
|
||||
rules.append(mkdeb.FileMap("../include/neuron/utils/zlog.h",
|
||||
"/usr/local/include/neuron/utils/"))
|
||||
rules.append(mkdeb.FileMap("../include/neuron/utils/protocol_buf.h",
|
||||
"/usr/local/include/neuron/utils/"))
|
||||
rules.append(mkdeb.FileMap("../include/neuron/adapter.h",
|
||||
"/usr/local/include/neuron/"))
|
||||
rules.append(mkdeb.FileMap("../include/neuron/adapter_msg.h",
|
||||
|
||||
Reference in New Issue
Block a user