[TASKKILL] Final sync with wine-10.0 (#7855)

[WINESYNC] taskkill: Build with msvcrt.
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
wine commit id fb80c1b554eaf07bf2f89fcf2960e39bd0d4787a by Alexandre Julliard <julliard@winehq.org>

[WINESYNC] taskkill: Use wide-char string literals.
Signed-off-by: Michael Stefaniuc <mstefani@winehq.org>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
wine commit id 3180972ee2c8e67c425aa7f5279d0cd830455c3d by Michael Stefaniuc <mstefani@winehq.org>

[WINESYNC] taskkill: Use the standard va_list instead of __ms_va_list.
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
wine commit id 2c2e75503bea973a3091ea48d431782da656ef8e by Alexandre Julliard <julliard@winehq.org>

[WINESYNC] taskkill: Use OEM code page for output.
Signed-off-by: Eric Pouech <eric.pouech@gmail.com>
Signed-off-by: Alexandre Julliard <julliard@winehq.org>
wine commit id 8fdf397505522cc8e41b58cd960899ef7cdf322b by Eric Pouech <eric.pouech@gmail.com>

[WINESYNC] taskkill: Use exit code 1 when terminating processes.
wine commit id fe6294c74346e9956fb839d2a4ca078c624f6bbf by Brendan Shanks <bshanks@codeweavers.com>

[WINESYNC] taskkill: Use CRT allocation functions.
wine commit id dd3f3f381f9e761325c7c06236de1241c9605ed6 by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Remove unneeded free() before process exit.
wine commit id 20ab5f06d0972440a7df7fb1ba390ab1b32f3b1d by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Enumerate processes in main().
wine commit id cf4a0b7392f33ba3e0b3fe69007a6d1f327f13f2 by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Factor out get_task_pid().
wine commit id 62ef3c5be1d2c5374399984588a9daa75663d030 by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Use toolhelp snapshot to get process information.
wine commit id 6cca1f5099a8354b67578b42dd34fd010e80b6de by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Mark processes for termination in main().
wine commit id 5c851451892e05c1747108432a5a2bff3a78ed9e by Paul Gofman <pgofman@codeweavers.com>

[WINESYNC] taskkill: Support terminating child processes.
wine commit id fb6b1c91bbf412f5eba260ae52ee38176fd693d4 by Paul Gofman <pgofman@codeweavers.com>

NOTE: This implementation is disabled for ReactOS, and we keep
our own. See the comment block in the code for the reasons why.

+ Adaptations for ReactOS-specific code.

In particular, great care has been taken to keep the `pkill_list`
functionality (read: fix) introduced in PR #2403 (commit 97e7efc020).
The current problem with Wine's code is that if many processes (more
than one) with the same image name are running, then:

   taskkill /im theimagename.exe

would only terminate *one* of the corresponding processes, instead of
all processes having this same image name (as on Windows).
The `pkill_list` array contains all the PIDs of these processes. This
replaces the single `pid` initialized by `get_task_pid`.

Co-authored-by: Hermès Bélusca-Maïto <hermes.belusca-maito@reactos.org>
This commit is contained in:
Hermès Bélusca-Maïto 2025-03-26 21:02:03 +01:00
parent f669426bf4
commit 4089e90890
No known key found for this signature in database
GPG key ID: 3B2539C65E7B93D0
2 changed files with 354 additions and 309 deletions

View file

@ -2,6 +2,6 @@
add_executable(taskkill taskkill.c taskkill.rc) add_executable(taskkill taskkill.c taskkill.rc)
target_link_libraries(taskkill wine) target_link_libraries(taskkill wine)
set_module_type(taskkill win32cui UNICODE) set_module_type(taskkill win32cui UNICODE)
add_importlibs(taskkill psapi user32 msvcrt kernel32 ntdll) add_importlibs(taskkill user32 msvcrt kernel32 ntdll)
add_cd_file(TARGET taskkill DESTINATION reactos/system32 FOR all) add_cd_file(TARGET taskkill DESTINATION reactos/system32 FOR all)
set_wine_module_FIXME(taskkill) # CORE-5743: No ARRAY_SIZE macro set_wine_module_FIXME(taskkill) # CORE-5743: No ARRAY_SIZE macro

View file

