Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 5c581041 authored by Arnaldo Carvalho de Melo's avatar Arnaldo Carvalho de Melo
Browse files

perf evlist: Adopt the pollfd array



Allocating just the space needed for nr_cpus * nr_threads * nr_evsels,
not the MAX_NR_CPUS and counters.

LKML-Reference: <new-submission>
Cc: Frederic Weisbecker <fweisbec@gmail.com>
Cc: Ingo Molnar <mingo@elte.hu>
Cc: Mike Galbraith <efault@gmx.de>
Cc: Paul Mackerras <paulus@samba.org>
Cc: Peter Zijlstra <peterz@infradead.org>
Cc: Stephane Eranian <eranian@google.com>
Cc: Tom Zanussi <tzanussi@gmail.com>
Signed-off-by: default avatarArnaldo Carvalho de Melo <acme@redhat.com>
parent 361c99a6
Loading
Loading
Loading
Loading
+7 −13
Original line number Original line Diff line number Diff line
@@ -72,9 +72,6 @@ static struct perf_evlist *evsel_list;
static long			samples				=      0;
static long			samples				=      0;
static u64			bytes_written			=      0;
static u64			bytes_written			=      0;


static struct pollfd		*event_array;

static int			nr_poll				=      0;
static int			nr_cpu				=      0;
static int			nr_cpu				=      0;


static int			file_new			=      1;
static int			file_new			=      1;
@@ -432,9 +429,9 @@ static void create_counter(struct perf_evlist *evlist,
				exit(-1);
				exit(-1);
			}
			}


			event_array[nr_poll].fd = FD(evsel, nr_cpu, thread_index);
			evlist->pollfd[evlist->nr_fds].fd = FD(evsel, nr_cpu, thread_index);
			event_array[nr_poll].events = POLLIN;
			evlist->pollfd[evlist->nr_fds].events = POLLIN;
			nr_poll++;
			evlist->nr_fds++;
		}
		}


		if (filter != NULL) {
		if (filter != NULL) {
@@ -793,7 +790,7 @@ static int __cmd_record(int argc, const char **argv)
		if (hits == samples) {
		if (hits == samples) {
			if (done)
			if (done)
				break;
				break;
			err = poll(event_array, nr_poll, -1);
			err = poll(evsel_list->pollfd, evsel_list->nr_fds, -1);
			waking++;
			waking++;
		}
		}


@@ -948,9 +945,8 @@ int cmd_record(int argc, const char **argv, const char *prefix __used)
		if (perf_header__push_event(pos->attr.config, event_name(pos)))
		if (perf_header__push_event(pos->attr.config, event_name(pos)))
			goto out_free_fd;
			goto out_free_fd;
	}
	}
	event_array = malloc((sizeof(struct pollfd) * MAX_NR_CPUS *

			      MAX_COUNTERS * threads->nr));
	if (perf_evlist__alloc_pollfd(evsel_list, cpus->nr, threads->nr) < 0)
	if (!event_array)
		goto out_free_fd;
		goto out_free_fd;


	if (user_interval != ULLONG_MAX)
	if (user_interval != ULLONG_MAX)
@@ -968,13 +964,11 @@ int cmd_record(int argc, const char **argv, const char *prefix __used)
	} else {
	} else {
		fprintf(stderr, "frequency and count are zero, aborting\n");
		fprintf(stderr, "frequency and count are zero, aborting\n");
		err = -EINVAL;
		err = -EINVAL;
		goto out_free_event_array;
		goto out_free_fd;
	}
	}


	err = __cmd_record(argc, argv);
	err = __cmd_record(argc, argv);


out_free_event_array:
	free(event_array);
out_free_fd:
out_free_fd:
	thread_map__delete(threads);
	thread_map__delete(threads);
	threads = NULL;
	threads = NULL;
+11 −15
Original line number Original line Diff line number Diff line
@@ -1193,8 +1193,6 @@ static void perf_session__mmap_read_counter(struct perf_session *self,
	md->prev = old;
	md->prev = old;
}
}


static struct pollfd *event_array;

static void perf_session__mmap_read(struct perf_session *self)
static void perf_session__mmap_read(struct perf_session *self)
{
{
	struct perf_evsel *counter;
	struct perf_evsel *counter;
@@ -1212,10 +1210,10 @@ static void perf_session__mmap_read(struct perf_session *self)
	}
	}
}
}


int nr_poll;
int group_fd;
int group_fd;


