#include <stdlib.h>
#include <string.h>
#include <errno.h>
+#include <libgen.h>
#include "parse.h"
#include "pagemap.h"
return map;
}
-static struct maps *parse_maps(FILE *file, int pid)
+static struct maps *parse_maps(FILE *file, int pid, int tid)
{
struct maps *the_map = NULL;
char line[1024];
int ret;
- while(fgets(line, sizeof(line), file)) {
+ while (fgets(line, sizeof(line), file)) {
struct maps *map = alloc_map();
unsigned long start, end;
char name[1024];
map->end = end;
map->size = end - start;
map->pid = pid;
+ map->tid = tid;
if (ret >= 3)
strncpy(map->name, name, sizeof(map->name));
.compare = compare_pageframe,
};
+static int read_cmdline(int pid, int tid, char *cmdline, size_t len)
+{
+ FILE *file;
+ char path[512];
+ int ret;
+
+ snprintf(path, sizeof(path), "/proc/%d/task/%d/cmdline", pid, tid);
+ file = fopen(path, "rb");
+
+ if (!file)
+ return -1;
+
+ ret = fread(cmdline, 1, len, file);
+ if (ret > 0)
+ cmdline[ret - 1] = 0;
+ fclose(file);
+
+ return ret > 0 ? 0 : -1;
+}
+
+static char *get_name_by_pid(int pid)
+{
+ static int last_pid;
+ static char cmdline[128];
+ static char *bname;
+
+ if (last_pid == pid)
+ return bname;
+
+ if (read_cmdline(pid, pid, cmdline, sizeof(cmdline))) {
+ bname = NULL;
+ return NULL;
+ }
+
+ bname = basename(cmdline);
+
+ last_pid = pid;
+ return bname;
+}
+
static int check_parse_opts(struct parse_opts *opts, struct pageframe *pf,
struct maps *map)
{
}
if (opts->parse_mask & PARSE_MAP_NAME) {
- if (!strcmp(opts->map_name, map->name))
+ if (!strcmp(opts->name, map->name))
+ return 1;
+ }
+
+ if (opts->parse_mask & PARSE_PROCESS_NAME) {
+ if (!strcmp(opts->name, get_name_by_pid(map->pid)))
return 1;
}
/* Go through the list of allocated memory areas */
list_for_each_entry(map, &maps->list, list) {
start = map->start >> (PAGE_SHIFT - 3);
- len = map->size >> (PAGE_SHIFT - 3);
+ len = map->size >> (PAGE_SHIFT);
ret = fseek(file, start, SEEK_SET);
if (ret) {
} else {
tmp = alloc_maplist();
tmp->map = map;
- list_add(&match->ml->list, &tmp->list);
+ list_add(&tmp->list, &match->ml->list);
}
- if (match->page_present) {
+ if (match->page_present)
map->pages_present++;
- } else if (match->page_swapped) {
+ else if (match->page_swapped)
map->pages_swapped++;
- }
}
}
return 0;
}
-void read_pageframe(int pid, struct pageframe *pageframe,
- struct process **process_list, struct parse_opts *opts)
+static int read_pageframe(int pid, int tid, struct pageframe *pageframe,
+ struct process **process_list, struct parse_opts *opts)
{
struct maps *maps;
struct process *process;
FILE *file;
char path[512];
- int ret;
process = malloc(sizeof(*process));
memset(process, 0, sizeof(*process));
*process_list = process;
process->pid = pid;
+ process->tid = tid;
list_add_tail(&process->list, &(*process_list)->list);
- snprintf(path, sizeof(path), "/proc/%d/maps", pid);
+ snprintf(path, sizeof(path), "/proc/%d/task/%d/maps", pid, tid);
file = fopen(path, "rb");
if (!file)
- return;
+ return 0;
- maps = parse_maps(file, pid);
+ maps = parse_maps(file, pid, tid);
fclose(file);
process->maps = maps;
- snprintf(path, sizeof(path), "/proc/%d/pagemap", pid);
+ snprintf(path, sizeof(path), "/proc/%d/task/%d/pagemap", pid, tid);
file = fopen(path, "rb");
if (!file)
- return;
+ return 0;
parse_pageframe(file, pageframe, maps, opts);
fclose(file);
- snprintf(path, sizeof(path), "/proc/%d/cmdline", pid);
- file = fopen(path, "rb");
-
- if (!file)
- return;
-
- ret = fread(process->name, 1, sizeof(process->name), file);
- if (ret > 0)
- process->name[ret - 1] = 0;
- fclose(file);
+ if (read_cmdline(pid, tid, process->name, sizeof(process->name)))
+ return 1;
if (maps == NULL)
- return;
+ return 1;
list_for_each_entry(maps, &process->maps->list, list) {
process->pages_present += maps->pages_present;
process->pages_swapped += maps->pages_swapped;
}
- return;
+ return 1;
}
-static int get_next_pid(void)
+static int parse_pid(DIR **dir)
{
- static DIR *dir = NULL;
struct dirent *dirent;
int error;
- if (!dir) {
- dir = opendir("/proc");
- if (!dir) {
- error = errno;
- printf("Failed to open /proc directory: %s\n",
- strerror(error));
- return -1;
- }
- }
-
restart:
- dirent = readdir(dir);
+ dirent = readdir(*dir);
if (!dirent) {
if (errno == 0) {
- closedir(dir);
- dir = NULL;
+ closedir(*dir);
+ *dir = NULL;
return 0;
}
error = errno;
return atoi(dirent->d_name);
}
-void scan_all_pids(struct pageframe *pf, struct process **process_list,
+static int opendir_check(DIR **dir, const char *path)
+{
+ int error;
+
+ if (!*dir) {
+ *dir = opendir(path);
+ if (!dir) {
+ error = errno;
+ fprintf(stderr, "Failed to open %s directory: %s\n",
+ path, strerror(error));
+ return -1;
+ }
+ }
+
+ return 0;
+}
+
+static int get_next_tid(int pid, DIR **dir)
+{
+ if (*dir == NULL) {
+ char path[64];
+
+ snprintf(path, sizeof(path), "/proc/%d/task/", pid);
+ if (opendir_check(dir, path))
+ return -1;
+ }
+
+ return parse_pid(dir);
+}
+
+static int get_next_pid(DIR **dir)
+{
+ if (opendir_check(dir, "/proc"))
+ return -1;
+
+ return parse_pid(dir);
+}
+
+static int get_next_pid_by_name(DIR **dir, char *name)
+{
+ int pid;
+ char *pname;
+
+ if (opendir_check(dir, "/proc"))
+ return -1;
+
+ while (1) {
+ pid = parse_pid(dir);
+ if (pid <= 0)
+ break;
+
+ pname = get_name_by_pid(pid);
+ if (pname == NULL)
+ continue;
+ if (strcmp(pname, name))
+ continue;
+
+ return pid;
+ }
+
+ return 0;
+}
+
+static int read_pageframe_with_threads(int pid,
+ struct pageframe *pageframe,
+ struct process **process_list,
+ struct parse_opts *opts)
+{
+ DIR *dir = NULL;
+ int tid;
+ int count = 0;
+
+ while (1) {
+ if (opts->with_threads)
+ tid = get_next_tid(pid, &dir);
+ else
+ tid = pid;
+
+ if (tid <= 0)
+ return count;
+
+ count += read_pageframe(pid, tid, pageframe, process_list,
+ opts);
+
+ if (!opts->with_threads)
+ break;
+ }
+
+ return count;
+}
+
+int scan_all_pids(struct pageframe *pf, struct process **process_list,
struct parse_opts *opts)
{
+ DIR *dir = NULL;
int pid;
+ int count = 0;
+
+ if (opts->parse_mask & PARSE_PROCESS_NAME) {
+ while ((pid = get_next_pid_by_name(&dir, opts->name))) {
+ count += read_pageframe_with_threads(pid, pf,
+ process_list,
+ opts);
+ }
+ dir = NULL;
+ }
if (opts->parse_mask & PARSE_PID)
- read_pageframe(opts->pid, pf, process_list, opts);
+ count = read_pageframe_with_threads(opts->pid, pf, process_list,
+ opts);
+
+ if ((count == 0) && !(opts->parse_mask & PARSE_MAP_NAME)) {
+ printf("Failed to find any matching processes "
+ "with given arguments\n");
+ return -1;
+ }
+
+ if (opts->parse_mask & PARSE_DUMP)
+ return 0;
- while(1) {
- pid = get_next_pid();
+ while (1) {
+ pid = get_next_pid(&dir);
if (pid <= 0)
break;
- read_pageframe(pid, pf, process_list, opts);
+ read_pageframe_with_threads(pid, pf, process_list, opts);
}
+
+ return 0;
}
projects / scan-pagemap / blobdiff