packet: replace struct desc by struct iovec

Signed-off-by: Laurent Vivier <lvivier@redhat.com>
This commit is contained in:
Laurent Vivier 2023-08-11 15:51:51 +02:00
parent 0938100596
commit 27a713947c
2 changed files with 45 additions and 48 deletions

View file

@ -22,6 +22,36 @@
#include "util.h" #include "util.h"
#include "log.h" #include "log.h"
static int packet_check_range(const struct pool *p, size_t offset, size_t len,
const char *start, const char *func, int line)
{
if (start < p->buf) {
if (func) {
trace("add packet start %p before buffer start %p, "
"%s:%i", (void *)start, (void *)p->buf, func, line);
}
return -1;
}
if (start + len + offset > p->buf + p->buf_size) {
if (func) {
trace("packet offset plus length %lu from size %lu, "
"%s:%i", start - p->buf + len + offset,
p->buf_size, func, line);
}
return -1;
}
#if UINTPTR_MAX == UINT64_MAX
if ((uintptr_t)start - (uintptr_t)p->buf > UINT32_MAX) {
trace("add packet start %p, buffer start %p, %s:%i",
(void *)start, (void *)p->buf, func, line);
return -1;
}
#endif
return 0;
}
/** /**
* packet_add_do() - Add data as packet descriptor to given pool * packet_add_do() - Add data as packet descriptor to given pool
* @p: Existing pool * @p: Existing pool
@ -41,34 +71,16 @@ void packet_add_do(struct pool *p, size_t len, const char *start,
return; return;
} }
if (start < p->buf) { if (packet_check_range(p, 0, len, start, func, line))
trace("add packet start %p before buffer start %p, %s:%i",
(void *)start, (void *)p->buf, func, line);
return; return;
}
if (start + len > p->buf + p->buf_size) {
trace("add packet start %p, length: %zu, buffer end %p, %s:%i",
(void *)start, len, (void *)(p->buf + p->buf_size),
func, line);
return;
}
if (len > UINT16_MAX) { if (len > UINT16_MAX) {
trace("add packet length %zu, %s:%i", len, func, line); trace("add packet length %zu, %s:%i", len, func, line);
return; return;
} }
#if UINTPTR_MAX == UINT64_MAX p->pkt[idx].iov_base = (void *)start;
if ((uintptr_t)start - (uintptr_t)p->buf > UINT32_MAX) { p->pkt[idx].iov_len = len;
trace("add packet start %p, buffer start %p, %s:%i",
(void *)start, (void *)p->buf, func, line);
return;
}
#endif
p->pkt[idx].offset = start - p->buf;
p->pkt[idx].len = len;
p->count++; p->count++;
} }
@ -104,28 +116,23 @@ void *packet_get_do(const struct pool *p, size_t idx, size_t offset,
return NULL; return NULL;
} }
if (p->pkt[idx].offset + len + offset > p->buf_size) { if (len + offset > p->pkt[idx].iov_len) {
if (func) { if (func) {
trace("packet offset plus length %zu from size %zu, " trace("data length %zu, offset %zu from length %zu, "
"%s:%i", p->pkt[idx].offset + len + offset, "%s:%i", len, offset, p->pkt[idx].iov_len,
p->buf_size, func, line);
}
return NULL;
}
if (len + offset > p->pkt[idx].len) {
if (func) {
trace("data length %zu, offset %zu from length %u, "
"%s:%i", len, offset, p->pkt[idx].len,
func, line); func, line);
} }
return NULL; return NULL;
} }
if (left) if (packet_check_range(p, offset, len, p->pkt[idx].iov_base,
*left = p->pkt[idx].len - offset - len; func, line))
return NULL;
return p->buf + p->pkt[idx].offset + offset; if (left)
*left = p->pkt[idx].iov_len - offset - len;
return (char *)p->pkt[idx].iov_base + offset;
} }
/** /**

View file

@ -6,16 +6,6 @@
#ifndef PACKET_H #ifndef PACKET_H
#define PACKET_H #define PACKET_H
/**
* struct desc - Generic offset-based descriptor within buffer
* @offset: Offset of descriptor relative to buffer start, 32-bit limit
* @len: Length of descriptor, host order, 16-bit limit
*/
struct desc {
uint32_t offset;
uint16_t len;
};
/** /**
* struct pool - Generic pool of packets stored in a buffer * struct pool - Generic pool of packets stored in a buffer
* @buf: Buffer storing packet descriptors * @buf: Buffer storing packet descriptors
@ -29,7 +19,7 @@ struct pool {
size_t buf_size; size_t buf_size;
size_t size; size_t size;
size_t count; size_t count;
struct desc pkt[1]; struct iovec pkt[1];
}; };
void packet_add_do(struct pool *p, size_t len, const char *start, void packet_add_do(struct pool *p, size_t len, const char *start,
@ -54,7 +44,7 @@ struct _name ## _t { \
size_t buf_size; \ size_t buf_size; \
size_t size; \ size_t size; \
size_t count; \ size_t count; \
struct desc pkt[_size]; \ struct iovec pkt[_size]; \
} }
#define PACKET_POOL_INIT_NOCAST(_size, _buf, _buf_size) \ #define PACKET_POOL_INIT_NOCAST(_size, _buf, _buf_size) \