static void start_counter(int i, struct perf_evsel *evsel)
static void start_counter(int i, struct perf_evlist *evlist,
			  struct perf_evsel *evsel)
{
{
	struct xyarray *mmap_array = evsel->priv;
	struct xyarray *mmap_array = evsel->priv;
	struct mmap_data *mm;
	struct mmap_data *mm;
@@ -1281,9 +1279,9 @@ static void start_counter(int i, struct perf_evsel *evsel)
		if (group && group_fd == -1)
		if (group && group_fd == -1)
			group_fd = FD(evsel, i, thread_index);
			group_fd = FD(evsel, i, thread_index);


		event_array[nr_poll].fd = FD(evsel, i, thread_index);
		evlist->pollfd[evlist->nr_fds].fd = FD(evsel, i, thread_index);
		event_array[nr_poll].events = POLLIN;
		evlist->pollfd[evlist->nr_fds].events = POLLIN;
		nr_poll++;
		evlist->nr_fds++;


		mm = xyarray__entry(mmap_array, i, thread_index);
		mm = xyarray__entry(mmap_array, i, thread_index);
		mm->prev = 0;
		mm->prev = 0;
@@ -1316,11 +1314,11 @@ static int __cmd_top(void)
	for (i = 0; i < cpus->nr; i++) {
	for (i = 0; i < cpus->nr; i++) {
		group_fd = -1;
		group_fd = -1;
		list_for_each_entry(counter, &evsel_list->entries, node)
		list_for_each_entry(counter, &evsel_list->entries, node)
			start_counter(i, counter);
			start_counter(i, evsel_list, counter);
	}
	}


	/* Wait for a minimal set of events before starting the snapshot */
	/* Wait for a minimal set of events before starting the snapshot */
	poll(&event_array[0], nr_poll, 100);
	poll(evsel_list->pollfd, evsel_list->nr_fds, 100);


	perf_session__mmap_read(session);
	perf_session__mmap_read(session);


@@ -1345,7 +1343,7 @@ static int __cmd_top(void)
		perf_session__mmap_read(session);
		perf_session__mmap_read(session);


		if (hits == samples)
		if (hits == samples)
			ret = poll(event_array, nr_poll, 100);
			ret = poll(evsel_list->pollfd, evsel_list->nr_fds, 100);
	}
	}


	return 0;
	return 0;
@@ -1426,11 +1424,6 @@ int cmd_top(int argc, const char **argv, const char *prefix __used)
		usage_with_options(top_usage, options);
		usage_with_options(top_usage, options);
	}
	}


	event_array = malloc((sizeof(struct pollfd) *
			      MAX_NR_CPUS * MAX_COUNTERS * threads->nr));
	if (!event_array)
		return -ENOMEM;

	/* CPU and PID are mutually exclusive */
	/* CPU and PID are mutually exclusive */
	if (target_tid > 0 && cpu_list) {
	if (target_tid > 0 && cpu_list) {
		printf("WARNING: PID switch overriding CPU\n");
		printf("WARNING: PID switch overriding CPU\n");
@@ -1480,6 +1473,9 @@ int cmd_top(int argc, const char **argv, const char *prefix __used)
		pos->attr.sample_period = default_interval;
		pos->attr.sample_period = default_interval;
	}
	}


	if (perf_evlist__alloc_pollfd(evsel_list, cpus->nr, threads->nr) < 0)
		goto out_free_fd;

	sym_evsel = list_entry(evsel_list->entries.next, struct perf_evsel, node);
	sym_evsel = list_entry(evsel_list->entries.next, struct perf_evsel, node);


	symbol_conf.priv_size = (sizeof(struct sym_entry) +
	symbol_conf.priv_size = (sizeof(struct sym_entry) +
+9 −0
Original line number Original line Diff line number Diff line
#include <poll.h>
#include "evlist.h"
#include "evlist.h"
#include "evsel.h"
#include "evsel.h"
#include "util.h"
#include "util.h"
@@ -28,6 +29,7 @@ static void perf_evlist__purge(struct perf_evlist *evlist)
void perf_evlist__delete(struct perf_evlist *evlist)
void perf_evlist__delete(struct perf_evlist *evlist)
{
{
	perf_evlist__purge(evlist);
	perf_evlist__purge(evlist);
	free(evlist->pollfd);
	free(evlist);
	free(evlist);
}
}


@@ -51,3 +53,10 @@ int perf_evlist__add_default(struct perf_evlist *evlist)
	perf_evlist__add(evlist, evsel);
	perf_evlist__add(evlist, evsel);
	return 0;
	return 0;
}
}

int perf_evlist__alloc_pollfd(struct perf_evlist *evlist, int ncpus, int nthreads)
{
	int nfds = ncpus * nthreads * evlist->nr_entries;
	evlist->pollfd = malloc(sizeof(struct pollfd) * nfds);
	return evlist->pollfd != NULL ? 0 : -ENOMEM;
}
+6 −0
Original line number Original line Diff line number Diff line
@@ -3,9 +3,13 @@


#include <linux/list.h>
#include <linux/list.h>


struct pollfd;

struct perf_evlist {
struct perf_evlist {
	struct list_head entries;
	struct list_head entries;
	int		 nr_entries;
	int		 nr_entries;
	int		 nr_fds;
	struct pollfd	 *pollfd;
};
};


struct perf_evsel;
struct perf_evsel;
@@ -16,4 +20,6 @@ void perf_evlist__delete(struct perf_evlist *evlist);
void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry);
void perf_evlist__add(struct perf_evlist *evlist, struct perf_evsel *entry);
int perf_evlist__add_default(struct perf_evlist *evlist);
int perf_evlist__add_default(struct perf_evlist *evlist);


int perf_evlist__alloc_pollfd(struct perf_evlist *evlist, int ncpus, int nthreads);

#endif /* __PERF_EVLIST_H */
#endif /* __PERF_EVLIST_H */