We may meet git-am error with window-format files. So convert the ipcs.c from window format to unix format. Use dos2unix to convert the file, and remove some whitespaces manually. Signed-off-by: Huang Shijie <huangsj(a)hygon.cn&gt; --- ipcs.c | 2325 ++++++++++++++++++++++++++++---------------------------- 1 file changed, 1162 insertions(+), 1163 deletions(-) diff --git a/ipcs.c b/ipcs.c index 59dc9b6..adea201 100644 --- a/ipcs.c +++ b/ipcs.c @@ -1,1163 +1,1162 @@ -/* ipcs.c - provide information on ipc facilities - * - * Copyright (C) 2012 FUJITSU LIMITED - * Auther: Qiao Nuohan <qiaonuohan(a)cn.fujitsu.com&gt; - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - */ - -#include "defs.h" /* From the crash source top-level directory */ - -#define SPECIFIED_NOTHING 0x0 -#define SPECIFIED_ID 0x1 -#define SPECIFIED_ADDR 0x2 - -#define IPCS_INIT 0x1 -#define IDR_ORIG 0x2 -#define IDR_RADIX 0x4 -#define IDR_XARRAY 0x8 - -#define MAX_ID_SHIFT (sizeof(int)*8 - 1) -#define MAX_ID_BIT (1U << MAX_ID_SHIFT) -#define MAX_ID_MASK (MAX_ID_BIT - 1) - -#define SHM_DEST 01000 -#define SHM_LOCKED 02000 - -struct shm_info { - ulong shmid_kernel; - int key; - int shmid; - ulong rss; - ulong swap; - unsigned int uid; - unsigned int perms; - ulong bytes; - ulong nattch; - ulong shm_inode; - int deleted; -}; - -struct sem_info { - ulong sem_array; - int key; - int semid; - unsigned int uid; - unsigned int perms; - ulong nsems; - int deleted; -}; - -struct msg_info { - ulong msg_queue; - int key; - int msgid; - unsigned int uid; - unsigned int perms; - ulong bytes; - ulong messages; - int deleted; -}; - -struct ipcs_table { - int idr_bits; - ulong init_flags; - ulong hugetlbfs_f_op_addr; - ulong shm_f_op_addr; - ulong shm_f_op_huge_addr; - int use_shm_f_op; - int seq_multiplier; - int cnt; - struct list_pair *lp; -}; - -/* - * function declaration - */ - -static int dump_shared_memory(int, ulong, int, ulong); -static int dump_semaphore_arrays(int, ulong, int, ulong); -static int dump_message_queues(int, ulong, int, ulong); -static int ipc_search_idr(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); -static int ipc_search_array(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); -static int dump_shm_info(ulong, int, ulong, int, int); -static int dump_sem_info(ulong, int, ulong, int, int); -static int dump_msg_info(ulong, int, ulong, int, int); -static void get_shm_info(struct shm_info *, ulong, int); -static void get_sem_info(struct sem_info *, ulong, int); -static void get_msg_info(struct msg_info *, ulong, int); -static void add_rss_swap(ulong, int, ulong *, ulong *); -static int is_file_hugepages(ulong); -static void gather_radix_tree_entries(ulong); -static void gather_xarray_entries(ulong); - -/* - * global data - */ -static struct ipcs_table ipcs_table = { 0 }; - -void -ipcs_init(void) -{ - if (ipcs_table.init_flags & IPCS_INIT) { - return; - } - - ipcs_table.init_flags |= IPCS_INIT; - - MEMBER_OFFSET_INIT(file_f_op, "file", "f_op"); - MEMBER_OFFSET_INIT(file_private_data, "file", "private_data"); - MEMBER_OFFSET_INIT(hstate_order, "hstate", "order"); - MEMBER_OFFSET_INIT(hugetlbfs_sb_info_hstate, "hugetlbfs_sb_info", - "hstate"); - MEMBER_OFFSET_INIT(idr_layers, "idr", "layers"); - MEMBER_OFFSET_INIT(idr_layer_layer, "idr_layer", "layer"); - MEMBER_OFFSET_INIT(idr_layer_ary, "idr_layer", "ary"); - MEMBER_OFFSET_INIT(idr_top, "idr", "top"); - MEMBER_OFFSET_INIT(idr_cur, "idr", "cur"); - MEMBER_OFFSET_INIT(ipc_id_ary_p, "ipc_id_ary", "p"); - MEMBER_OFFSET_INIT(ipc_ids_entries, "ipc_ids", "entries"); - MEMBER_OFFSET_INIT(ipc_ids_max_id, "ipc_ids", "max_id"); - MEMBER_OFFSET_INIT(ipc_ids_in_use, "ipc_ids", "in_use"); - MEMBER_OFFSET_INIT(ipc_ids_ipcs_idr, "ipc_ids", "ipcs_idr"); - MEMBER_OFFSET_INIT(ipc_namespace_ids, "ipc_namespace", "ids"); - MEMBER_OFFSET_INIT(kern_ipc_perm_key, "kern_ipc_perm", "key"); - MEMBER_OFFSET_INIT(kern_ipc_perm_id, "kern_ipc_perm", "id"); - MEMBER_OFFSET_INIT(kern_ipc_perm_uid, "kern_ipc_perm", "uid"); - MEMBER_OFFSET_INIT(kern_ipc_perm_mode, "kern_ipc_perm", "mode"); - MEMBER_OFFSET_INIT(kern_ipc_perm_deleted, "kern_ipc_perm", - "deleted"); - MEMBER_OFFSET_INIT(kern_ipc_perm_seq, "kern_ipc_perm", "seq"); - MEMBER_OFFSET_INIT(nsproxy_ipc_ns, "nsproxy", "ipc_ns"); - MEMBER_OFFSET_INIT(shmem_inode_info_vfs_inode, "shmem_inode_info", - "vfs_inode"); - MEMBER_OFFSET_INIT(shmem_inode_info_swapped, "shmem_inode_info", - "swapped"); - if (INVALID_MEMBER(shmem_inode_info_swapped)) - ANON_MEMBER_OFFSET_INIT(shmem_inode_info_swapped, - "shmem_inode_info", "swapped"); - MEMBER_OFFSET_INIT(shm_file_data_file, "shm_file_data", "file"); - MEMBER_OFFSET_INIT(shmid_kernel_shm_perm, "shmid_kernel", - "shm_perm"); - MEMBER_OFFSET_INIT(shmid_kernel_shm_segsz, "shmid_kernel", - "shm_segsz"); - MEMBER_OFFSET_INIT(shmid_kernel_shm_nattch, "shmid_kernel", - "shm_nattch"); - MEMBER_OFFSET_INIT(shmid_kernel_shm_file, "shmid_kernel", - "shm_file"); - MEMBER_OFFSET_INIT(shmid_kernel_id, "shmid_kernel", "id"); - MEMBER_OFFSET_INIT(sem_array_sem_perm, "sem_array", "sem_perm"); - MEMBER_OFFSET_INIT(sem_array_sem_id, "sem_array", "sem_id"); - MEMBER_OFFSET_INIT(sem_array_sem_nsems, "sem_array", "sem_nsems"); - MEMBER_OFFSET_INIT(msg_queue_q_perm, "msg_queue", "q_perm"); - MEMBER_OFFSET_INIT(msg_queue_q_id, "msg_queue", "q_id"); - MEMBER_OFFSET_INIT(msg_queue_q_cbytes, "msg_queue", "q_cbytes"); - MEMBER_OFFSET_INIT(msg_queue_q_qnum, "msg_queue", "q_qnum"); - MEMBER_OFFSET_INIT(super_block_s_fs_info, "super_block", - "s_fs_info"); - - /* - * struct size - */ - STRUCT_SIZE_INIT(ipc_ids, "ipc_ids"); - STRUCT_SIZE_INIT(shmid_kernel, "shmid_kernel"); - STRUCT_SIZE_INIT(sem_array, "sem_array"); - STRUCT_SIZE_INIT(msg_queue, "msg_queue"); - STRUCT_SIZE_INIT(hstate, "hstate"); - - if (symbol_exists("hugetlbfs_file_operations")) - ipcs_table.hugetlbfs_f_op_addr = - symbol_value("hugetlbfs_file_operations"); - if (symbol_exists("is_file_shm_hugepages")) { - ipcs_table.use_shm_f_op = TRUE; - ipcs_table.shm_f_op_addr = - symbol_value("shm_file_operations"); - if (symbol_exists("shm_file_operations_huge")) { - ipcs_table.shm_f_op_huge_addr = - symbol_value("shm_file_operations_huge"); - } else { - ipcs_table.shm_f_op_huge_addr = -1; - } - } else { - ipcs_table.use_shm_f_op = FALSE; - ipcs_table.shm_f_op_addr = -1; - ipcs_table.shm_f_op_huge_addr = -1; - } - - if (VALID_MEMBER(idr_layer_ary) && - get_array_length("idr_layer.ary", NULL, 0) > 64) - ipcs_table.idr_bits = 8; - else if (BITS32()) - ipcs_table.idr_bits = 5; - else if (BITS64()) - ipcs_table.idr_bits = 6; - else - error(FATAL, "machdep->bits is not 32 or 64"); - - if (VALID_MEMBER(idr_idr_rt)) { - if (STREQ(MEMBER_TYPE_NAME("idr", "idr_rt"), "xarray")) - ipcs_table.init_flags |= IDR_XARRAY; - else { - if (MEMBER_EXISTS("radix_tree_root", "rnode")) - ipcs_table.init_flags |= IDR_RADIX; - else if (MEMBER_EXISTS("radix_tree_root", "xa_head")) - ipcs_table.init_flags |= IDR_XARRAY; - } - } else - ipcs_table.init_flags |= IDR_ORIG; - - ipcs_table.seq_multiplier = 32768; -} - -/* - * Arguments are passed to the command functions in the global args[argcnt] - * array. See getopt(3) for info on dash arguments. Check out defs.h and - * other crash commands for usage of the myriad of utility routines available - * to accomplish what your task. - */ -void -cmd_ipcs(void) -{ - int specified; - char *specified_value[MAXARGS]; - int value_index; - int c; - int shm, sem, msg, verbose; - int i; - ulong value, task; - int found; - struct task_context *tc; - char buf[BUFSIZE]; - - value_index = 0; - specified = SPECIFIED_NOTHING; - shm = 0; - sem = 0; - msg = 0; - verbose = 0; - tc = NULL; - - while ((c = getopt(argcnt, args, "smMqn:")) != EOF) { - switch(c) { - case 's': - sem = 1; - break; - case 'm': - shm = 1; - break; - case 'M': - shm = 1; - verbose = 1; - break; - case 'q': - msg = 1; - break; - case 'n': - switch (str_to_context(optarg, &value, &tc)) { - case STR_PID: - case STR_TASK: - break; - case STR_INVALID: - error(FATAL, "invalid task or pid value: %s\n", - optarg); - break; - } - break; - default: - cmd_usage(pc->curcmd, SYNOPSIS);; - return; - } - } - - while (args[optind]) { - if (value_index >= MAXARGS) - error(FATAL, "too many id/member specified\n"); - specified |= SPECIFIED_ID | SPECIFIED_ADDR; - specified_value[value_index] = args[optind]; - stol(args[optind], FAULT_ON_ERROR, NULL); - optind++; - value_index++; - } - - if (THIS_KERNEL_VERSION < LINUX(2,6,0)) - command_not_supported(); - - ipcs_init(); - - if (!shm && !sem && !msg) - shm = sem = msg = 1; - - task = tc ? tc->task : pid_to_task(0); - - if (!value_index) { - if (shm) - dump_shared_memory(specified, 0, verbose, task); - if (sem) - dump_semaphore_arrays(specified, 0, 0, task); - if (msg) - dump_message_queues(specified, 0, 0, task); - } else { - open_tmpfile(); - i = 0; - while (i < value_index) { - found = 0; - value = stol(specified_value[i], FAULT_ON_ERROR, NULL); - if (shm) - found += dump_shared_memory(specified, - value, verbose, task); - if (sem) - found += dump_semaphore_arrays(specified, - value, 0, task); - if (msg) - found += dump_message_queues(specified, - value, 0, task); - - if (!found) - fprintf(pc->saved_fp, "invalid id or address: %s\n\n", - specified_value[i]); - - i++; - } - fflush(fp); - rewind(fp); - - while (fgets(buf, BUFSIZE, fp)) - fprintf(pc->saved_fp, "%s", buf); - - close_tmpfile(); - } -} - -static int -dump_shared_memory(int specified, ulong specified_value, int verbose, ulong task) -{ - ulong nsproxy_p, ipc_ns_p; - ulong ipc_ids_p; - int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); - int (*dump_shm)(ulong, int, ulong, int, int); - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - char buf6[BUFSIZE]; - char buf7[BUFSIZE]; - - if (!verbose && specified == SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, - LJUST, "SHMID_KERNEL"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "SHMID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 10, LJUST, "BYTES"), - mkstring(buf6, 6, LJUST, "NATTCH"), - mkstring(buf7, 6, LJUST, "STATUS")); - } - - dump_shm = dump_shm_info; - - if (VALID_MEMBER(kern_ipc_perm_id)) { - ipc_search = ipc_search_idr; - } else { - ipc_search = ipc_search_array; - } - - if (symbol_exists("shm_ids")) { - ipc_ids_p = symbol_value("shm_ids"); - } else { - readmem(task + OFFSET(task_struct_nsproxy), KVADDR, - &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", - FAULT_ON_ERROR); - if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, - &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", - RETURN_ON_ERROR|QUIET)) - error(FATAL, - "cannot determine ipc_namespace location!\n"); - - if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) - readmem(ipc_ns_p + OFFSET(ipc_namespace_ids) + - sizeof(ulong) * 2, KVADDR, &ipc_ids_p, - sizeof(ulong), "ipc_namespace.ids[2]", - FAULT_ON_ERROR); - else - ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids) + - 2 * SIZE(ipc_ids); - } - - if (ipc_search(ipc_ids_p, specified, specified_value, dump_shm, verbose)) { - return 1; - } else { - if (verbose && specified == SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, - LJUST, "SHMID_KERNEL"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "SHMID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 10, LJUST, "BYTES"), - mkstring(buf6, 6, LJUST, "NATTCH"), - mkstring(buf7, 6, LJUST, "STATUS")); - fprintf(fp, "(none allocated)\n\n"); - } - return 0; - } -} - -static int -dump_semaphore_arrays(int specified, ulong specified_value, int verbose, ulong task) -{ - ulong nsproxy_p, ipc_ns_p; - ulong ipc_ids_p; - int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); - int (*dump_sem)(ulong, int, ulong, int, int); - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - - if (specified == SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, - LJUST, "SEM_ARRAY"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "SEMID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 10, LJUST, "NSEMS")); - } - - dump_sem = dump_sem_info; - - if (VALID_MEMBER(kern_ipc_perm_id)) { - ipc_search = ipc_search_idr; - } else { - ipc_search = ipc_search_array; - } - - if (symbol_exists("sem_ids")) { - ipc_ids_p = symbol_value("sem_ids"); - } else { - readmem(task + OFFSET(task_struct_nsproxy), KVADDR, - &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", - FAULT_ON_ERROR); - - if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, - &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", - FAULT_ON_ERROR|QUIET)) - error(FATAL, - "cannot determine ipc_namespace location!\n"); - - if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) - readmem(ipc_ns_p + OFFSET(ipc_namespace_ids), - KVADDR, &ipc_ids_p, sizeof(ulong), - "ipc_namespace.ids[2]", FAULT_ON_ERROR); - else - ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids); - } - - return ipc_search(ipc_ids_p, specified, specified_value, dump_sem, verbose); -} - -static int -dump_message_queues(int specified, ulong specified_value, int verbose, ulong task) -{ - ulong nsproxy_p, ipc_ns_p; - ulong ipc_ids_p; - int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); - int (*dump_msg)(ulong, int, ulong, int, int); - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - char buf6[BUFSIZE]; - - if (specified == SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, - LJUST, "MSG_QUEUE"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "MSQID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 12, LJUST, "USED-BYTES"), - mkstring(buf6, 12, LJUST, "MESSAGES")); - } - - dump_msg = dump_msg_info; - - if (VALID_MEMBER(kern_ipc_perm_id)) { - ipc_search = ipc_search_idr; - } else { - ipc_search = ipc_search_array; - } - - if (symbol_exists("msg_ids")) { - ipc_ids_p = symbol_value("msg_ids"); - } else { - readmem(task + OFFSET(task_struct_nsproxy), KVADDR, - &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", - FAULT_ON_ERROR); - if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, - &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", - FAULT_ON_ERROR|QUIET)) - error(FATAL, - "cannot determine ipc_namespace location!\n"); - - if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) - readmem(ipc_ns_p + OFFSET(ipc_namespace_ids) + - sizeof(ulong), KVADDR, &ipc_ids_p, - sizeof(ulong), "ipc_namespace.ids[2]", - FAULT_ON_ERROR); - else - ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids) + - SIZE(ipc_ids); - } - - return ipc_search(ipc_ids_p, specified, specified_value, dump_msg, verbose); -} - -/* - * if shared memory information is stored in an array, use this function. - */ -static int -ipc_search_array(ulong ipc_ids_p, int specified, ulong specified_value, int (*fn)(ulong, int, ulong, int, int), int verbose) -{ - ulong entries_p; - int max_id, i; - ulong *array; - int found = 0; - int allocated = 0; - - readmem(ipc_ids_p + OFFSET(ipc_ids_entries), KVADDR, &entries_p, - sizeof(ulong), "ipc_ids.entries", FAULT_ON_ERROR); - readmem(ipc_ids_p + OFFSET(ipc_ids_max_id), KVADDR, &max_id, - sizeof(int), "ipc_ids.max_id", FAULT_ON_ERROR); - - if (max_id < 0) { - if (specified == SPECIFIED_NOTHING && !verbose) - fprintf(fp, "(none allocated)\n\n"); - return 0; - } - - array = (ulong *)GETBUF(sizeof(ulong *) * (max_id + 1)); - if (VALID_MEMBER(ipc_id_ary_p)) - readmem(entries_p + OFFSET(ipc_id_ary_p), KVADDR, array, - sizeof(ulong *) * (max_id + 1), "ipc_id_ary.p", - FAULT_ON_ERROR); - else - readmem(entries_p, KVADDR, array, sizeof(ulong *)*(max_id+1), - "ipc_id array", FAULT_ON_ERROR); - - for (i=0; i<=max_id; i++) { - if (array[i] == 0) - continue; - if (fn(array[i], specified, specified_value, i, verbose)) { - allocated++; - found = 1; - if (specified != SPECIFIED_NOTHING) - break; - } - } - - if (specified == SPECIFIED_NOTHING && !verbose) { - if (!allocated) - fprintf(fp, "(none allocated)\n"); - fprintf(fp, "\n"); - } - - FREEBUF(array); - - if (found) - return 1; - else - return 0; -} - -/* - * if shared memory information is stored by using idr, use this function to - * get data. - */ -static int -ipc_search_idr(ulong ipc_ids_p, int specified, ulong specified_value, int (*fn)(ulong, int, ulong, int, int), int verbose) -{ - int i, in_use; - ulong ipcs_idr_p; - ulong ipc; - int next_id, total; - int found = 0; - - readmem(ipc_ids_p + OFFSET(ipc_ids_in_use), KVADDR, &in_use, - sizeof(int), "ipc_ids.in_use", FAULT_ON_ERROR); - - ipcs_idr_p = ipc_ids_p + OFFSET(ipc_ids_ipcs_idr); - - if (!in_use) { - if (specified == SPECIFIED_NOTHING && !verbose) - fprintf(fp, "(none allocated)\n\n"); - return 0; - } - - if (VALID_MEMBER(idr_idr_rt)) { - switch (ipcs_table.init_flags & (IDR_RADIX|IDR_XARRAY)) - { - case IDR_RADIX: - gather_radix_tree_entries(ipcs_idr_p); - break; - case IDR_XARRAY: - gather_xarray_entries(ipcs_idr_p); - break; - } - - for (i = 0; i < ipcs_table.cnt; i++) { - ipc = (ulong)ipcs_table.lp[i].value; - if (fn(ipc, specified, specified_value, UNUSED, verbose)) { - found = 1; - if (specified != SPECIFIED_NOTHING) - break; - } - } - - if (ipcs_table.lp) - FREEBUF(ipcs_table.lp); - } else { - for (total = 0, next_id = 0; total < in_use; next_id++) { - ipc = idr_find(ipcs_idr_p, next_id); - if (ipc == 0) - continue; - - total++; - if (fn(ipc, specified, specified_value, next_id, verbose)) { - found = 1; - if (specified != SPECIFIED_NOTHING) - break; - } - } - } - - if (!verbose && specified == SPECIFIED_NOTHING) - fprintf(fp, "\n"); - - if (found || specified == SPECIFIED_NOTHING) - return 1; - else - return 0; -} - -/* - * search every idr_layer - */ -ulong -idr_find(ulong idp, int id) -{ - ulong idr_layer_p; - int layer; - int idr_layers; - int n; - int index; - - readmem(idp + OFFSET(idr_top), KVADDR, &idr_layer_p, - sizeof(ulong), "idr.top", FAULT_ON_ERROR); - - if (!idr_layer_p) - return 0; - - if (VALID_MEMBER(idr_layer_layer)) { - readmem(idr_layer_p + OFFSET(idr_layer_layer), KVADDR, - &layer, sizeof(int), "idr_layer.layer", - FAULT_ON_ERROR); - n = (layer + 1) * ipcs_table.idr_bits; - } else { - readmem(idp + OFFSET(idr_layers), KVADDR, &idr_layers, - sizeof(int), "idr.layers", FAULT_ON_ERROR); - n = idr_layers * ipcs_table.idr_bits; - } - id &= MAX_ID_MASK; - - if (id >= (1 << n)) - return 0; - - while (n > 0 && idr_layer_p) { - n -= ipcs_table.idr_bits; - index = (id >> n) & ((1 << ipcs_table.idr_bits) - 1); - readmem(idr_layer_p + OFFSET(idr_layer_ary) + - sizeof(ulong) * index, KVADDR, &idr_layer_p, - sizeof(ulong), "idr_layer.ary", FAULT_ON_ERROR); - } - - return idr_layer_p; -} - -/* - * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, - * then return 1 - */ -static int -dump_shm_info(ulong shp, int specified, ulong specified_value, int id, int verbose) -{ - struct shm_info shm_info; - char buf[BUFSIZE]; - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - char buf6[BUFSIZE]; - char buf7[BUFSIZE]; - - get_shm_info(&shm_info, shp, id); - - if (shm_info.deleted) - return 0; - - if (((specified & SPECIFIED_ID) && shm_info.shmid == specified_value) || - ((specified & SPECIFIED_ADDR) && shm_info.shmid_kernel == - specified_value) || specified == SPECIFIED_NOTHING) { - if (verbose || specified != SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, - LJUST, "SHMID_KERNEL"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "SHMID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 10, LJUST, "BYTES"), - mkstring(buf6, 6, LJUST, "NATTCH"), - mkstring(buf7, 6, LJUST, "STATUS")); - } - - fprintf(fp, "%s %08x %-10d %-5d %-5o %-10ld %-6ld %-s %-s\n", - mkstring(buf, VADDR_PRLEN <= 12 ? 12 : VADDR_PRLEN, - LJUST|LONG_HEX, (char *)shm_info.shmid_kernel), - shm_info.key, - shm_info.shmid, - shm_info.uid, - shm_info.perms & 0777, - shm_info.bytes, - shm_info.nattch, - shm_info.perms & SHM_DEST ? "dest" : "", - shm_info.perms & SHM_LOCKED ? "locked" : ""); - - if (verbose) { - fprintf(fp, "PAGES ALLOCATED/RESIDENT/SWAPPED: %ld/%ld/%ld\n", - (shm_info.bytes+PAGESIZE()-1) >> PAGESHIFT(), - shm_info.rss, shm_info.swap); - fprintf(fp, "INODE: %lx\n", shm_info.shm_inode); - } - - if (verbose || specified != SPECIFIED_NOTHING) - fprintf(fp, "\n"); - - return 1; - } else - return 0; -} - -/* - * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, - * then return 1 - */ -static int -dump_sem_info(ulong shp, int specified, ulong specified_value, int id, int verbose) -{ - struct sem_info sem_info; - char buf[BUFSIZE]; - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - - get_sem_info(&sem_info, shp, id); - - if (sem_info.deleted) - return 0; - - if (((specified & SPECIFIED_ID) && sem_info.semid == specified_value) || - ((specified & SPECIFIED_ADDR) && sem_info.sem_array == - specified_value) || specified == SPECIFIED_NOTHING) { - if (specified != SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, - LJUST, "SEM_ARRAY"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "SEMID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 10, LJUST, "NSEMS")); - } - - fprintf(fp, "%s %08x %-10d %-5d %-5o %-10ld\n", - mkstring(buf, VADDR_PRLEN <= 10 ? 10 : VADDR_PRLEN, - LJUST|LONG_HEX, (char *)sem_info.sem_array), - sem_info.key, - sem_info.semid, - sem_info.uid, - sem_info.perms & 0777, - sem_info.nsems); - - if (specified != SPECIFIED_NOTHING) - fprintf(fp, "\n"); - - return 1; - } else - return 0; -} - -/* - * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, - * then return 1 - */ -static int -dump_msg_info(ulong shp, int specified, ulong specified_value, int id, int verbose) -{ - struct msg_info msg_info; - char buf[BUFSIZE]; - char buf0[BUFSIZE]; - char buf1[BUFSIZE]; - char buf2[BUFSIZE]; - char buf3[BUFSIZE]; - char buf4[BUFSIZE]; - char buf5[BUFSIZE]; - char buf6[BUFSIZE]; - - get_msg_info(&msg_info, shp, id); - - if (msg_info.deleted) - return 0; - - if (((specified & SPECIFIED_ID) && msg_info.msgid == specified_value) || - ((specified & SPECIFIED_ADDR) && msg_info.msg_queue == - specified_value) || specified == SPECIFIED_NOTHING) { - if (specified != SPECIFIED_NOTHING) { - fprintf(fp, "%s %s %s %s %s %s %s\n", - mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, - LJUST, "MSG_QUEUE"), - mkstring(buf1, 8, LJUST, "KEY"), - mkstring(buf2, 10, LJUST, "MSQID"), - mkstring(buf3, 5, LJUST, "UID"), - mkstring(buf4, 5, LJUST, "PERMS"), - mkstring(buf5, 12, LJUST, "USED-BYTES"), - mkstring(buf6, 12, LJUST, "MESSAGES")); - } - - fprintf(fp, "%s %08x %-10d %-5d %-5o %-12ld %-12ld\n", - mkstring(buf, VADDR_PRLEN <= 10 ? 10 : VADDR_PRLEN, - LJUST|LONG_HEX, (char *)msg_info.msg_queue), - msg_info.key, - msg_info.msgid, - msg_info.uid, - msg_info.perms & 0777, - msg_info.bytes, - msg_info.messages); - - if (specified != SPECIFIED_NOTHING) - fprintf(fp, "\n"); - - return 1; - } else - return 0; -} - -static void -get_shm_info(struct shm_info *shm_info, ulong shp, int id) -{ - char buf[BUFSIZE]; - ulong filep, dentryp, inodep; - - shm_info->shmid_kernel = shp - OFFSET(shmid_kernel_shm_perm); - - /* - * cache shmid_kernel - */ - readmem(shm_info->shmid_kernel, KVADDR, buf, SIZE(shmid_kernel), - "shmid_kernel", FAULT_ON_ERROR); - - shm_info->key = INT(buf + OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_key)); - if (VALID_MEMBER(shmid_kernel_id)) - shm_info->shmid = INT(buf + OFFSET(shmid_kernel_id)); - else - shm_info->shmid = INT(buf + - OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_id)); - - shm_info->uid = UINT(buf + OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_uid)); - - if (BITS32()) - shm_info->perms = USHORT(buf + - OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_mode)); - else - shm_info->perms = UINT(buf + - OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_mode)); - - shm_info->bytes = ULONG(buf + OFFSET(shmid_kernel_shm_segsz)); - - shm_info->nattch = ULONG(buf + OFFSET(shmid_kernel_shm_nattch)); - - filep = ULONG(buf + OFFSET(shmid_kernel_shm_file)); - readmem(filep + OFFSET(file_f_dentry), KVADDR, &dentryp, sizeof(ulong), - "file.f_dentry", FAULT_ON_ERROR); - readmem(dentryp + OFFSET(dentry_d_inode), KVADDR, &inodep, - sizeof(ulong), "dentry.d_inode", FAULT_ON_ERROR); - /* - * shm_inode here is the vfs_inode of struct shmem_inode_info - */ - shm_info->shm_inode = inodep; - - shm_info->rss = 0; - shm_info->swap = 0; - - add_rss_swap(inodep, is_file_hugepages(filep), &shm_info->rss, - &shm_info->swap); - - shm_info->deleted = UCHAR(buf + OFFSET(shmid_kernel_shm_perm) + - OFFSET(kern_ipc_perm_deleted)); -} - -static void -get_sem_info(struct sem_info *sem_info, ulong shp, int id) -{ - char buf[BUFSIZE]; - - sem_info->sem_array = shp - OFFSET(sem_array_sem_perm); - - /* - * cache sem_array - */ - readmem(sem_info->sem_array, KVADDR, buf, SIZE(sem_array), - "sem_array", FAULT_ON_ERROR); - - sem_info->key = INT(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_key)); - - if (VALID_MEMBER(sem_array_sem_id)) - sem_info->semid = INT(buf + OFFSET(sem_array_sem_id)); - else if (VALID_MEMBER(kern_ipc_perm_id)) - sem_info->semid = INT(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_id)); - else { - ulong seq; - seq = ULONG(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_seq)); - sem_info->semid = ipcs_table.seq_multiplier * seq + id; - } - - sem_info->uid = UINT(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_uid)); - - if (BITS32()) - sem_info->perms = USHORT(buf + - OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_mode)); - else - sem_info->perms = UINT(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_mode)); - - sem_info->nsems = ULONG(buf + OFFSET(sem_array_sem_nsems)); - - sem_info->deleted = UCHAR(buf + OFFSET(sem_array_sem_perm) + - OFFSET(kern_ipc_perm_deleted)); -} - -static void -get_msg_info(struct msg_info *msg_info, ulong shp, int id) -{ - char buf[BUFSIZE]; - - msg_info->msg_queue = shp - OFFSET(msg_queue_q_perm); - - /* - * cache msg_queue - */ - readmem(msg_info->msg_queue, KVADDR, buf, SIZE(msg_queue), - "msg_queue", FAULT_ON_ERROR); - - msg_info->key = INT(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_key)); - - if (VALID_MEMBER(msg_queue_q_id)) - msg_info->msgid = INT(buf + OFFSET(msg_queue_q_id)); - else if (VALID_MEMBER(kern_ipc_perm_id)) - msg_info->msgid = INT(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_id)); - else { - ulong seq; - seq = ULONG(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_seq)); - msg_info->msgid = ipcs_table.seq_multiplier * seq + id; - } - - msg_info->uid = UINT(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_uid)); - - if (BITS32()) - msg_info->perms = USHORT(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_mode)); - else - msg_info->perms = UINT(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_mode)); - - msg_info->bytes = ULONG(buf + OFFSET(msg_queue_q_cbytes)); - - msg_info->messages = ULONG(buf + OFFSET(msg_queue_q_qnum)); - - msg_info->deleted = UCHAR(buf + OFFSET(msg_queue_q_perm) + - OFFSET(kern_ipc_perm_deleted)); -} - -/* - * get rss & swap related to every shared memory, and get the total number of rss - * & swap - */ -static void -add_rss_swap(ulong inode_p, int hugepage, ulong *rss, ulong *swap) -{ - unsigned long mapping_p, nr_pages; - - readmem(inode_p + OFFSET(inode_i_mapping), KVADDR, &mapping_p, - sizeof(ulong), "inode.i_mapping", FAULT_ON_ERROR); - readmem(mapping_p + OFFSET(address_space_nrpages), KVADDR, &nr_pages, - sizeof(ulong), "address_space.nrpages", - FAULT_ON_ERROR); - - if (hugepage) { - unsigned long pages_per_hugepage; - if (VALID_SIZE(hstate)) { - unsigned long i_sb_p, hsb_p, hstate_p; - unsigned int order; - - readmem(inode_p + OFFSET(inode_i_sb), KVADDR, &i_sb_p, - sizeof(ulong), "inode.i_sb", - FAULT_ON_ERROR); - readmem(i_sb_p + OFFSET(super_block_s_fs_info), - KVADDR, &hsb_p, sizeof(ulong), - "super_block.s_fs_info", FAULT_ON_ERROR); - readmem(hsb_p + OFFSET(hugetlbfs_sb_info_hstate), - KVADDR, &hstate_p, sizeof(ulong), - "hugetlbfs_sb_info.hstate", FAULT_ON_ERROR); - readmem(hstate_p + OFFSET(hstate_order), KVADDR, - &order, sizeof(uint), "hstate.order", - FAULT_ON_ERROR); - pages_per_hugepage = 1 << order; - } else { - unsigned long hpage_shift; - /* - * HPAGE_SHIFT is 21 after commit 83a5101b - * (kernel > 2.6.24) - */ - if (THIS_KERNEL_VERSION > LINUX(2, 6, 24)) { - hpage_shift = 21; - } else { - /* - * HPAGE_SHIFT: - * x86(PAE): 21 - * x86(no PAE): 22 - * x86_64: 21 - */ - if ((machine_type("X86") && - !(machdep->flags & PAE))) - hpage_shift = 22; - else - hpage_shift = 21; - } - pages_per_hugepage = (1 << hpage_shift) / PAGESIZE(); - } - *rss += pages_per_hugepage * nr_pages; - } else { - unsigned long swapped; - - *rss += nr_pages; - readmem(inode_p - OFFSET(shmem_inode_info_vfs_inode) + - OFFSET(shmem_inode_info_swapped), KVADDR, - &swapped, sizeof(ulong), "shmem_inode_info.swapped", - FAULT_ON_ERROR); - *swap += swapped; - } -} - -static int -is_file_hugepages(ulong file_p) -{ - unsigned long f_op, sfd_p; - -again: - readmem(file_p + OFFSET(file_f_op), KVADDR, &f_op, sizeof(ulong), - "file.f_op", FAULT_ON_ERROR); - if (f_op == ipcs_table.hugetlbfs_f_op_addr) - return 1; - - if (ipcs_table.use_shm_f_op) { - if (ipcs_table.shm_f_op_huge_addr != -1) { - if (f_op == ipcs_table.shm_f_op_huge_addr) - return 1; - } else { - if (f_op == ipcs_table.shm_f_op_addr) { - readmem(file_p + - OFFSET(file_private_data), - KVADDR, &sfd_p, sizeof(ulong), - "file.private_data", FAULT_ON_ERROR); - readmem(sfd_p + - OFFSET(shm_file_data_file), - KVADDR, &file_p, sizeof(ulong), - "shm_file_data.file", FAULT_ON_ERROR); - goto again; - } - } - } - - return 0; -} - -static void -gather_radix_tree_entries(ulong ipcs_idr_p) -{ - long len; - - ipcs_table.cnt = do_radix_tree(ipcs_idr_p, RADIX_TREE_COUNT, NULL); - - if (ipcs_table.cnt) { - len = sizeof(struct list_pair) * (ipcs_table.cnt+1); - ipcs_table.lp = (struct list_pair *)GETBUF(len); - ipcs_table.lp[0].index = ipcs_table.cnt; - ipcs_table.cnt = do_radix_tree(ipcs_idr_p, RADIX_TREE_GATHER, ipcs_table.lp); - } else - ipcs_table.lp = NULL; -} - -static void -gather_xarray_entries(ulong ipcs_idr_p) -{ - long len; - - ipcs_table.cnt = do_xarray(ipcs_idr_p, XARRAY_COUNT, NULL); - - if (ipcs_table.cnt) { - len = sizeof(struct list_pair) * (ipcs_table.cnt+1); - ipcs_table.lp = (struct list_pair *)GETBUF(len); - ipcs_table.lp[0].index = ipcs_table.cnt; - ipcs_table.cnt = do_xarray(ipcs_idr_p, XARRAY_GATHER, ipcs_table.lp); - } else - ipcs_table.lp = NULL; -} - +/* ipcs.c - provide information on ipc facilities + * + * Copyright (C) 2012 FUJITSU LIMITED + * Auther: Qiao Nuohan <qiaonuohan(a)cn.fujitsu.com&gt; + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + */ + +#include "defs.h" /* From the crash source top-level directory */ + +#define SPECIFIED_NOTHING 0x0 +#define SPECIFIED_ID 0x1 +#define SPECIFIED_ADDR 0x2 + +#define IPCS_INIT 0x1 +#define IDR_ORIG 0x2 +#define IDR_RADIX 0x4 +#define IDR_XARRAY 0x8 + +#define MAX_ID_SHIFT (sizeof(int)*8 - 1) +#define MAX_ID_BIT (1U << MAX_ID_SHIFT) +#define MAX_ID_MASK (MAX_ID_BIT - 1) + +#define SHM_DEST 01000 +#define SHM_LOCKED 02000 + +struct shm_info { + ulong shmid_kernel; + int key; + int shmid; + ulong rss; + ulong swap; + unsigned int uid; + unsigned int perms; + ulong bytes; + ulong nattch; + ulong shm_inode; + int deleted; +}; + +struct sem_info { + ulong sem_array; + int key; + int semid; + unsigned int uid; + unsigned int perms; + ulong nsems; + int deleted; +}; + +struct msg_info { + ulong msg_queue; + int key; + int msgid; + unsigned int uid; + unsigned int perms; + ulong bytes; + ulong messages; + int deleted; +}; + +struct ipcs_table { + int idr_bits; + ulong init_flags; + ulong hugetlbfs_f_op_addr; + ulong shm_f_op_addr; + ulong shm_f_op_huge_addr; + int use_shm_f_op; + int seq_multiplier; + int cnt; + struct list_pair *lp; +}; + +/* + * function declaration + */ + +static int dump_shared_memory(int, ulong, int, ulong); +static int dump_semaphore_arrays(int, ulong, int, ulong); +static int dump_message_queues(int, ulong, int, ulong); +static int ipc_search_idr(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); +static int ipc_search_array(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); +static int dump_shm_info(ulong, int, ulong, int, int); +static int dump_sem_info(ulong, int, ulong, int, int); +static int dump_msg_info(ulong, int, ulong, int, int); +static void get_shm_info(struct shm_info *, ulong, int); +static void get_sem_info(struct sem_info *, ulong, int); +static void get_msg_info(struct msg_info *, ulong, int); +static void add_rss_swap(ulong, int, ulong *, ulong *); +static int is_file_hugepages(ulong); +static void gather_radix_tree_entries(ulong); +static void gather_xarray_entries(ulong); + +/* + * global data + */ +static struct ipcs_table ipcs_table = { 0 }; + +void +ipcs_init(void) +{ + if (ipcs_table.init_flags & IPCS_INIT) { + return; + } + + ipcs_table.init_flags |= IPCS_INIT; + + MEMBER_OFFSET_INIT(file_f_op, "file", "f_op"); + MEMBER_OFFSET_INIT(file_private_data, "file", "private_data"); + MEMBER_OFFSET_INIT(hstate_order, "hstate", "order"); + MEMBER_OFFSET_INIT(hugetlbfs_sb_info_hstate, "hugetlbfs_sb_info", + "hstate"); + MEMBER_OFFSET_INIT(idr_layers, "idr", "layers"); + MEMBER_OFFSET_INIT(idr_layer_layer, "idr_layer", "layer"); + MEMBER_OFFSET_INIT(idr_layer_ary, "idr_layer", "ary"); + MEMBER_OFFSET_INIT(idr_top, "idr", "top"); + MEMBER_OFFSET_INIT(idr_cur, "idr", "cur"); + MEMBER_OFFSET_INIT(ipc_id_ary_p, "ipc_id_ary", "p"); + MEMBER_OFFSET_INIT(ipc_ids_entries, "ipc_ids", "entries"); + MEMBER_OFFSET_INIT(ipc_ids_max_id, "ipc_ids", "max_id"); + MEMBER_OFFSET_INIT(ipc_ids_in_use, "ipc_ids", "in_use"); + MEMBER_OFFSET_INIT(ipc_ids_ipcs_idr, "ipc_ids", "ipcs_idr"); + MEMBER_OFFSET_INIT(ipc_namespace_ids, "ipc_namespace", "ids"); + MEMBER_OFFSET_INIT(kern_ipc_perm_key, "kern_ipc_perm", "key"); + MEMBER_OFFSET_INIT(kern_ipc_perm_id, "kern_ipc_perm", "id"); + MEMBER_OFFSET_INIT(kern_ipc_perm_uid, "kern_ipc_perm", "uid"); + MEMBER_OFFSET_INIT(kern_ipc_perm_mode, "kern_ipc_perm", "mode"); + MEMBER_OFFSET_INIT(kern_ipc_perm_deleted, "kern_ipc_perm", + "deleted"); + MEMBER_OFFSET_INIT(kern_ipc_perm_seq, "kern_ipc_perm", "seq"); + MEMBER_OFFSET_INIT(nsproxy_ipc_ns, "nsproxy", "ipc_ns"); + MEMBER_OFFSET_INIT(shmem_inode_info_vfs_inode, "shmem_inode_info", + "vfs_inode"); + MEMBER_OFFSET_INIT(shmem_inode_info_swapped, "shmem_inode_info", + "swapped"); + if (INVALID_MEMBER(shmem_inode_info_swapped)) + ANON_MEMBER_OFFSET_INIT(shmem_inode_info_swapped, + "shmem_inode_info", "swapped"); + MEMBER_OFFSET_INIT(shm_file_data_file, "shm_file_data", "file"); + MEMBER_OFFSET_INIT(shmid_kernel_shm_perm, "shmid_kernel", + "shm_perm"); + MEMBER_OFFSET_INIT(shmid_kernel_shm_segsz, "shmid_kernel", + "shm_segsz"); + MEMBER_OFFSET_INIT(shmid_kernel_shm_nattch, "shmid_kernel", + "shm_nattch"); + MEMBER_OFFSET_INIT(shmid_kernel_shm_file, "shmid_kernel", + "shm_file"); + MEMBER_OFFSET_INIT(shmid_kernel_id, "shmid_kernel", "id"); + MEMBER_OFFSET_INIT(sem_array_sem_perm, "sem_array", "sem_perm"); + MEMBER_OFFSET_INIT(sem_array_sem_id, "sem_array", "sem_id"); + MEMBER_OFFSET_INIT(sem_array_sem_nsems, "sem_array", "sem_nsems"); + MEMBER_OFFSET_INIT(msg_queue_q_perm, "msg_queue", "q_perm"); + MEMBER_OFFSET_INIT(msg_queue_q_id, "msg_queue", "q_id"); + MEMBER_OFFSET_INIT(msg_queue_q_cbytes, "msg_queue", "q_cbytes"); + MEMBER_OFFSET_INIT(msg_queue_q_qnum, "msg_queue", "q_qnum"); + MEMBER_OFFSET_INIT(super_block_s_fs_info, "super_block", + "s_fs_info"); + + /* + * struct size + */ + STRUCT_SIZE_INIT(ipc_ids, "ipc_ids"); + STRUCT_SIZE_INIT(shmid_kernel, "shmid_kernel"); + STRUCT_SIZE_INIT(sem_array, "sem_array"); + STRUCT_SIZE_INIT(msg_queue, "msg_queue"); + STRUCT_SIZE_INIT(hstate, "hstate"); + + if (symbol_exists("hugetlbfs_file_operations")) + ipcs_table.hugetlbfs_f_op_addr = + symbol_value("hugetlbfs_file_operations"); + if (symbol_exists("is_file_shm_hugepages")) { + ipcs_table.use_shm_f_op = TRUE; + ipcs_table.shm_f_op_addr = + symbol_value("shm_file_operations"); + if (symbol_exists("shm_file_operations_huge")) { + ipcs_table.shm_f_op_huge_addr = + symbol_value("shm_file_operations_huge"); + } else { + ipcs_table.shm_f_op_huge_addr = -1; + } + } else { + ipcs_table.use_shm_f_op = FALSE; + ipcs_table.shm_f_op_addr = -1; + ipcs_table.shm_f_op_huge_addr = -1; + } + + if (VALID_MEMBER(idr_layer_ary) && + get_array_length("idr_layer.ary", NULL, 0) > 64) + ipcs_table.idr_bits = 8; + else if (BITS32()) + ipcs_table.idr_bits = 5; + else if (BITS64()) + ipcs_table.idr_bits = 6; + else + error(FATAL, "machdep->bits is not 32 or 64"); + + if (VALID_MEMBER(idr_idr_rt)) { + if (STREQ(MEMBER_TYPE_NAME("idr", "idr_rt"), "xarray")) + ipcs_table.init_flags |= IDR_XARRAY; + else { + if (MEMBER_EXISTS("radix_tree_root", "rnode")) + ipcs_table.init_flags |= IDR_RADIX; + else if (MEMBER_EXISTS("radix_tree_root", "xa_head")) + ipcs_table.init_flags |= IDR_XARRAY; + } + } else + ipcs_table.init_flags |= IDR_ORIG; + + ipcs_table.seq_multiplier = 32768; +} + +/* + * Arguments are passed to the command functions in the global args[argcnt] + * array. See getopt(3) for info on dash arguments. Check out defs.h and + * other crash commands for usage of the myriad of utility routines available + * to accomplish what your task. + */ +void +cmd_ipcs(void) +{ + int specified; + char *specified_value[MAXARGS]; + int value_index; + int c; + int shm, sem, msg, verbose; + int i; + ulong value, task; + int found; + struct task_context *tc; + char buf[BUFSIZE]; + + value_index = 0; + specified = SPECIFIED_NOTHING; + shm = 0; + sem = 0; + msg = 0; + verbose = 0; + tc = NULL; + + while ((c = getopt(argcnt, args, "smMqn:")) != EOF) { + switch(c) { + case 's': + sem = 1; + break; + case 'm': + shm = 1; + break; + case 'M': + shm = 1; + verbose = 1; + break; + case 'q': + msg = 1; + break; + case 'n': + switch (str_to_context(optarg, &value, &tc)) { + case STR_PID: + case STR_TASK: + break; + case STR_INVALID: + error(FATAL, "invalid task or pid value: %s\n", + optarg); + break; + } + break; + default: + cmd_usage(pc->curcmd, SYNOPSIS);; + return; + } + } + + while (args[optind]) { + if (value_index >= MAXARGS) + error(FATAL, "too many id/member specified\n"); + specified |= SPECIFIED_ID | SPECIFIED_ADDR; + specified_value[value_index] = args[optind]; + stol(args[optind], FAULT_ON_ERROR, NULL); + optind++; + value_index++; + } + + if (THIS_KERNEL_VERSION < LINUX(2,6,0)) + command_not_supported(); + + ipcs_init(); + + if (!shm && !sem && !msg) + shm = sem = msg = 1; + + task = tc ? tc->task : pid_to_task(0); + + if (!value_index) { + if (shm) + dump_shared_memory(specified, 0, verbose, task); + if (sem) + dump_semaphore_arrays(specified, 0, 0, task); + if (msg) + dump_message_queues(specified, 0, 0, task); + } else { + open_tmpfile(); + i = 0; + while (i < value_index) { + found = 0; + value = stol(specified_value[i], FAULT_ON_ERROR, NULL); + if (shm) + found += dump_shared_memory(specified, + value, verbose, task); + if (sem) + found += dump_semaphore_arrays(specified, + value, 0, task); + if (msg) + found += dump_message_queues(specified, + value, 0, task); + + if (!found) + fprintf(pc->saved_fp, "invalid id or address: %s\n\n", + specified_value[i]); + + i++; + } + fflush(fp); + rewind(fp); + + while (fgets(buf, BUFSIZE, fp)) + fprintf(pc->saved_fp, "%s", buf); + + close_tmpfile(); + } +} + +static int +dump_shared_memory(int specified, ulong specified_value, int verbose, ulong task) +{ + ulong nsproxy_p, ipc_ns_p; + ulong ipc_ids_p; + int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); + int (*dump_shm)(ulong, int, ulong, int, int); + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + char buf6[BUFSIZE]; + char buf7[BUFSIZE]; + + if (!verbose && specified == SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, + LJUST, "SHMID_KERNEL"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "SHMID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 10, LJUST, "BYTES"), + mkstring(buf6, 6, LJUST, "NATTCH"), + mkstring(buf7, 6, LJUST, "STATUS")); + } + + dump_shm = dump_shm_info; + + if (VALID_MEMBER(kern_ipc_perm_id)) { + ipc_search = ipc_search_idr; + } else { + ipc_search = ipc_search_array; + } + + if (symbol_exists("shm_ids")) { + ipc_ids_p = symbol_value("shm_ids"); + } else { + readmem(task + OFFSET(task_struct_nsproxy), KVADDR, + &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", + FAULT_ON_ERROR); + if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, + &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", + RETURN_ON_ERROR|QUIET)) + error(FATAL, + "cannot determine ipc_namespace location!\n"); + + if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) + readmem(ipc_ns_p + OFFSET(ipc_namespace_ids) + + sizeof(ulong) * 2, KVADDR, &ipc_ids_p, + sizeof(ulong), "ipc_namespace.ids[2]", + FAULT_ON_ERROR); + else + ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids) + + 2 * SIZE(ipc_ids); + } + + if (ipc_search(ipc_ids_p, specified, specified_value, dump_shm, verbose)) { + return 1; + } else { + if (verbose && specified == SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, + LJUST, "SHMID_KERNEL"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "SHMID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 10, LJUST, "BYTES"), + mkstring(buf6, 6, LJUST, "NATTCH"), + mkstring(buf7, 6, LJUST, "STATUS")); + fprintf(fp, "(none allocated)\n\n"); + } + return 0; + } +} + +static int +dump_semaphore_arrays(int specified, ulong specified_value, int verbose, ulong task) +{ + ulong nsproxy_p, ipc_ns_p; + ulong ipc_ids_p; + int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); + int (*dump_sem)(ulong, int, ulong, int, int); + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + + if (specified == SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, + LJUST, "SEM_ARRAY"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "SEMID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 10, LJUST, "NSEMS")); + } + + dump_sem = dump_sem_info; + + if (VALID_MEMBER(kern_ipc_perm_id)) { + ipc_search = ipc_search_idr; + } else { + ipc_search = ipc_search_array; + } + + if (symbol_exists("sem_ids")) { + ipc_ids_p = symbol_value("sem_ids"); + } else { + readmem(task + OFFSET(task_struct_nsproxy), KVADDR, + &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", + FAULT_ON_ERROR); + + if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, + &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", + FAULT_ON_ERROR|QUIET)) + error(FATAL, + "cannot determine ipc_namespace location!\n"); + + if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) + readmem(ipc_ns_p + OFFSET(ipc_namespace_ids), + KVADDR, &ipc_ids_p, sizeof(ulong), + "ipc_namespace.ids[2]", FAULT_ON_ERROR); + else + ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids); + } + + return ipc_search(ipc_ids_p, specified, specified_value, dump_sem, verbose); +} + +static int +dump_message_queues(int specified, ulong specified_value, int verbose, ulong task) +{ + ulong nsproxy_p, ipc_ns_p; + ulong ipc_ids_p; + int (*ipc_search)(ulong, int, ulong, int (*)(ulong, int, ulong, int, int), int); + int (*dump_msg)(ulong, int, ulong, int, int); + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + char buf6[BUFSIZE]; + + if (specified == SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, + LJUST, "MSG_QUEUE"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "MSQID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 12, LJUST, "USED-BYTES"), + mkstring(buf6, 12, LJUST, "MESSAGES")); + } + + dump_msg = dump_msg_info; + + if (VALID_MEMBER(kern_ipc_perm_id)) { + ipc_search = ipc_search_idr; + } else { + ipc_search = ipc_search_array; + } + + if (symbol_exists("msg_ids")) { + ipc_ids_p = symbol_value("msg_ids"); + } else { + readmem(task + OFFSET(task_struct_nsproxy), KVADDR, + &nsproxy_p, sizeof(ulong), "task_struct.nsproxy", + FAULT_ON_ERROR); + if (!readmem(nsproxy_p + OFFSET(nsproxy_ipc_ns), KVADDR, + &ipc_ns_p, sizeof(ulong), "nsproxy.ipc_ns", + FAULT_ON_ERROR|QUIET)) + error(FATAL, + "cannot determine ipc_namespace location!\n"); + + if (MEMBER_SIZE("ipc_namespace","ids") == sizeof(ulong) * 3) + readmem(ipc_ns_p + OFFSET(ipc_namespace_ids) + + sizeof(ulong), KVADDR, &ipc_ids_p, + sizeof(ulong), "ipc_namespace.ids[2]", + FAULT_ON_ERROR); + else + ipc_ids_p = ipc_ns_p + OFFSET(ipc_namespace_ids) + + SIZE(ipc_ids); + } + + return ipc_search(ipc_ids_p, specified, specified_value, dump_msg, verbose); +} + +/* + * if shared memory information is stored in an array, use this function. + */ +static int +ipc_search_array(ulong ipc_ids_p, int specified, ulong specified_value, int (*fn)(ulong, int, ulong, int, int), int verbose) +{ + ulong entries_p; + int max_id, i; + ulong *array; + int found = 0; + int allocated = 0; + + readmem(ipc_ids_p + OFFSET(ipc_ids_entries), KVADDR, &entries_p, + sizeof(ulong), "ipc_ids.entries", FAULT_ON_ERROR); + readmem(ipc_ids_p + OFFSET(ipc_ids_max_id), KVADDR, &max_id, + sizeof(int), "ipc_ids.max_id", FAULT_ON_ERROR); + + if (max_id < 0) { + if (specified == SPECIFIED_NOTHING && !verbose) + fprintf(fp, "(none allocated)\n\n"); + return 0; + } + + array = (ulong *)GETBUF(sizeof(ulong *) * (max_id + 1)); + if (VALID_MEMBER(ipc_id_ary_p)) + readmem(entries_p + OFFSET(ipc_id_ary_p), KVADDR, array, + sizeof(ulong *) * (max_id + 1), "ipc_id_ary.p", + FAULT_ON_ERROR); + else + readmem(entries_p, KVADDR, array, sizeof(ulong *)*(max_id+1), + "ipc_id array", FAULT_ON_ERROR); + + for (i=0; i<=max_id; i++) { + if (array[i] == 0) + continue; + if (fn(array[i], specified, specified_value, i, verbose)) { + allocated++; + found = 1; + if (specified != SPECIFIED_NOTHING) + break; + } + } + + if (specified == SPECIFIED_NOTHING && !verbose) { + if (!allocated) + fprintf(fp, "(none allocated)\n"); + fprintf(fp, "\n"); + } + + FREEBUF(array); + + if (found) + return 1; + else + return 0; +} + +/* + * if shared memory information is stored by using idr, use this function to + * get data. + */ +static int +ipc_search_idr(ulong ipc_ids_p, int specified, ulong specified_value, int (*fn)(ulong, int, ulong, int, int), int verbose) +{ + int i, in_use; + ulong ipcs_idr_p; + ulong ipc; + int next_id, total; + int found = 0; + + readmem(ipc_ids_p + OFFSET(ipc_ids_in_use), KVADDR, &in_use, + sizeof(int), "ipc_ids.in_use", FAULT_ON_ERROR); + + ipcs_idr_p = ipc_ids_p + OFFSET(ipc_ids_ipcs_idr); + + if (!in_use) { + if (specified == SPECIFIED_NOTHING && !verbose) + fprintf(fp, "(none allocated)\n\n"); + return 0; + } + + if (VALID_MEMBER(idr_idr_rt)) { + switch (ipcs_table.init_flags & (IDR_RADIX|IDR_XARRAY)) + { + case IDR_RADIX: + gather_radix_tree_entries(ipcs_idr_p); + break; + case IDR_XARRAY: + gather_xarray_entries(ipcs_idr_p); + break; + } + + for (i = 0; i < ipcs_table.cnt; i++) { + ipc = (ulong)ipcs_table.lp[i].value; + if (fn(ipc, specified, specified_value, UNUSED, verbose)) { + found = 1; + if (specified != SPECIFIED_NOTHING) + break; + } + } + + if (ipcs_table.lp) + FREEBUF(ipcs_table.lp); + } else { + for (total = 0, next_id = 0; total < in_use; next_id++) { + ipc = idr_find(ipcs_idr_p, next_id); + if (ipc == 0) + continue; + + total++; + if (fn(ipc, specified, specified_value, next_id, verbose)) { + found = 1; + if (specified != SPECIFIED_NOTHING) + break; + } + } + } + + if (!verbose && specified == SPECIFIED_NOTHING) + fprintf(fp, "\n"); + + if (found || specified == SPECIFIED_NOTHING) + return 1; + else + return 0; +} + +/* + * search every idr_layer + */ +ulong +idr_find(ulong idp, int id) +{ + ulong idr_layer_p; + int layer; + int idr_layers; + int n; + int index; + + readmem(idp + OFFSET(idr_top), KVADDR, &idr_layer_p, + sizeof(ulong), "idr.top", FAULT_ON_ERROR); + + if (!idr_layer_p) + return 0; + + if (VALID_MEMBER(idr_layer_layer)) { + readmem(idr_layer_p + OFFSET(idr_layer_layer), KVADDR, + &layer, sizeof(int), "idr_layer.layer", + FAULT_ON_ERROR); + n = (layer + 1) * ipcs_table.idr_bits; + } else { + readmem(idp + OFFSET(idr_layers), KVADDR, &idr_layers, + sizeof(int), "idr.layers", FAULT_ON_ERROR); + n = idr_layers * ipcs_table.idr_bits; + } + id &= MAX_ID_MASK; + + if (id >= (1 << n)) + return 0; + + while (n > 0 && idr_layer_p) { + n -= ipcs_table.idr_bits; + index = (id >> n) & ((1 << ipcs_table.idr_bits) - 1); + readmem(idr_layer_p + OFFSET(idr_layer_ary) + + sizeof(ulong) * index, KVADDR, &idr_layer_p, + sizeof(ulong), "idr_layer.ary", FAULT_ON_ERROR); + } + + return idr_layer_p; +} + +/* + * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, + * then return 1 + */ +static int +dump_shm_info(ulong shp, int specified, ulong specified_value, int id, int verbose) +{ + struct shm_info shm_info; + char buf[BUFSIZE]; + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + char buf6[BUFSIZE]; + char buf7[BUFSIZE]; + + get_shm_info(&shm_info, shp, id); + + if (shm_info.deleted) + return 0; + + if (((specified & SPECIFIED_ID) && shm_info.shmid == specified_value) || + ((specified & SPECIFIED_ADDR) && shm_info.shmid_kernel == + specified_value) || specified == SPECIFIED_NOTHING) { + if (verbose || specified != SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=12?12:VADDR_PRLEN, + LJUST, "SHMID_KERNEL"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "SHMID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 10, LJUST, "BYTES"), + mkstring(buf6, 6, LJUST, "NATTCH"), + mkstring(buf7, 6, LJUST, "STATUS")); + } + + fprintf(fp, "%s %08x %-10d %-5d %-5o %-10ld %-6ld %-s %-s\n", + mkstring(buf, VADDR_PRLEN <= 12 ? 12 : VADDR_PRLEN, + LJUST|LONG_HEX, (char *)shm_info.shmid_kernel), + shm_info.key, + shm_info.shmid, + shm_info.uid, + shm_info.perms & 0777, + shm_info.bytes, + shm_info.nattch, + shm_info.perms & SHM_DEST ? "dest" : "", + shm_info.perms & SHM_LOCKED ? "locked" : ""); + + if (verbose) { + fprintf(fp, "PAGES ALLOCATED/RESIDENT/SWAPPED: %ld/%ld/%ld\n", + (shm_info.bytes+PAGESIZE()-1) >> PAGESHIFT(), + shm_info.rss, shm_info.swap); + fprintf(fp, "INODE: %lx\n", shm_info.shm_inode); + } + + if (verbose || specified != SPECIFIED_NOTHING) + fprintf(fp, "\n"); + + return 1; + } else + return 0; +} + +/* + * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, + * then return 1 + */ +static int +dump_sem_info(ulong shp, int specified, ulong specified_value, int id, int verbose) +{ + struct sem_info sem_info; + char buf[BUFSIZE]; + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + + get_sem_info(&sem_info, shp, id); + + if (sem_info.deleted) + return 0; + + if (((specified & SPECIFIED_ID) && sem_info.semid == specified_value) || + ((specified & SPECIFIED_ADDR) && sem_info.sem_array == + specified_value) || specified == SPECIFIED_NOTHING) { + if (specified != SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, + LJUST, "SEM_ARRAY"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "SEMID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 10, LJUST, "NSEMS")); + } + + fprintf(fp, "%s %08x %-10d %-5d %-5o %-10ld\n", + mkstring(buf, VADDR_PRLEN <= 10 ? 10 : VADDR_PRLEN, + LJUST|LONG_HEX, (char *)sem_info.sem_array), + sem_info.key, + sem_info.semid, + sem_info.uid, + sem_info.perms & 0777, + sem_info.nsems); + + if (specified != SPECIFIED_NOTHING) + fprintf(fp, "\n"); + + return 1; + } else + return 0; +} + +/* + * only specified is not SPECIFIED_NOTHIND, and the specified_value is found, + * then return 1 + */ +static int +dump_msg_info(ulong shp, int specified, ulong specified_value, int id, int verbose) +{ + struct msg_info msg_info; + char buf[BUFSIZE]; + char buf0[BUFSIZE]; + char buf1[BUFSIZE]; + char buf2[BUFSIZE]; + char buf3[BUFSIZE]; + char buf4[BUFSIZE]; + char buf5[BUFSIZE]; + char buf6[BUFSIZE]; + + get_msg_info(&msg_info, shp, id); + + if (msg_info.deleted) + return 0; + + if (((specified & SPECIFIED_ID) && msg_info.msgid == specified_value) || + ((specified & SPECIFIED_ADDR) && msg_info.msg_queue == + specified_value) || specified == SPECIFIED_NOTHING) { + if (specified != SPECIFIED_NOTHING) { + fprintf(fp, "%s %s %s %s %s %s %s\n", + mkstring(buf0, VADDR_PRLEN<=10?10:VADDR_PRLEN, + LJUST, "MSG_QUEUE"), + mkstring(buf1, 8, LJUST, "KEY"), + mkstring(buf2, 10, LJUST, "MSQID"), + mkstring(buf3, 5, LJUST, "UID"), + mkstring(buf4, 5, LJUST, "PERMS"), + mkstring(buf5, 12, LJUST, "USED-BYTES"), + mkstring(buf6, 12, LJUST, "MESSAGES")); + } + + fprintf(fp, "%s %08x %-10d %-5d %-5o %-12ld %-12ld\n", + mkstring(buf, VADDR_PRLEN <= 10 ? 10 : VADDR_PRLEN, + LJUST|LONG_HEX, (char *)msg_info.msg_queue), + msg_info.key, + msg_info.msgid, + msg_info.uid, + msg_info.perms & 0777, + msg_info.bytes, + msg_info.messages); + + if (specified != SPECIFIED_NOTHING) + fprintf(fp, "\n"); + + return 1; + } else + return 0; +} + +static void +get_shm_info(struct shm_info *shm_info, ulong shp, int id) +{ + char buf[BUFSIZE]; + ulong filep, dentryp, inodep; + + shm_info->shmid_kernel = shp - OFFSET(shmid_kernel_shm_perm); + + /* + * cache shmid_kernel + */ + readmem(shm_info->shmid_kernel, KVADDR, buf, SIZE(shmid_kernel), + "shmid_kernel", FAULT_ON_ERROR); + + shm_info->key = INT(buf + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_key)); + if (VALID_MEMBER(shmid_kernel_id)) + shm_info->shmid = INT(buf + OFFSET(shmid_kernel_id)); + else + shm_info->shmid = INT(buf + + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_id)); + + shm_info->uid = UINT(buf + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_uid)); + + if (BITS32()) + shm_info->perms = USHORT(buf + + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_mode)); + else + shm_info->perms = UINT(buf + + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_mode)); + + shm_info->bytes = ULONG(buf + OFFSET(shmid_kernel_shm_segsz)); + + shm_info->nattch = ULONG(buf + OFFSET(shmid_kernel_shm_nattch)); + + filep = ULONG(buf + OFFSET(shmid_kernel_shm_file)); + readmem(filep + OFFSET(file_f_dentry), KVADDR, &dentryp, sizeof(ulong), + "file.f_dentry", FAULT_ON_ERROR); + readmem(dentryp + OFFSET(dentry_d_inode), KVADDR, &inodep, + sizeof(ulong), "dentry.d_inode", FAULT_ON_ERROR); + /* + * shm_inode here is the vfs_inode of struct shmem_inode_info + */ + shm_info->shm_inode = inodep; + + shm_info->rss = 0; + shm_info->swap = 0; + + add_rss_swap(inodep, is_file_hugepages(filep), &shm_info->rss, + &shm_info->swap); + + shm_info->deleted = UCHAR(buf + OFFSET(shmid_kernel_shm_perm) + + OFFSET(kern_ipc_perm_deleted)); +} + +static void +get_sem_info(struct sem_info *sem_info, ulong shp, int id) +{ + char buf[BUFSIZE]; + + sem_info->sem_array = shp - OFFSET(sem_array_sem_perm); + + /* + * cache sem_array + */ + readmem(sem_info->sem_array, KVADDR, buf, SIZE(sem_array), + "sem_array", FAULT_ON_ERROR); + + sem_info->key = INT(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_key)); + + if (VALID_MEMBER(sem_array_sem_id)) + sem_info->semid = INT(buf + OFFSET(sem_array_sem_id)); + else if (VALID_MEMBER(kern_ipc_perm_id)) + sem_info->semid = INT(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_id)); + else { + ulong seq; + seq = ULONG(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_seq)); + sem_info->semid = ipcs_table.seq_multiplier * seq + id; + } + + sem_info->uid = UINT(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_uid)); + + if (BITS32()) + sem_info->perms = USHORT(buf + + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_mode)); + else + sem_info->perms = UINT(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_mode)); + + sem_info->nsems = ULONG(buf + OFFSET(sem_array_sem_nsems)); + + sem_info->deleted = UCHAR(buf + OFFSET(sem_array_sem_perm) + + OFFSET(kern_ipc_perm_deleted)); +} + +static void +get_msg_info(struct msg_info *msg_info, ulong shp, int id) +{ + char buf[BUFSIZE]; + + msg_info->msg_queue = shp - OFFSET(msg_queue_q_perm); + + /* + * cache msg_queue + */ + readmem(msg_info->msg_queue, KVADDR, buf, SIZE(msg_queue), + "msg_queue", FAULT_ON_ERROR); + + msg_info->key = INT(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_key)); + + if (VALID_MEMBER(msg_queue_q_id)) + msg_info->msgid = INT(buf + OFFSET(msg_queue_q_id)); + else if (VALID_MEMBER(kern_ipc_perm_id)) + msg_info->msgid = INT(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_id)); + else { + ulong seq; + seq = ULONG(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_seq)); + msg_info->msgid = ipcs_table.seq_multiplier * seq + id; + } + + msg_info->uid = UINT(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_uid)); + + if (BITS32()) + msg_info->perms = USHORT(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_mode)); + else + msg_info->perms = UINT(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_mode)); + + msg_info->bytes = ULONG(buf + OFFSET(msg_queue_q_cbytes)); + + msg_info->messages = ULONG(buf + OFFSET(msg_queue_q_qnum)); + + msg_info->deleted = UCHAR(buf + OFFSET(msg_queue_q_perm) + + OFFSET(kern_ipc_perm_deleted)); +} + +/* + * get rss & swap related to every shared memory, and get the total number of rss + * & swap + */ +static void +add_rss_swap(ulong inode_p, int hugepage, ulong *rss, ulong *swap) +{ + unsigned long mapping_p, nr_pages; + + readmem(inode_p + OFFSET(inode_i_mapping), KVADDR, &mapping_p, + sizeof(ulong), "inode.i_mapping", FAULT_ON_ERROR); + readmem(mapping_p + OFFSET(address_space_nrpages), KVADDR, &nr_pages, + sizeof(ulong), "address_space.nrpages", + FAULT_ON_ERROR); + + if (hugepage) { + unsigned long pages_per_hugepage; + if (VALID_SIZE(hstate)) { + unsigned long i_sb_p, hsb_p, hstate_p; + unsigned int order; + + readmem(inode_p + OFFSET(inode_i_sb), KVADDR, &i_sb_p, + sizeof(ulong), "inode.i_sb", + FAULT_ON_ERROR); + readmem(i_sb_p + OFFSET(super_block_s_fs_info), + KVADDR, &hsb_p, sizeof(ulong), + "super_block.s_fs_info", FAULT_ON_ERROR); + readmem(hsb_p + OFFSET(hugetlbfs_sb_info_hstate), + KVADDR, &hstate_p, sizeof(ulong), + "hugetlbfs_sb_info.hstate", FAULT_ON_ERROR); + readmem(hstate_p + OFFSET(hstate_order), KVADDR, + &order, sizeof(uint), "hstate.order", + FAULT_ON_ERROR); + pages_per_hugepage = 1 << order; + } else { + unsigned long hpage_shift; + /* + * HPAGE_SHIFT is 21 after commit 83a5101b + * (kernel > 2.6.24) + */ + if (THIS_KERNEL_VERSION > LINUX(2, 6, 24)) { + hpage_shift = 21; + } else { + /* + * HPAGE_SHIFT: + * x86(PAE): 21 + * x86(no PAE): 22 + * x86_64: 21 + */ + if ((machine_type("X86") && + !(machdep->flags & PAE))) + hpage_shift = 22; + else + hpage_shift = 21; + } + pages_per_hugepage = (1 << hpage_shift) / PAGESIZE(); + } + *rss += pages_per_hugepage * nr_pages; + } else { + unsigned long swapped; + + *rss += nr_pages; + readmem(inode_p - OFFSET(shmem_inode_info_vfs_inode) + + OFFSET(shmem_inode_info_swapped), KVADDR, + &swapped, sizeof(ulong), "shmem_inode_info.swapped", + FAULT_ON_ERROR); + *swap += swapped; + } +} + +static int +is_file_hugepages(ulong file_p) +{ + unsigned long f_op, sfd_p; + +again: + readmem(file_p + OFFSET(file_f_op), KVADDR, &f_op, sizeof(ulong), + "file.f_op", FAULT_ON_ERROR); + if (f_op == ipcs_table.hugetlbfs_f_op_addr) + return 1; + + if (ipcs_table.use_shm_f_op) { + if (ipcs_table.shm_f_op_huge_addr != -1) { + if (f_op == ipcs_table.shm_f_op_huge_addr) + return 1; + } else { + if (f_op == ipcs_table.shm_f_op_addr) { + readmem(file_p + + OFFSET(file_private_data), + KVADDR, &sfd_p, sizeof(ulong), + "file.private_data", FAULT_ON_ERROR); + readmem(sfd_p + + OFFSET(shm_file_data_file), + KVADDR, &file_p, sizeof(ulong), + "shm_file_data.file", FAULT_ON_ERROR); + goto again; + } + } + } + + return 0; +} + +static void +gather_radix_tree_entries(ulong ipcs_idr_p) +{ + long len; + + ipcs_table.cnt = do_radix_tree(ipcs_idr_p, RADIX_TREE_COUNT, NULL); + + if (ipcs_table.cnt) { + len = sizeof(struct list_pair) * (ipcs_table.cnt+1); + ipcs_table.lp = (struct list_pair *)GETBUF(len); + ipcs_table.lp[0].index = ipcs_table.cnt; + ipcs_table.cnt = do_radix_tree(ipcs_idr_p, RADIX_TREE_GATHER, ipcs_table.lp); + } else + ipcs_table.lp = NULL; +} + +static void +gather_xarray_entries(ulong ipcs_idr_p) +{ + long len; + + ipcs_table.cnt = do_xarray(ipcs_idr_p, XARRAY_COUNT, NULL); + + if (ipcs_table.cnt) { + len = sizeof(struct list_pair) * (ipcs_table.cnt+1); + ipcs_table.lp = (struct list_pair *)GETBUF(len); + ipcs_table.lp[0].index = ipcs_table.cnt; + ipcs_table.cnt = do_xarray(ipcs_idr_p, XARRAY_GATHER, ipcs_table.lp); + } else + ipcs_table.lp = NULL; +} -- 2.43.0

