Signed-off-by: Nicolas Morey-Chaisemartin <[email protected]>
---
.../linux-generic/include/odp_packet_io_internal.h | 6 +--
platform/linux-generic/include/odp_packet_socket.h | 20 ++++-----
platform/linux-generic/odp_packet_io.c | 52 +++++++++++-----------
platform/linux-generic/pktio/loop.c | 6 +--
platform/linux-generic/pktio/socket.c | 12 ++---
platform/linux-generic/pktio/socket_mmap.c | 8 ++--
6 files changed, 52 insertions(+), 52 deletions(-)
diff --git a/platform/linux-generic/include/odp_packet_io_internal.h
b/platform/linux-generic/include/odp_packet_io_internal.h
index 63315af..dbba438 100644
--- a/platform/linux-generic/include/odp_packet_io_internal.h
+++ b/platform/linux-generic/include/odp_packet_io_internal.h
@@ -88,10 +88,10 @@ static inline pktio_entry_t *get_pktio_entry(odp_pktio_t
pktio)
int pktin_poll(pktio_entry_t *entry);
-int init_loopback(pktio_entry_t *pktio_entry, odp_pktio_t id);
-int recv_pkt_loopback(pktio_entry_t *pktio_entry, odp_packet_t pkts[],
+int loopback_init(pktio_entry_t *pktio_entry, odp_pktio_t id);
+int loopback_recv_pkt(pktio_entry_t *pktio_entry, odp_packet_t pkts[],
unsigned len);
-int send_pkt_loopback(pktio_entry_t *pktio_entry, odp_packet_t pkt_tbl[],
+int loopback_send_pkt(pktio_entry_t *pktio_entry, odp_packet_t pkt_tbl[],
unsigned len);
#ifdef __cplusplus
diff --git a/platform/linux-generic/include/odp_packet_socket.h
b/platform/linux-generic/include/odp_packet_socket.h
index c3921e6..2cdb124 100644
--- a/platform/linux-generic/include/odp_packet_socket.h
+++ b/platform/linux-generic/include/odp_packet_socket.h
@@ -100,39 +100,39 @@ ethaddrs_equal(unsigned char mac_a[], unsigned char
mac_b[])
/**
* Open & configure a raw packet socket
*/
-int setup_pkt_sock(pkt_sock_t * const pkt_sock, const char *netdev,
+int sock_setup_pkt(pkt_sock_t * const pkt_sock, const char *netdev,
odp_pool_t pool);
-int setup_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock, const char *netdev,
+int sock_mmap_setup_pkt(pkt_sock_mmap_t * const pkt_sock, const char *netdev,
odp_pool_t pool, int fanout);
/**
* Close a packet socket
*/
-int close_pkt_sock(pkt_sock_t * const pkt_sock);
+int sock_close_pkt(pkt_sock_t * const pkt_sock);
-int close_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock);
+int sock_mmap_close_pkt(pkt_sock_mmap_t * const pkt_sock);
/**
* Receive packets from the packet socket
*/
-int recv_pkt_sock_basic(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
+int sock_basic_recv_pkt(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
-int recv_pkt_sock_mmsg(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
+int sock_mmsg_recv_pkt(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
-int recv_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock,
+int sock_mmap_recv_pkt(pkt_sock_mmap_t * const pkt_sock,
odp_packet_t pkt_table[], unsigned len);
/**
* Send packets through the packet socket
*/
-int send_pkt_sock_basic(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
+int sock_basic_send_pkt(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
-int send_pkt_sock_mmsg(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
+int sock_mmsg_send_pkt(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
-int send_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock,
+int sock_mmap_send_pkt(pkt_sock_mmap_t * const pkt_sock,
odp_packet_t pkt_table[], unsigned len);
#endif
diff --git a/platform/linux-generic/odp_packet_io.c
b/platform/linux-generic/odp_packet_io.c
index 79e907e..c97e6a2 100644
--- a/platform/linux-generic/odp_packet_io.c
+++ b/platform/linux-generic/odp_packet_io.c
@@ -191,30 +191,30 @@ static int free_pktio_entry(odp_pktio_t id)
return 0;
}
-static int init_socket(pktio_entry_t *entry, const char *dev,
- odp_pool_t pool)
+static int sock_init(pktio_entry_t *entry, const char *dev,
+ odp_pool_t pool)
{
int fd = -1;
if (getenv("ODP_PKTIO_DISABLE_SOCKET_MMAP") == NULL) {
entry->s.type = ODP_PKTIO_TYPE_SOCKET_MMAP;
- fd = setup_pkt_sock_mmap(&entry->s.pkt_sock_mmap, dev, pool, 1);
+ fd = sock_mmap_setup_pkt(&entry->s.pkt_sock_mmap, dev, pool, 1);
if (fd == -1)
- close_pkt_sock_mmap(&entry->s.pkt_sock_mmap);
+ sock_mmap_close_pkt(&entry->s.pkt_sock_mmap);
}
if (fd == -1 && getenv("ODP_PKTIO_DISABLE_SOCKET_MMSG") == NULL) {
entry->s.type = ODP_PKTIO_TYPE_SOCKET_MMSG;
- fd = setup_pkt_sock(&entry->s.pkt_sock, dev, pool);
+ fd = sock_setup_pkt(&entry->s.pkt_sock, dev, pool);
if (fd == -1)
- close_pkt_sock(&entry->s.pkt_sock);
+ sock_close_pkt(&entry->s.pkt_sock);
}
if (fd == -1 && getenv("ODP_PKTIO_DISABLE_SOCKET_BASIC") == NULL) {
entry->s.type = ODP_PKTIO_TYPE_SOCKET_BASIC;
- fd = setup_pkt_sock(&entry->s.pkt_sock, dev, pool);
+ fd = sock_setup_pkt(&entry->s.pkt_sock, dev, pool);
if (fd == -1)
- close_pkt_sock(&entry->s.pkt_sock);
+ sock_close_pkt(&entry->s.pkt_sock);
}
if (fd == -1)
@@ -248,9 +248,9 @@ static odp_pktio_t setup_pktio_entry(const char *dev,
odp_pool_t pool)
return ODP_PKTIO_INVALID;
if (strcmp(dev, "loop") == 0)
- ret = init_loopback(pktio_entry, id);
+ ret = loopback_init(pktio_entry, id);
else
- ret = init_socket(pktio_entry, dev, pool);
+ ret = sock_init(pktio_entry, dev, pool);
if (ret != 0) {
unlock_entry_classifier(pktio_entry);
@@ -299,10 +299,10 @@ int odp_pktio_close(odp_pktio_t id)
switch (entry->s.type) {
case ODP_PKTIO_TYPE_SOCKET_BASIC:
case ODP_PKTIO_TYPE_SOCKET_MMSG:
- res = close_pkt_sock(&entry->s.pkt_sock);
+ res = sock_close_pkt(&entry->s.pkt_sock);
break;
case ODP_PKTIO_TYPE_SOCKET_MMAP:
- res = close_pkt_sock_mmap(&entry->s.pkt_sock_mmap);
+ res = sock_mmap_close_pkt(&entry->s.pkt_sock_mmap);
break;
case ODP_PKTIO_TYPE_LOOPBACK:
res = odp_queue_destroy(entry->s.loopq);
@@ -364,19 +364,19 @@ int odp_pktio_recv(odp_pktio_t id, odp_packet_t
pkt_table[], int len)
lock_entry(pktio_entry);
switch (pktio_entry->s.type) {
case ODP_PKTIO_TYPE_SOCKET_BASIC:
- pkts = recv_pkt_sock_basic(&pktio_entry->s.pkt_sock,
- pkt_table, len);
+ pkts = sock_basic_recv_pkt(&pktio_entry->s.pkt_sock,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_SOCKET_MMSG:
- pkts = recv_pkt_sock_mmsg(&pktio_entry->s.pkt_sock,
- pkt_table, len);
+ pkts = sock_mmsg_recv_pkt(&pktio_entry->s.pkt_sock,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_SOCKET_MMAP:
- pkts = recv_pkt_sock_mmap(&pktio_entry->s.pkt_sock_mmap,
- pkt_table, len);
+ pkts = sock_mmap_recv_pkt(&pktio_entry->s.pkt_sock_mmap,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_LOOPBACK:
- pkts = recv_pkt_loopback(pktio_entry, pkt_table, len);
+ pkts = loopback_recv_pkt(pktio_entry, pkt_table, len);
break;
default:
pkts = -1;
@@ -404,19 +404,19 @@ int odp_pktio_send(odp_pktio_t id, odp_packet_t
pkt_table[], int len)
lock_entry(pktio_entry);
switch (pktio_entry->s.type) {
case ODP_PKTIO_TYPE_SOCKET_BASIC:
- pkts = send_pkt_sock_basic(&pktio_entry->s.pkt_sock,
- pkt_table, len);
+ pkts = sock_basic_send_pkt(&pktio_entry->s.pkt_sock,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_SOCKET_MMSG:
- pkts = send_pkt_sock_mmsg(&pktio_entry->s.pkt_sock,
- pkt_table, len);
+ pkts = sock_mmsg_send_pkt(&pktio_entry->s.pkt_sock,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_SOCKET_MMAP:
- pkts = send_pkt_sock_mmap(&pktio_entry->s.pkt_sock_mmap,
- pkt_table, len);
+ pkts = sock_mmap_send_pkt(&pktio_entry->s.pkt_sock_mmap,
+ pkt_table, len);
break;
case ODP_PKTIO_TYPE_LOOPBACK:
- pkts = send_pkt_loopback(pktio_entry, pkt_table, len);
+ pkts = loopback_send_pkt(pktio_entry, pkt_table, len);
break;
default:
pkts = -1;
diff --git a/platform/linux-generic/pktio/loop.c
b/platform/linux-generic/pktio/loop.c
index 26b4a33..ef858c0 100644
--- a/platform/linux-generic/pktio/loop.c
+++ b/platform/linux-generic/pktio/loop.c
@@ -19,7 +19,7 @@
#include <odp/helper/eth.h>
#include <odp/helper/ip.h>
-int init_loopback(pktio_entry_t *pktio_entry, odp_pktio_t id)
+int loopback_init(pktio_entry_t *pktio_entry, odp_pktio_t id)
{
char loopq_name[ODP_QUEUE_NAME_LEN];
@@ -35,7 +35,7 @@ int init_loopback(pktio_entry_t *pktio_entry, odp_pktio_t id)
return 0;
}
-int recv_pkt_loopback(pktio_entry_t *pktio_entry, odp_packet_t pkts[],
+int loopback_recv_pkt(pktio_entry_t *pktio_entry, odp_packet_t pkts[],
unsigned len)
{
int nbr, i;
@@ -53,7 +53,7 @@ int recv_pkt_loopback(pktio_entry_t *pktio_entry,
odp_packet_t pkts[],
return nbr;
}
-int send_pkt_loopback(pktio_entry_t *pktio_entry, odp_packet_t pkt_tbl[],
+int loopback_send_pkt(pktio_entry_t *pktio_entry, odp_packet_t pkt_tbl[],
unsigned len)
{
odp_buffer_hdr_t *hdr_tbl[QUEUE_MULTI_MAX];
diff --git a/platform/linux-generic/pktio/socket.c
b/platform/linux-generic/pktio/socket.c
index c1fb008..971d057 100644
--- a/platform/linux-generic/pktio/socket.c
+++ b/platform/linux-generic/pktio/socket.c
@@ -91,7 +91,7 @@ int sendmmsg(int fd, struct mmsghdr *vmessages, unsigned int
vlen, int flags)
* ODP_PACKET_SOCKET_BASIC:
* ODP_PACKET_SOCKET_MMSG:
*/
-int setup_pkt_sock(pkt_sock_t *const pkt_sock, const char *netdev,
+int sock_setup_pkt(pkt_sock_t *const pkt_sock, const char *netdev,
odp_pool_t pool)
{
int sockfd;
@@ -164,7 +164,7 @@ error:
* ODP_PACKET_SOCKET_BASIC:
* ODP_PACKET_SOCKET_MMSG:
*/
-int close_pkt_sock(pkt_sock_t *const pkt_sock)
+int sock_close_pkt(pkt_sock_t *const pkt_sock)
{
if (pkt_sock->sockfd != -1 && close(pkt_sock->sockfd) != 0) {
__odp_errno = errno;
@@ -178,7 +178,7 @@ int close_pkt_sock(pkt_sock_t *const pkt_sock)
/*
* ODP_PACKET_SOCKET_BASIC:
*/
-int recv_pkt_sock_basic(pkt_sock_t *const pkt_sock,
+int sock_basic_recv_pkt(pkt_sock_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
ssize_t recv_bytes;
@@ -236,7 +236,7 @@ int recv_pkt_sock_basic(pkt_sock_t *const pkt_sock,
/*
* ODP_PACKET_SOCKET_BASIC:
*/
-int send_pkt_sock_basic(pkt_sock_t *const pkt_sock,
+int sock_basic_send_pkt(pkt_sock_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
odp_packet_t pkt;
@@ -279,7 +279,7 @@ int send_pkt_sock_basic(pkt_sock_t *const pkt_sock,
/*
* ODP_PACKET_SOCKET_MMSG:
*/
-int recv_pkt_sock_mmsg(pkt_sock_t *const pkt_sock,
+int sock_mmsg_recv_pkt(pkt_sock_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
const int sockfd = pkt_sock->sockfd;
@@ -345,7 +345,7 @@ int recv_pkt_sock_mmsg(pkt_sock_t *const pkt_sock,
/*
* ODP_PACKET_SOCKET_MMSG:
*/
-int send_pkt_sock_mmsg(pkt_sock_t *const pkt_sock,
+int sock_mmsg_send_pkt(pkt_sock_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
struct mmsghdr msgvec[ODP_PACKET_SOCKET_MAX_BURST_TX];
diff --git a/platform/linux-generic/pktio/socket_mmap.c
b/platform/linux-generic/pktio/socket_mmap.c
index b9c2ee4..84a3a06 100644
--- a/platform/linux-generic/pktio/socket_mmap.c
+++ b/platform/linux-generic/pktio/socket_mmap.c
@@ -405,7 +405,7 @@ static int mmap_store_hw_addr(pkt_sock_mmap_t *const
pkt_sock,
return 0;
}
-int setup_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock, const char *netdev,
+int sock_mmap_setup_pkt(pkt_sock_mmap_t *const pkt_sock, const char *netdev,
odp_pool_t pool, int fanout)
{
int if_idx;
@@ -463,7 +463,7 @@ int setup_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock,
const char *netdev,
return pkt_sock->sockfd;
}
-int close_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock)
+int sock_mmap_close_pkt(pkt_sock_mmap_t *const pkt_sock)
{
mmap_unmap_sock(pkt_sock);
if (pkt_sock->sockfd != -1 && close(pkt_sock->sockfd) != 0) {
@@ -475,7 +475,7 @@ int close_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock)
return 0;
}
-int recv_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock,
+int sock_mmap_recv_pkt(pkt_sock_mmap_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
return pkt_mmap_v2_rx(pkt_sock->rx_ring.sock, &pkt_sock->rx_ring,
@@ -483,7 +483,7 @@ int recv_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock,
pkt_sock->if_mac);
}
-int send_pkt_sock_mmap(pkt_sock_mmap_t *const pkt_sock,
+int sock_mmap_send_pkt(pkt_sock_mmap_t *const pkt_sock,
odp_packet_t pkt_table[], unsigned len)
{
return pkt_mmap_v2_tx(pkt_sock->tx_ring.sock, &pkt_sock->tx_ring,
--
2.4.5.3.g4915f6f
_______________________________________________
lng-odp mailing list
[email protected]
https://lists.linaro.org/mailman/listinfo/lng-odp
