diff options
Diffstat (limited to 'winsup/cygwin/fhandler_process.cc')
| -rw-r--r-- | winsup/cygwin/fhandler_process.cc | 1070 |
1 files changed, 0 insertions, 1070 deletions
diff --git a/winsup/cygwin/fhandler_process.cc b/winsup/cygwin/fhandler_process.cc deleted file mode 100644 index 526cd3322..000000000 --- a/winsup/cygwin/fhandler_process.cc +++ /dev/null @@ -1,1070 +0,0 @@ -/* fhandler_process.cc: fhandler for /proc/<pid> virtual filesystem - - Copyright 2002, 2003, 2004, 2005, 2006, 2007, 2008, 2009 Red Hat, Inc. - -This file is part of Cygwin. - -This software is a copyrighted work licensed under the terms of the -Cygwin license. Please consult the file "CYGWIN_LICENSE" for -details. */ - -#include "winsup.h" -#include <stdlib.h> -#include <stdio.h> -#include <sys/cygwin.h> -#include "cygerrno.h" -#include "security.h" -#include "path.h" -#include "fhandler.h" -#include "fhandler_virtual.h" -#include "pinfo.h" -#include "shared_info.h" -#include "dtable.h" -#include "cygheap.h" -#include "ntdll.h" -#include "cygtls.h" -#include "pwdgrp.h" -#include "tls_pbuf.h" -#include <sys/param.h> -#include <ctype.h> -#include <psapi.h> - -#define _COMPILING_NEWLIB -#include <dirent.h> - -static _off64_t format_process_maps (void *, char *&); -static _off64_t format_process_stat (void *, char *&); -static _off64_t format_process_status (void *, char *&); -static _off64_t format_process_statm (void *, char *&); -static _off64_t format_process_winexename (void *, char *&); -static _off64_t format_process_winpid (void *, char *&); -static _off64_t format_process_exename (void *, char *&); -static _off64_t format_process_root (void *, char *&); -static _off64_t format_process_cwd (void *, char *&); -static _off64_t format_process_cmdline (void *, char *&); -static _off64_t format_process_ppid (void *, char *&); -static _off64_t format_process_uid (void *, char *&); -static _off64_t format_process_pgid (void *, char *&); -static _off64_t format_process_sid (void *, char *&); -static _off64_t format_process_gid (void *, char *&); -static _off64_t format_process_ctty (void *, char *&); -static _off64_t format_process_fd (void *, char *&); -static _off64_t format_process_mounts (void *, char *&); - -static const virt_tab_t process_tab[] = -{ - { _VN ("."), FH_PROCESS, virt_directory, NULL }, - { _VN (".."), FH_PROCESS, virt_directory, NULL }, - { _VN ("cmdline"), FH_PROCESS, virt_file, format_process_cmdline }, - { _VN ("ctty"), FH_PROCESS, virt_file, format_process_ctty }, - { _VN ("cwd"), FH_PROCESS, virt_symlink, format_process_cwd }, - { _VN ("exe"), FH_PROCESS, virt_symlink, format_process_exename }, - { _VN ("exename"), FH_PROCESS, virt_file, format_process_exename }, - { _VN ("fd"), FH_PROCESSFD, virt_directory, format_process_fd }, - { _VN ("gid"), FH_PROCESS, virt_file, format_process_gid }, - { _VN ("maps"), FH_PROCESS, virt_file, format_process_maps }, - { _VN ("mounts"), FH_PROCESS, virt_file, format_process_mounts }, - { _VN ("pgid"), FH_PROCESS, virt_file, format_process_pgid }, - { _VN ("ppid"), FH_PROCESS, virt_file, format_process_ppid }, - { _VN ("root"), FH_PROCESS, virt_symlink, format_process_root }, - { _VN ("sid"), FH_PROCESS, virt_file, format_process_sid }, - { _VN ("stat"), FH_PROCESS, virt_file, format_process_stat }, - { _VN ("statm"), FH_PROCESS, virt_file, format_process_statm }, - { _VN ("status"), FH_PROCESS, virt_file, format_process_status }, - { _VN ("uid"), FH_PROCESS, virt_file, format_process_uid }, - { _VN ("winexename"), FH_PROCESS, virt_file, format_process_winexename }, - { _VN ("winpid"), FH_PROCESS, virt_file, format_process_winpid }, - { NULL, 0, 0, virt_none, NULL } -}; - -static const int PROCESS_LINK_COUNT = - (sizeof (process_tab) / sizeof (virt_tab_t)) - 1; - -static int get_process_state (DWORD dwProcessId); -static bool get_mem_values (DWORD dwProcessId, unsigned long *vmsize, - unsigned long *vmrss, unsigned long *vmtext, - unsigned long *vmdata, unsigned long *vmlib, - unsigned long *vmshare); - -/* Returns 0 if path doesn't exist, >0 if path is a directory, - * -1 if path is a file, -2 if path is a symlink, -3 if path is a pipe, - * -4 if path is a socket. - */ -virtual_ftype_t -fhandler_process::exists () -{ - const char *path = get_name (); - debug_printf ("exists (%s)", path); - path += proc_len + 1; - while (*path != 0 && !isdirsep (*path)) - path++; - if (*path == 0) - return virt_rootdir; - - virt_tab_t *entry = virt_tab_search (path + 1, true, process_tab, - PROCESS_LINK_COUNT); - if (entry) - { - if (!path[entry->name_len + 1]) - { - fileid = entry - process_tab; - return entry->type; - } - if (entry->type == virt_directory) - { - fileid = entry - process_tab; - if (fill_filebuf ()) - return virt_symlink; - /* Check for nameless device entries. */ - path = strrchr (path, '/'); - if (path && *++path) - { - if (!strncmp (path, "pipe:[", 6)) - return virt_pipe; - else if (!strncmp (path, "socket:[", 8)) - return virt_socket; - } - } - } - return virt_none; -} - -fhandler_process::fhandler_process (): - fhandler_proc () -{ -} - -int -fhandler_process::fstat (struct __stat64 *buf) -{ - const char *path = get_name (); - int file_type = exists (); - fhandler_base::fstat (buf); - path += proc_len + 1; - pid = atoi (path); - pinfo p (pid); - if (!p) - { - set_errno (ENOENT); - return -1; - } - - buf->st_mode &= ~_IFMT & NO_W; - - switch (file_type) - { - case virt_none: - set_errno (ENOENT); - return -1; - case virt_directory: - case virt_rootdir: - buf->st_ctime = buf->st_mtime = buf->st_birthtime = p->start_time; - buf->st_ctim.tv_nsec = buf->st_mtim.tv_nsec - = buf->st_birthtim.tv_nsec = 0; - time_as_timestruc_t (&buf->st_atim); - buf->st_uid = p->uid; - buf->st_gid = p->gid; - buf->st_mode |= S_IFDIR | S_IXUSR | S_IXGRP | S_IXOTH; - if (file_type == 1) - buf->st_nlink = 2; - else - buf->st_nlink = 3; - return 0; - case virt_symlink: - buf->st_uid = p->uid; - buf->st_gid = p->gid; - buf->st_mode = S_IFLNK | S_IRWXU | S_IRWXG | S_IRWXO; - return 0; - case virt_pipe: - buf->st_uid = p->uid; - buf->st_gid = p->gid; - buf->st_mode = S_IFIFO | S_IRUSR | S_IWUSR; - return 0; - case virt_socket: - buf->st_uid = p->uid; - buf->st_gid = p->gid; - buf->st_mode = S_IFSOCK | S_IRUSR | S_IWUSR; - return 0; - case virt_file: - default: - buf->st_uid = p->uid; - buf->st_gid = p->gid; - buf->st_mode |= S_IFREG | S_IRUSR | S_IRGRP | S_IROTH; - return 0; - } -} - -DIR * -fhandler_process::opendir (int fd) -{ - DIR *dir = fhandler_virtual::opendir (fd); - if (dir && process_tab[fileid].fhandler == FH_PROCESSFD) - fill_filebuf (); - return dir; -} - -int -fhandler_process::readdir (DIR *dir, dirent *de) -{ - int res = ENMFILE; - if (process_tab[fileid].fhandler == FH_PROCESSFD) - { - if (dir->__d_position >= 2 + filesize / sizeof (int)) - goto out; - } - else if (dir->__d_position >= PROCESS_LINK_COUNT) - goto out; - if (process_tab[fileid].fhandler == FH_PROCESSFD && dir->__d_position > 1) - { - int *p = (int *) filebuf; - __small_sprintf (de->d_name, "%d", p[dir->__d_position++ - 2]); - } - else - strcpy (de->d_name, process_tab[dir->__d_position++].name); - dir->__flags |= dirent_saw_dot | dirent_saw_dot_dot; - res = 0; -out: - syscall_printf ("%d = readdir (%p, %p) (%s)", res, dir, de, de->d_name); - return res; -} - -int -fhandler_process::open (int flags, mode_t mode) -{ - int res = fhandler_virtual::open (flags, mode); - if (!res) - goto out; - - nohandle (true); - - const char *path; - path = get_name () + proc_len + 1; - pid = atoi (path); - while (*path != 0 && !isdirsep (*path)) - path++; - - if (*path == 0) - { - if ((flags & (O_CREAT | O_EXCL)) == (O_CREAT | O_EXCL)) - { - set_errno (EEXIST); - res = 0; - goto out; - } - else if (flags & O_WRONLY) - { - set_errno (EISDIR); - res = 0; - goto out; - } - else - { - flags |= O_DIROPEN; - goto success; - } - } - - virt_tab_t *entry; - entry = virt_tab_search (path + 1, true, process_tab, PROCESS_LINK_COUNT); - if (!entry) - { - set_errno ((flags & O_CREAT) ? EROFS : ENOENT); - res = 0; - goto out; - } - if (entry->fhandler == FH_PROCESSFD) - { - flags |= O_DIROPEN; - goto success; - } - if (flags & O_WRONLY) - { - set_errno (EROFS); - res = 0; - goto out; - } - - fileid = entry - process_tab; - if (!fill_filebuf ()) - { - res = 0; - goto out; - } - - if (flags & O_APPEND) - position = filesize; - else - position = 0; - -success: - res = 1; - set_flags ((flags & ~O_TEXT) | O_BINARY); - set_open_status (); -out: - syscall_printf ("%d = fhandler_proc::open (%p, %d)", res, flags, mode); - return res; -} - -struct process_fd_t { - const char *path; - _pinfo *p; -}; - -bool -fhandler_process::fill_filebuf () -{ - const char *path; - path = get_name () + proc_len + 1; - if (!pid) - pid = atoi (path); - - pinfo p (pid); - - if (!p) - { - set_errno (ENOENT); - return false; - } - - if (process_tab[fileid].format_func) - { - if (process_tab[fileid].fhandler == FH_PROCESSFD) - { - process_fd_t fd = { path, p }; - filesize = process_tab[fileid].format_func (&fd, filebuf); - } - else - filesize = process_tab[fileid].format_func (p, filebuf); - return !filesize ? false : true; - } - return false; -} - -static _off64_t -format_process_fd (void *data, char *&destbuf) -{ - _pinfo *p = ((process_fd_t *) data)->p; - const char *path = ((process_fd_t *) data)->path; - size_t fs = 0; - char *fdp = strrchr (path, '/'); - - if (!fdp || *++fdp == 'f') /* The "fd" directory itself. */ - { - if (destbuf) - cfree (destbuf); - destbuf = p->fds (fs); - } - else - { - if (destbuf) - cfree (destbuf); - int fd = atoi (fdp); - if (fd < 0 || (fd == 0 && !isdigit (*fdp))) - { - set_errno (ENOENT); - return 0; - } - destbuf = p->fd (fd, fs); - if (!destbuf || !*destbuf) - { - set_errno (ENOENT); - return 0; - } - } - return fs; -} - -static _off64_t -format_process_ppid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->ppid); -} - -static _off64_t -format_process_uid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->uid); -} - -static _off64_t -format_process_pgid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->pgid); -} - -static _off64_t -format_process_sid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->sid); -} - -static _off64_t -format_process_gid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->gid); -} - -static _off64_t -format_process_ctty (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 40); - return __small_sprintf (destbuf, "%d\n", p->ctty); -} - -static _off64_t -format_process_root (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - size_t fs; - - if (destbuf) - { - cfree (destbuf); - destbuf = NULL; - } - destbuf = p->root (fs); - if (!destbuf || !*destbuf) - { - destbuf = cstrdup ("<defunct>"); - fs = strlen (destbuf) + 1; - } - return fs; -} - -static _off64_t -format_process_cwd (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - size_t fs; - - if (destbuf) - { - cfree (destbuf); - destbuf = NULL; - } - destbuf = p->cwd (fs); - if (!destbuf || !*destbuf) - { - destbuf = cstrdup ("<defunct>"); - fs = strlen (destbuf) + 1; - } - return fs; -} - -static _off64_t -format_process_cmdline (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - size_t fs; - - if (destbuf) - { - cfree (destbuf); - destbuf = NULL; - } - destbuf = p->cmdline (fs); - if (!destbuf || !*destbuf) - { - destbuf = cstrdup ("<defunct>"); - fs = strlen (destbuf) + 1; - } - return fs; -} - -static _off64_t -format_process_exename (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - int len; - tmp_pathbuf tp; - - char *buf = tp.c_get (); - if (p->process_state & PID_EXITED) - stpcpy (buf, "<defunct>"); - else - { - mount_table->conv_to_posix_path (p->progname, buf, 1); - len = strlen (buf); - if (len > 4) - { - char *s = buf + len - 4; - if (ascii_strcasematch (s, ".exe")) - *s = 0; - } - } - destbuf = (char *) crealloc_abort (destbuf, (len = strlen (buf)) + 1); - stpcpy (destbuf, buf); - return len; -} - -static _off64_t -format_process_winpid (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - destbuf = (char *) crealloc_abort (destbuf, 20); - return __small_sprintf (destbuf, "%d\n", p->dwProcessId); -} - -static _off64_t -format_process_winexename (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - size_t len = sys_wcstombs (NULL, 0, p->progname); - destbuf = (char *) crealloc_abort (destbuf, len + 1); - sys_wcstombs (destbuf, len, p->progname); - destbuf[len] = '\n'; - return len + 1; -} - -static _off64_t -format_process_maps (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - HANDLE proc = OpenProcess (PROCESS_QUERY_INFORMATION | PROCESS_VM_READ, - FALSE, - p->dwProcessId); - if (!proc) - return 0; - - _off64_t len = 0; - HMODULE *modules; - DWORD needed, i; - DWORD_PTR wset_size; - DWORD_PTR *workingset = NULL; - MODULEINFO info; - - tmp_pathbuf tp; - PWCHAR modname = tp.w_get (); - char *posix_modname = tp.c_get (); - size_t maxsize = 0; - - if (destbuf) - { - cfree (destbuf); - destbuf = NULL; - } - if (!EnumProcessModules (proc, NULL, 0, &needed)) - { - __seterrno (); - len = -1; - goto out; - } - modules = (HMODULE*) alloca (needed); - if (!EnumProcessModules (proc, modules, needed, &needed)) - { - __seterrno (); - len = -1; - goto out; - } - - QueryWorkingSet (proc, (void *) &wset_size, sizeof wset_size); - if (GetLastError () == ERROR_BAD_LENGTH) - { - workingset = (DWORD_PTR *) alloca (sizeof (DWORD_PTR) * ++wset_size); - if (!QueryWorkingSet (proc, (void *) workingset, - sizeof (DWORD_PTR) * wset_size)) - workingset = NULL; - } - for (i = 0; i < needed / sizeof (HMODULE); i++) - if (GetModuleInformation (proc, modules[i], &info, sizeof info) - && GetModuleFileNameExW (proc, modules[i], modname, NT_MAX_PATH)) - { - char access[5]; - strcpy (access, "r--p"); - struct __stat64 st; - if (mount_table->conv_to_posix_path (modname, posix_modname, 0)) - sys_wcstombs (posix_modname, NT_MAX_PATH, modname); - if (stat64 (posix_modname, &st)) - { - st.st_dev = 0; - st.st_ino = 0; - } - size_t newlen = strlen (posix_modname) + 62; - if (len + newlen >= maxsize) - destbuf = (char *) crealloc_abort (destbuf, - maxsize += roundup2 (newlen, 2048)); - if (workingset) - for (unsigned i = 1; i <= wset_size; ++i) - { - DWORD_PTR addr = workingset[i] & 0xfffff000UL; - if ((char *)addr >= info.lpBaseOfDll - && (char *)addr < (char *)info.lpBaseOfDll + info.SizeOfImage) - { - access[0] = (workingset[i] & 0x5) ? 'r' : '-'; - access[1] = (workingset[i] & 0x4) ? 'w' : '-'; - access[2] = (workingset[i] & 0x2) ? 'x' : '-'; - access[3] = (workingset[i] & 0x100) ? 's' : 'p'; - } - } - int written = __small_sprintf (destbuf + len, - "%08lx-%08lx %s %08lx %04x:%04x %U ", - info.lpBaseOfDll, - (unsigned long)info.lpBaseOfDll - + info.SizeOfImage, - access, - info.EntryPoint, - st.st_dev >> 16, - st.st_dev & 0xffff, - st.st_ino); - while (written < 62) - destbuf[len + written++] = ' '; - len += written; - len += __small_sprintf (destbuf + len, "%s\n", posix_modname); - } -out: - CloseHandle (proc); - return len; -} - -static _off64_t -format_process_stat (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - char cmd[NAME_MAX + 1]; - WCHAR wcmd[NAME_MAX + 1]; - int state = 'R'; - unsigned long fault_count = 0UL, - utime = 0UL, stime = 0UL, - start_time = 0UL, - vmsize = 0UL, vmrss = 0UL, vmmaxrss = 0UL; - int priority = 0; - if (p->process_state & PID_EXITED) - strcpy (cmd, "<defunct>"); - else - { - PWCHAR last_slash = wcsrchr (p->progname, L'\\'); - wcscpy (wcmd, last_slash ? last_slash + 1 : p->progname); - sys_wcstombs (cmd, NAME_MAX + 1, wcmd); - int len = strlen (cmd); - if (len > 4) - { - char *s = cmd + len - 4; - if (ascii_strcasematch (s, ".exe")) - *s = 0; - } - } - /* - * Note: under Windows, a _process_ is always running - it's only _threads_ - * that get suspended. Therefore the default state is R (runnable). - */ - if (p->process_state & PID_EXITED) - state = 'Z'; - else if (p->process_state & PID_STOPPED) - state = 'T'; - else - state = get_process_state (p->dwProcessId); - start_time = (GetTickCount () / 1000 - time (NULL) + p->start_time) * HZ; - - NTSTATUS ret; - HANDLE hProcess; - VM_COUNTERS vmc; - KERNEL_USER_TIMES put; - PROCESS_BASIC_INFORMATION pbi; - QUOTA_LIMITS ql; - SYSTEM_TIME_OF_DAY_INFORMATION stodi; - SYSTEM_PROCESSOR_TIMES spt; - hProcess = OpenProcess (PROCESS_VM_READ | PROCESS_QUERY_INFORMATION, - FALSE, p->dwProcessId); - if (hProcess != NULL) - { - ret = NtQueryInformationProcess (hProcess, - ProcessVmCounters, - (PVOID) &vmc, - sizeof vmc, NULL); - if (ret == STATUS_SUCCESS) - ret = NtQueryInformationProcess (hProcess, - ProcessTimes, - (PVOID) &put, - sizeof put, NULL); - if (ret == STATUS_SUCCESS) - ret = NtQueryInformationProcess (hProcess, - ProcessBasicInformation, - (PVOID) &pbi, - sizeof pbi, NULL); - if (ret == STATUS_SUCCESS) - ret = NtQueryInformationProcess (hProcess, - ProcessQuotaLimits, - (PVOID) &ql, - sizeof ql, NULL); - CloseHandle (hProcess); - } - else - { - DWORD error = GetLastError (); - __seterrno_from_win_error (error); - debug_printf ("OpenProcess: ret %d", error); - return 0; - } - if (ret == STATUS_SUCCESS) - ret = NtQuerySystemInformation (SystemTimeOfDayInformation, - (PVOID) &stodi, - sizeof stodi, NULL); - if (ret == STATUS_SUCCESS) - ret = NtQuerySystemInformation (SystemProcessorTimes, - (PVOID) &spt, - sizeof spt, NULL); - if (ret != STATUS_SUCCESS) - { - __seterrno_from_nt_status (ret); - debug_printf ("NtQueryInformationProcess: ret %d, Dos(ret) %E", ret); - return 0; - } - fault_count = vmc.PageFaultCount; - utime = put.UserTime.QuadPart * HZ / 10000000ULL; - stime = put.KernelTime.QuadPart * HZ / 10000000ULL; -#if 0 - if (stodi.CurrentTime.QuadPart > put.CreateTime.QuadPart) - start_time = (spt.KernelTime.QuadPart + spt.UserTime.QuadPart - - stodi.CurrentTime.QuadPart + put.CreateTime.QuadPart) * HZ / 10000000ULL; - else - /* - * sometimes stodi.CurrentTime is a bit behind - * Note: some older versions of procps are broken and can't cope - * with process start times > time(NULL). - */ - start_time = (spt.KernelTme.QuadPart + spt.UserTime.QuadPart) * HZ / 10000000ULL; -#endif - priority = pbi.BasePriority; - unsigned page_size = getsystempagesize (); - vmsize = vmc.PagefileUsage; - vmrss = vmc.WorkingSetSize / page_size; - vmmaxrss = ql.MaximumWorkingSetSize / page_size; - - destbuf = (char *) crealloc_abort (destbuf, strlen (cmd) + 320); - return __small_sprintf (destbuf, "%d (%s) %c " - "%d %d %d %d %d " - "%lu %lu %lu %lu %lu %lu %lu " - "%ld %ld %ld %ld %ld %ld " - "%lu %lu " - "%ld " - "%lu", - p->pid, cmd, - state, - p->ppid, p->pgid, p->sid, makedev (FH_TTYS, p->ctty), - -1, 0, fault_count, fault_count, 0, 0, utime, stime, - utime, stime, priority, 0, 0, 0, - start_time, vmsize, - vmrss, vmmaxrss - ); -} - -static _off64_t -format_process_status (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - char cmd[NAME_MAX + 1]; - WCHAR wcmd[NAME_MAX + 1]; - int state = 'R'; - const char *state_str = "unknown"; - unsigned long vmsize = 0UL, vmrss = 0UL, vmdata = 0UL, vmlib = 0UL, vmtext = 0UL, - vmshare = 0UL; - if (p->process_state & PID_EXITED) - strcpy (cmd, "<defunct>"); - else - { - PWCHAR last_slash = wcsrchr (p->progname, L'\\'); - wcscpy (wcmd, last_slash ? last_slash + 1 : p->progname); - sys_wcstombs (cmd, NAME_MAX + 1, wcmd); - int len = strlen (cmd); - if (len > 4) - { - char *s = cmd + len - 4; - if (ascii_strcasematch (s, ".exe")) - *s = 0; - } - } - /* - * Note: under Windows, a _process_ is always running - it's only _threads_ - * that get suspended. Therefore the default state is R (runnable). - */ - if (p->process_state & PID_EXITED) - state = 'Z'; - else if (p->process_state & PID_STOPPED) - state = 'T'; - else - state = get_process_state (p->dwProcessId); - switch (state) - { - case 'O': - state_str = "running"; - break; - case 'D': - case 'S': - state_str = "sleeping"; - break; - case 'R': - state_str = "runnable"; - break; - case 'Z': - state_str = "zombie"; - break; - case 'T': - state_str = "stopped"; - break; - } - if (!get_mem_values (p->dwProcessId, &vmsize, &vmrss, &vmtext, &vmdata, - &vmlib, &vmshare)) - return 0; - unsigned page_size = getsystempagesize (); - vmsize *= page_size; vmrss *= page_size; vmdata *= page_size; - vmtext *= page_size; vmlib *= page_size; - // The real uid value for *this* process is stored at cygheap->user.real_uid - // but we can't get at the real uid value for any other process, so - // just fake it as p->uid. Similar for p->gid. - destbuf = (char *) crealloc_abort (destbuf, strlen (cmd) + 320); - return __small_sprintf (destbuf, "Name:\t%s\n" - "State:\t%c (%s)\n" - "Tgid:\t%d\n" - "Pid:\t%d\n" - "PPid:\t%d\n" - "Uid:\t%d %d %d %d\n" - "Gid:\t%d %d %d %d\n" - "VmSize:\t%8d kB\n" - "VmLck:\t%8d kB\n" - "VmRSS:\t%8d kB\n" - "VmData:\t%8d kB\n" - "VmStk:\t%8d kB\n" - "VmExe:\t%8d kB\n" - "VmLib:\t%8d kB\n" - "SigPnd:\t%016x\n" - "SigBlk:\t%016x\n" - "SigIgn:\t%016x\n", - cmd, - state, state_str, - p->pgid, - p->pid, - p->ppid, - p->uid, p->uid, p->uid, p->uid, - p->gid, p->gid, p->gid, p->gid, - vmsize >> 10, 0, vmrss >> 10, vmdata >> 10, 0, - vmtext >> 10, vmlib >> 10, - 0, 0, _my_tls.sigmask - ); -} - -static _off64_t -format_process_statm (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - unsigned long vmsize = 0UL, vmrss = 0UL, vmtext = 0UL, vmdata = 0UL, - vmlib = 0UL, vmshare = 0UL; - if (!get_mem_values (p->dwProcessId, &vmsize, &vmrss, &vmtext, &vmdata, - &vmlib, &vmshare)) - return 0; - destbuf = (char *) crealloc_abort (destbuf, 96); - return __small_sprintf (destbuf, "%ld %ld %ld %ld %ld %ld %ld", - vmsize, vmrss, vmshare, vmtext, vmlib, vmdata, 0); -} - -extern "C" { - FILE *setmntent (const char *, const char *); - struct mntent *getmntent (FILE *); -}; - -static _off64_t -format_process_mounts (void *data, char *&destbuf) -{ - _pinfo *p = (_pinfo *) data; - user_info *u_shared = NULL; - HANDLE u_hdl = NULL; - _off64_t len = 0; - struct mntent *mnt; - - if (p->pid != myself->pid) - { - WCHAR sid_string[UNLEN + 1] = L""; /* Large enough for SID */ - - cygsid p_sid; - - if (!p_sid.getfrompw (internal_getpwuid (p->uid))) - return 0; - p_sid.string (sid_string); - u_shared = (user_info *) open_shared (sid_string, USER_VERSION, u_hdl, - sizeof (user_info), SH_JUSTOPEN, - &sec_none_nih); - if (!u_shared) - return 0; - } - else - u_shared = user_shared; - - /* Store old value of _my_tls.locals here. */ - int iteration = _my_tls.locals.iteration; - unsigned available_drives = _my_tls.locals.available_drives; - /* This reinitializes the above values in _my_tls. */ - setmntent (NULL, NULL); - while ((mnt = getmntent (NULL))) - { - destbuf = (char *) crealloc_abort (destbuf, len - + strlen (mnt->mnt_fsname) - + strlen (mnt->mnt_dir) - + strlen (mnt->mnt_type) - + strlen (mnt->mnt_opts) - + 28); - len += __small_sprintf (destbuf + len, "%s %s %s %s %d %d\n", - mnt->mnt_fsname, mnt->mnt_dir, mnt->mnt_type, - mnt->mnt_opts, mnt->mnt_freq, mnt->mnt_passno); - } - /* Restore old value of _my_tls.locals here. */ - _my_tls.locals.iteration = iteration; - _my_tls.locals.available_drives = available_drives; - - if (u_hdl) /* Only not-NULL if open_shared has been called. */ - { - UnmapViewOfFile (u_shared); - CloseHandle (u_hdl); - } - return len; -} - -static int -get_process_state (DWORD dwProcessId) -{ - /* - * This isn't really heavy magic - just go through the processes' - * threads one by one and return a value accordingly - * Errors are silently ignored. - */ - NTSTATUS ret; - SYSTEM_PROCESSES *sp; - ULONG n = 0x1000; - PULONG p = new ULONG[n]; - int state =' '; - while (STATUS_INFO_LENGTH_MISMATCH == - (ret = NtQuerySystemInformation (SystemProcessesAndThreadsInformation, - (PVOID) p, - n * sizeof *p, NULL))) - delete [] p, p = new ULONG[n *= 2]; - if (ret != STATUS_SUCCESS) - { - debug_printf ("NtQuerySystemInformation: ret %d, Dos(ret) %d", - ret, RtlNtStatusToDosError (ret)); - goto out; - } - state = 'Z'; - sp = (SYSTEM_PROCESSES *) p; - for (;;) - { - if (sp->ProcessId == dwProcessId) - { - SYSTEM_THREADS *st; - if (wincap.has_process_io_counters ()) - /* - * Windows 2000 and XP have an extra member in SYSTEM_PROCESSES - * which means the offset of the first SYSTEM_THREADS entry is - * different on these operating systems compared to NT 4. - */ - st = &sp->Threads[0]; - else - /* - * 136 is the offset of the first SYSTEM_THREADS entry on - * Windows NT 4. - */ - st = (SYSTEM_THREADS *) ((char *) sp + 136); - state = 'S'; - for (unsigned i = 0; i < sp->ThreadCount; i++) - { - if (st->State == StateRunning || - st->State == StateReady) - { - state = 'R'; - goto out; - } - st++; - } - break; - } - if (!sp->NextEntryDelta) - break; - sp = (SYSTEM_PROCESSES *) ((char *) sp + sp->NextEntryDelta); - } -out: - delete [] p; - return state; -} - -static bool -get_mem_values (DWORD dwProcessId, unsigned long *vmsize, unsigned long *vmrss, - unsigned long *vmtext, unsigned long *vmdata, - unsigned long *vmlib, unsigned long *vmshare) -{ - bool res = false; - NTSTATUS ret; - HANDLE hProcess; - VM_COUNTERS vmc; - MEMORY_WORKING_SET_LIST *mwsl; - ULONG n = 0x4000, length; - PMEMORY_WORKING_SET_LIST p = (PMEMORY_WORKING_SET_LIST) malloc (n); - unsigned page_size = getsystempagesize (); - hProcess = OpenProcess (PROCESS_QUERY_INFORMATION, - FALSE, dwProcessId); - if (hProcess == NULL) - { - __seterrno (); - debug_printf ("OpenProcess, %E"); - return false; - } - do - { - ret = NtQueryVirtualMemory (hProcess, 0, MemoryWorkingSetList, - (PVOID) p, n, (length = ULONG_MAX, &length)); - if (ret == STATUS_INFO_LENGTH_MISMATCH - || (!NT_SUCCESS (ret) && length > n)) - { - ret = STATUS_INFO_LENGTH_MISMATCH; - n <<= 1; - PMEMORY_WORKING_SET_LIST new_p = (PMEMORY_WORKING_SET_LIST) - realloc (p, n); - if (!new_p) - goto out; - p = new_p; - } - } - while (!NT_SUCCESS (ret)); - if (!NT_SUCCESS (ret)) - { - debug_printf ("NtQueryVirtualMemory: ret %p", ret); - __seterrno_from_nt_status (ret); - goto out; - } - mwsl = (MEMORY_WORKING_SET_LIST *) p; - for (unsigned long i = 0; i < mwsl->NumberOfPages; i++) - { - ++*vmrss; - unsigned flags = mwsl->WorkingSetList[i] & 0x0FFF; - if ((flags & (WSLE_PAGE_EXECUTE | WSLE_PAGE_SHAREABLE)) - == (WSLE_PAGE_EXECUTE | WSLE_PAGE_SHAREABLE)) - ++*vmlib; - else if (flags & WSLE_PAGE_SHAREABLE) - ++*vmshare; - else if (flags & WSLE_PAGE_EXECUTE) - ++*vmtext; - else - ++*vmdata; - } - ret = NtQueryInformationProcess (hProcess, ProcessVmCounters, (PVOID) &vmc, - sizeof vmc, NULL); - if (!NT_SUCCESS (ret)) - { - debug_printf ("NtQueryInformationProcess: ret %p", ret); - __seterrno_from_nt_status (ret); - goto out; - } - *vmsize = vmc.PagefileUsage / page_size; - res = true; -out: - free (p); - CloseHandle (hProcess); - return res; -} |