26 RCSIDH(dbuff_h,
"$Id: a23e9485252fc865dc48a3df535ca9046222481f $")
33 #include <freeradius-devel/missing.h>
34 #include <freeradius-devel/util/debug.h>
35 #include <freeradius-devel/util/nbo.h>
39 #include <sys/types.h>
113 struct fr_dbuff_marker_s {
124 #define FR_DBUFF_ADV_PARENT_CURRENT 0x01
126 #define FR_DBUFF_ADV_PARENT_END 0x02
184 #define FR_DBUFF_RETURN(_func, ...) \
186 ssize_t _slen = _func(__VA_ARGS__ ); \
187 if (_slen < 0) return _slen; \
200 #define _FR_DBUFF(_dbuff_or_marker, _start, _adv_parent) \
202 .buff = fr_dbuff_buff(_dbuff_or_marker), \
204 .end = fr_dbuff_end(_dbuff_or_marker), \
205 .p = fr_dbuff_current(_dbuff_or_marker), \
206 .is_const = fr_dbuff_ptr(_dbuff_or_marker)->is_const, \
207 .adv_parent = (_adv_parent), \
208 .shifted = fr_dbuff_ptr(_dbuff_or_marker)->shifted, \
209 .extend = fr_dbuff_ptr(_dbuff_or_marker)->extend, \
210 .uctx = fr_dbuff_ptr(_dbuff_or_marker)->uctx, \
211 .parent = fr_dbuff_ptr(_dbuff_or_marker) \
222 #define FR_DBUFF(_dbuff_or_marker) _FR_DBUFF(_dbuff_or_marker, fr_dbuff_current(_dbuff_or_marker), 0x00)
231 #define FR_DBUFF_ABS(_dbuff_or_marker) _FR_DBUFF(_dbuff_or_marker, fr_dbuff_start(_dbuff_or_marker), 0x00)
240 #define FR_DBUFF_BIND_CURRENT(_dbuff_or_marker) _FR_DBUFF(_dbuff_or_marker, fr_dbuff_current(_dbuff_or_marker), FR_DBUFF_ADV_PARENT_CURRENT)
249 #define FR_DBUFF_BIND_CURRENT_ABS(_dbuff_or_marker) FR_DBUFF_ABS(_dbuff_or_marker, fr_dbuff_start(_dbuff_or_marker), FR_DBUFF_ADV_PARENT_CURRENT)
260 #define FR_DBUFF_BIND_END_ABS(_dbuff_or_marker) _FR_DBUFF(_dbuff_or_marker, fr_dbuff_start(_dbuff_or_marker), FR_DBUFF_ADV_PARENT_END)
267 #define _FR_DBUFF_MAX(_dbuff_or_marker, _max, _adv_parent) \
269 .buff = fr_dbuff_buff(_dbuff_or_marker), \
270 .start = fr_dbuff_current(_dbuff_or_marker), \
271 .end = (((fr_dbuff_end(_dbuff_or_marker) - (_max) < fr_dbuff_current(_dbuff_or_marker))) ? fr_dbuff_end(_dbuff_or_marker) : (fr_dbuff_current(_dbuff_or_marker) + (_max))), \
272 .p = fr_dbuff_current(_dbuff_or_marker), \
273 .is_const = fr_dbuff_ptr(_dbuff_or_marker)->is_const, \
274 .adv_parent = _adv_parent, \
275 .shifted = fr_dbuff_ptr(_dbuff_or_marker)->shifted, \
278 .parent = fr_dbuff_ptr(_dbuff_or_marker) \
301 #define FR_DBUFF_MAX(_dbuff_or_marker, _max) _FR_DBUFF_MAX(_dbuff_or_marker, _max, 0x00)
318 #define FR_DBUFF_MAX_BIND_CURRENT(_dbuff_or_marker, _max) _FR_DBUFF_MAX(_dbuff_or_marker, _max, FR_DBUFF_ADV_PARENT_CURRENT)
324 #if defined(__GNUC__) && __GNUC__ >= 11
336 if (
unlikely(end < start)) end = start;
354 #define fr_dbuff_init(_out, _start, _len_or_end) \
355 _fr_dbuff_init(_out, \
356 (uint8_t const *)(_start), \
357 _Generic((_len_or_end), \
358 size_t : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
359 long : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
360 int : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
361 unsigned int : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
362 uint8_t * : (uint8_t const *)(_len_or_end), \
363 uint8_t const * : (uint8_t const *)(_len_or_end), \
364 char * : (uint8_t const *)(_len_or_end), \
365 char const * : (uint8_t const *)(_len_or_end) \
369 uint8_t const * : true, \
371 char const * : true \
373 #if defined(__GNUC__) && __GNUC__ >= 11
393 } fr_dbuff_uctx_talloc_t;
407 fr_dbuff_t *dbuff, fr_dbuff_uctx_talloc_t *tctx,
408 size_t init,
size_t max)
412 *tctx = (fr_dbuff_uctx_talloc_t){
429 memset(dbuff, 0,
sizeof(*dbuff));
450 TALLOC_FREE(dbuff->buff);
465 } fr_dbuff_uctx_fd_t;
483 *fctx = (fr_dbuff_uctx_fd_t){
486 .buff_end =
buff + len
509 #define FR_DBUFF_TMP(_start, _len_or_end) \
511 .buff_i = (uint8_t const *)(_start), \
512 .start_i = (uint8_t const *)(_start), \
513 .end_i = _Generic((_len_or_end), \
514 size_t : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
515 long : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
516 int : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
517 unsigned int : (uint8_t const *)(_start) + (size_t)(_len_or_end), \
518 uint8_t * : (uint8_t const *)(_len_or_end), \
519 uint8_t const * : (uint8_t const *)(_len_or_end), \
520 char * : (uint8_t const *)(_len_or_end), \
521 char const * : (uint8_t const *)(_len_or_end) \
524 .is_const = _Generic((_start), \
526 uint8_t const * : true, \
528 char const * : true \
551 #define FR_DBUFF_TALLOC_THREAD_LOCAL(_out, _init, _max) \
553 static _Thread_local fr_dbuff_thread_local_t *_dbuff_t_local; \
554 if (!_dbuff_t_local) { \
555 fr_dbuff_thread_local_t *dbtl = talloc_zero(NULL, fr_dbuff_thread_local_t); \
556 fr_dbuff_init_talloc(dbtl, &dbtl->dbuff, &dbtl->tctx, _init, _max); \
557 fr_atexit_thread_local(_dbuff_t_local, _dbuff_thread_local_free, dbtl); \
558 *(_out) = &_dbuff_t_local->dbuff; \
560 fr_dbuff_reset_talloc(&_dbuff_t_local->dbuff); \
561 *(_out) = &_dbuff_t_local->dbuff; \
577 #define FR_DBUFF_FLAG_EXTENDABLE 0x01
581 #define FR_DBUFF_FLAG_EXTENDED 0x02
605 #define fr_dbuff_is_extendable(_status) ((_status) & FR_DBUFF_FLAG_EXTENDABLE)
609 #define fr_dbuff_was_extended(_status) ((_status) & FR_DBUFF_FLAG_EXTENDED)
615 size_t remaining,
size_t lowat)
625 if (remaining >= lowat) {
630 if (!
in->extend || !(extended =
in->extend(
in, lowat - remaining)))
goto not_extendable;
634 return remaining + extended;
655 #define fr_dbuff_extend_lowat(_status, _dbuff_or_marker, _lowat) \
656 _fr_dbuff_extend_lowat(_status, \
657 fr_dbuff_ptr(_dbuff_or_marker), \
658 fr_dbuff_remaining(_dbuff_or_marker), _lowat)
668 #define FR_DBUFF_EXTEND_LOWAT_OR_RETURN(_dbuff_or_marker, _lowat) \
670 size_t _remaining = fr_dbuff_extend_lowat(NULL, _dbuff_or_marker, _lowat); \
671 if (_remaining < _lowat) return -(_lowat - _remaining); \
684 #define _FR_DBUFF_EXTEND_LOWAT_POS_OR_RETURN(_pos_p, _dbuff_or_marker, _lowat) \
686 size_t _remaining = _fr_dbuff_extend_lowat(NULL, \
687 fr_dbuff_ptr(_dbuff_or_marker), \
688 fr_dbuff_end(_dbuff_or_marker) - (*(_pos_p)), _lowat); \
689 if (_remaining < _lowat) return -(_lowat - _remaining); \
700 #define fr_dbuff_extend(_dbuff) fr_dbuff_extend_lowat(NULL, _dbuff, 1)
738 #define fr_dbuff_remaining(_dbuff_or_marker) \
739 ((size_t)(fr_dbuff_end(_dbuff_or_marker) < fr_dbuff_current(_dbuff_or_marker) ? \
740 0 : (fr_dbuff_end(_dbuff_or_marker) - fr_dbuff_current(_dbuff_or_marker))))
756 #define FR_DBUFF_REMAINING_RETURN(_dbuff_or_marker, _len) \
757 if ((_len) > fr_dbuff_remaining(_dbuff_or_marker)) return -((_len) - fr_dbuff_remaining(_dbuff_or_marker))
762 #define fr_dbuff_used(_dbuff_or_marker) \
763 ((size_t)(fr_dbuff_start(_dbuff_or_marker) > fr_dbuff_current(_dbuff_or_marker) ? \
764 0 : (fr_dbuff_current(_dbuff_or_marker) - fr_dbuff_start(_dbuff_or_marker))))
771 #define fr_dbuff_len(_dbuff_or_marker) \
772 ((size_t)(fr_dbuff_end(_dbuff_or_marker) - fr_dbuff_start(_dbuff_or_marker)))
781 #define fr_dbuff_behind(_dbuff_or_marker) \
782 (fr_dbuff_current(_dbuff_or_marker) > fr_dbuff_current((_dbuff_or_marker)->parent) ? \
783 0 : fr_dbuff_current((_dbuff_or_marker)->parent) - fr_dbuff_current(_dbuff_or_marker))
791 #define fr_dbuff_ahead(_dbuff_or_marker) \
792 (fr_dbuff_current((_dbuff_or_marker)->parent) > fr_dbuff_current(_dbuff_or_marker) ? \
793 0 : fr_dbuff_current(_dbuff_or_marker) - fr_dbuff_current((_dbuff_or_marker)->parent))
853 #define fr_dbuff_ptr(_dbuff_or_marker) \
854 _Generic((_dbuff_or_marker), \
855 fr_dbuff_t * : ((fr_dbuff_t *)(_dbuff_or_marker)), \
856 fr_dbuff_marker_t * : (((fr_dbuff_marker_t *)(_dbuff_or_marker))->parent) \
864 #define fr_dbuff_ptr_const(_dbuff_or_marker) \
865 _Generic((_dbuff_or_marker), \
866 fr_dbuff_t * : ((fr_dbuff_t const *)(_dbuff_or_marker)), \
867 fr_dbuff_t const * : ((fr_dbuff_t const *)(_dbuff_or_marker)), \
868 fr_dbuff_marker_t * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent), \
869 fr_dbuff_marker_t const * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent) \
877 #define fr_dbuff_buff(_dbuff_or_marker) \
878 _Generic((_dbuff_or_marker), \
879 fr_dbuff_t * : (((fr_dbuff_t const *)(_dbuff_or_marker))->buff), \
880 fr_dbuff_t const * : (((fr_dbuff_t const *)(_dbuff_or_marker))->buff), \
881 fr_dbuff_marker_t * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->buff), \
882 fr_dbuff_marker_t const * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->buff) \
893 #define fr_dbuff_start(_dbuff_or_marker) \
894 (_Generic((_dbuff_or_marker), \
895 fr_dbuff_t * : (((fr_dbuff_t const *)(_dbuff_or_marker))->start), \
896 fr_dbuff_t const * : (((fr_dbuff_t const *)(_dbuff_or_marker))->start), \
897 fr_dbuff_marker_t * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->start), \
898 fr_dbuff_marker_t const * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->start) \
906 #define fr_dbuff_current(_dbuff_or_marker) \
907 (_Generic((_dbuff_or_marker), \
908 fr_dbuff_t * : (((fr_dbuff_t const *)(_dbuff_or_marker))->p), \
909 fr_dbuff_t const * : (((fr_dbuff_t const *)(_dbuff_or_marker))->p), \
910 fr_dbuff_marker_t * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->p), \
911 fr_dbuff_marker_t const * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->p) \
921 #define _fr_dbuff_current_ptr(_dbuff_or_marker) \
922 (_Generic((_dbuff_or_marker), \
923 fr_dbuff_t * : &(((fr_dbuff_t *)(_dbuff_or_marker))->p), \
924 fr_dbuff_marker_t * : &(((fr_dbuff_marker_t *)(_dbuff_or_marker))->p) \
933 #define fr_dbuff_end(_dbuff_or_marker) \
934 (_Generic((_dbuff_or_marker), \
935 fr_dbuff_t * : (((fr_dbuff_t const *)(_dbuff_or_marker))->end), \
936 fr_dbuff_t const * : (((fr_dbuff_t const *)(_dbuff_or_marker))->end), \
937 fr_dbuff_marker_t * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->end), \
938 fr_dbuff_marker_t const * : (((fr_dbuff_marker_t const *)(_dbuff_or_marker))->parent->end) \
956 if (dbuff->adv_parent && dbuff->parent) _fr_dbuff_set_recurse(dbuff->parent, dbuff->adv_parent, p);
975 if (
unlikely(p > dbuff->end))
return -(p - dbuff->end);
976 if (
unlikely(p < dbuff->start))
return 0;
979 if (dbuff->adv_parent && dbuff->parent) _fr_dbuff_set_recurse(dbuff->parent, dbuff->adv_parent, p);
999 #define fr_dbuff_set(_dst, _src) \
1001 _fr_dbuff_current_ptr(_dst), fr_dbuff_ptr(_dst), \
1003 fr_dbuff_t * : fr_dbuff_current((fr_dbuff_t const *)(_src)), \
1004 fr_dbuff_marker_t * : fr_dbuff_current((fr_dbuff_marker_t const *)(_src)), \
1005 uint8_t const * : (uint8_t const *)(_src), \
1006 uint8_t * : (uint8_t const *)(_src), \
1007 size_t : (fr_dbuff_start(_dst) + (uintptr_t)(_src)), \
1008 long : (fr_dbuff_start(_dst) + (uintptr_t)(_src)), \
1009 int : (fr_dbuff_start(_dst) + (uintptr_t)(_src)) \
1017 #define FR_DBUFF_SET_RETURN(_dst, _src) FR_DBUFF_RETURN(fr_dbuff_set, _dst, _src)
1030 if (
unlikely(p > dbuff->end))
return -(p - dbuff->end);
1031 if (
unlikely(p < dbuff->start))
return 0;
1035 return dbuff->end - p;
1046 #define fr_dbuff_set_end(_dst, _end) \
1048 fr_dbuff_ptr(_dst), \
1050 fr_dbuff_t * : fr_dbuff_current((fr_dbuff_t const *)(_end)), \
1051 fr_dbuff_marker_t * : fr_dbuff_current((fr_dbuff_marker_t const *)(_end)), \
1052 uint8_t const * : (uint8_t const *)(_end), \
1053 uint8_t * : (uint8_t const *)(_end) \
1067 #define fr_dbuff_advance(_dbuff_or_marker, _len) \
1068 fr_dbuff_set(_dbuff_or_marker, \
1069 (fr_dbuff_current(_dbuff_or_marker) + \
1071 unsigned char : (size_t)(_len), \
1072 unsigned short : (size_t)(_len), \
1073 unsigned int : (size_t)(_len), \
1074 unsigned long : (size_t)(_len), \
1075 unsigned long long : (size_t)(_len), \
1076 int : (size_t)(_len) \
1083 #define FR_DBUFF_ADVANCE_RETURN(_dbuff_or_marker, _len) FR_DBUFF_RETURN(fr_dbuff_advance, _dbuff_or_marker, _len)
1103 if (p > dbuff->end) {
1104 size_t rel = p - dbuff->start;
1106 if (!dbuff->extend) {
1108 return -((dbuff->start + rel) - dbuff->end);
1111 dbuff->extend(dbuff, p - dbuff->end);
1112 if ((dbuff->start + rel) > dbuff->end)
goto oos;
1114 *pos_p = dbuff->start + rel;
1119 if (dbuff->adv_parent && dbuff->parent) _fr_dbuff_set_recurse(dbuff->parent, dbuff->adv_parent, *pos_p);
1134 #define fr_dbuff_advance_extend(_dbuff_or_marker, _len) \
1135 _fr_dbuff_advance(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), \
1137 unsigned char : (size_t)(_len), \
1138 unsigned short : (size_t)(_len), \
1139 unsigned int : (size_t)(_len), \
1140 unsigned long : (size_t)(_len), \
1141 unsigned long long : (size_t)(_len), \
1142 int : (size_t)(_len) \
1145 #define FR_DBUFF_BIND_EXTEND_RETURN(_dbuff_or_marker, _len) FR_DBUFF_RETURN(fr_dbuff_advance_extend, _dbuff_or_marker, _len)
1150 #define fr_dbuff_set_to_start(_dbuff_or_marker) \
1151 fr_dbuff_set(_dbuff_or_marker, fr_dbuff_start(_dbuff_or_marker))
1156 #define fr_dbuff_set_to_end(_dbuff_or_marker) \
1157 fr_dbuff_set(_dbuff_or_marker, fr_dbuff_end(_dbuff_or_marker))
1207 m->parent->m = m->next;
1210 memset(m, 0,
sizeof(*m));
1269 static inline CC_HINT(always_inline)
size_t _fr_dbuff_safecpy(
uint8_t *o_start,
uint8_t *o_end,
1273 size_t i_len = i_end - i_start;
1275 if (
unlikely((o_end < o_start) || (i_end < i_start)))
return 0;
1277 diff = (o_end - o_start) - (i_len);
1278 if (diff < 0)
return 0;
1280 if ((i_start > o_end) || (i_end < o_start)) {
1281 memcpy(o_start, i_start, i_len);
1283 memmove(o_start, i_start, i_len);
1298 _FR_DBUFF_EXTEND_LOWAT_POS_OR_RETURN(pos_p,
out,
inlen);
1300 return _fr_dbuff_set(pos_p,
out, (*pos_p) + _fr_dbuff_safecpy((*pos_p), (*pos_p) +
inlen,
in,
in +
inlen));
1314 memcpy(&our_in, &
in,
sizeof(our_in));
1315 memcpy(&our_in_p, &in_p,
sizeof(our_in_p));
1317 if (
inlen == SIZE_MAX) {
1318 ext_len = _fr_dbuff_extend_lowat(NULL, our_in,
fr_dbuff_end(our_in) - (*our_in_p),
inlen);
1321 _FR_DBUFF_EXTEND_LOWAT_POS_OR_RETURN(our_in_p, our_in,
inlen);
1323 return _fr_dbuff_in_memcpy(pos_p,
out, *our_in_p,
inlen);
1345 #define fr_dbuff_in_memcpy(_dbuff_or_marker, _in, _inlen) \
1347 uint8_t * : _fr_dbuff_in_memcpy(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1348 fr_dbuff_ptr(_dbuff_or_marker), \
1349 (uint8_t const *)(_in), \
1351 uint8_t const * : _fr_dbuff_in_memcpy(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1352 fr_dbuff_ptr(_dbuff_or_marker), \
1353 (uint8_t const *)(_in), \
1355 char * : _fr_dbuff_in_memcpy(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1356 fr_dbuff_ptr(_dbuff_or_marker), \
1357 (uint8_t const *)(_in), \
1358 (size_t)(_inlen) == SIZE_MAX ? strlen((char const *)(_in)) : (_inlen)), \
1359 char const * : _fr_dbuff_in_memcpy(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1360 fr_dbuff_ptr(_dbuff_or_marker), \
1361 (uint8_t const *)(_in), \
1362 (size_t)(_inlen) == SIZE_MAX ? strlen((char const *)(_in)) : (_inlen)), \
1363 fr_dbuff_t * : _fr_dbuff_in_memcpy_dbuff(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1364 fr_dbuff_ptr(_dbuff_or_marker), \
1365 &((fr_dbuff_t const *)(_in))->p, \
1366 ((fr_dbuff_t const *)(_in)), \
1368 fr_dbuff_marker_t * : _fr_dbuff_in_memcpy_dbuff(_fr_dbuff_current_ptr(_dbuff_or_marker), \
1369 fr_dbuff_ptr(_dbuff_or_marker), \
1370 &((fr_dbuff_marker_t const *)(_in))->p, \
1371 ((fr_dbuff_marker_t const *)(_in))->parent, _inlen) \
1377 #define FR_DBUFF_IN_MEMCPY_RETURN(_dbuff_or_marker, _in, _inlen) FR_DBUFF_RETURN(fr_dbuff_in_memcpy, _dbuff_or_marker, _in, _inlen)
1393 return _fr_dbuff_set(pos_p,
out, (*pos_p) + _fr_dbuff_safecpy((*pos_p), (*pos_p) +
inlen,
in,
in +
inlen));
1407 ext_len = _fr_dbuff_extend_lowat(NULL, our_in,
fr_dbuff_end(our_in) - (*our_in_p),
inlen);
1410 return _fr_dbuff_in_memcpy_partial(pos_p,
out, (*our_in_p),
inlen);
1433 #define fr_dbuff_in_memcpy_partial(_out, _in, _inlen) \
1435 uint8_t * : _fr_dbuff_in_memcpy_partial(_fr_dbuff_current_ptr(_out), _out, (uint8_t const *)(_in), _inlen), \
1436 uint8_t const * : _fr_dbuff_in_memcpy_partial(_fr_dbuff_current_ptr(_out), _out, (uint8_t const *)(_in), _inlen), \
1437 char * : _fr_dbuff_in_memcpy_partial(_fr_dbuff_current_ptr(_out), _out, (uint8_t const *)(_in), _inlen == SIZE_MAX ? strlen((char const *)(_in)) : _inlen), \
1438 char const * : _fr_dbuff_in_memcpy_partial(_fr_dbuff_current_ptr(_out), _out, (uint8_t const *)(_in), _inlen == SIZE_MAX ? strlen((char const *)(_in)) : _inlen), \
1439 fr_dbuff_t * : _fr_dbuff_in_memcpy_partial_dbuff(_fr_dbuff_current_ptr(_out), fr_dbuff_ptr(_out), &((fr_dbuff_t const *)(_in))->p, ((fr_dbuff_t const *)(_in)), _inlen), \
1440 fr_dbuff_marker_t * : _fr_dbuff_in_memcpy_partial_dbuff(_fr_dbuff_current_ptr(_out), fr_dbuff_ptr(_out), &((fr_dbuff_marker_t const *)(_in))->p, ((fr_dbuff_marker_t const *)(_in))->parent, _inlen) \
1450 #define fr_dbuff_in_bytes_partial(_dbuff, ...) \
1451 fr_dbuff_in_memcpy_partial(_dbuff, ((uint8_t []){ __VA_ARGS__ }), sizeof((uint8_t []){ __VA_ARGS__ }))
1460 #define fr_dbuff_in_bytes(_dbuff_or_marker, ...) \
1461 fr_dbuff_in_memcpy(_dbuff_or_marker, ((uint8_t []){ __VA_ARGS__ }), sizeof((uint8_t []){ __VA_ARGS__ }))
1467 #define FR_DBUFF_IN_BYTES_RETURN(_dbuff_or_marker, ...) \
1468 FR_DBUFF_IN_MEMCPY_RETURN(_dbuff_or_marker, ((uint8_t []){ __VA_ARGS__ }), sizeof((uint8_t []){ __VA_ARGS__ }))
1478 _FR_DBUFF_EXTEND_LOWAT_POS_OR_RETURN(pos_p, dbuff,
inlen);
1480 memset((*pos_p), c,
inlen);
1482 return _fr_dbuff_set(pos_p, dbuff, (*pos_p) +
inlen);
1496 #define fr_dbuff_memset(_dbuff_or_marker, _c, _inlen) \
1497 _fr_dbuff_memset(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), _c, _inlen)
1503 #define FR_DBUFF_MEMSET_RETURN(_dbuff_or_marker, _c, _inlen) FR_DBUFF_RETURN(fr_dbuff_memset, _dbuff_or_marker, _c, _inlen)
1509 #define FR_DBUFF_PARSE_INT_DEF(_type) \
1510 static inline ssize_t _fr_dbuff_in_##_type(uint8_t **pos_p, fr_dbuff_t *out, _type##_t num) \
1512 fr_assert(!out->is_const); \
1513 _FR_DBUFF_EXTEND_LOWAT_POS_OR_RETURN(pos_p, out, sizeof(_type##_t)); \
1514 fr_nbo_from_##_type((*pos_p), num); \
1515 return _fr_dbuff_set(pos_p, out, (*pos_p) + sizeof(_type##_t)); \
1517 FR_DBUFF_PARSE_INT_DEF(uint16)
1518 FR_DBUFF_PARSE_INT_DEF(uint32)
1519 FR_DBUFF_PARSE_INT_DEF(uint64)
1520 FR_DBUFF_PARSE_INT_DEF(int16)
1521 FR_DBUFF_PARSE_INT_DEF(int32)
1522 FR_DBUFF_PARSE_INT_DEF(int64)
1539 return _fr_dbuff_in_uint32(pos_p,
out, *(
uint32_t *)(&num));
1550 return _fr_dbuff_in_uint64(pos_p,
out, *(uint64_t *)(&num));
1562 #define fr_dbuff_in(_dbuff_or_marker, _in) \
1564 int8_t : fr_dbuff_in_bytes(_dbuff_or_marker, (int8_t)_in), \
1565 int16_t : _fr_dbuff_in_int16(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (int16_t)_in), \
1566 int32_t : _fr_dbuff_in_int32(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (int32_t)_in), \
1567 int64_t : _fr_dbuff_in_int64(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (int64_t)_in), \
1568 uint8_t : fr_dbuff_in_bytes(_dbuff_or_marker, (uint8_t)_in), \
1569 uint16_t : _fr_dbuff_in_uint16(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (uint16_t)_in), \
1570 uint32_t : _fr_dbuff_in_uint32(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (uint32_t)_in), \
1571 uint64_t : _fr_dbuff_in_uint64(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (uint64_t)_in), \
1572 float : _fr_dbuff_in_float(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (float)_in), \
1573 double : _fr_dbuff_in_double(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), (double)_in) \
1580 #define FR_DBUFF_IN_RETURN(_dbuff_or_marker, _in) FR_DBUFF_RETURN(fr_dbuff_in, _dbuff_or_marker, _in)
1588 uint8_t swapped[
sizeof(uint64_t)];
1593 return _fr_dbuff_in_memcpy(pos_p, dbuff, (swapped + (
sizeof(uint64_t) - ret)), ret);
1604 #define fr_dbuff_in_uint64v(_dbuff_or_marker, _num) \
1605 _fr_dbuff_in_uint64v(_fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), _num)
1611 #define FR_DBUFF_IN_UINT64V(_dbuff_or_marker, _num) FR_DBUFF_RETURN(fr_dbuff_in_uint64v, _dbuff_or_marker, _num)
1648 #define fr_dbuff_move(_out, _in, _len) \
1652 fr_dbuff_t * : _fr_dbuff_move_dbuff_to_dbuff((fr_dbuff_t *)_out, \
1653 (fr_dbuff_t *)_in, \
1655 fr_dbuff_marker_t * : _fr_dbuff_move_dbuff_marker_to_dbuff((fr_dbuff_t *)_out, \
1656 (fr_dbuff_marker_t *)_in, \
1659 fr_dbuff_marker_t * : \
1661 fr_dbuff_t * : _fr_dbuff_move_dbuff_to_dbuff_marker((fr_dbuff_marker_t *)_out, \
1662 (fr_dbuff_t *)_in, \
1664 fr_dbuff_marker_t * : _fr_dbuff_move_dbuff_marker_to_dbuff_marker((fr_dbuff_marker_t *)_out, \
1665 (fr_dbuff_marker_t *)_in, \
1681 size_t ext_len, to_copy, remaining;
1683 for (remaining = outlen; remaining > 0; remaining -= to_copy) {
1684 to_copy = remaining;
1685 ext_len = _fr_dbuff_extend_lowat(NULL,
in,
fr_dbuff_end(
in) - (*pos_p), 1);
1686 if (ext_len == 0)
return -remaining;
1687 if (ext_len < to_copy) to_copy = ext_len;
1688 out += _fr_dbuff_set(pos_p,
in,
1689 (*pos_p) + _fr_dbuff_safecpy(
out,
out + to_copy, (*pos_p), (*pos_p) + to_copy));
1700 if (outlen == SIZE_MAX) outlen = _fr_dbuff_extend_lowat(NULL,
out,
fr_dbuff_end(
out) - (*out_p), outlen);
1702 return _fr_dbuff_out_memcpy((*out_p), pos_p,
in, outlen);
1724 #define fr_dbuff_out_memcpy(_out, _dbuff_or_marker, _outlen) \
1726 uint8_t * : _fr_dbuff_out_memcpy((uint8_t *)(_out), \
1727 _fr_dbuff_current_ptr(_dbuff_or_marker), \
1728 fr_dbuff_ptr(_dbuff_or_marker), \
1730 fr_dbuff_t * : _fr_dbuff_out_memcpy_dbuff(_fr_dbuff_current_ptr((fr_dbuff_t *)_out), \
1731 fr_dbuff_ptr((fr_dbuff_t *)(_out)), \
1732 _fr_dbuff_current_ptr(_dbuff_or_marker), \
1733 fr_dbuff_ptr(_dbuff_or_marker), _outlen), \
1734 fr_dbuff_marker_t * : _fr_dbuff_out_memcpy_dbuff(_fr_dbuff_current_ptr((fr_dbuff_marker_t *)_out), \
1735 fr_dbuff_ptr((fr_dbuff_marker_t *)(_out)), \
1736 _fr_dbuff_current_ptr(_dbuff_or_marker), \
1737 fr_dbuff_ptr(_dbuff_or_marker), _outlen) \
1744 #define FR_DBUFF_OUT_MEMCPY_RETURN(_out, _dbuff_or_marker, _outlen) FR_DBUFF_RETURN(fr_dbuff_out_memcpy, _out, _dbuff_or_marker, _outlen)
1750 #define FR_DBUFF_OUT_DEF(_type) \
1751 static inline ssize_t _fr_dbuff_out_##_type(_type##_t *out, uint8_t **pos_p, fr_dbuff_t *in) \
1754 FR_DBUFF_EXTEND_LOWAT_OR_RETURN(in, sizeof(_type##_t)); \
1755 *out = fr_nbo_to_##_type((*pos_p)); \
1756 return _fr_dbuff_set(pos_p, in, (*pos_p) + sizeof(_type##_t)); \
1759 FR_DBUFF_OUT_DEF(uint16)
1760 FR_DBUFF_OUT_DEF(uint32)
1761 FR_DBUFF_OUT_DEF(uint64)
1762 FR_DBUFF_OUT_DEF(int16)
1763 FR_DBUFF_OUT_DEF(int32)
1764 FR_DBUFF_OUT_DEF(int64)
1779 #define fr_dbuff_out(_out, _dbuff_or_marker) \
1781 uint8_t * : _fr_dbuff_out_memcpy((uint8_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), 1), \
1782 uint16_t * : _fr_dbuff_out_uint16((uint16_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1783 uint32_t * : _fr_dbuff_out_uint32((uint32_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1784 uint64_t * : _fr_dbuff_out_uint64((uint64_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1785 int8_t * : _fr_dbuff_out_memcpy((uint8_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), 1), \
1786 int16_t * : _fr_dbuff_out_int16((int16_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1787 int32_t * : _fr_dbuff_out_int32((int32_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1788 int64_t * : _fr_dbuff_out_int64((int64_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1789 float * : _fr_dbuff_out_uint32((uint32_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)), \
1790 double * : _fr_dbuff_out_uint64((uint64_t *)(_out), _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker)) \
1797 #define FR_DBUFF_OUT_RETURN(_out, _dbuff_or_marker) FR_DBUFF_RETURN(fr_dbuff_out, _out, _dbuff_or_marker)
1806 fr_assert(length > 0 && length <=
sizeof(uint64_t));
1809 slen = _fr_dbuff_out_memcpy(((
uint8_t *) num) + (8 - length), pos_p, dbuff, length);
1810 if (slen <= 0)
return slen;
1827 #define fr_dbuff_out_uint64v(_num, _dbuff_or_marker, _len) \
1828 _fr_dbuff_out_uint64v(_num, _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), _len)
1834 #define FR_DBUFF_OUT_UINT64V_RETURN(_num, _dbuff_or_marker, _len) FR_DBUFF_RETURN(fr_dbuff_out_uint64v, _num, _dbuff_or_marker, _len)
1844 fr_assert(length > 0 && length <=
sizeof(uint64_t));
1847 slen = _fr_dbuff_out_memcpy(((
uint8_t *) num) + (8 - length), pos_p, dbuff, length);
1848 if (slen <= 0)
return slen;
1850 if (msb & 0x80) memset(((
uint8_t *)num), 0xff,
sizeof(*num) - length);
1867 #define fr_dbuff_out_int64v(_num, _dbuff_or_marker, _len) \
1868 _fr_dbuff_out_int64v(_num, _fr_dbuff_current_ptr(_dbuff_or_marker), fr_dbuff_ptr(_dbuff_or_marker), _len)
1874 #define FR_DBUFF_OUT_INT64V_RETURN(_num, _dbuff_or_marker, _len) FR_DBUFF_RETURN(fr_dbuff_out_int64v, _num, _dbuff_or_marker, _len)
#define UNCONST(_type, _ptr)
Remove const qualification from a pointer.
struct fr_dbuff_s fr_dbuff_t
A dbuff.
#define fr_dbuff_behind(_dbuff_or_marker)
How many bytes the dbuff or marker is behind its parent.
#define FR_DBUFF_FLAG_EXTENDED
Flag indicating that during the last extend call the dbuff was extended.
fr_dbuff_uctx_talloc_t tctx
Thread local tctx.
int fr_dbuff_reset_talloc(fr_dbuff_t *dbuff)
Reset a talloced buffer to its initial length, clearing any data stored.
static void fr_dbuff_free_talloc(fr_dbuff_t *dbuff)
Free the talloc buffer associated with a dbuff.
static int _dbuff_thread_local_free(void *dbtl)
static size_t fr_dbuff_marker_release_behind(fr_dbuff_marker_t *m)
Trims the linked list back to the specified pointer and return how many bytes marker was behind p.
struct fr_dbuff_marker_s fr_dbuff_marker_t
A position marker associated with a dbuff.
fr_dbuff_extend_status_t
Whether the buffer is currently extendable and whether it was extended.
@ FR_DBUFF_NOT_EXTENDABLE
dbuff cannot be extended
@ FR_DBUFF_EXTENDED
dbuff was extended in the last extend call but cannot be extended again
@ FR_DBUFF_EXTENDABLE
dbuff can be extended
@ FR_DBUFF_EXTENDABLE_EXTENDED
dbuff was extended in the last extend call and may be extended again
static fr_dbuff_t * fr_dbuff_init_fd(fr_dbuff_t *dbuff, fr_dbuff_uctx_fd_t *fctx, uint8_t *buff, size_t len, int fd, size_t max)
Initialise a special dbuff which automatically reads in more data as the buffer is exhausted.
size_t _fr_dbuff_extend_talloc(fr_dbuff_t *dbuff, size_t extension)
Reallocate the current buffer.
#define fr_dbuff_end(_dbuff_or_marker)
Return the current 'end' position of a dbuff or marker.
#define FR_DBUFF_ADV_PARENT_CURRENT
Advance current position of parent.
int fr_dbuff_trim_talloc(fr_dbuff_t *dbuff, size_t len)
Trim a talloced dbuff to the minimum length required to represent the contained string.
#define FR_DBUFF_FLAG_EXTENDABLE
Flag indicating a dbuff is extendable.
size_t _fr_dbuff_extend_fd(fr_dbuff_t *dbuff, size_t extension)
Refresh the buffer with more data from the file.
fr_dbuff_t dbuff
Thread local dbuff.
void fr_dbuff_update(fr_dbuff_t *dbuff, uint8_t *new_buff, size_t new_len)
Update all markers and pointers in the set of dbuffs to point to new_buff.
static fr_dbuff_t * fr_dbuff_init_talloc(TALLOC_CTX *ctx, fr_dbuff_t *dbuff, fr_dbuff_uctx_talloc_t *tctx, size_t init, size_t max)
Initialise a special dbuff which automatically extends as additional data is written.
static void fr_dbuff_marker_release(fr_dbuff_marker_t *m)
Releases the specified marker and any markers added before it.
#define fr_dbuff_is_extendable(_status)
Check if a dbuff can be extended again.
static uint8_t * fr_dbuff_marker(fr_dbuff_marker_t *m, fr_dbuff_t *dbuff)
Initialises a new marker pointing to the 'current' position of the dbuff.
#define fr_dbuff_ahead(_dbuff_or_marker)
How many bytes the dbuff or marker is ahead of its parent.
static size_t fr_dbuff_marker_release_ahead(fr_dbuff_marker_t *m)
Trims the linked list back to the specified pointer and return how many bytes marker was ahead of p.
#define FR_DBUFF_ADV_PARENT_END
Advance end pointer of parent.
size_t(* fr_dbuff_extend_t)(fr_dbuff_t *dbuff, size_t req_extension)
dbuff extension callback
size_t fr_dbuff_shift(fr_dbuff_t *dbuff, size_t shift)
Shift the contents of the dbuff, returning the number of bytes we managed to shift.
Structure to encapsulate a thread local dbuff information.
#define ROUND_UP_DIV(_x, _y)
Get the ceiling value of integer division.
static uint8_t fr_high_bit_pos(uint64_t num)
Find the highest order high bit in an unsigned 64 bit integer.
static uint64_t fr_nbo_to_uint64(uint8_t const data[static sizeof(uint64_t)])
Read an unsigned 64bit integer from wire format (big endian)
static void fr_nbo_from_uint64(uint8_t out[static sizeof(uint64_t)], uint64_t num)
Write out an unsigned 64bit integer in wire format (big endian)
#define fr_nbo_to_int64(_x)
static char buff[sizeof("18446744073709551615")+3]
init
Enter the EAP-IDENTITY state.
#define fr_strerror_printf(_fmt,...)
Log to thread local error buffer.
static size_t char fr_sbuff_t size_t inlen
static size_t char ** out