aboutsummaryrefslogtreecommitdiff
path: root/platform/linux-generic/odp_pcapng.c
diff options
context:
space:
mode:
authorMatias Elo <matias.elo@nokia.com>2018-09-25 12:53:53 +0300
committerMaxim Uvarov <maxim.uvarov@linaro.org>2018-10-04 15:15:31 +0300
commit9a4f8305e9c90f0ca0e7e4c240eb88d81b864ae0 (patch)
tree9a78d4f4bfe48d11306c2ab09c80e4b3977ada50 /platform/linux-generic/odp_pcapng.c
parenta08beb4afc6b7da7786cd7c827643689c1ee86d0 (diff)
linux-gen: split global data into RO and RW structs
RW global data is allocated from shm to enable process mode support. Signed-off-by: Matias Elo <matias.elo@nokia.com> Signed-off-by: Maxim Uvarov <maxim.uvarov@linaro.org>
Diffstat (limited to 'platform/linux-generic/odp_pcapng.c')
-rw-r--r--platform/linux-generic/odp_pcapng.c46
1 files changed, 23 insertions, 23 deletions
diff --git a/platform/linux-generic/odp_pcapng.c b/platform/linux-generic/odp_pcapng.c
index b8d29e5a8..07784c17e 100644
--- a/platform/linux-generic/odp_pcapng.c
+++ b/platform/linux-generic/odp_pcapng.c
@@ -74,7 +74,7 @@ static void get_pcapng_fifo_name(char *pcapng_entry, size_t len,
char *pktio_name, int qidx)
{
snprintf(pcapng_entry, len, "%d-%s-flow-%d",
- odp_global_data.main_pid, pktio_name, qidx);
+ odp_global_ro.main_pid, pktio_name, qidx);
pcapng_entry[len - 1] = 0;
}
@@ -120,13 +120,13 @@ static void *inotify_update(void *arg)
while (1) {
offset = 0;
FD_ZERO(&rfds);
- FD_SET(odp_global_data.inotify_pcapng_fd, &rfds);
+ FD_SET(odp_global_ro.inotify_pcapng_fd, &rfds);
time.tv_sec = 2;
time.tv_usec = 0;
- select(odp_global_data.inotify_pcapng_fd + 1, &rfds, NULL,
+ select(odp_global_ro.inotify_pcapng_fd + 1, &rfds, NULL,
NULL, &time);
- if (FD_ISSET(odp_global_data.inotify_pcapng_fd, &rfds)) {
- rdlen = read(odp_global_data.inotify_pcapng_fd,
+ if (FD_ISSET(odp_global_ro.inotify_pcapng_fd, &rfds)) {
+ rdlen = read(odp_global_ro.inotify_pcapng_fd,
buffer, INOTIFY_BUF_LEN);
while (offset < rdlen) {
int qidx;
@@ -219,23 +219,23 @@ int pcapng_prepare(pktio_entry_t *entry)
}
/* already running from a previous pktio */
- if (odp_global_data.inotify_pcapng_is_running == 1)
+ if (odp_global_ro.inotify_pcapng_is_running == 1)
return 0;
- odp_global_data.inotify_pcapng_fd = -1;
- odp_global_data.inotify_watch_fd = -1;
+ odp_global_ro.inotify_pcapng_fd = -1;
+ odp_global_ro.inotify_watch_fd = -1;
- odp_global_data.inotify_pcapng_fd = inotify_init();
- if (odp_global_data.inotify_pcapng_fd == -1) {
+ odp_global_ro.inotify_pcapng_fd = inotify_init();
+ if (odp_global_ro.inotify_pcapng_fd == -1) {
ODP_ERR("can't init inotify. pcap disabled\n");
goto out_destroy;
}
- odp_global_data.inotify_watch_fd =
- inotify_add_watch(odp_global_data.inotify_pcapng_fd,
+ odp_global_ro.inotify_watch_fd =
+ inotify_add_watch(odp_global_ro.inotify_pcapng_fd,
PCAPNG_WATCH_DIR, IN_CLOSE | IN_OPEN);
- if (odp_global_data.inotify_watch_fd == -1) {
+ if (odp_global_ro.inotify_watch_fd == -1) {
ODP_ERR("can't register inotify for %s. pcap disabled\n",
strerror(errno));
goto out_destroy;
@@ -243,12 +243,12 @@ int pcapng_prepare(pktio_entry_t *entry)
/* create a thread to poll inotify triggers */
pthread_attr_init(&attr);
- ret = pthread_create(&odp_global_data.inotify_thread, &attr,
+ ret = pthread_create(&odp_global_ro.inotify_thread, &attr,
inotify_update, entry);
if (ret)
ODP_ERR("can't start inotify thread. pcap disabled\n");
else
- odp_global_data.inotify_pcapng_is_running = 1;
+ odp_global_ro.inotify_pcapng_is_running = 1;
return ret;
@@ -265,24 +265,24 @@ void pcapng_destroy(pktio_entry_t *entry)
unsigned int max_queue =
MAX(entry->s.num_in_queue, entry->s.num_out_queue);
- if (odp_global_data.inotify_pcapng_is_running == 1) {
- ret = pthread_cancel(odp_global_data.inotify_thread);
+ if (odp_global_ro.inotify_pcapng_is_running == 1) {
+ ret = pthread_cancel(odp_global_ro.inotify_thread);
if (ret)
ODP_ERR("can't cancel inotify thread %s\n",
strerror(errno));
}
/* fd's will be -1 in case of any failure */
- ret = inotify_rm_watch(odp_global_data.inotify_pcapng_fd,
- odp_global_data.inotify_watch_fd);
+ ret = inotify_rm_watch(odp_global_ro.inotify_pcapng_fd,
+ odp_global_ro.inotify_watch_fd);
if (ret)
ODP_ERR("can't deregister inotify %s\n", strerror(errno));
- if (odp_global_data.inotify_pcapng_fd != -1)
- close(odp_global_data.inotify_pcapng_fd);
+ if (odp_global_ro.inotify_pcapng_fd != -1)
+ close(odp_global_ro.inotify_pcapng_fd);
- if (odp_global_data.inotify_watch_fd != -1)
- close(odp_global_data.inotify_watch_fd);
+ if (odp_global_ro.inotify_watch_fd != -1)
+ close(odp_global_ro.inotify_watch_fd);
for (i = 0; i < max_queue; i++) {
char pcapng_name[128];