The folio_order() was introduced to kernel at v5.16, but the first large folio support patch is in v5.17: 6795801366da "xfs: Support large folios" The folio_order() keeps the same logic as kernel code in different versions: 1.) In kernel v5.17, folio_order() uses page[1].compound_order to get the folio order. 2.) In kernel v6.1, the following patch introduces _folio_order: c3a15bff46cb5149 "mm: reimplement folio_order() and folio_nr_pages()" folio_order() uses _folio_order to get the folio order. 3.) In kernel v6.6, the following patch replaces the _folio_order with _flags_1: ebc1baf5c9b46c22 "mm: free up a word in the first tail page" folio_order() uses _flags_1 to get the folio order. This patch will be used in later patches. Signed-off-by: Huang Shijie <huangsj(a)hygon.cn&gt; --- defs.h | 8 +++++++ memory.c | 70 +++++++++++++++++++++++++++++++++++++++++++++++++++++++ symbols.c | 6 +++++ 3 files changed, 84 insertions(+) diff --git a/defs.h b/defs.h index 8f6784e..e832ea6 100644 --- a/defs.h +++ b/defs.h @@ -2290,6 +2290,9 @@ struct offset_table { /* stash of commonly-used offsets */ long bpf_ringbuf_nr_pages; long hrtimer_clock_base_index; long klp_patch_list; + long page_compound_order; + long folio__folio_order; + long folio__flags_1; }; struct size_table { /* stash of commonly-used sizes */ @@ -2469,6 +2472,9 @@ struct size_table { /* stash of commonly-used sizes */ long cpumask_t; long task_struct_exit_state; long bpf_ringbuf_map; + long page_compound_order; + long folio__folio_order; + long folio__flags_1; }; struct array_table { @@ -6008,6 +6014,8 @@ ulong do_xarray(ulong, int, struct list_pair *, int); #define XARRAY_TAG_MASK (3UL) #define XARRAY_TAG_INTERNAL (2UL) +int folio_order(ulong folio); + int file_dump(ulong, ulong, ulong, int, int); #define DUMP_FULL_NAME 0x1 #define DUMP_INODE_ONLY 0x2 diff --git a/memory.c b/memory.c index 17423a5..3b272ad 100644 --- a/memory.c +++ b/memory.c @@ -547,6 +547,13 @@ vm_init(void) MEMBER_OFFSET_INIT(page_freelist, "page", "freelist"); MEMBER_OFFSET_INIT(page_page_type, "page", "page_type"); + MEMBER_OFFSET_INIT(page_compound_order, "page", "compound_order"); + MEMBER_SIZE_INIT(page_compound_order, "page", "compound_order"); + MEMBER_OFFSET_INIT(folio__folio_order, "folio", "_folio_order"); + MEMBER_SIZE_INIT(folio__folio_order, "folio", "_folio_order"); + MEMBER_OFFSET_INIT(folio__flags_1, "folio", "_flags_1"); + MEMBER_SIZE_INIT(folio__flags_1, "folio", "_flags_1"); + MEMBER_OFFSET_INIT(mm_struct_pgd, "mm_struct", "pgd"); MEMBER_OFFSET_INIT(swap_info_struct_swap_file, @@ -20426,6 +20433,69 @@ static unsigned int oo_objects(ulong oo) return (oo & ((1 << 16) - 1)); } +/* + * The folio_order() was introduced to kernel at v5.16, but the first + * large folio support patch is in v5.17: + * 6795801366da "xfs: Support large folios" + * + * 1.) In kernel v5.17, folio_order() uses page[1].compound_order to + * get the folio order. + * + * 2.) In kernel v6.1, the following patch introduces _folio_order: + * c3a15bff46cb5149 "mm: reimplement folio_order() and folio_nr_pages()" + * + * folio_order() uses _folio_order to get the folio order. + * + * 3.) In kernel v6.6, the following patch replaces the _folio_order with _flags_1: + * ebc1baf5c9b46c22 "mm: free up a word in the first tail page" + * + * folio_order() uses _flags_1 to get the folio order. + */ +int +folio_order(ulong folio) +{ + ulong v = 0; + int PG_head = 16; + + if (THIS_KERNEL_VERSION < LINUX(5,17,0)) + return 0; + + if (THIS_KERNEL_VERSION < LINUX(6,1,0)) { + readmem(folio + OFFSET(page_flags), KVADDR, &v, sizeof(ulong), + "folio.page.flags", FAULT_ON_ERROR); + if (!(v & (1 << PG_head))) + return 0; + + readmem(folio + SIZE(page) + OFFSET(page_compound_order), KVADDR, &v, + SIZE(page_compound_order), "page[1].compound_order", FAULT_ON_ERROR); + + return v; + } else if (THIS_KERNEL_VERSION < LINUX(6,6,0)) { + readmem(folio + OFFSET(page_flags), KVADDR, &v, sizeof(ulong), + "folio.page.flags", FAULT_ON_ERROR); + if (!(v & (1 << PG_head))) + return 0; + + readmem(folio + OFFSET(folio__folio_order), KVADDR, &v, + SIZE(folio__folio_order), "folio->_folio_order", FAULT_ON_ERROR); + + return v; + } else { + /* The PG_head changes to bit 6 at kernel v6.6 */ + PG_head = 6; + + readmem(folio + OFFSET(page_flags), KVADDR, &v, sizeof(ulong), + "folio.page.flags", FAULT_ON_ERROR); + if (!(v & (1 << PG_head))) + return 0; + + readmem(folio + OFFSET(folio__flags_1), KVADDR, &v, + SIZE(folio__flags_1), "folio->_flags_1", FAULT_ON_ERROR); + + return v & 0xff; + } +} + #ifdef NOT_USED ulong slab_to_kmem_cache_node(struct meminfo *si, ulong slab_page) diff --git a/symbols.c b/symbols.c index e6865ca..08c07e9 100644 --- a/symbols.c +++ b/symbols.c @@ -10451,6 +10451,9 @@ dump_offset_table(char *spec, ulong makestruct) fprintf(fp, " page_private: %ld\n", OFFSET(page_private)); fprintf(fp, " page_page_type: %ld\n", OFFSET(page_page_type)); + fprintf(fp, " page_compound_order: %ld\n", OFFSET(page_compound_order)); + fprintf(fp, " folio__folio_order: %ld\n", OFFSET(folio__folio_order)); + fprintf(fp, " folio__flags_1: %ld\n", OFFSET(folio__flags_1)); fprintf(fp, " trace_print_flags_mask: %ld\n", OFFSET(trace_print_flags_mask)); @@ -11961,6 +11964,9 @@ dump_offset_table(char *spec, ulong makestruct) fprintf(fp, "\n size_table:\n"); fprintf(fp, " page: %ld\n", SIZE(page)); fprintf(fp, " page_flags: %ld\n", SIZE(page_flags)); + fprintf(fp, " page_compound_order: %ld\n", SIZE(page_compound_order)); + fprintf(fp, " folio__folio_order: %ld\n", SIZE(folio__folio_order)); + fprintf(fp, " folio__flags_1: %ld\n", SIZE(folio__flags_1)); fprintf(fp, " trace_print_flags: %ld\n", SIZE(trace_print_flags)); fprintf(fp, " free_area_struct: %ld\n", SIZE(free_area_struct)); -- 2.43.0

In the NUMA machine, it is useful to know the memory distribution of an inode page cache: How many pages in the node 0? How many pages in the node 1? Add "files -n" command to get the memory distribution information: 1.) Add new argument for dump_inode_page_cache_info() 2.) make page_to_nid() a global function. 3.) Add summary_inode_page() to check each page's node information. 4.) Use print_inode_summary_info() to print the memory distribution information of an inode. Signed-off-by: Huang Shijie <huangsj(a)hygon.cn&gt; --- defs.h | 1 + filesys.c | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++----- help.c | 24 +++++++++++++++++++++- memory.c | 4 ++-- 4 files changed, 81 insertions(+), 8 deletions(-) diff --git a/defs.h b/defs.h index e832ea6..6abc359 100644 --- a/defs.h +++ b/defs.h @@ -5953,6 +5953,7 @@ int dump_inode_page(ulong); ulong valid_section_nr(ulong); void display_memory_from_file_offset(ulonglong, long, void *); void swap_info_init(void); +int page_to_nid(ulong); /* * filesys.c diff --git a/filesys.c b/filesys.c index f0ac1bb..430482d 100644 --- a/filesys.c +++ b/filesys.c @@ -49,7 +49,7 @@ static int match_file_string(char *, char *, char *); static ulong get_root_vfsmount(char *); static void check_live_arch_mismatch(void); static long get_inode_nrpages(ulong); -static void dump_inode_page_cache_info(ulong); +static void dump_inode_page_cache_info(ulong, void *callback); #define DENTRY_CACHE (20) #define INODE_CACHE (20) @@ -2240,8 +2240,38 @@ get_inode_nrpages(ulong i_mapping) return nrpages; } +/* Used to collect the numa information for an inode */ +static ulong *numa_node; + static void -dump_inode_page_cache_info(ulong inode) +print_inode_summary_info(void) +{ + int i; + + fprintf(fp, " NODE PAGES\n"); + for (i = 0; i < vt->numnodes; i++) + fprintf(fp, " %2d %8ld\n", i, numa_node[i]); +} + +static int +summary_inode_page(ulong page) +{ + int node; + + if (!is_page_ptr(page, NULL)) + error(FATAL, "Invalid inode page(0x%lx)\n", page); + + node = page_to_nid(page); + if (node < 0 || node >= vt->numnodes) + error(FATAL, "Invalid node(%d) for page(0x%lx)\n", node, page); + + numa_node[node] += 1 << folio_order(page); + + return 1; +} + +static void +dump_inode_page_cache_info(ulong inode, void *callback) { char *inode_buf; ulong i_mapping, nrpages, root_rnode, xarray, count; @@ -2284,7 +2314,7 @@ dump_inode_page_cache_info(ulong inode) root_rnode = i_mapping + OFFSET(address_space_page_tree); lp.index = 0; - lp.value = (void *)&dump_inode_page; + lp.value = callback; if (root_rnode) count = do_radix_tree(root_rnode, RADIX_TREE_DUMP_CB, &lp); @@ -2324,7 +2354,7 @@ cmd_files(void) ref = NULL; refarg = NULL; - while ((c = getopt(argcnt, args, "d:R:p:c")) != EOF) { + while ((c = getopt(argcnt, args, "d:n:R:p:c")) != EOF) { switch(c) { case 'R': @@ -2343,11 +2373,31 @@ cmd_files(void) display_dentry_info(value); return; + case 'n': + if (VALID_MEMBER(address_space_page_tree) && + VALID_MEMBER(inode_i_mapping)) { + value = htol(optarg, FAULT_ON_ERROR, NULL); + + /* Allocate the array for this inode */ + numa_node = malloc(sizeof(ulong) * vt->numnodes); + BZERO(numa_node, sizeof(ulong) * vt->numnodes); + + dump_inode_page_cache_info(value, (void *)&summary_inode_page); + + /* Print out the NUMA node information for this inode */ + print_inode_summary_info(); + + free(numa_node); + numa_node = NULL; + } else + option_not_supported('n'); + return; + case 'p': if (VALID_MEMBER(address_space_page_tree) && VALID_MEMBER(inode_i_mapping)) { value = htol(optarg, FAULT_ON_ERROR, NULL); - dump_inode_page_cache_info(value); + dump_inode_page_cache_info(value, (void *)&dump_inode_page); } else option_not_supported('p'); return; diff --git a/help.c b/help.c index 91d1550..6f97289 100644 --- a/help.c +++ b/help.c @@ -7900,7 +7900,7 @@ NULL char *help_files[] = { "files", "open files", -"[-d dentry] | [-p inode] | [-c] [-R reference] [pid | taskp] ... ", +"[-d dentry] | [-p inode] | [-n inode]|[-c] [-R reference] [pid | taskp] ... ", " This command displays information about open files of a context.", " It prints the context's current root directory and current working", " directory, and then for each open file descriptor it prints a pointer", @@ -7915,6 +7915,8 @@ char *help_files[] = { " super block, file type, and full pathname.", " -p inode given a hexadecimal inode address, dump all of its pages", " that are in the page cache.", +" -n inode given a hexadecimal inode address, check all the pages", +" in the page cache, and display a NUMA node distribution.", " -c for each open file descriptor, prints a pointer to its", " inode, a pointer to the inode's i_mapping address_space", " structure, the number of pages of the inode that are in", @@ -8024,6 +8026,26 @@ char *help_files[] = { " ca1ddde0 2eeef000 f59b91ac 3 2 82c referenced,uptodate,lru,private", " ca36b300 3b598000 f59b91ac 4 2 82c referenced,uptodate,lru,private", " ca202680 30134000 f59b91ac 5 2 82c referenced,uptodate,lru,private", +" ", +" For the inode at address ffff8898857c55a8, display the NUMA node", +" distribution of its pages that are in the page cache:", +" %s> files -n ffff8898857c55a8", +" INODE NRPAGES", +" ffff8898857c55a8 51748", +" ", +" NODE PAGES", +" 0 51536", +" 1 0", +" 2 0", +" 3 0", +" 4 0", +" 5 212", +" 6 0", +" 7 0", +" 8 0", +" 9 0", +" 10 0", +" 11 0", " ", NULL }; diff --git a/memory.c b/memory.c index 3b272ad..a8da5b1 100644 --- a/memory.c +++ b/memory.c @@ -301,7 +301,7 @@ static int dump_vm_event_state(void); static int dump_page_states(void); static int generic_read_dumpfile(ulonglong, void *, long, char *, ulong); static int generic_write_dumpfile(ulonglong, void *, long, char *, ulong); -static int page_to_nid(ulong); +int page_to_nid(ulong); static int get_kmem_cache_list(ulong **); static int get_kmem_cache_root_list(ulong **); static int get_kmem_cache_child_list(ulong **, ulong); @@ -20065,7 +20065,7 @@ is_kmem_cache_addr_common(ulong vaddr, char *kbuf) /* * Kernel-config-neutral page-to-node evaluator. */ -static int +int page_to_nid(ulong page) { int i; -- 2.43.0