@ -22,10 +22,12 @@
#include <stdlib.h> #include <stdlib.h>
#include <windows.h> #include <windows.h>
#include <psapi.h>
#include <tlhelp32.h> #include <tlhelp32.h>
#include <wine/debug.h> #include <wine/debug.h>
#include <wine/unicode.h>
#ifdef __REACTOS__
#define wcsicmp _wcsicmp
#endif
#include "taskkill.h" #include "taskkill.h"
@ -37,15 +39,30 @@ static BOOL kill_child_processes = FALSE;
static WCHAR **task_list; static WCHAR **task_list;
static unsigned int task_count; static unsigned int task_count;
static struct
{
PROCESSENTRY32W p;
BOOL matched;
BOOL is_numeric;
}
*process_list;
static unsigned int process_count;
struct pid_close_info
{
DWORD pid;
BOOL found;
};
#ifdef __REACTOS__
unsigned int* pkill_list;
DWORD pkill_size;
DWORD self_pid;
#endif
#ifdef __REACTOS__ #ifdef __REACTOS__
static WCHAR opForceTerminate[] = L"f"; static PWCHAR opList[] = {L"f", L"im", L"pid", L"?", L"t"};
static WCHAR opImage[] = L"im";
static WCHAR opPID[] = L"pid";
static WCHAR opHelp[] = L"?";
static WCHAR opTerminateChildren[] = L"t";
static PWCHAR opList[] = {opForceTerminate, opImage, opPID, opHelp, opTerminateChildren};
#define OP_PARAM_INVALID -1 #define OP_PARAM_INVALID -1
@ -57,41 +74,32 @@ static PWCHAR opList[] = {opForceTerminate, opImage, opPID, opHelp, opTerminateC
#endif // __REACTOS__ #endif // __REACTOS__
struct pid_close_info static int taskkill_vprintfW(const WCHAR *msg, va_list va_args)
{
DWORD pid;
BOOL found;
};
static int taskkill_vprintfW(const WCHAR *msg, __ms_va_list va_args)
{ {
int wlen; int wlen;
DWORD count, ret; DWORD count;
WCHAR msg_buffer[8192]; WCHAR msg_buffer[8192];
wlen = FormatMessageW(FORMAT_MESSAGE_FROM_STRING, msg, 0, 0, msg_buffer, wlen = FormatMessageW(FORMAT_MESSAGE_FROM_STRING, msg, 0, 0, msg_buffer,
ARRAY_SIZE(msg_buffer), &va_args); ARRAY_SIZE(msg_buffer), &va_args);
ret = WriteConsoleW(GetStdHandle(STD_OUTPUT_HANDLE), msg_buffer, wlen, &count, NULL); if (!WriteConsoleW(GetStdHandle(STD_OUTPUT_HANDLE), msg_buffer, wlen, &count, NULL))
if (!ret)
{ {
DWORD len; DWORD len;
char *msgA; char *msgA;
/* On Windows WriteConsoleW() fails if the output is redirected. So fall /* On Windows WriteConsoleW() fails if the output is redirected. So fall
* back to WriteFile(), assuming the console encoding is still the right * back to WriteFile() using OEM code page.
* one in that case.
*/ */
len = WideCharToMultiByte(GetConsoleOutputCP(), 0, msg_buffer, wlen, len = WideCharToMultiByte(GetOEMCP(), 0, msg_buffer, wlen,
NULL, 0, NULL, NULL); NULL, 0, NULL, NULL);
msgA = HeapAlloc(GetProcessHeap(), 0, len); msgA = malloc(len);
if (!msgA) if (!msgA)
return 0; return 0;
WideCharToMultiByte(GetConsoleOutputCP(), 0, msg_buffer, wlen, msgA, len, WideCharToMultiByte(GetOEMCP(), 0, msg_buffer, wlen, msgA, len, NULL, NULL);
NULL, NULL);
WriteFile(GetStdHandle(STD_OUTPUT_HANDLE), msgA, len, &count, FALSE); WriteFile(GetStdHandle(STD_OUTPUT_HANDLE), msgA, len, &count, FALSE);
HeapFree(GetProcessHeap(), 0, msgA); free(msgA);
} }
return count; return count;
@ -99,39 +107,38 @@ static int taskkill_vprintfW(const WCHAR *msg, __ms_va_list va_args)
static int WINAPIV taskkill_printfW(const WCHAR *msg, ...) static int WINAPIV taskkill_printfW(const WCHAR *msg, ...)
{ {
__ms_va_list va_args; va_list va_args;
int len; int len;
__ms_va_start(va_args, msg); va_start(va_args, msg);
len = taskkill_vprintfW(msg, va_args); len = taskkill_vprintfW(msg, va_args);
__ms_va_end(va_args); va_end(va_args);
return len; return len;
} }
static int WINAPIV taskkill_message_printfW(int msg, ...) static int WINAPIV taskkill_message_printfW(int msg, ...)
{ {
__ms_va_list va_args; va_list va_args;
WCHAR msg_buffer[8192]; WCHAR msg_buffer[8192];
int len; int len;
LoadStringW(GetModuleHandleW(NULL), msg, msg_buffer, ARRAY_SIZE(msg_buffer)); LoadStringW(GetModuleHandleW(NULL), msg, msg_buffer, ARRAY_SIZE(msg_buffer));
__ms_va_start(va_args, msg); va_start(va_args, msg);
len = taskkill_vprintfW(msg_buffer, va_args); len = taskkill_vprintfW(msg_buffer, va_args);
__ms_va_end(va_args); va_end(va_args);
return len; return len;
} }
static int taskkill_message(int msg) static int taskkill_message(int msg)
{ {
static const WCHAR formatW[] = {'%','1',0};
WCHAR msg_buffer[8192]; WCHAR msg_buffer[8192];
LoadStringW(GetModuleHandleW(NULL), msg, msg_buffer, ARRAY_SIZE(msg_buffer)); LoadStringW(GetModuleHandleW(NULL), msg, msg_buffer, ARRAY_SIZE(msg_buffer));
return taskkill_printfW(formatW, msg_buffer); return taskkill_printfW(L"%1", msg_buffer);
} }
/* Post WM_CLOSE to all top-level windows belonging to the process with specified PID. */ /* Post WM_CLOSE to all top-level windows belonging to the process with specified PID. */
@ -151,72 +158,204 @@ static BOOL CALLBACK pid_enum_proc(HWND hwnd, LPARAM lParam)
return TRUE; return TRUE;
} }
static DWORD *enumerate_processes(DWORD *list_count) static BOOL enumerate_processes(void)
{ {
DWORD *pid_list, alloc_bytes = 1024 * sizeof(*pid_list), needed_bytes; unsigned int alloc_count = 128;
void *realloc_list;
HANDLE snapshot;
pid_list = HeapAlloc(GetProcessHeap(), 0, alloc_bytes); snapshot = CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);
if (!pid_list) if (snapshot == INVALID_HANDLE_VALUE)
return NULL; return FALSE;
for (;;) process_list = malloc(alloc_count * sizeof(*process_list));
if (!process_list)
return FALSE;
process_list[0].p.dwSize = sizeof(process_list[0].p);
if (!Process32FirstW(snapshot, &process_list[0].p))
return FALSE;
do
{ {
DWORD *realloc_list; process_list[process_count].is_numeric = FALSE;
process_list[process_count++].matched = FALSE;
if (!EnumProcesses(pid_list, alloc_bytes, &needed_bytes)) if (process_count == alloc_count)
{ {
HeapFree(GetProcessHeap(), 0, pid_list); alloc_count *= 2;
return NULL; realloc_list = realloc(process_list, alloc_count * sizeof(*process_list));
}
/* EnumProcesses can't signal an insufficient buffer condition, so the
* only way to possibly determine whether a larger buffer is required
* is to see whether the written number of bytes is the same as the
* buffer size. If so, the buffer will be reallocated to twice the
* size. */
if (alloc_bytes != needed_bytes)
break;
alloc_bytes *= 2;
realloc_list = HeapReAlloc(GetProcessHeap(), 0, pid_list, alloc_bytes);
if (!realloc_list) if (!realloc_list)
{
HeapFree(GetProcessHeap(), 0, pid_list);
return NULL;
}
pid_list = realloc_list;
}
*list_count = needed_bytes / sizeof(*pid_list);
return pid_list;
}
static BOOL get_process_name_from_pid(DWORD pid, WCHAR *buf, DWORD chars)
{
HANDLE process;
HMODULE module;
DWORD required_size;
process = OpenProcess(PROCESS_QUERY_INFORMATION | PROCESS_VM_READ, FALSE, pid);
if (!process)
return FALSE;
if (!EnumProcessModules(process, &module, sizeof(module), &required_size))
{
CloseHandle(process);
return FALSE; return FALSE;
process_list = realloc_list;
} }
process_list[process_count].p.dwSize = sizeof(process_list[process_count].p);
if (!GetModuleBaseNameW(process, module, buf, chars)) } while (Process32NextW(snapshot, &process_list[process_count].p));
{ CloseHandle(snapshot);
CloseHandle(process);
return FALSE;
}
CloseHandle(process);
return TRUE; return TRUE;
} }
static void mark_task_process(const WCHAR *str, int *status_code)
{
#ifndef __REACTOS__
DWORD self_pid = GetCurrentProcessId();
#endif
const WCHAR *p = str;
BOOL is_numeric;
unsigned int i;
DWORD pid;
is_numeric = TRUE;
while (*p)
{
if (!iswdigit(*p++))
{
is_numeric = FALSE;
break;
}
}
if (is_numeric)
{
pid = wcstol(str, NULL, 10);
for (i = 0; i < process_count; ++i)
{
if (process_list[i].p.th32ProcessID == pid)
break;
}
if (i == process_count || process_list[i].matched)
goto not_found;
process_list[i].matched = TRUE;
process_list[i].is_numeric = TRUE;
if (pid == self_pid)
{
taskkill_message(STRING_SELF_TERMINATION);
*status_code = 1;
}
#ifdef __REACTOS__
else
{
pkill_list[pkill_size++] = i;
}
#endif
return;
}
for (i = 0; i < process_count; ++i)
{
if (!wcsicmp(process_list[i].p.szExeFile, str) && !process_list[i].matched)
{
process_list[i].matched = TRUE;
if (process_list[i].p.th32ProcessID == self_pid)
{
taskkill_message(STRING_SELF_TERMINATION);
*status_code = 1;
}
#ifdef __REACTOS__
else
{
pkill_list[pkill_size++] = i;
continue;
}
#endif
return;
}
}
#ifdef __REACTOS__
// Cannot find any process matching the PID or name
if (pkill_size == 0)
{
#endif
not_found:
taskkill_message_printfW(STRING_SEARCH_FAILED, str);
*status_code = 128;
#ifdef __REACTOS__
}
#endif
}
static void taskkill_message_print_process(int msg, unsigned int index)
{
WCHAR pid_str[16];
if (!process_list[index].is_numeric)
{
taskkill_message_printfW(msg, process_list[index].p.szExeFile);
return;
}
wsprintfW(pid_str, L"%lu", process_list[index].p.th32ProcessID);
taskkill_message_printfW(msg, pid_str);
}
#ifndef __REACTOS__
/*
* Below is the Wine method of terminating child processes.
* Its problem is that it doesn't terminate them in either a parent-to-children
* or children-to-parent relationship, but instead in the order in which they
* appear in the process list. This differs from Windows' (or ReactOS) method.
* Wine's termination ordering can cause problems in scenarii where e.g. a
* parent process could re-spawn killed children processes, or, where it is
* of interest to kill the parent process first and then its children.
*
* NOTE: The following two functions implicitly assume that the process list
* obtained from the system, is such that any child process P[j] of a given
* parent process P[i] is enumerated *AFTER* its parent (i.e. i < j).
*
* Because of these facts, the ReactOS recursive method is employed instead.
* Note however that the Wine method (below) has been adapted for ease of
* usage and comparison with that of ReactOS.
*/
static BOOL find_parent(unsigned int process_index, unsigned int *parent_index)
{
DWORD parent_id = process_list[process_index].p.th32ParentProcessID;
unsigned int i;
if (!parent_id)
return FALSE;
for (i = 0; i < process_count; ++i)
{
if (process_list[i].p.th32ProcessID == parent_id)
{
*parent_index = i;
return TRUE;
}
}
return FALSE;
}
static void mark_child_processes(void)
{
unsigned int i, parent;
for (i = 0; i < process_count; ++i)
{
if (process_list[i].matched)
continue;
#ifdef __REACTOS__
// Prevent self-termination if we are in the process tree
if (process_list[i].p.th32ProcessID == self_pid)
continue;
#endif
parent = i;
while (find_parent(parent, &parent))
{
if (process_list[parent].matched)
{
WINE_TRACE("Adding child %04lx.\n", process_list[i].p.th32ProcessID);
process_list[i].matched = TRUE;
#ifdef __REACTOS__
pkill_list[pkill_size++] = i;
#endif
break;
}
}
}
}
#endif // !__REACTOS__
/* The implemented task enumeration and termination behavior does not /* The implemented task enumeration and termination behavior does not
* exactly match native behavior. On Windows: * exactly match native behavior. On Windows:
* *
@ -232,10 +371,11 @@ static BOOL get_process_name_from_pid(DWORD pid, WCHAR *buf, DWORD chars)
* A PID of zero causes taskkill to warn about the inability to terminate * A PID of zero causes taskkill to warn about the inability to terminate
* system processes. */ * system processes. */
#ifdef __REACTOS__
static BOOL get_pid_creation_time(DWORD pid, FILETIME *time) static BOOL get_pid_creation_time(DWORD pid, FILETIME *time)
{ {
HANDLE process = INVALID_HANDLE_VALUE; HANDLE process;
FILETIME t1 = { 0 }, t2 = { 0 }, t3 = { 0 }; FILETIME t1 = { 0 }, t2 = { 0 }, t3 = { 0 };
process = OpenProcess(PROCESS_QUERY_INFORMATION, FALSE, pid); process = OpenProcess(PROCESS_QUERY_INFORMATION, FALSE, pid);
@ -297,115 +437,64 @@ static void send_close_messages_tree(DWORD ppid)
CloseHandle(h); CloseHandle(h);
} }
#endif // __REACTOS__
static int send_close_messages(void) static int send_close_messages(void)
{ {
DWORD *pid_list, pid_list_size, *pkill_list; const WCHAR *process_name;
DWORD self_pid = GetCurrentProcessId(); struct pid_close_info info;
unsigned int i; unsigned int i;
int status_code = 0; int status_code = 0;
pid_list = enumerate_processes(&pid_list_size); #ifdef __REACTOS__
if (!pid_list) DWORD index;
for (index = 0; index < pkill_size; ++index)
#else
for (i = 0; i < process_count; i++)
#endif
{ {
taskkill_message(STRING_ENUM_FAILED); #ifdef __REACTOS__
return 1; i = pkill_list[index];
} #else
if (!process_list[i].matched)
pkill_list = HeapAlloc(GetProcessHeap(), 0, pid_list_size * sizeof(DWORD));
if (!pkill_list)
return 1;
for (i = 0; i < task_count; i++)
{
WCHAR *p = task_list[i];
BOOL is_numeric = TRUE;
DWORD pkill_size = 0, index = 0;
memset(pkill_list, 0, pid_list_size * sizeof(DWORD));
/* Determine whether the string is not numeric. */
while (*p)
{
if (!isdigitW(*p++))
{
is_numeric = FALSE;
break;
}
}
// Find processes to kill
if (is_numeric)
{
WCHAR ps_name[MAX_PATH] = { 0 };
if (get_process_name_from_pid(atoiW(task_list[i]), ps_name, MAX_PATH))
{
pkill_list[pkill_size] = atoiW(task_list[i]);
pkill_size++;
}
}
else
{
for (index = 0; index < pid_list_size; index++)
{
WCHAR process_name[MAX_PATH];
if (get_process_name_from_pid(pid_list[index], process_name, MAX_PATH) &&
!strcmpiW(process_name, task_list[i]))
{
pkill_list[pkill_size] = pid_list[index];
pkill_size++;
}
}
}
// Can't find any process same as name or PID
if (pkill_size == 0)
{
taskkill_message_printfW(STRING_SEARCH_FAILED, task_list[i]);
status_code = 128;
continue; continue;
} #endif
// Try to send close messages to process in `pkill_list` info.pid = process_list[i].p.th32ProcessID;
for (index = 0; index < pkill_size; index++) #ifdef __REACTOS__
{ if (info.pid == self_pid)
DWORD pid = pkill_list[index];
WCHAR process_name[MAX_PATH] = { 0 };
struct pid_close_info info = { pid };
if (pid == self_pid)
{ {
taskkill_message(STRING_SELF_TERMINATION); taskkill_message(STRING_SELF_TERMINATION);
status_code = 1; status_code = 1;
continue; continue;
} }
// Send close messages to child first // Send close messages to child first
if (kill_child_processes) if (kill_child_processes)
{ send_close_messages_tree(info.pid);
send_close_messages_tree(pid); #endif
} process_name = process_list[i].p.szExeFile;
info.found = FALSE;
get_process_name_from_pid(pid, process_name, MAX_PATH); WINE_TRACE("Terminating pid %04lx.\n", info.pid);
EnumWindows(pid_enum_proc, (LPARAM)&info); EnumWindows(pid_enum_proc, (LPARAM)&info);
if (info.found) if (info.found)
{ {
if (is_numeric) if (kill_child_processes)
{ taskkill_message_printfW(STRING_CLOSE_CHILD, info.pid, process_list[i].p.th32ParentProcessID);
taskkill_message_printfW(STRING_CLOSE_PID_SEARCH, pid); else if (process_list[i].is_numeric)
} taskkill_message_printfW(STRING_CLOSE_PID_SEARCH, info.pid);
else else
{ taskkill_message_printfW(STRING_CLOSE_PROC_SRCH, process_name, info.pid);
taskkill_message_printfW(STRING_CLOSE_PROC_SRCH, process_name, pid); continue;
}
}
} }
taskkill_message_print_process(STRING_SEARCH_FAILED, i);
status_code = 128;
} }
HeapFree(GetProcessHeap(), 0, pkill_list);
HeapFree(GetProcessHeap(), 0, pid_list);
return status_code; return status_code;
} }
#ifdef __REACTOS__
static void terminate_process_tree(DWORD ppid) static void terminate_process_tree(DWORD ppid)
{ {
FILETIME parent_creation_time = { 0 }; FILETIME parent_creation_time = { 0 };
@ -434,7 +523,7 @@ static void terminate_process_tree(DWORD ppid)
if (pe.th32ParentProcessID == ppid && if (pe.th32ParentProcessID == ppid &&
CompareFileTime(&parent_creation_time, &child_creation_time) < 0) CompareFileTime(&parent_creation_time, &child_creation_time) < 0)
{ {
HANDLE process = INVALID_HANDLE_VALUE; HANDLE process;
// Use recursion to browse all child processes // Use recursion to browse all child processes
terminate_process_tree(pe.th32ProcessID); terminate_process_tree(pe.th32ProcessID);
@ -444,7 +533,7 @@ static void terminate_process_tree(DWORD ppid)
continue; continue;
} }
if (!TerminateProcess(process, 0)) if (!TerminateProcess(process, 1))
{ {
taskkill_message_printfW(STRING_TERM_CHILD_FAILED, pe.th32ProcessID, ppid); taskkill_message_printfW(STRING_TERM_CHILD_FAILED, pe.th32ProcessID, ppid);
CloseHandle(process); CloseHandle(process);
@ -460,124 +549,70 @@ static void terminate_process_tree(DWORD ppid)
CloseHandle(h); CloseHandle(h);
} }
#endif // __REACTOS__
static int terminate_processes(void) static int terminate_processes(void)
{ {
DWORD *pid_list, pid_list_size, *pkill_list; const WCHAR *process_name;
DWORD self_pid = GetCurrentProcessId();
unsigned int i; unsigned int i;
int status_code = 0; int status_code = 0;
HANDLE process;
DWORD pid;
pid_list = enumerate_processes(&pid_list_size); #ifdef __REACTOS__
if (!pid_list) DWORD index;
for (index = 0; index < pkill_size; ++index)
#else
for (i = 0; i < process_count; i++)
#endif
{ {
taskkill_message(STRING_ENUM_FAILED); #ifdef __REACTOS__
return 1; i = pkill_list[index];
} #else
if (!process_list[i].matched)
pkill_list = HeapAlloc(GetProcessHeap(), 0, pid_list_size * sizeof(DWORD));
if (!pkill_list)
return 1;
for (i = 0; i < task_count; i++)
{
WCHAR *p = task_list[i];
BOOL is_numeric = TRUE;
DWORD pkill_size = 0, index = 0;
memset(pkill_list, 0, pid_list_size * sizeof(DWORD));
/* Determine whether the string is not numeric. */
while (*p)
{
if (!isdigitW(*p++))
{
is_numeric = FALSE;
break;
}
}
// Find processes to kill
if (is_numeric)
{
WCHAR ps_name[MAX_PATH] = { 0 };
if (get_process_name_from_pid(atoiW(task_list[i]), ps_name, MAX_PATH))
{
pkill_list[pkill_size] = atoiW(task_list[i]);
pkill_size++;
}
}
else
{
for (index = 0; index < pid_list_size; index++)
{
WCHAR process_name[MAX_PATH];
if (get_process_name_from_pid(pid_list[index], process_name, MAX_PATH) &&
!strcmpiW(process_name, task_list[i]))
{
pkill_list[pkill_size] = pid_list[index];
pkill_size++;
}
}
}
// Can't find any process same as name or PID
if (!pkill_size)
{
taskkill_message_printfW(STRING_SEARCH_FAILED, task_list[i]);
status_code = 128;
continue; continue;
} #endif
// Try to terminate to process in `pkill_list`
for (index = 0; index < pkill_size; index++)
{
DWORD pid = pkill_list[index];
WCHAR process_name[MAX_PATH] = { 0 };
HANDLE process = INVALID_HANDLE_VALUE;
pid = process_list[i].p.th32ProcessID;
#ifdef __REACTOS__
if (pid == self_pid) if (pid == self_pid)
{ {
taskkill_message(STRING_SELF_TERMINATION); taskkill_message(STRING_SELF_TERMINATION);
status_code = 1; status_code = 1;
continue; continue;
} }
// Terminate child first // Terminate child first
if (kill_child_processes) if (kill_child_processes)
{
terminate_process_tree(pid); terminate_process_tree(pid);
} #endif
process_name = process_list[i].p.szExeFile;
process = OpenProcess(PROCESS_TERMINATE, FALSE, pid); process = OpenProcess(PROCESS_TERMINATE, FALSE, pid);
if (get_process_name_from_pid(pid, process_name, MAX_PATH) && !process) if (!process)
{ {
taskkill_message_printfW(STRING_SEARCH_FAILED, task_list[i]); taskkill_message_print_process(STRING_SEARCH_FAILED, i);
status_code = 128; status_code = 128;
continue; continue;
} }
if (!TerminateProcess(process, 1))
if (!TerminateProcess(process, 0))
{ {
taskkill_message_printfW(STRING_TERMINATE_FAILED, process_name); #ifdef __REACTOS__
if (kill_child_processes)
taskkill_message_printfW(STRING_TERM_CHILD_FAILED, pid, process_list[i].p.th32ParentProcessID);
else
#endif
taskkill_message_print_process(STRING_TERMINATE_FAILED, i);
status_code = 1; status_code = 1;
CloseHandle(process); CloseHandle(process);
continue; continue;
} }
if (kill_child_processes)
if (is_numeric) taskkill_message_printfW(STRING_TERM_CHILD, pid, process_list[i].p.th32ParentProcessID);
{ else if (process_list[i].is_numeric)
taskkill_message_printfW(STRING_TERM_PID_SEARCH, pid); taskkill_message_printfW(STRING_TERM_PID_SEARCH, pid);
}
else else
{
taskkill_message_printfW(STRING_TERM_PROC_SEARCH, process_name, pid); taskkill_message_printfW(STRING_TERM_PROC_SEARCH, process_name, pid);
}
CloseHandle(process); CloseHandle(process);
} }
}
HeapFree(GetProcessHeap(), 0, pkill_list);
HeapFree(GetProcessHeap(), 0, pid_list);
return status_code; return status_code;
} }
@ -587,8 +622,7 @@ static BOOL add_to_task_list(WCHAR *name)
if (!task_list) if (!task_list)
{ {
task_list = HeapAlloc(GetProcessHeap(), 0, task_list = malloc(list_size * sizeof(*task_list));
list_size * sizeof(*task_list));
if (!task_list) if (!task_list)
return FALSE; return FALSE;
} }
@ -597,8 +631,7 @@ static BOOL add_to_task_list(WCHAR *name)
void *realloc_list; void *realloc_list;
list_size *= 2; list_size *= 2;
realloc_list = HeapReAlloc(GetProcessHeap(), 0, task_list, realloc_list = realloc(task_list, list_size * sizeof(*task_list));
list_size * sizeof(*task_list));
if (!realloc_list) if (!realloc_list)
return FALSE; return FALSE;
@ -623,7 +656,7 @@ static int get_argument_type(WCHAR* argument)
for (i = 0; i < _countof(opList); i++) for (i = 0; i < _countof(opList); i++)
{ {
if (!strcmpiW(opList[i], argument)) if (!wcsicmp(opList[i], argument))
{ {
return i; return i;
} }
@ -757,12 +790,6 @@ static BOOL process_arguments(int argc, WCHAR* argv[])
* options are detected as parameters when placed after options that accept one. */ * options are detected as parameters when placed after options that accept one. */
static BOOL process_arguments(int argc, WCHAR *argv[]) static BOOL process_arguments(int argc, WCHAR *argv[])
{ {
static const WCHAR opForceTerminate[] = {'f',0};
static const WCHAR opImage[] = {'i','m',0};
static const WCHAR opPID[] = {'p','i','d',0};
static const WCHAR opHelp[] = {'?',0};
static const WCHAR opTerminateChildren[] = {'t',0};
if (argc > 1) if (argc > 1)
{ {
int i; int i;
@ -773,7 +800,7 @@ static BOOL process_arguments(int argc, WCHAR *argv[])
if (argc == 2) if (argc == 2)
{ {
argdata = argv[1]; argdata = argv[1];
if ((*argdata == '/' || *argdata == '-') && !strcmpW(opHelp, argdata + 1)) if ((*argdata == '/' || *argdata == '-') && !lstrcmpW(L"?", argdata + 1))
{ {
taskkill_message(STRING_USAGE); taskkill_message(STRING_USAGE);
exit(0); exit(0);
@ -789,14 +816,14 @@ static BOOL process_arguments(int argc, WCHAR *argv[])
goto invalid; goto invalid;
argdata++; argdata++;
if (!strcmpiW(opTerminateChildren, argdata)) if (!wcsicmp(L"t", argdata))
kill_child_processes = TRUE; kill_child_processes = TRUE;
else if (!strcmpiW(opForceTerminate, argdata)) else if (!wcsicmp(L"f", argdata))
force_termination = TRUE; force_termination = TRUE;
/* Options /IM and /PID appear to behave identically, except for /* Options /IM and /PID appear to behave identically, except for
* the fact that they cannot be specified at the same time. */ * the fact that they cannot be specified at the same time. */
else if ((got_im = !strcmpiW(opImage, argdata)) || else if ((got_im = !wcsicmp(L"im", argdata)) ||
(got_pid = !strcmpiW(opPID, argdata))) (got_pid = !wcsicmp(L"pid", argdata)))
{ {
if (!argv[i + 1]) if (!argv[i + 1])
{ {
@ -842,19 +869,37 @@ static BOOL process_arguments(int argc, WCHAR *argv[])
int wmain(int argc, WCHAR *argv[]) int wmain(int argc, WCHAR *argv[])
{ {
int status_code = 0; int search_status = 0, terminate_status;
unsigned int i;
if (!process_arguments(argc, argv)) if (!process_arguments(argc, argv))
return 1;
if (!enumerate_processes())
{ {
HeapFree(GetProcessHeap(), 0, task_list); taskkill_message(STRING_ENUM_FAILED);
return 1; return 1;
} }
if (force_termination) #ifdef __REACTOS__
status_code = terminate_processes(); pkill_list = malloc(process_count * sizeof(unsigned int*));
else if (!pkill_list)
status_code = send_close_messages(); return 1;
memset(pkill_list, 0, process_count * sizeof(unsigned int*));
pkill_size = 0;
HeapFree(GetProcessHeap(), 0, task_list); self_pid = GetCurrentProcessId();
return status_code; #endif
for (i = 0; i < task_count; ++i)
mark_task_process(task_list[i], &search_status);
#ifndef __REACTOS__
if (kill_child_processes)
mark_child_processes();
#endif
if (force_termination)
terminate_status = terminate_processes();
else
terminate_status = send_close_messages();
return search_status ? search_status : terminate_status;
} }