/* * Server-side process management * * Copyright (C) 1998 Alexandre Julliard * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library 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 * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA */ #include "config.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef HAVE_SYS_PARAM_H # include #endif #ifdef HAVE_SYS_QUEUE_H # include #endif #ifdef HAVE_SYS_SYSCTL_H # include #endif #ifdef HAVE_SYS_USER_H # define thread __unix_thread # include # undef thread #endif #ifdef HAVE_LIBPROCSTAT # include #endif #include "ntstatus.h" #define WIN32_NO_STATUS #include "winternl.h" #include "file.h" #include "handle.h" #include "process.h" #include "thread.h" #include "request.h" #include "user.h" #include "security.h" /* process object */ static struct list process_list = LIST_INIT(process_list); static int running_processes, user_processes; static struct event *shutdown_event; /* signaled when shutdown starts */ static struct timeout_user *shutdown_timeout; /* timeout for server shutdown */ static int shutdown_stage; /* current stage in the shutdown process */ static const WCHAR process_name[] = {'P','r','o','c','e','s','s'}; struct type_descr process_type = { { process_name, sizeof(process_name) }, /* name */ PROCESS_ALL_ACCESS, /* valid_access */ { /* mapping */ STANDARD_RIGHTS_READ | PROCESS_VM_READ | PROCESS_QUERY_INFORMATION, STANDARD_RIGHTS_WRITE | PROCESS_SUSPEND_RESUME | PROCESS_SET_INFORMATION | PROCESS_SET_QUOTA | PROCESS_CREATE_PROCESS | PROCESS_DUP_HANDLE | PROCESS_VM_WRITE | PROCESS_VM_OPERATION | PROCESS_CREATE_THREAD, STANDARD_RIGHTS_EXECUTE | SYNCHRONIZE | PROCESS_QUERY_LIMITED_INFORMATION | PROCESS_TERMINATE, PROCESS_ALL_ACCESS }, }; static void process_dump( struct object *obj, int verbose ); static int process_signaled( struct object *obj, struct wait_queue_entry *entry ); static unsigned int process_map_access( struct object *obj, unsigned int access ); static struct security_descriptor *process_get_sd( struct object *obj ); static void process_poll_event( struct fd *fd, int event ); static struct list *process_get_kernel_obj_list( struct object *obj ); static void process_destroy( struct object *obj ); static void terminate_process( struct process *process, struct thread *skip, int exit_code ); static const struct object_ops process_ops = { sizeof(struct process), /* size */ &process_type, /* type */ process_dump, /* dump */ add_queue, /* add_queue */ remove_queue, /* remove_queue */ process_signaled, /* signaled */ no_satisfied, /* satisfied */ no_signal, /* signal */ no_get_fd, /* get_fd */ process_map_access, /* map_access */ process_get_sd, /* get_sd */ default_set_sd, /* set_sd */ no_get_full_name, /* get_full_name */ no_lookup_name, /* lookup_name */ no_link_name, /* link_name */ NULL, /* unlink_name */ no_open_file, /* open_file */ process_get_kernel_obj_list, /* get_kernel_obj_list */ no_close_handle, /* close_handle */ process_destroy /* destroy */ }; static const struct fd_ops process_fd_ops = { NULL, /* get_poll_events */ process_poll_event, /* poll_event */ NULL, /* flush */ NULL, /* get_fd_type */ NULL, /* ioctl */ NULL, /* queue_async */ NULL, /* reselect_async */ NULL /* cancel async */ }; /* process startup info */ struct startup_info { struct object obj; /* object header */ struct process *process; /* created process */ data_size_t info_size; /* size of startup info */ data_size_t data_size; /* size of whole startup data */ startup_info_t *data; /* data for startup info */ }; static void startup_info_dump( struct object *obj, int verbose ); static int startup_info_signaled( struct object *obj, struct wait_queue_entry *entry ); static void startup_info_destroy( struct object *obj ); static const struct object_ops startup_info_ops = { sizeof(struct startup_info), /* size */ &no_type, /* type */ startup_info_dump, /* dump */ add_queue, /* add_queue */ remove_queue, /* remove_queue */ startup_info_signaled, /* signaled */ no_satisfied, /* satisfied */ no_signal, /* signal */ no_get_fd, /* get_fd */ default_map_access, /* map_access */ default_get_sd, /* get_sd */ default_set_sd, /* set_sd */ no_get_full_name, /* get_full_name */ no_lookup_name, /* lookup_name */ no_link_name, /* link_name */ NULL, /* unlink_name */ no_open_file, /* open_file */ no_kernel_obj_list, /* get_kernel_obj_list */ no_close_handle, /* close_handle */ startup_info_destroy /* destroy */ }; /* job object */ static const WCHAR job_name[] = {'J','o','b'}; struct type_descr job_type = { { job_name, sizeof(job_name) }, /* name */ JOB_OBJECT_ALL_ACCESS, /* valid_access */ { /* mapping */ STANDARD_RIGHTS_READ | JOB_OBJECT_QUERY, STANDARD_RIGHTS_WRITE | JOB_OBJECT_TERMINATE | JOB_OBJECT_SET_ATTRIBUTES | JOB_OBJECT_ASSIGN_PROCESS, STANDARD_RIGHTS_EXECUTE | SYNCHRONIZE, JOB_OBJECT_ALL_ACCESS }, }; static void job_dump( struct object *obj, int verbose ); static int job_signaled( struct object *obj, struct wait_queue_entry *entry ); static int job_close_handle( struct object *obj, struct process *process, obj_handle_t handle ); static void job_destroy( struct object *obj ); struct job { struct object obj; /* object header */ struct list process_list; /* list of processes */ int num_processes; /* count of running processes */ int total_processes; /* count of processes which have been assigned */ unsigned int limit_flags; /* limit flags */ int terminating; /* job is terminating */ int signaled; /* job is signaled */ struct completion *completion_port; /* associated completion port */ apc_param_t completion_key; /* key to send with completion messages */ struct job *parent; struct list parent_job_entry; /* list entry for parent job */ struct list child_job_list; /* list of child jobs */ }; static const struct object_ops job_ops = { sizeof(struct job), /* size */ &job_type, /* type */ job_dump, /* dump */ add_queue, /* add_queue */ remove_queue, /* remove_queue */ job_signaled, /* signaled */ no_satisfied, /* satisfied */ no_signal, /* signal */ no_get_fd, /* get_fd */ default_map_access, /* map_access */ default_get_sd, /* get_sd */ default_set_sd, /* set_sd */ default_get_full_name, /* get_full_name */ no_lookup_name, /* lookup_name */ directory_link_name, /* link_name */ default_unlink_name, /* unlink_name */ no_open_file, /* open_file */ no_kernel_obj_list, /* get_kernel_obj_list */ job_close_handle, /* close_handle */ job_destroy /* destroy */ }; static struct job *create_job_object( struct object *root, const struct unicode_str *name, unsigned int attr, const struct security_descriptor *sd ) { struct job *job; if ((job = create_named_object( root, &job_ops, name, attr, sd ))) { if (get_error() != STATUS_OBJECT_NAME_EXISTS) { /* initialize it if it didn't already exist */ list_init( &job->process_list ); list_init( &job->child_job_list ); job->num_processes = 0; job->total_processes = 0; job->limit_flags = 0; job->terminating = 0; job->signaled = 0; job->completion_port = NULL; job->completion_key = 0; job->parent = NULL; } } return job; } static struct job *get_job_obj( struct process *process, obj_handle_t handle, unsigned int access ) { return (struct job *)get_handle_obj( process, handle, access, &job_ops ); } static void add_job_completion( struct job *job, apc_param_t msg, apc_param_t pid ) { if (job->completion_port) add_completion( job->completion_port, job->completion_key, pid, STATUS_SUCCESS, msg ); } static void add_job_completion_existing_processes( struct job *job, struct job *completion_job ) { struct process *process; struct job *j; assert( completion_job->obj.ops == &job_ops ); LIST_FOR_EACH_ENTRY( j, &job->child_job_list, struct job, parent_job_entry ) { add_job_completion_existing_processes( j, completion_job ); } LIST_FOR_EACH_ENTRY( process, &job->process_list, struct process, job_entry ) { if (process->running_threads) add_job_completion( completion_job, JOB_OBJECT_MSG_NEW_PROCESS, get_process_id( process )); } } static int process_in_job( struct job *job, struct process *process ) { struct job *j; LIST_FOR_EACH_ENTRY( j, &job->child_job_list, struct job, parent_job_entry ) { assert( j->parent == job ); if (process_in_job( j, process )) return 1; } return process->job == job; } static process_id_t *get_job_pids( struct job *job, process_id_t *pids, process_id_t *end ) { struct process *process; struct job *j; LIST_FOR_EACH_ENTRY( j, &job->child_job_list, struct job, parent_job_entry ) pids = get_job_pids( j, pids, end ); LIST_FOR_EACH_ENTRY( process, &job->process_list, struct process, job_entry ) { if (pids == end) break; if (process->end_time) continue; /* skip processes that ended */ *pids++ = process->id; } return pids; } static void add_job_process( struct job *job, struct process *process ) { struct job *j, *common_parent; process_id_t pid; if (job == process->job) return; if ((common_parent = process->job)) { if (job->parent) { for (j = job->parent; j; j = j->parent) if (j == common_parent) break; if (j != common_parent) { /* Job already has parent and the process is not in the job's chain. */ set_error( STATUS_ACCESS_DENIED ); return; } /* process->job is referenced in the job->parent chain. */ release_object( process->job ); } else { if (job->total_processes) { set_error( STATUS_ACCESS_DENIED ); return; } /* transfer reference. */ job->parent = process->job; list_add_tail( &job->parent->child_job_list, &job->parent_job_entry ); } list_remove( &process->job_entry ); } process->job = (struct job *)grab_object( job ); list_add_tail( &job->process_list, &process->job_entry ); pid = get_process_id( process ); for (j = job; j != common_parent; j = j->parent) { j->num_processes++; j->total_processes++; add_job_completion( j, JOB_OBJECT_MSG_NEW_PROCESS, pid ); } } /* called when a process has terminated, allow one additional process */ static void release_job_process( struct process *process ) { struct job *job = process->job; while (job) { assert( job->num_processes ); job->num_processes--; if (!job->terminating) add_job_completion( job, JOB_OBJECT_MSG_EXIT_PROCESS, get_process_id(process) ); if (!job->num_processes) add_job_completion( job, JOB_OBJECT_MSG_ACTIVE_PROCESS_ZERO, 0 ); job = job->parent; } } static void terminate_job( struct job *job, int exit_code ) { struct process *process, *next_process; struct job *j, *next_job; LIST_FOR_EACH_ENTRY_SAFE( j, next_job, &job->child_job_list, struct job, parent_job_entry ) { assert( j->parent == job ); grab_object( j ); terminate_job( j, exit_code ); release_object( j ); } job->terminating = 1; LIST_FOR_EACH_ENTRY_SAFE( process, next_process, &job->process_list, struct process, job_entry ) { assert( process->job == job ); if (process->running_threads) terminate_process( process, NULL, exit_code ); } job->terminating = 0; job->signaled = 1; wake_up( &job->obj, 0 ); } static int job_close_handle( struct object *obj, struct process *process, obj_handle_t handle ) { struct job *job = (struct job *)obj; assert( obj->ops == &job_ops ); if (obj->handle_count == 1) /* last handle */ { if (job->limit_flags & JOB_OBJECT_LIMIT_KILL_ON_JOB_CLOSE) terminate_job( job, 0 ); } return 1; } static void job_destroy( struct object *obj ) { struct job *job = (struct job *)obj; assert( obj->ops == &job_ops ); assert( !job->num_processes ); assert( list_empty( &job->process_list )); assert( list_empty( &job->child_job_list )); if (job->completion_port) release_object( job->completion_port ); if (job->parent) { list_remove( &job->parent_job_entry ); release_object( job->parent ); } } static void job_dump( struct object *obj, int verbose ) { struct job *job = (struct job *)obj; assert( obj->ops == &job_ops ); fprintf( stderr, "Job processes=%d child_jobs=%d parent=%p\n", list_count(&job->process_list), list_count(&job->child_job_list), job->parent ); } static int job_signaled( struct object *obj, struct wait_queue_entry *entry ) { struct job *job = (struct job *)obj; return job->signaled; } struct ptid_entry { void *ptr; /* entry ptr */ unsigned int next; /* next free entry */ }; static struct ptid_entry *ptid_entries; /* array of ptid entries */ static unsigned int used_ptid_entries; /* number of entries in use */ static unsigned int alloc_ptid_entries; /* number of allocated entries */ static unsigned int next_free_ptid; /* next free entry */ static unsigned int last_free_ptid; /* last free entry */ static unsigned int num_free_ptids; /* number of free ptids */ static void kill_all_processes(void); #define PTID_OFFSET 8 /* offset for first ptid value */ static unsigned int index_from_ptid(unsigned int id) { return id / 4; } static unsigned int ptid_from_index(unsigned int index) { return index * 4; } /* allocate a new process or thread id */ unsigned int alloc_ptid( void *ptr ) { struct ptid_entry *entry; unsigned int index; if (used_ptid_entries < alloc_ptid_entries) { index = used_ptid_entries + PTID_OFFSET; entry = &ptid_entries[used_ptid_entries++]; } else if (next_free_ptid && num_free_ptids >= 256) { index = next_free_ptid; entry = &ptid_entries[index - PTID_OFFSET]; if (!(next_free_ptid = entry->next)) last_free_ptid = 0; num_free_ptids--; } else /* need to grow the array */ { unsigned int count = alloc_ptid_entries + (alloc_ptid_entries / 2); if (!count) count = 512; if (!(entry = realloc( ptid_entries, count * sizeof(*entry) ))) { set_error( STATUS_NO_MEMORY ); return 0; } ptid_entries = entry; alloc_ptid_entries = count; index = used_ptid_entries + PTID_OFFSET; entry = &ptid_entries[used_ptid_entries++]; } entry->ptr = ptr; return ptid_from_index( index ); } /* free a process or thread id */ void free_ptid( unsigned int id ) { unsigned int index = index_from_ptid( id ); struct ptid_entry *entry = &ptid_entries[index - PTID_OFFSET]; entry->ptr = NULL; entry->next = 0; /* append to end of free list so that we don't reuse it too early */ if (last_free_ptid) ptid_entries[last_free_ptid - PTID_OFFSET].next = index; else next_free_ptid = index; last_free_ptid = index; num_free_ptids++; } /* retrieve the pointer corresponding to a process or thread id */ void *get_ptid_entry( unsigned int id ) { unsigned int index = index_from_ptid( id ); if (index < PTID_OFFSET) return NULL; if (index - PTID_OFFSET >= used_ptid_entries) return NULL; return ptid_entries[index - PTID_OFFSET].ptr; } /* return the main thread of the process */ struct thread *get_process_first_thread( struct process *process ) { struct list *ptr = list_head( &process->thread_list ); if (!ptr) return NULL; return LIST_ENTRY( ptr, struct thread, proc_entry ); } /* set the state of the process startup info */ static void set_process_startup_state( struct process *process, enum startup_state state ) { if (process->startup_state == STARTUP_IN_PROGRESS) process->startup_state = state; if (process->startup_info) { wake_up( &process->startup_info->obj, 0 ); release_object( process->startup_info ); process->startup_info = NULL; } } /* callback for server shutdown */ static void server_shutdown_timeout( void *arg ) { shutdown_timeout = NULL; if (!running_processes) { close_master_socket( 0 ); return; } switch(++shutdown_stage) { case 1: /* signal system processes to exit */ if (debug_level) fprintf( stderr, "wineserver: shutting down\n" ); if (shutdown_event) set_event( shutdown_event ); shutdown_timeout = add_timeout_user( 2 * -TICKS_PER_SEC, server_shutdown_timeout, NULL ); close_master_socket( 4 * -TICKS_PER_SEC ); break; case 2: /* now forcibly kill all processes (but still wait for SIGKILL timeouts) */ kill_all_processes(); break; } } /* forced shutdown, used for wineserver -k */ void shutdown_master_socket(void) { kill_all_processes(); shutdown_stage = 2; if (shutdown_timeout) { remove_timeout_user( shutdown_timeout ); shutdown_timeout = NULL; } close_master_socket( 2 * -TICKS_PER_SEC ); /* for SIGKILL timeouts */ } /* final cleanup once we are sure a process is really dead */ static void process_died( struct process *process ) { if (debug_level) fprintf( stderr, "%04x: *process killed*\n", process->id ); if (!process->is_system) { if (!--user_processes && !shutdown_stage && master_socket_timeout != TIMEOUT_INFINITE) shutdown_timeout = add_timeout_user( master_socket_timeout, server_shutdown_timeout, NULL ); } release_object( process ); if (!--running_processes && shutdown_stage) close_master_socket( 0 ); } /* callback for process sigkill timeout */ static void process_sigkill( void *private ) { struct process *process = private; int signal = 0; process->sigkill_delay *= 2; if (process->sigkill_delay >= TICKS_PER_SEC / 2) signal = SIGKILL; if (!kill( process->unix_pid, signal ) && !signal) process->sigkill_timeout = add_timeout_user( -process->sigkill_delay, process_sigkill, process ); else { process->sigkill_delay = TICKS_PER_SEC / 64; process->sigkill_timeout = NULL; process_died( process ); } } /* start the sigkill timer for a process upon exit */ static void start_sigkill_timer( struct process *process ) { grab_object( process ); if (process->unix_pid != -1) process->sigkill_timeout = add_timeout_user( -process->sigkill_delay, process_sigkill, process ); else process_died( process ); } /* create a new process */ /* if the function fails the fd is closed */ struct process *create_process( int fd, struct process *parent, unsigned int flags, const startup_info_t *info, const struct security_descriptor *sd, const obj_handle_t *handles, unsigned int handle_count, struct token *token ) { struct process *process; if (!(process = alloc_object( &process_ops ))) { close( fd ); goto error; } process->parent_id = 0; process->debug_obj = NULL; process->debug_event = NULL; process->handles = NULL; process->msg_fd = NULL; process->sigkill_timeout = NULL; process->sigkill_delay = TICKS_PER_SEC / 64; process->unix_pid = -1; process->exit_code = STILL_ACTIVE; process->running_threads = 0; process->priority = PROCESS_PRIOCLASS_NORMAL; process->suspend = 0; process->is_system = 0; process->debug_children = 1; process->is_terminating = 0; process->imagelen = 0; process->image = NULL; process->job = NULL; process->console = NULL; process->startup_state = STARTUP_IN_PROGRESS; process->startup_info = NULL; process->idle_event = NULL; process->peb = 0; process->ldt_copy = 0; process->dir_cache = NULL; process->winstation = 0; process->desktop = 0; process->token = NULL; process->trace_data = 0; process->rawinput_mouse = NULL; process->rawinput_kbd = NULL; memset( &process->image_info, 0, sizeof(process->image_info) ); list_init( &process->kernel_object ); list_init( &process->thread_list ); list_init( &process->locks ); list_init( &process->asyncs ); list_init( &process->classes ); list_init( &process->views ); list_init( &process->rawinput_devices ); process->end_time = 0; if (sd && !default_set_sd( &process->obj, sd, OWNER_SECURITY_INFORMATION | GROUP_SECURITY_INFORMATION | DACL_SECURITY_INFORMATION | SACL_SECURITY_INFORMATION )) { close( fd ); goto error; } if (!(process->id = process->group_id = alloc_ptid( process ))) { close( fd ); goto error; } if (!(process->msg_fd = create_anonymous_fd( &process_fd_ops, fd, &process->obj, 0 ))) goto error; /* create the handle table */ if (!parent) { process->handles = alloc_handle_table( process, 0 ); process->token = token_create_admin( TRUE, -1, TokenElevationTypeFull, default_session_id ); process->affinity = ~0; } else { obj_handle_t std_handles[3]; std_handles[0] = info->hstdin; std_handles[1] = info->hstdout; std_handles[2] = info->hstderr; process->parent_id = parent->id; if (flags & PROCESS_CREATE_FLAGS_INHERIT_HANDLES) process->handles = copy_handle_table( process, parent, handles, handle_count, std_handles ); else process->handles = alloc_handle_table( process, 0 ); /* Note: for security reasons, starting a new process does not attempt * to use the current impersonation token for the new process */ process->token = token_duplicate( token ? token : parent->token, TRUE, 0, NULL, NULL, 0, NULL, 0 ); process->affinity = parent->affinity; } if (!process->handles || !process->token) goto error; process->session_id = token_get_session_id( process->token ); /* Assign a high security label to the token. The default would be medium * but Wine provides admin access to all applications right now so high * makes more sense for the time being. */ if (!token_assign_label( process->token, &high_label_sid )) goto error; set_fd_events( process->msg_fd, POLLIN ); /* start listening to events */ return process; error: if (process) release_object( process ); /* if we failed to start our first process, close everything down */ if (!running_processes && master_socket_timeout != TIMEOUT_INFINITE) close_master_socket( 0 ); return NULL; } /* get the process data size */ data_size_t get_process_startup_info_size( struct process *process ) { struct startup_info *info = process->startup_info; if (!info) return 0; return info->data_size; } /* destroy a process when its refcount is 0 */ static void process_destroy( struct object *obj ) { struct process *process = (struct process *)obj; assert( obj->ops == &process_ops ); /* we can't have a thread remaining */ assert( list_empty( &process->thread_list )); assert( list_empty( &process->asyncs )); assert( !process->sigkill_timeout ); /* timeout should hold a reference to the process */ close_process_handles( process ); set_process_startup_state( process, STARTUP_ABORTED ); if (process->job) { list_remove( &process->job_entry ); release_object( process->job ); } if (process->console) release_object( process->console ); if (process->msg_fd) release_object( process->msg_fd ); if (process->idle_event) release_object( process->idle_event ); if (process->id) free_ptid( process->id ); if (process->token) release_object( process->token ); free( process->dir_cache ); free( process->image ); } /* dump a process on stdout for debugging purposes */ static void process_dump( struct object *obj, int verbose ) { struct process *process = (struct process *)obj; assert( obj->ops == &process_ops ); fprintf( stderr, "Process id=%04x handles=%p\n", process->id, process->handles ); } static int process_signaled( struct object *obj, struct wait_queue_entry *entry ) { struct process *process = (struct process *)obj; return !process->running_threads; } static unsigned int process_map_access( struct object *obj, unsigned int access ) { access = default_map_access( obj, access ); if (access & PROCESS_QUERY_INFORMATION) access |= PROCESS_QUERY_LIMITED_INFORMATION; if (access & PROCESS_SET_INFORMATION) access |= PROCESS_SET_LIMITED_INFORMATION; return access; } static struct list *process_get_kernel_obj_list( struct object *obj ) { struct process *process = (struct process *)obj; return &process->kernel_object; } static struct security_descriptor *process_get_sd( struct object *obj ) { static struct security_descriptor *process_default_sd; if (obj->sd) return obj->sd; if (!process_default_sd) { struct ace *ace; struct acl *dacl; struct sid *sid; size_t users_sid_len = sid_len( &domain_users_sid ); size_t admins_sid_len = sid_len( &builtin_admins_sid ); size_t dacl_len = sizeof(*dacl) + 2 * sizeof(*ace) + users_sid_len + admins_sid_len; process_default_sd = mem_alloc( sizeof(*process_default_sd) + admins_sid_len + users_sid_len + dacl_len ); process_default_sd->control = SE_DACL_PRESENT; process_default_sd->owner_len = admins_sid_len; process_default_sd->group_len = users_sid_len; process_default_sd->sacl_len = 0; process_default_sd->dacl_len = dacl_len; sid = (struct sid *)(process_default_sd + 1); sid = copy_sid( sid, &builtin_admins_sid ); sid = copy_sid( sid, &domain_users_sid ); dacl = (struct acl *)((char *)(process_default_sd + 1) + admins_sid_len + users_sid_len); dacl->revision = ACL_REVISION; dacl->pad1 = 0; dacl->size = dacl_len; dacl->count = 2; dacl->pad2 = 0; ace = set_ace( ace_first( dacl ), &domain_users_sid, ACCESS_ALLOWED_ACE_TYPE, INHERIT_ONLY_ACE | CONTAINER_INHERIT_ACE, GENERIC_READ ); set_ace( ace_next( ace ), &builtin_admins_sid, ACCESS_ALLOWED_ACE_TYPE, 0, PROCESS_ALL_ACCESS ); } return process_default_sd; } static void process_poll_event( struct fd *fd, int event ) { struct process *process = get_fd_user( fd ); assert( process->obj.ops == &process_ops ); if (event & (POLLERR | POLLHUP)) kill_process( process, 0 ); else if (event & POLLIN) receive_fd( process ); } static void startup_info_destroy( struct object *obj ) { struct startup_info *info = (struct startup_info *)obj; assert( obj->ops == &startup_info_ops ); free( info->data ); if (info->process) release_object( info->process ); } static void startup_info_dump( struct object *obj, int verbose ) { struct startup_info *info = (struct startup_info *)obj; assert( obj->ops == &startup_info_ops ); fputs( "Startup info", stderr ); if (info->data) fprintf( stderr, " in=%04x out=%04x err=%04x", info->data->hstdin, info->data->hstdout, info->data->hstderr ); fputc( '\n', stderr ); } static int startup_info_signaled( struct object *obj, struct wait_queue_entry *entry ) { struct startup_info *info = (struct startup_info *)obj; return info->process && info->process->startup_state != STARTUP_IN_PROGRESS; } /* get a process from an id (and increment the refcount) */ struct process *get_process_from_id( process_id_t id ) { struct object *obj = get_ptid_entry( id ); if (obj && obj->ops == &process_ops) return (struct process *)grab_object( obj ); set_error( STATUS_INVALID_CID ); return NULL; } /* get a process from a handle (and increment the refcount) */ struct process *get_process_from_handle( obj_handle_t handle, unsigned int access ) { return (struct process *)get_handle_obj( current->process, handle, access, &process_ops ); } /* terminate a process with the given exit code */ static void terminate_process( struct process *process, struct thread *skip, int exit_code ) { struct thread *thread; grab_object( process ); /* make sure it doesn't get freed when threads die */ process->is_terminating = 1; restart: LIST_FOR_EACH_ENTRY( thread, &process->thread_list, struct thread, proc_entry ) { if (exit_code) thread->exit_code = exit_code; if (thread == skip) continue; if (thread->state == TERMINATED) continue; kill_thread( thread, 1 ); goto restart; } release_object( process ); } /* kill all processes */ static void kill_all_processes(void) { struct list *ptr; while ((ptr = list_head( &process_list ))) { struct process *process = LIST_ENTRY( ptr, struct process, entry ); terminate_process( process, NULL, 1 ); } } /* kill all processes being attached to a console renderer */ void kill_console_processes( struct thread *renderer, int exit_code ) { for (;;) /* restart from the beginning of the list every time */ { struct process *process; /* find the first process being attached to 'renderer' and still running */ LIST_FOR_EACH_ENTRY( process, &process_list, struct process, entry ) { if (process == renderer->process) continue; if (process->console && console_get_renderer( process->console ) == renderer) break; } if (&process->entry == &process_list) break; /* no process found */ terminate_process( process, NULL, exit_code ); } } /* a process has been killed (i.e. its last thread died) */ static void process_killed( struct process *process ) { struct list *ptr; assert( list_empty( &process->thread_list )); process->end_time = current_time; close_process_desktop( process ); process->winstation = 0; process->desktop = 0; cancel_process_asyncs( process ); close_process_handles( process ); if (process->idle_event) release_object( process->idle_event ); process->idle_event = NULL; assert( !process->console ); while ((ptr = list_head( &process->rawinput_devices ))) { struct rawinput_device_entry *entry = LIST_ENTRY( ptr, struct rawinput_device_entry, entry ); list_remove( &entry->entry ); free( entry ); } destroy_process_classes( process ); free_mapped_views( process ); free_process_user_handles( process ); remove_process_locks( process ); set_process_startup_state( process, STARTUP_ABORTED ); finish_process_tracing( process ); release_job_process( process ); start_sigkill_timer( process ); wake_up( &process->obj, 0 ); } /* add a thread to a process running threads list */ void add_process_thread( struct process *process, struct thread *thread ) { list_add_tail( &process->thread_list, &thread->proc_entry ); if (!process->running_threads++) { list_add_tail( &process_list, &process->entry ); running_processes++; if (!process->is_system) { if (!user_processes++ && shutdown_timeout) { remove_timeout_user( shutdown_timeout ); shutdown_timeout = NULL; } } } grab_object( thread ); } /* remove a thread from a process running threads list */ void remove_process_thread( struct process *process, struct thread *thread ) { assert( process->running_threads > 0 ); assert( !list_empty( &process->thread_list )); list_remove( &thread->proc_entry ); if (!--process->running_threads) { /* we have removed the last running thread, exit the process */ process->exit_code = thread->exit_code; generate_debug_event( thread, DbgExitProcessStateChange, process ); list_remove( &process->entry ); process_killed( process ); } else generate_debug_event( thread, DbgExitThreadStateChange, thread ); release_object( thread ); } /* suspend all the threads of a process */ void suspend_process( struct process *process ) { if (!process->suspend++) { struct list *ptr, *next; LIST_FOR_EACH_SAFE( ptr, next, &process->thread_list ) { struct thread *thread = LIST_ENTRY( ptr, struct thread, proc_entry ); if (!thread->suspend) stop_thread( thread ); } } } /* resume all the threads of a process */ void resume_process( struct process *process ) { assert (process->suspend > 0); if (!--process->suspend) { struct list *ptr, *next; LIST_FOR_EACH_SAFE( ptr, next, &process->thread_list ) { struct thread *thread = LIST_ENTRY( ptr, struct thread, proc_entry ); if (!thread->suspend) wake_thread( thread ); } } } /* kill a process on the spot */ void kill_process( struct process *process, int violent_death ) { if (!violent_death && process->msg_fd) /* normal termination on pipe close */ { release_object( process->msg_fd ); process->msg_fd = NULL; } if (process->sigkill_timeout) return; /* already waiting for it to die */ if (violent_death) terminate_process( process, NULL, 1 ); else { struct list *ptr; grab_object( process ); /* make sure it doesn't get freed when threads die */ while ((ptr = list_head( &process->thread_list ))) { struct thread *thread = LIST_ENTRY( ptr, struct thread, proc_entry ); kill_thread( thread, 0 ); } release_object( process ); } } /* detach all processes being debugged by a given thread */ void detach_debugged_processes( struct debug_obj *debug_obj, int exit_code ) { for (;;) /* restart from the beginning of the list every time */ { struct process *process; /* find the first process being debugged by 'debugger' and still running */ LIST_FOR_EACH_ENTRY( process, &process_list, struct process, entry ) if (process->debug_obj == debug_obj) break; if (&process->entry == &process_list) break; /* no process found */ if (exit_code) { process->debug_obj = NULL; terminate_process( process, NULL, exit_code ); } else debugger_detach( process, debug_obj ); } } void enum_processes( int (*cb)(struct process*, void*), void *user ) { struct list *ptr, *next; LIST_FOR_EACH_SAFE( ptr, next, &process_list ) { struct process *process = LIST_ENTRY( ptr, struct process, entry ); if ((cb)(process, user)) break; } } /* set the debugged flag in the process PEB */ int set_process_debug_flag( struct process *process, int flag ) { char data = (flag != 0); client_ptr_t peb32 = 0; if (!is_machine_64bit( process->machine ) && is_machine_64bit( native_machine )) peb32 = process->peb + 0x1000; /* BeingDebugged flag is the byte at offset 2 in the PEB */ if (peb32 && !write_process_memory( process, peb32 + 2, 1, &data )) return 0; return write_process_memory( process, process->peb + 2, 1, &data ); } /* create a new process */ DECL_HANDLER(new_process) { struct startup_info *info; const void *info_ptr; struct unicode_str name; const struct security_descriptor *sd; const struct object_attributes *objattr = get_req_object_attributes( &sd, &name, NULL ); struct process *process = NULL; struct token *token = NULL; struct debug_obj *debug_obj = NULL; struct process *parent; struct thread *parent_thread = current; int socket_fd = thread_get_inflight_fd( current, req->socket_fd ); const obj_handle_t *handles = NULL; const obj_handle_t *job_handles = NULL; unsigned int i, job_handle_count; struct job *job; if (socket_fd == -1) { set_error( STATUS_INVALID_PARAMETER ); return; } if (!objattr) { set_error( STATUS_INVALID_PARAMETER ); close( socket_fd ); return; } if (fcntl( socket_fd, F_SETFL, O_NONBLOCK ) == -1) { set_error( STATUS_INVALID_HANDLE ); close( socket_fd ); return; } if (shutdown_stage) { set_error( STATUS_SHUTDOWN_IN_PROGRESS ); close( socket_fd ); return; } if (req->parent_process) { if (!(parent = get_process_from_handle( req->parent_process, PROCESS_CREATE_PROCESS))) { close( socket_fd ); return; } parent_thread = NULL; } else parent = (struct process *)grab_object( current->process ); /* If a job further in the job chain does not permit breakaway process creation * succeeds and the process which is trying to breakaway is assigned to that job. */ if (parent->job && (req->flags & PROCESS_CREATE_FLAGS_BREAKAWAY) && !(parent->job->limit_flags & (JOB_OBJECT_LIMIT_BREAKAWAY_OK | JOB_OBJECT_LIMIT_SILENT_BREAKAWAY_OK))) { set_error( STATUS_ACCESS_DENIED ); close( socket_fd ); release_object( parent ); return; } /* build the startup info for a new process */ if (!(info = alloc_object( &startup_info_ops ))) { close( socket_fd ); release_object( parent ); return; } info->process = NULL; info->data = NULL; info_ptr = get_req_data_after_objattr( objattr, &info->data_size ); if ((req->handles_size & 3) || req->handles_size > info->data_size) { set_error( STATUS_INVALID_PARAMETER ); close( socket_fd ); goto done; } if (req->handles_size) { handles = info_ptr; info_ptr = (const char *)info_ptr + req->handles_size; info->data_size -= req->handles_size; } if ((req->jobs_size & 3) || req->jobs_size > info->data_size) { set_error( STATUS_INVALID_PARAMETER ); close( socket_fd ); goto done; } if (req->jobs_size) { job_handles = info_ptr; info_ptr = (const char *)info_ptr + req->jobs_size; info->data_size -= req->jobs_size; } job_handle_count = req->jobs_size / sizeof(*handles); for (i = 0; i < job_handle_count; ++i) { if (!(job = get_job_obj( current->process, job_handles[i], JOB_OBJECT_ASSIGN_PROCESS ))) { close( socket_fd ); goto done; } release_object( job ); } info->info_size = min( req->info_size, info->data_size ); if (req->info_size < sizeof(*info->data)) { /* make sure we have a full startup_info_t structure */ data_size_t env_size = info->data_size - info->info_size; data_size_t info_size = min( req->info_size, FIELD_OFFSET( startup_info_t, curdir_len )); if (!(info->data = mem_alloc( sizeof(*info->data) + env_size ))) { close( socket_fd ); goto done; } memcpy( info->data, info_ptr, info_size ); memset( (char *)info->data + info_size, 0, sizeof(*info->data) - info_size ); memcpy( info->data + 1, (const char *)info_ptr + req->info_size, env_size ); info->info_size = sizeof(startup_info_t); info->data_size = info->info_size + env_size; } else { data_size_t pos = sizeof(*info->data); if (!(info->data = memdup( info_ptr, info->data_size ))) { close( socket_fd ); goto done; } #define FIXUP_LEN(len) do { (len) = min( (len), info->info_size - pos ); pos += (len); } while(0) FIXUP_LEN( info->data->curdir_len ); FIXUP_LEN( info->data->dllpath_len ); FIXUP_LEN( info->data->imagepath_len ); FIXUP_LEN( info->data->cmdline_len ); FIXUP_LEN( info->data->title_len ); FIXUP_LEN( info->data->desktop_len ); FIXUP_LEN( info->data->shellinfo_len ); FIXUP_LEN( info->data->runtime_len ); #undef FIXUP_LEN } if (req->token && !(token = get_token_obj( current->process, req->token, TOKEN_QUERY | TOKEN_ASSIGN_PRIMARY ))) { close( socket_fd ); goto done; } if (req->debug && !(debug_obj = get_debug_obj( current->process, req->debug, DEBUG_PROCESS_ASSIGN ))) { close( socket_fd ); goto done; } if (!(process = create_process( socket_fd, parent, req->flags, info->data, sd, handles, req->handles_size / sizeof(*handles), token ))) goto done; process->startup_info = (struct startup_info *)grab_object( info ); job = parent->job; while (job) { if (!(job->limit_flags & JOB_OBJECT_LIMIT_SILENT_BREAKAWAY_OK) && !(req->flags & PROCESS_CREATE_FLAGS_BREAKAWAY && job->limit_flags & JOB_OBJECT_LIMIT_BREAKAWAY_OK)) { add_job_process( job, process ); assert( !get_error() ); break; } job = job->parent; } for (i = 0; i < job_handle_count; ++i) { job = get_job_obj( current->process, job_handles[i], JOB_OBJECT_ASSIGN_PROCESS ); add_job_process( job, process ); release_object( job ); if (get_error()) { release_job_process( process ); goto done; } } /* connect to the window station */ connect_process_winstation( process, parent_thread, parent ); /* inherit the process console, but keep pseudo handles (< 0), and 0 (= not attached to a console) as is */ if ((int)info->data->console > 0) info->data->console = duplicate_handle( parent, info->data->console, process, 0, 0, DUPLICATE_SAME_ACCESS ); if (!(req->flags & PROCESS_CREATE_FLAGS_INHERIT_HANDLES) && info->data->console != 1) { info->data->hstdin = duplicate_handle( parent, info->data->hstdin, process, 0, OBJ_INHERIT, DUPLICATE_SAME_ACCESS ); info->data->hstdout = duplicate_handle( parent, info->data->hstdout, process, 0, OBJ_INHERIT, DUPLICATE_SAME_ACCESS ); info->data->hstderr = duplicate_handle( parent, info->data->hstderr, process, 0, OBJ_INHERIT, DUPLICATE_SAME_ACCESS ); /* some handles above may have been invalid; this is not an error */ if (get_error() == STATUS_INVALID_HANDLE || get_error() == STATUS_OBJECT_TYPE_MISMATCH) clear_error(); } /* attach to the debugger */ if (debug_obj) { process->debug_obj = debug_obj; process->debug_children = !(req->flags & PROCESS_CREATE_FLAGS_NO_DEBUG_INHERIT); } else if (parent->debug_children) { process->debug_obj = parent->debug_obj; /* debug_children is set to 1 by default */ } if (!info->data->console_flags) process->group_id = parent->group_id; info->process = (struct process *)grab_object( process ); reply->info = alloc_handle( current->process, info, SYNCHRONIZE, 0 ); reply->pid = get_process_id( process ); reply->handle = alloc_handle_no_access_check( current->process, process, req->access, objattr->attributes ); done: if (process) release_object( process ); if (debug_obj) release_object( debug_obj ); if (token) release_object( token ); release_object( parent ); release_object( info ); } /* Retrieve information about a newly started process */ DECL_HANDLER(get_new_process_info) { struct startup_info *info; if ((info = (struct startup_info *)get_handle_obj( current->process, req->info, 0, &startup_info_ops ))) { reply->success = is_process_init_done( info->process ); reply->exit_code = info->process->exit_code; release_object( info ); } } /* Retrieve the new process startup info */ DECL_HANDLER(get_startup_info) { struct process *process = current->process; struct startup_info *info = process->startup_info; data_size_t size; if (!info) return; /* we return the data directly without making a copy so this can only be called once */ reply->info_size = info->info_size; size = info->data_size; if (size > get_reply_max_size()) size = get_reply_max_size(); set_reply_data_ptr( info->data, size ); info->data = NULL; info->data_size = 0; } /* signal the end of the process initialization */ DECL_HANDLER(init_process_done) { struct process *process = current->process; struct memory_view *view; client_ptr_t base; const pe_image_info_t *image_info; if (is_process_init_done(process)) { set_error( STATUS_INVALID_PARAMETER ); return; } if (!(view = get_exe_view( process ))) { set_error( STATUS_DLL_NOT_FOUND ); return; } if (!(image_info = get_view_image_info( view, &base ))) return; current->teb = req->teb; process->peb = req->peb; process->ldt_copy = req->ldt_copy; process->start_time = current_time; current->entry_point = base + image_info->entry_point; init_process_tracing( process ); generate_startup_debug_events( process ); set_process_startup_state( process, STARTUP_DONE ); if (image_info->subsystem != IMAGE_SUBSYSTEM_WINDOWS_CUI) process->idle_event = create_event( NULL, NULL, 0, 1, 0, NULL ); if (process->debug_obj) set_process_debug_flag( process, 1 ); reply->entry = current->entry_point; reply->suspend = (current->suspend || process->suspend); } /* open a handle to a process */ DECL_HANDLER(open_process) { struct process *process = get_process_from_id( req->pid ); reply->handle = 0; if (process) { reply->handle = alloc_handle( current->process, process, req->access, req->attributes ); release_object( process ); } } /* terminate a process */ DECL_HANDLER(terminate_process) { struct process *process; if (req->handle) { process = get_process_from_handle( req->handle, PROCESS_TERMINATE ); if (!process) return; } else process = (struct process *)grab_object( current->process ); reply->self = (current->process == process); terminate_process( process, current, req->exit_code ); release_object( process ); } /* fetch information about a process */ DECL_HANDLER(get_process_info) { struct process *process; if ((process = get_process_from_handle( req->handle, PROCESS_QUERY_LIMITED_INFORMATION ))) { reply->pid = get_process_id( process ); reply->ppid = process->parent_id; reply->exit_code = process->exit_code; reply->priority = process->priority; reply->affinity = process->affinity; reply->peb = process->peb; reply->start_time = process->start_time; reply->end_time = process->end_time; reply->session_id = process->session_id; reply->machine = process->machine; if (get_reply_max_size()) { if (!process->running_threads) set_error( STATUS_PROCESS_IS_TERMINATING ); else set_reply_data( &process->image_info, min( sizeof(process->image_info), get_reply_max_size() )); } release_object( process ); } } /* retrieve debug information about a process */ DECL_HANDLER(get_process_debug_info) { struct process *process; if (!(process = get_process_from_handle( req->handle, PROCESS_QUERY_LIMITED_INFORMATION ))) return; reply->debug_children = process->debug_children; if (!process->debug_obj) set_error( STATUS_PORT_NOT_SET ); else reply->debug = alloc_handle( current->process, process->debug_obj, MAXIMUM_ALLOWED, 0 ); release_object( process ); } /* fetch the name of the process image */ DECL_HANDLER(get_process_image_name) { struct process *process = get_process_from_handle( req->handle, PROCESS_QUERY_LIMITED_INFORMATION ); if (!process) return; if (process->image) { struct unicode_str name = { process->image, process->imagelen }; /* skip the \??\ prefix */ if (req->win32 && name.len > 6 * sizeof(WCHAR) && name.str[5] == ':') { name.str += 4; name.len -= 4 * sizeof(WCHAR); } /* FIXME: else resolve symlinks in NT path */ reply->len = name.len; if (name.len <= get_reply_max_size()) { WCHAR *ptr = set_reply_data( name.str, name.len ); /* change \??\ to \\?\ */ if (req->win32 && name.len > sizeof(WCHAR) && ptr[1] == '?') ptr[1] = '\\'; } else set_error( STATUS_BUFFER_TOO_SMALL ); } release_object( process ); } /* retrieve information about a process memory usage */ DECL_HANDLER(get_process_vm_counters) { struct process *process = get_process_from_handle( req->handle, PROCESS_QUERY_LIMITED_INFORMATION ); if (!process) return; if (process->unix_pid != -1) { #ifdef linux FILE *f; char proc_path[32], line[256]; unsigned long value; sprintf( proc_path, "/proc/%u/status", process->unix_pid ); if ((f = fopen( proc_path, "r" ))) { while (fgets( line, sizeof(line), f )) { if (sscanf( line, "VmPeak: %lu", &value )) reply->peak_virtual_size = (mem_size_t)value * 1024; else if (sscanf( line, "VmSize: %lu", &value )) reply->virtual_size = (mem_size_t)value * 1024; else if (sscanf( line, "VmHWM: %lu", &value )) reply->peak_working_set_size = (mem_size_t)value * 1024; else if (sscanf( line, "VmRSS: %lu", &value )) reply->working_set_size = (mem_size_t)value * 1024; else if (sscanf( line, "RssAnon: %lu", &value )) reply->pagefile_usage += (mem_size_t)value * 1024; else if (sscanf( line, "VmSwap: %lu", &value )) reply->pagefile_usage += (mem_size_t)value * 1024; } reply->peak_pagefile_usage = reply->pagefile_usage; fclose( f ); } else set_error( STATUS_ACCESS_DENIED ); #elif defined(HAVE_LIBPROCSTAT) struct procstat *procstat; unsigned int count; if ((procstat = procstat_open_sysctl())) { struct kinfo_proc *kp = procstat_getprocs( procstat, KERN_PROC_PID, process->unix_pid, &count ); if (kp) { reply->virtual_size = kp->ki_size; reply->peak_virtual_size = reply->virtual_size; reply->working_set_size = kp->ki_rssize << PAGE_SHIFT; reply->peak_working_set_size = kp->ki_rusage.ru_maxrss * 1024; procstat_freeprocs( procstat, kp ); } else set_error( STATUS_ACCESS_DENIED ); procstat_close( procstat ); } else set_error( STATUS_ACCESS_DENIED ); #endif } else set_error( STATUS_ACCESS_DENIED ); release_object( process ); } static void set_process_affinity( struct process *process, affinity_t affinity ) { struct thread *thread; if (!process->running_threads) { set_error( STATUS_PROCESS_IS_TERMINATING ); return; } process->affinity = affinity; LIST_FOR_EACH_ENTRY( thread, &process->thread_list, struct thread, proc_entry ) { set_thread_affinity( thread, affinity ); } } /* set information about a process */ DECL_HANDLER(set_process_info) { struct process *process; if ((process = get_process_from_handle( req->handle, PROCESS_SET_INFORMATION ))) { if (req->mask & SET_PROCESS_INFO_PRIORITY) process->priority = req->priority; if (req->mask & SET_PROCESS_INFO_AFFINITY) set_process_affinity( process, req->affinity ); release_object( process ); } } /* read data from a process address space */ DECL_HANDLER(read_process_memory) { struct process *process; data_size_t len = get_reply_max_size(); if (!(process = get_process_from_handle( req->handle, PROCESS_VM_READ ))) return; if (len) { char *buffer = mem_alloc( len ); if (buffer) { if (read_process_memory( process, req->addr, len, buffer )) set_reply_data_ptr( buffer, len ); else free( buffer ); } } release_object( process ); } /* write data to a process address space */ DECL_HANDLER(write_process_memory) { struct process *process; if ((process = get_process_from_handle( req->handle, PROCESS_VM_WRITE ))) { data_size_t len = get_req_data_size(); if (len) write_process_memory( process, req->addr, len, get_req_data() ); else set_error( STATUS_INVALID_PARAMETER ); release_object( process ); } } /* retrieve the process idle event */ DECL_HANDLER(get_process_idle_event) { struct process *process; reply->event = 0; if ((process = get_process_from_handle( req->handle, PROCESS_QUERY_INFORMATION ))) { if (process->idle_event && process != current->process) reply->event = alloc_handle( current->process, process->idle_event, EVENT_ALL_ACCESS, 0 ); release_object( process ); } } /* make the current process a system process */ DECL_HANDLER(make_process_system) { struct process *process; struct thread *thread; if (!shutdown_event) { if (!(shutdown_event = create_event( NULL, NULL, OBJ_PERMANENT, 1, 0, NULL ))) return; release_object( shutdown_event ); } if (!(process = get_process_from_handle( req->handle, PROCESS_SET_INFORMATION ))) return; if (!(reply->event = alloc_handle( current->process, shutdown_event, SYNCHRONIZE, 0 ))) { release_object( process ); return; } if (!process->is_system) { LIST_FOR_EACH_ENTRY( thread, &process->thread_list, struct thread, proc_entry ) release_thread_desktop( thread, 0 ); process->is_system = 1; if (!--user_processes && !shutdown_stage && master_socket_timeout != TIMEOUT_INFINITE) shutdown_timeout = add_timeout_user( master_socket_timeout, server_shutdown_timeout, NULL ); } release_object( process ); } /* create a new job object */ DECL_HANDLER(create_job) { struct job *job; struct unicode_str name; struct object *root; const struct security_descriptor *sd; const struct object_attributes *objattr = get_req_object_attributes( &sd, &name, &root ); if (!objattr) return; if ((job = create_job_object( root, &name, objattr->attributes, sd ))) { if (get_error() == STATUS_OBJECT_NAME_EXISTS) reply->handle = alloc_handle( current->process, job, req->access, objattr->attributes ); else reply->handle = alloc_handle_no_access_check( current->process, job, req->access, objattr->attributes ); release_object( job ); } if (root) release_object( root ); } /* open a job object */ DECL_HANDLER(open_job) { struct unicode_str name = get_req_unicode_str(); reply->handle = open_object( current->process, req->rootdir, req->access, &job_ops, &name, req->attributes ); } /* assign a job object to a process */ DECL_HANDLER(assign_job) { struct process *process; struct job *job = get_job_obj( current->process, req->job, JOB_OBJECT_ASSIGN_PROCESS ); if (!job) return; if ((process = get_process_from_handle( req->process, PROCESS_SET_QUOTA | PROCESS_TERMINATE ))) { if (!process->running_threads) set_error( STATUS_PROCESS_IS_TERMINATING ); else add_job_process( job, process ); release_object( process ); } release_object( job ); } /* check if a process is associated with a job */ DECL_HANDLER(process_in_job) { struct process *process; struct job *job; if (!(process = get_process_from_handle( req->process, PROCESS_QUERY_INFORMATION ))) return; if (!req->job) { set_error( process->job ? STATUS_PROCESS_IN_JOB : STATUS_PROCESS_NOT_IN_JOB ); } else if ((job = get_job_obj( current->process, req->job, JOB_OBJECT_QUERY ))) { set_error( process_in_job( job, process ) ? STATUS_PROCESS_IN_JOB : STATUS_PROCESS_NOT_IN_JOB ); release_object( job ); } release_object( process ); } /* retrieve information about a job */ DECL_HANDLER(get_job_info) { struct job *job = get_job_obj( current->process, req->handle, JOB_OBJECT_QUERY ); process_id_t *pids; data_size_t len; if (!job) return; reply->total_processes = job->total_processes; reply->active_processes = job->num_processes; len = min( get_reply_max_size(), reply->active_processes * sizeof(*pids) ); if (len && ((pids = set_reply_data_size( len )))) get_job_pids( job, pids, pids + len / sizeof(*pids) ); release_object( job ); } /* terminate all processes associated with the job */ DECL_HANDLER(terminate_job) { struct job *job = get_job_obj( current->process, req->handle, JOB_OBJECT_TERMINATE ); if (!job) return; terminate_job( job, req->status ); release_object( job ); } /* update limits of the job object */ DECL_HANDLER(set_job_limits) { struct job *job = get_job_obj( current->process, req->handle, JOB_OBJECT_SET_ATTRIBUTES ); if (!job) return; job->limit_flags = req->limit_flags; release_object( job ); } /* set the jobs completion port */ DECL_HANDLER(set_job_completion_port) { struct job *job = get_job_obj( current->process, req->job, JOB_OBJECT_SET_ATTRIBUTES ); if (!job) return; if (!job->completion_port) { job->completion_port = get_completion_obj( current->process, req->port, IO_COMPLETION_MODIFY_STATE ); job->completion_key = req->key; add_job_completion_existing_processes( job, job ); } else set_error( STATUS_INVALID_PARAMETER ); release_object( job ); } /* Suspend a process */ DECL_HANDLER(suspend_process) { struct process *process; if ((process = get_process_from_handle( req->handle, PROCESS_SUSPEND_RESUME ))) { struct list *ptr, *next; LIST_FOR_EACH_SAFE( ptr, next, &process->thread_list ) { struct thread *thread = LIST_ENTRY( ptr, struct thread, proc_entry ); suspend_thread( thread ); } release_object( process ); } } /* Resume a process */ DECL_HANDLER(resume_process) { struct process *process; if ((process = get_process_from_handle( req->handle, PROCESS_SUSPEND_RESUME ))) { struct list *ptr, *next; LIST_FOR_EACH_SAFE( ptr, next, &process->thread_list ) { struct thread *thread = LIST_ENTRY( ptr, struct thread, proc_entry ); resume_thread( thread ); } release_object( process ); } } /* Get a list of processes and threads currently running */ DECL_HANDLER(list_processes) { struct process *process; struct thread *thread; unsigned int pos = 0; char *buffer; reply->process_count = 0; reply->total_thread_count = 0; reply->total_name_len = 0; reply->info_size = 0; LIST_FOR_EACH_ENTRY( process, &process_list, struct process, entry ) { reply->info_size = (reply->info_size + 7) & ~7; reply->info_size += sizeof(struct process_info) + process->imagelen; reply->info_size = (reply->info_size + 7) & ~7; reply->info_size += process->running_threads * sizeof(struct thread_info); reply->process_count++; reply->total_thread_count += process->running_threads; reply->total_name_len += process->imagelen; } if (reply->info_size > get_reply_max_size()) { set_error( STATUS_INFO_LENGTH_MISMATCH ); return; } if (!(buffer = set_reply_data_size( reply->info_size ))) return; memset( buffer, 0, reply->info_size ); LIST_FOR_EACH_ENTRY( process, &process_list, struct process, entry ) { struct process_info *process_info; pos = (pos + 7) & ~7; process_info = (struct process_info *)(buffer + pos); process_info->start_time = process->start_time; process_info->name_len = process->imagelen; process_info->thread_count = process->running_threads; process_info->priority = process->priority; process_info->pid = process->id; process_info->parent_pid = process->parent_id; process_info->session_id = process->session_id; process_info->handle_count = get_handle_table_count(process); process_info->unix_pid = process->unix_pid; pos += sizeof(*process_info); memcpy( buffer + pos, process->image, process->imagelen ); pos += process->imagelen; pos = (pos + 7) & ~7; LIST_FOR_EACH_ENTRY( thread, &process->thread_list, struct thread, proc_entry ) { struct thread_info *thread_info = (struct thread_info *)(buffer + pos); thread_info->start_time = thread->creation_time; thread_info->tid = thread->id; thread_info->base_priority = thread->priority; thread_info->current_priority = thread->priority; /* FIXME */ thread_info->unix_tid = thread->unix_tid; thread_info->entry_point = thread->entry_point; thread_info->teb = thread->teb; pos += sizeof(*thread_info); } } }