libperf: Move 'pollfd' from 'struct evlist' to 'struct perf_evlist'
Moving 'pollfd' from 'struct evlist' to 'struct perf_evlist' it will be used in following patches. Signed-off-by: Jiri Olsa <jolsa@kernel.org> Cc: Alexander Shishkin <alexander.shishkin@linux.intel.com> Cc: Michael Petlan <mpetlan@redhat.com> Cc: Namhyung Kim <namhyung@kernel.org> Cc: Peter Zijlstra <a.p.zijlstra@chello.nl> Link: http://lore.kernel.org/lkml/20190913132355.21634-23-jolsa@kernel.org Signed-off-by: Arnaldo Carvalho de Melo <acme@redhat.com>
This commit is contained in:
parent
f6fa437577
commit
40cb2d5141
|
@ -981,7 +981,7 @@ static int kvm_events_live_report(struct perf_kvm_stat *kvm)
|
||||||
evlist__enable(kvm->evlist);
|
evlist__enable(kvm->evlist);
|
||||||
|
|
||||||
while (!done) {
|
while (!done) {
|
||||||
struct fdarray *fda = &kvm->evlist->pollfd;
|
struct fdarray *fda = &kvm->evlist->core.pollfd;
|
||||||
int rc;
|
int rc;
|
||||||
|
|
||||||
rc = perf_kvm__mmap_read(kvm);
|
rc = perf_kvm__mmap_read(kvm);
|
||||||
|
|
|
@ -3,6 +3,7 @@
|
||||||
#define __LIBPERF_INTERNAL_EVLIST_H
|
#define __LIBPERF_INTERNAL_EVLIST_H
|
||||||
|
|
||||||
#include <linux/list.h>
|
#include <linux/list.h>
|
||||||
|
#include <api/fd/array.h>
|
||||||
|
|
||||||
struct perf_cpu_map;
|
struct perf_cpu_map;
|
||||||
struct perf_thread_map;
|
struct perf_thread_map;
|
||||||
|
@ -15,6 +16,7 @@ struct perf_evlist {
|
||||||
struct perf_thread_map *threads;
|
struct perf_thread_map *threads;
|
||||||
int nr_mmaps;
|
int nr_mmaps;
|
||||||
size_t mmap_len;
|
size_t mmap_len;
|
||||||
|
struct fdarray pollfd;
|
||||||
};
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -61,7 +61,7 @@ void evlist__init(struct evlist *evlist, struct perf_cpu_map *cpus,
|
||||||
INIT_HLIST_HEAD(&evlist->heads[i]);
|
INIT_HLIST_HEAD(&evlist->heads[i]);
|
||||||
perf_evlist__init(&evlist->core);
|
perf_evlist__init(&evlist->core);
|
||||||
perf_evlist__set_maps(&evlist->core, cpus, threads);
|
perf_evlist__set_maps(&evlist->core, cpus, threads);
|
||||||
fdarray__init(&evlist->pollfd, 64);
|
fdarray__init(&evlist->core.pollfd, 64);
|
||||||
evlist->workload.pid = -1;
|
evlist->workload.pid = -1;
|
||||||
evlist->bkw_mmap_state = BKW_MMAP_NOTREADY;
|
evlist->bkw_mmap_state = BKW_MMAP_NOTREADY;
|
||||||
}
|
}
|
||||||
|
@ -142,7 +142,7 @@ void evlist__exit(struct evlist *evlist)
|
||||||
{
|
{
|
||||||
zfree(&evlist->mmap);
|
zfree(&evlist->mmap);
|
||||||
zfree(&evlist->overwrite_mmap);
|
zfree(&evlist->overwrite_mmap);
|
||||||
fdarray__exit(&evlist->pollfd);
|
fdarray__exit(&evlist->core.pollfd);
|
||||||
}
|
}
|
||||||
|
|
||||||
void evlist__delete(struct evlist *evlist)
|
void evlist__delete(struct evlist *evlist)
|
||||||
|
@ -416,8 +416,8 @@ int perf_evlist__alloc_pollfd(struct evlist *evlist)
|
||||||
nfds += nr_cpus * nr_threads;
|
nfds += nr_cpus * nr_threads;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (fdarray__available_entries(&evlist->pollfd) < nfds &&
|
if (fdarray__available_entries(&evlist->core.pollfd) < nfds &&
|
||||||
fdarray__grow(&evlist->pollfd, nfds) < 0)
|
fdarray__grow(&evlist->core.pollfd, nfds) < 0)
|
||||||
return -ENOMEM;
|
return -ENOMEM;
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
|
@ -426,13 +426,13 @@ int perf_evlist__alloc_pollfd(struct evlist *evlist)
|
||||||
static int __perf_evlist__add_pollfd(struct evlist *evlist, int fd,
|
static int __perf_evlist__add_pollfd(struct evlist *evlist, int fd,
|
||||||
struct mmap *map, short revent)
|
struct mmap *map, short revent)
|
||||||
{
|
{
|
||||||
int pos = fdarray__add(&evlist->pollfd, fd, revent | POLLERR | POLLHUP);
|
int pos = fdarray__add(&evlist->core.pollfd, fd, revent | POLLERR | POLLHUP);
|
||||||
/*
|
/*
|
||||||
* Save the idx so that when we filter out fds POLLHUP'ed we can
|
* Save the idx so that when we filter out fds POLLHUP'ed we can
|
||||||
* close the associated evlist->mmap[] entry.
|
* close the associated evlist->mmap[] entry.
|
||||||
*/
|
*/
|
||||||
if (pos >= 0) {
|
if (pos >= 0) {
|
||||||
evlist->pollfd.priv[pos].ptr = map;
|
evlist->core.pollfd.priv[pos].ptr = map;
|
||||||
|
|
||||||
fcntl(fd, F_SETFL, O_NONBLOCK);
|
fcntl(fd, F_SETFL, O_NONBLOCK);
|
||||||
}
|
}
|
||||||
|
@ -456,13 +456,13 @@ static void perf_evlist__munmap_filtered(struct fdarray *fda, int fd,
|
||||||
|
|
||||||
int perf_evlist__filter_pollfd(struct evlist *evlist, short revents_and_mask)
|
int perf_evlist__filter_pollfd(struct evlist *evlist, short revents_and_mask)
|
||||||
{
|
{
|
||||||
return fdarray__filter(&evlist->pollfd, revents_and_mask,
|
return fdarray__filter(&evlist->core.pollfd, revents_and_mask,
|
||||||
perf_evlist__munmap_filtered, NULL);
|
perf_evlist__munmap_filtered, NULL);
|
||||||
}
|
}
|
||||||
|
|
||||||
int perf_evlist__poll(struct evlist *evlist, int timeout)
|
int perf_evlist__poll(struct evlist *evlist, int timeout)
|
||||||
{
|
{
|
||||||
return fdarray__poll(&evlist->pollfd, timeout);
|
return fdarray__poll(&evlist->core.pollfd, timeout);
|
||||||
}
|
}
|
||||||
|
|
||||||
static void perf_evlist__id_hash(struct evlist *evlist,
|
static void perf_evlist__id_hash(struct evlist *evlist,
|
||||||
|
@ -1009,7 +1009,7 @@ int evlist__mmap_ex(struct evlist *evlist, unsigned int pages,
|
||||||
if (!evlist->mmap)
|
if (!evlist->mmap)
|
||||||
return -ENOMEM;
|
return -ENOMEM;
|
||||||
|
|
||||||
if (evlist->pollfd.entries == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
|
if (evlist->core.pollfd.entries == NULL && perf_evlist__alloc_pollfd(evlist) < 0)
|
||||||
return -ENOMEM;
|
return -ENOMEM;
|
||||||
|
|
||||||
evlist->core.mmap_len = evlist__mmap_size(pages);
|
evlist->core.mmap_len = evlist__mmap_size(pages);
|
||||||
|
|
|
@ -64,7 +64,6 @@ struct evlist {
|
||||||
int cork_fd;
|
int cork_fd;
|
||||||
pid_t pid;
|
pid_t pid;
|
||||||
} workload;
|
} workload;
|
||||||
struct fdarray pollfd;
|
|
||||||
struct mmap *mmap;
|
struct mmap *mmap;
|
||||||
struct mmap *overwrite_mmap;
|
struct mmap *overwrite_mmap;
|
||||||
struct evsel *selected;
|
struct evsel *selected;
|
||||||
|
|
|
@ -935,17 +935,17 @@ static PyObject *pyrf_evlist__get_pollfd(struct pyrf_evlist *pevlist,
|
||||||
PyObject *list = PyList_New(0);
|
PyObject *list = PyList_New(0);
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
for (i = 0; i < evlist->pollfd.nr; ++i) {
|
for (i = 0; i < evlist->core.pollfd.nr; ++i) {
|
||||||
PyObject *file;
|
PyObject *file;
|
||||||
#if PY_MAJOR_VERSION < 3
|
#if PY_MAJOR_VERSION < 3
|
||||||
FILE *fp = fdopen(evlist->pollfd.entries[i].fd, "r");
|
FILE *fp = fdopen(evlist->core.pollfd.entries[i].fd, "r");
|
||||||
|
|
||||||
if (fp == NULL)
|
if (fp == NULL)
|
||||||
goto free_list;
|
goto free_list;
|
||||||
|
|
||||||
file = PyFile_FromFile(fp, "perf", "r", NULL);
|
file = PyFile_FromFile(fp, "perf", "r", NULL);
|
||||||
#else
|
#else
|
||||||
file = PyFile_FromFd(evlist->pollfd.entries[i].fd, "perf", "r", -1,
|
file = PyFile_FromFd(evlist->core.pollfd.entries[i].fd, "perf", "r", -1,
|
||||||
NULL, NULL, NULL, 0);
|
NULL, NULL, NULL, 0);
|
||||||
#endif
|
#endif
|
||||||
if (file == NULL)
|
if (file == NULL)
|
||||||
|
|
Loading…
Reference in New Issue