X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=src%2Frmr%2Fcommon%2Fsrc%2Fmbuf_api.c;h=6dbc71ae4aa0c825881a73f131f93707255a9a8c;hb=fcea3951d44de0cc55d33c5e114487abe79d3406;hp=84996ee7b6be6a5f869129510d97e8e95f91ffc4;hpb=190665fe57168a4b9d544b88d3f69797f258c04c;p=ric-plt%2Flib%2Frmr.git diff --git a/src/rmr/common/src/mbuf_api.c b/src/rmr/common/src/mbuf_api.c index 84996ee..6dbc71a 100644 --- a/src/rmr/common/src/mbuf_api.c +++ b/src/rmr/common/src/mbuf_api.c @@ -23,7 +23,7 @@ Abstract: These are common functions which work only on the mbuf and thus (because they do not touch an endpoint or context) can be agnostic to the underlying transport, or the transport - layer provides a transport specific function (e.g. payload + layer provides a transport specific function (e.g. payload reallocation). Author: E. Scott Daniels @@ -40,6 +40,10 @@ #include "rmr.h" // things the users see #include "rmr_agnostic.h" // agnostic things (must be included before private) +#include "rmr_logging.h" + +//#define BUF_TOOLS_ONLY 1 +#include "tools_static.c" // ---------- some wrappers need explicit copy-in functions, also header field setters ----- @@ -72,7 +76,7 @@ extern int rmr_bytes2meid( rmr_mbuf_t* mbuf, unsigned char const* src, int len ) if( len > RMR_MAX_MEID ) { len = RMR_MAX_MEID; errno = EOVERFLOW; - } + } hdr = (uta_mhdr_t *) mbuf->header; memcpy( hdr->meid, src, len ); @@ -429,7 +433,7 @@ extern unsigned char* rmr_get_src( rmr_mbuf_t* msg, unsigned char* dest ) { if( dest != NULL ) { hdr = msg->header; - strcpy( dest, hdr->src ); + zt_buf_fill( dest, hdr->src, RMR_MAX_SRC ); } return dest; @@ -453,11 +457,11 @@ extern unsigned char* rmr_get_srcip( rmr_mbuf_t* msg, unsigned char* dest ) { hdr = msg->header; if( HDR_VERSION( msg->header ) > 2 ) { // src ip was not present in hdr until ver 3 errno = 0; - strcpy( dest, hdr->srcip ); + zt_buf_fill( dest, hdr->srcip, RMR_MAX_SRC ); rstr = dest; } else { errno = 0; - strcpy( dest, hdr->src ); // reutrn the name:port for old messages + zt_buf_fill( dest, hdr->src, RMR_MAX_SRC ); // reutrn the name:port for old messages rstr = dest; } }