/* * Services.exe - RPC functions * * Copyright 2007 Google (Mikolaj Zalewski) * * 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 */ #define WIN32_LEAN_AND_MEAN #define NONAMELESSSTRUCT #define NONAMELESSUNION #include #include #include #include #include #include #include "wine/list.h" #include "wine/debug.h" #include "services.h" #include "svcctl.h" extern HANDLE CDECL __wine_make_process_system(void); WINE_DEFAULT_DEBUG_CHANNEL(service); static const GENERIC_MAPPING g_scm_generic = { (STANDARD_RIGHTS_READ | SC_MANAGER_ENUMERATE_SERVICE | SC_MANAGER_QUERY_LOCK_STATUS), (STANDARD_RIGHTS_WRITE | SC_MANAGER_CREATE_SERVICE | SC_MANAGER_MODIFY_BOOT_CONFIG), (STANDARD_RIGHTS_EXECUTE | SC_MANAGER_CONNECT | SC_MANAGER_LOCK), SC_MANAGER_ALL_ACCESS }; static const GENERIC_MAPPING g_svc_generic = { (STANDARD_RIGHTS_READ | SERVICE_QUERY_CONFIG | SERVICE_QUERY_STATUS | SERVICE_INTERROGATE | SERVICE_ENUMERATE_DEPENDENTS), (STANDARD_RIGHTS_WRITE | SERVICE_CHANGE_CONFIG), (STANDARD_RIGHTS_EXECUTE | SERVICE_START | SERVICE_STOP | SERVICE_PAUSE_CONTINUE | SERVICE_USER_DEFINED_CONTROL), SERVICE_ALL_ACCESS }; typedef enum { SC_HTYPE_DONT_CARE = 0, SC_HTYPE_MANAGER, SC_HTYPE_SERVICE, SC_HTYPE_NOTIFY } SC_HANDLE_TYPE; struct sc_handle { SC_HANDLE_TYPE type; DWORD access; }; struct sc_manager_handle /* service control manager handle */ { struct sc_handle hdr; struct scmdatabase *db; }; struct sc_notify_handle { struct sc_handle hdr; HANDLE event; DWORD notify_mask; LONG ref; SC_RPC_NOTIFY_PARAMS_LIST *params_list; }; struct sc_service_handle /* service handle */ { struct sc_handle hdr; struct list entry; BOOL status_notified; struct service_entry *service_entry; struct sc_notify_handle *notify; }; static void sc_notify_retain(struct sc_notify_handle *notify) { InterlockedIncrement(¬ify->ref); } static void sc_notify_release(struct sc_notify_handle *notify) { ULONG r = InterlockedDecrement(¬ify->ref); if (r == 0) { CloseHandle(notify->event); HeapFree(GetProcessHeap(), 0, notify->params_list); HeapFree(GetProcessHeap(), 0, notify); } } struct sc_lock { struct scmdatabase *db; }; static const WCHAR emptyW[] = {0}; static PTP_CLEANUP_GROUP cleanup_group; HANDLE exit_event; static void CALLBACK group_cancel_callback(void *object, void *userdata) { struct process_entry *process = object; release_process(process); } static void CALLBACK terminate_callback(TP_CALLBACK_INSTANCE *instance, void *context, TP_WAIT *wait, TP_WAIT_RESULT result) { struct process_entry *process = context; if (result == WAIT_TIMEOUT) process_terminate(process); release_process(process); CloseThreadpoolWait(wait); } static void terminate_after_timeout(struct process_entry *process, DWORD timeout) { TP_CALLBACK_ENVIRON environment; LARGE_INTEGER timestamp; TP_WAIT *wait; FILETIME ft; memset(&environment, 0, sizeof(environment)); environment.Version = 1; environment.CleanupGroup = cleanup_group; environment.CleanupGroupCancelCallback = group_cancel_callback; timestamp.QuadPart = (ULONGLONG)timeout * -10000; ft.dwLowDateTime = timestamp.u.LowPart; ft.dwHighDateTime = timestamp.u.HighPart; if ((wait = CreateThreadpoolWait(terminate_callback, grab_process(process), &environment))) SetThreadpoolWait(wait, process->process, &ft); else release_process(process); } static void CALLBACK shutdown_callback(TP_CALLBACK_INSTANCE *instance, void *context) { struct process_entry *process = context; DWORD result; result = WaitForSingleObject(process->control_mutex, 30000); if (result == WAIT_OBJECT_0) { process_send_control(process, FALSE, emptyW, SERVICE_CONTROL_STOP, NULL, 0, &result); ReleaseMutex(process->control_mutex); } release_process(process); } static void shutdown_shared_process(struct process_entry *process) { TP_CALLBACK_ENVIRON environment; struct service_entry *service; struct scmdatabase *db = process->db; scmdatabase_lock(db); LIST_FOR_EACH_ENTRY(service, &db->services, struct service_entry, entry) { if (service->process != process) continue; service->status.dwCurrentState = SERVICE_STOP_PENDING; } scmdatabase_unlock(db); memset(&environment, 0, sizeof(environment)); environment.Version = 1; environment.CleanupGroup = cleanup_group; environment.CleanupGroupCancelCallback = group_cancel_callback; if (!TrySubmitThreadpoolCallback(shutdown_callback, grab_process(process), &environment)) release_process(process); } static void free_service_strings(struct service_entry *old, struct service_entry *new) { QUERY_SERVICE_CONFIGW *old_cfg = &old->config; QUERY_SERVICE_CONFIGW *new_cfg = &new->config; if (old_cfg->lpBinaryPathName != new_cfg->lpBinaryPathName) HeapFree(GetProcessHeap(), 0, old_cfg->lpBinaryPathName); if (old_cfg->lpLoadOrderGroup != new_cfg->lpLoadOrderGroup) HeapFree(GetProcessHeap(), 0, old_cfg->lpLoadOrderGroup); if (old_cfg->lpServiceStartName != new_cfg->lpServiceStartName) HeapFree(GetProcessHeap(), 0, old_cfg->lpServiceStartName); if (old_cfg->lpDisplayName != new_cfg->lpDisplayName) HeapFree(GetProcessHeap(), 0, old_cfg->lpDisplayName); if (old->dependOnServices != new->dependOnServices) HeapFree(GetProcessHeap(), 0, old->dependOnServices); if (old->dependOnGroups != new->dependOnGroups) HeapFree(GetProcessHeap(), 0, old->dependOnGroups); } /* Check if the given handle is of the required type and allows the requested access. */ static DWORD validate_context_handle(SC_RPC_HANDLE handle, DWORD type, DWORD needed_access, struct sc_handle **out_hdr) { struct sc_handle *hdr = handle; if (type != SC_HTYPE_DONT_CARE && hdr->type != type) { WINE_ERR("Handle is of an invalid type (%d, %d)\n", hdr->type, type); return ERROR_INVALID_HANDLE; } if ((needed_access & hdr->access) != needed_access) { WINE_ERR("Access denied - handle created with access %x, needed %x\n", hdr->access, needed_access); return ERROR_ACCESS_DENIED; } *out_hdr = hdr; return ERROR_SUCCESS; } static DWORD validate_scm_handle(SC_RPC_HANDLE handle, DWORD needed_access, struct sc_manager_handle **manager) { struct sc_handle *hdr; DWORD err = validate_context_handle(handle, SC_HTYPE_MANAGER, needed_access, &hdr); if (err == ERROR_SUCCESS) *manager = (struct sc_manager_handle *)hdr; return err; } static DWORD validate_service_handle(SC_RPC_HANDLE handle, DWORD needed_access, struct sc_service_handle **service) { struct sc_handle *hdr; DWORD err = validate_context_handle(handle, SC_HTYPE_SERVICE, needed_access, &hdr); if (err == ERROR_SUCCESS) *service = (struct sc_service_handle *)hdr; return err; } static DWORD validate_notify_handle(SC_RPC_HANDLE handle, DWORD needed_access, struct sc_notify_handle **notify) { struct sc_handle *hdr; DWORD err = validate_context_handle(handle, SC_HTYPE_NOTIFY, needed_access, &hdr); if (err == ERROR_SUCCESS) *notify = (struct sc_notify_handle *)hdr; return err; } DWORD __cdecl svcctl_OpenSCManagerW( MACHINE_HANDLEW MachineName, /* Note: this parameter is ignored */ LPCWSTR DatabaseName, DWORD dwAccessMask, SC_RPC_HANDLE *handle) { struct sc_manager_handle *manager; WINE_TRACE("(%s, %s, %x)\n", wine_dbgstr_w(MachineName), wine_dbgstr_w(DatabaseName), dwAccessMask); if (DatabaseName != NULL && DatabaseName[0]) { if (lstrcmpW(DatabaseName, SERVICES_FAILED_DATABASEW) == 0) return ERROR_DATABASE_DOES_NOT_EXIST; if (lstrcmpW(DatabaseName, SERVICES_ACTIVE_DATABASEW) != 0) return ERROR_INVALID_NAME; } if (!(manager = HeapAlloc(GetProcessHeap(), 0, sizeof(*manager)))) return ERROR_NOT_ENOUGH_SERVER_MEMORY; manager->hdr.type = SC_HTYPE_MANAGER; if (dwAccessMask & MAXIMUM_ALLOWED) dwAccessMask |= SC_MANAGER_ALL_ACCESS; manager->hdr.access = dwAccessMask; RtlMapGenericMask(&manager->hdr.access, &g_scm_generic); manager->db = active_database; *handle = &manager->hdr; return ERROR_SUCCESS; } static void SC_RPC_HANDLE_destroy(SC_RPC_HANDLE handle) { struct sc_handle *hdr = handle; switch (hdr->type) { case SC_HTYPE_MANAGER: { struct sc_manager_handle *manager = (struct sc_manager_handle *)hdr; HeapFree(GetProcessHeap(), 0, manager); break; } case SC_HTYPE_SERVICE: { struct sc_service_handle *service = (struct sc_service_handle *)hdr; service_lock(service->service_entry); list_remove(&service->entry); if (service->notify) { SetEvent(service->notify->event); sc_notify_release(service->notify); } service_unlock(service->service_entry); release_service(service->service_entry); HeapFree(GetProcessHeap(), 0, service); break; } default: WINE_ERR("invalid handle type %d\n", hdr->type); RpcRaiseException(ERROR_INVALID_HANDLE); } } DWORD __cdecl svcctl_GetServiceDisplayNameW( SC_RPC_HANDLE hSCManager, LPCWSTR lpServiceName, WCHAR *lpBuffer, DWORD *cchBufSize) { struct sc_manager_handle *manager; struct service_entry *entry; DWORD err; WINE_TRACE("(%s, %d)\n", wine_dbgstr_w(lpServiceName), *cchBufSize); if ((err = validate_scm_handle(hSCManager, 0, &manager)) != ERROR_SUCCESS) return err; scmdatabase_lock(manager->db); entry = scmdatabase_find_service(manager->db, lpServiceName); if (entry != NULL) { LPCWSTR name; int len; name = get_display_name(entry); len = lstrlenW(name); if (len <= *cchBufSize) { err = ERROR_SUCCESS; memcpy(lpBuffer, name, (len + 1)*sizeof(*name)); } else err = ERROR_INSUFFICIENT_BUFFER; *cchBufSize = len; } else err = ERROR_SERVICE_DOES_NOT_EXIST; scmdatabase_unlock(manager->db); if (err != ERROR_SUCCESS) lpBuffer[0] = 0; return err; } DWORD __cdecl svcctl_GetServiceKeyNameW( SC_RPC_HANDLE hSCManager, LPCWSTR lpServiceDisplayName, WCHAR *lpBuffer, DWORD *cchBufSize) { struct service_entry *entry; struct sc_manager_handle *manager; DWORD err; WINE_TRACE("(%s, %d)\n", wine_dbgstr_w(lpServiceDisplayName), *cchBufSize); if ((err = validate_scm_handle(hSCManager, 0, &manager)) != ERROR_SUCCESS) return err; scmdatabase_lock(manager->db); entry = scmdatabase_find_service_by_displayname(manager->db, lpServiceDisplayName); if (entry != NULL) { int len; len = lstrlenW(entry->name); if (len <= *cchBufSize) { err = ERROR_SUCCESS; memcpy(lpBuffer, entry->name, (len + 1)*sizeof(*entry->name)); } else err = ERROR_INSUFFICIENT_BUFFER; *cchBufSize = len; } else err = ERROR_SERVICE_DOES_NOT_EXIST; scmdatabase_unlock(manager->db); if (err != ERROR_SUCCESS) lpBuffer[0] = 0; return err; } static DWORD create_handle_for_service(struct service_entry *entry, DWORD dwDesiredAccess, SC_RPC_HANDLE *phService) { struct sc_service_handle *service; if (!(service = HeapAlloc(GetProcessHeap(), 0, sizeof(*service)))) { release_service(entry); return ERROR_NOT_ENOUGH_SERVER_MEMORY; } if (dwDesiredAccess & MAXIMUM_ALLOWED) dwDesiredAccess |= SERVICE_ALL_ACCESS; service->hdr.type = SC_HTYPE_SERVICE; service->hdr.access = dwDesiredAccess; service->notify = NULL; service->status_notified = FALSE; RtlMapGenericMask(&service->hdr.access, &g_svc_generic); service_lock(entry); service->service_entry = entry; list_add_tail(&entry->handles, &service->entry); service_unlock(entry); *phService = &service->hdr; return ERROR_SUCCESS; } DWORD __cdecl svcctl_OpenServiceW( SC_RPC_HANDLE hSCManager, LPCWSTR lpServiceName, DWORD dwDesiredAccess, SC_RPC_HANDLE *phService) { struct sc_manager_handle *manager; struct service_entry *entry; DWORD err; WINE_TRACE("(%s, 0x%x)\n", wine_dbgstr_w(lpServiceName), dwDesiredAccess); if ((err = validate_scm_handle(hSCManager, 0, &manager)) != ERROR_SUCCESS) return err; if (!validate_service_name(lpServiceName)) return ERROR_INVALID_NAME; scmdatabase_lock(manager->db); entry = grab_service(scmdatabase_find_service(manager->db, lpServiceName)); scmdatabase_unlock(manager->db); if (entry == NULL) return ERROR_SERVICE_DOES_NOT_EXIST; return create_handle_for_service(entry, dwDesiredAccess, phService); } static DWORD parse_dependencies(const WCHAR *dependencies, struct service_entry *entry) { WCHAR *services = NULL, *groups, *s; DWORD len, len_services = 0, len_groups = 0; const WCHAR *ptr = dependencies; if (!dependencies || !dependencies[0]) { entry->dependOnServices = NULL; entry->dependOnGroups = NULL; return ERROR_SUCCESS; } while (*ptr) { len = lstrlenW(ptr) + 1; if (ptr[0] == '+' && ptr[1]) len_groups += len - 1; else len_services += len; ptr += len; } if (!len_services) entry->dependOnServices = NULL; else { services = HeapAlloc(GetProcessHeap(), 0, (len_services + 1) * sizeof(WCHAR)); if (!services) return ERROR_OUTOFMEMORY; s = services; ptr = dependencies; while (*ptr) { len = lstrlenW(ptr) + 1; if (*ptr != '+') { lstrcpyW(s, ptr); s += len; } ptr += len; } *s = 0; entry->dependOnServices = services; } if (!len_groups) entry->dependOnGroups = NULL; else { groups = HeapAlloc(GetProcessHeap(), 0, (len_groups + 1) * sizeof(WCHAR)); if (!groups) { HeapFree(GetProcessHeap(), 0, services); return ERROR_OUTOFMEMORY; } s = groups; ptr = dependencies; while (*ptr) { len = lstrlenW(ptr) + 1; if (ptr[0] == '+' && ptr[1]) { lstrcpyW(s, ptr + 1); s += len - 1; } ptr += len; } *s = 0; entry->dependOnGroups = groups; } return ERROR_SUCCESS; } static DWORD create_serviceW( SC_RPC_HANDLE hSCManager, LPCWSTR lpServiceName, LPCWSTR lpDisplayName, DWORD dwDesiredAccess, DWORD dwServiceType, DWORD dwStartType, DWORD dwErrorControl, LPCWSTR lpBinaryPathName, LPCWSTR lpLoadOrderGroup, DWORD *lpdwTagId, const BYTE *lpDependencies, DWORD dwDependenciesSize, LPCWSTR lpServiceStartName, const BYTE *lpPassword, DWORD dwPasswordSize, SC_RPC_HANDLE *phService, BOOL is_wow64) { struct service_entry *entry, *found; struct sc_manager_handle *manager; DWORD err; WINE_TRACE("(%s, %s, 0x%x, %s)\n", wine_dbgstr_w(lpServiceName), wine_dbgstr_w(lpDisplayName), dwDesiredAccess, wine_dbgstr_w(lpBinaryPathName)); if ((err = validate_scm_handle(hSCManager, SC_MANAGER_CREATE_SERVICE, &manager)) != ERROR_SUCCESS) return err; if (!validate_service_name(lpServiceName)) return ERROR_INVALID_NAME; if (!check_multisz((LPCWSTR)lpDependencies, dwDependenciesSize) || !lpServiceName[0] || !lpBinaryPathName[0]) return ERROR_INVALID_PARAMETER; if (lpPassword) WINE_FIXME("Don't know how to add a password\n"); /* I always get ERROR_GEN_FAILURE */ err = service_create(lpServiceName, &entry); if (err != ERROR_SUCCESS) return err; err = parse_dependencies((LPCWSTR)lpDependencies, entry); if (err != ERROR_SUCCESS) { free_service_entry(entry); return err; } entry->is_wow64 = is_wow64; entry->config.dwServiceType = entry->status.dwServiceType = dwServiceType; entry->config.dwStartType = dwStartType; entry->config.dwErrorControl = dwErrorControl; entry->config.lpBinaryPathName = strdupW(lpBinaryPathName); entry->config.lpLoadOrderGroup = strdupW(lpLoadOrderGroup); entry->config.lpServiceStartName = strdupW(lpServiceStartName); entry->config.lpDisplayName = strdupW(lpDisplayName); if (lpdwTagId) /* TODO: In most situations a non-NULL TagId will generate an ERROR_INVALID_PARAMETER. */ entry->config.dwTagId = *lpdwTagId; else entry->config.dwTagId = 0; /* other fields NULL*/ if (!validate_service_config(entry)) { WINE_ERR("Invalid data while trying to create service\n"); free_service_entry(entry); return ERROR_INVALID_PARAMETER; } scmdatabase_lock(manager->db); if ((found = scmdatabase_find_service(manager->db, lpServiceName))) { err = is_marked_for_delete(found) ? ERROR_SERVICE_MARKED_FOR_DELETE : ERROR_SERVICE_EXISTS; scmdatabase_unlock(manager->db); free_service_entry(entry); return err; } if (scmdatabase_find_service_by_displayname(manager->db, get_display_name(entry))) { scmdatabase_unlock(manager->db); free_service_entry(entry); return ERROR_DUPLICATE_SERVICE_NAME; } err = scmdatabase_add_service(manager->db, entry); if (err != ERROR_SUCCESS) { scmdatabase_unlock(manager->db); free_service_entry(entry); return err; } scmdatabase_unlock(manager->db); return create_handle_for_service(entry, dwDesiredAccess, phService); } DWORD __cdecl svcctl_CreateServiceW( SC_RPC_HANDLE hSCManager, LPCWSTR lpServiceName, LPCWSTR lpDisplayName, DWORD dwDesiredAccess, DWORD dwServiceType, DWORD dwStartType, DWORD dwErrorControl, LPCWSTR lpBinaryPathName, LPCWSTR lpLoadOrderGroup, DWORD *lpdwTagId, const BYTE *lpDependencies, DWORD dwDependenciesSize, LPCWSTR lpServiceStartName, const BYTE *lpPassword, DWORD dwPasswordSize, SC_RPC_HANDLE *phService) { WINE_TRACE("(%s, %s, 0x%x, %s)\n", wine_dbgstr_w(lpServiceName), wine_dbgstr_w(lpDisplayName), dwDesiredAccess, wine_dbgstr_w(lpBinaryPathName)); return create_serviceW(hSCManager, lpServiceName, lpDisplayName, dwDesiredAccess, dwServiceType, dwStartType, dwErrorControl, lpBinaryPathName, lpLoadOrderGroup, lpdwTagId, lpDependencies, dwDependenciesSize, lpServiceStartName, lpPassword, dwPasswordSize, phService, FALSE); } DWORD __cdecl svcctl_DeleteService( SC_RPC_HANDLE hService) { struct sc_service_handle *service; DWORD err; if ((err = validate_service_handle(hService, DELETE, &service)) != ERROR_SUCCESS) return err; service_lock(service->service_entry); if (!is_marked_for_delete(service->service_entry)) err = mark_for_delete(service->service_entry); else err = ERROR_SERVICE_MARKED_FOR_DELETE; service_unlock(service->service_entry); return err; } DWORD __cdecl svcctl_QueryServiceConfigW( SC_RPC_HANDLE hService, QUERY_SERVICE_CONFIGW *config, DWORD buf_size, DWORD *needed_size) { struct sc_service_handle *service; DWORD err; WINE_TRACE("(%p)\n", config); if ((err = validate_service_handle(hService, SERVICE_QUERY_CONFIG, &service)) != 0) return err; service_lock(service->service_entry); config->dwServiceType = service->service_entry->config.dwServiceType; config->dwStartType = service->service_entry->config.dwStartType; config->dwErrorControl = service->service_entry->config.dwErrorControl; config->lpBinaryPathName = strdupW(service->service_entry->config.lpBinaryPathName); config->lpLoadOrderGroup = strdupW(service->service_entry->config.lpLoadOrderGroup); config->dwTagId = service->service_entry->config.dwTagId; config->lpDependencies = NULL; /* TODO */ config->lpServiceStartName = strdupW(service->service_entry->config.lpServiceStartName); config->lpDisplayName = strdupW(service->service_entry->config.lpDisplayName); service_unlock(service->service_entry); return ERROR_SUCCESS; } DWORD __cdecl svcctl_ChangeServiceConfigW( SC_RPC_HANDLE hService, DWORD dwServiceType, DWORD dwStartType, DWORD dwErrorControl, LPCWSTR lpBinaryPathName, LPCWSTR lpLoadOrderGroup, DWORD *lpdwTagId, const BYTE *lpDependencies, DWORD dwDependenciesSize, LPCWSTR lpServiceStartName, const BYTE *lpPassword, DWORD dwPasswordSize, LPCWSTR lpDisplayName) { struct service_entry new_entry, *entry; struct sc_service_handle *service; DWORD err; WINE_TRACE("\n"); if ((err = validate_service_handle(hService, SERVICE_CHANGE_CONFIG, &service)) != 0) return err; if (!check_multisz((LPCWSTR)lpDependencies, dwDependenciesSize)) return ERROR_INVALID_PARAMETER; /* first check if the new configuration is correct */ service_lock(service->service_entry); if (is_marked_for_delete(service->service_entry)) { service_unlock(service->service_entry); return ERROR_SERVICE_MARKED_FOR_DELETE; } if (lpDisplayName != NULL && (entry = scmdatabase_find_service_by_displayname(service->service_entry->db, lpDisplayName)) && (entry != service->service_entry)) { service_unlock(service->service_entry); return ERROR_DUPLICATE_SERVICE_NAME; } new_entry = *service->service_entry; if (dwServiceType != SERVICE_NO_CHANGE) new_entry.config.dwServiceType = dwServiceType; if (dwStartType != SERVICE_NO_CHANGE) new_entry.config.dwStartType = dwStartType; if (dwErrorControl != SERVICE_NO_CHANGE) new_entry.config.dwErrorControl = dwErrorControl; if (lpBinaryPathName != NULL) new_entry.config.lpBinaryPathName = (LPWSTR)lpBinaryPathName; if (lpLoadOrderGroup != NULL) new_entry.config.lpLoadOrderGroup = (LPWSTR)lpLoadOrderGroup; if (lpdwTagId != NULL) WINE_FIXME("Changing tag id not supported\n"); if (lpServiceStartName != NULL) new_entry.config.lpServiceStartName = (LPWSTR)lpServiceStartName; if (lpPassword != NULL) WINE_FIXME("Setting password not supported\n"); if (lpDisplayName != NULL) new_entry.config.lpDisplayName = (LPWSTR)lpDisplayName; err = parse_dependencies((LPCWSTR)lpDependencies, &new_entry); if (err != ERROR_SUCCESS) { service_unlock(service->service_entry); return err; } if (!validate_service_config(&new_entry)) { WINE_ERR("The configuration after the change wouldn't be valid\n"); service_unlock(service->service_entry); return ERROR_INVALID_PARAMETER; } /* configuration OK. The strings needs to be duplicated */ if (lpBinaryPathName != NULL) new_entry.config.lpBinaryPathName = strdupW(lpBinaryPathName); if (lpLoadOrderGroup != NULL) new_entry.config.lpLoadOrderGroup = strdupW(lpLoadOrderGroup); if (lpServiceStartName != NULL) new_entry.config.lpServiceStartName = strdupW(lpServiceStartName); if (lpDisplayName != NULL) new_entry.config.lpDisplayName = strdupW(lpDisplayName); /* try to save to Registry, commit or rollback depending on success */ err = save_service_config(&new_entry); if (ERROR_SUCCESS == err) { free_service_strings(service->service_entry, &new_entry); *service->service_entry = new_entry; } else free_service_strings(&new_entry, service->service_entry); service_unlock(service->service_entry); return err; } static void fill_status_process(SERVICE_STATUS_PROCESS *status, struct service_entry *service) { struct process_entry *process = service->process; memcpy(status, &service->status, sizeof(service->status)); status->dwProcessId = 0; if (process && !(service->status.dwServiceType & SERVICE_DRIVER)) status->dwProcessId = process->process_id; status->dwServiceFlags = 0; } static void fill_notify(struct sc_notify_handle *notify, struct service_entry *service) { SC_RPC_NOTIFY_PARAMS_LIST *list; SERVICE_NOTIFY_STATUS_CHANGE_PARAMS_2 *cparams; list = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(SC_RPC_NOTIFY_PARAMS_LIST) + sizeof(SERVICE_NOTIFY_STATUS_CHANGE_PARAMS_2)); if (!list) return; cparams = (SERVICE_NOTIFY_STATUS_CHANGE_PARAMS_2 *)(list + 1); cparams->dwNotifyMask = notify->notify_mask; fill_status_process(&cparams->ServiceStatus, service); cparams->dwNotificationStatus = ERROR_SUCCESS; cparams->dwNotificationTriggered = 1 << (cparams->ServiceStatus.dwCurrentState - SERVICE_STOPPED); cparams->pszServiceNames = NULL; list->cElements = 1; list->NotifyParamsArray[0].dwInfoLevel = 2; list->NotifyParamsArray[0].u.params = cparams; InterlockedExchangePointer((void**)¬ify->params_list, list); SetEvent(notify->event); } DWORD __cdecl svcctl_SetServiceStatus(SC_RPC_HANDLE handle, SERVICE_STATUS *status) { struct sc_service_handle *service, *service_handle; struct process_entry *process; DWORD err, mask; WINE_TRACE("(%p, %p)\n", handle, status); if ((err = validate_service_handle(handle, SERVICE_SET_STATUS, &service)) != 0) return err; service_lock(service->service_entry); /* FIXME: be a bit more discriminant about what parts of the status we set * and check that fields are valid */ service->service_entry->status.dwCurrentState = status->dwCurrentState; service->service_entry->status.dwControlsAccepted = status->dwControlsAccepted; service->service_entry->status.dwWin32ExitCode = status->dwWin32ExitCode; service->service_entry->status.dwServiceSpecificExitCode = status->dwServiceSpecificExitCode; service->service_entry->status.dwCheckPoint = status->dwCheckPoint; service->service_entry->status.dwWaitHint = status->dwWaitHint; SetEvent(service->service_entry->status_changed_event); if ((process = service->service_entry->process) && status->dwCurrentState == SERVICE_STOPPED) { service->service_entry->process = NULL; if (!--process->use_count) terminate_after_timeout(process, service_kill_timeout); if (service->service_entry->shared_process && process->use_count <= 1) shutdown_shared_process(process); release_process(process); } mask = 1 << (service->service_entry->status.dwCurrentState - SERVICE_STOPPED); LIST_FOR_EACH_ENTRY(service_handle, &service->service_entry->handles, struct sc_service_handle, entry) { struct sc_notify_handle *notify = service_handle->notify; if (notify && (notify->notify_mask & mask)) { fill_notify(notify, service->service_entry); sc_notify_release(notify); service_handle->notify = NULL; service_handle->status_notified = TRUE; } else service_handle->status_notified = FALSE; } service_unlock(service->service_entry); return ERROR_SUCCESS; } DWORD __cdecl svcctl_ChangeServiceConfig2W( SC_RPC_HANDLE hService, SC_RPC_CONFIG_INFOW config ) { struct sc_service_handle *service; DWORD err; if ((err = validate_service_handle(hService, SERVICE_CHANGE_CONFIG, &service)) != 0) return err; switch (config.dwInfoLevel) { case SERVICE_CONFIG_DESCRIPTION: { WCHAR *descr = NULL; if (!config.u.descr->lpDescription) break; if (config.u.descr->lpDescription[0]) { if (!(descr = strdupW( config.u.descr->lpDescription ))) return ERROR_NOT_ENOUGH_MEMORY; } WINE_TRACE( "changing service %p descr to %s\n", service, wine_dbgstr_w(descr) ); service_lock( service->service_entry ); HeapFree( GetProcessHeap(), 0, service->service_entry->description ); service->service_entry->description = descr; save_service_config( service->service_entry ); service_unlock( service->service_entry ); } break; case SERVICE_CONFIG_FAILURE_ACTIONS: WINE_FIXME( "SERVICE_CONFIG_FAILURE_ACTIONS not implemented: period %u msg %s cmd %s\n", config.u.actions->dwResetPeriod, wine_dbgstr_w(config.u.actions->lpRebootMsg), wine_dbgstr_w(config.u.actions->lpCommand) ); break; case SERVICE_CONFIG_PRESHUTDOWN_INFO: WINE_TRACE( "changing service %p preshutdown timeout to %d\n", service, config.u.preshutdown->dwPreshutdownTimeout ); service_lock( service->service_entry ); service->service_entry->preshutdown_timeout = config.u.preshutdown->dwPreshutdownTimeout; save_service_config( service->service_entry ); service_unlock( service->service_entry ); break; default: WINE_FIXME("level %u not implemented\n", config.dwInfoLevel); err = ERROR_INVALID_LEVEL; break; } return err; } DWORD __cdecl svcctl_QueryServiceConfig2W( SC_RPC_HANDLE hService, DWORD level, BYTE *buffer, DWORD size, LPDWORD needed ) { struct sc_service_handle *service; DWORD err; memset(buffer, 0, size); if ((err = validate_service_handle(hService, SERVICE_QUERY_STATUS, &service)) != 0) return err; switch (level) { case SERVICE_CONFIG_DESCRIPTION: { struct service_description *desc = (struct service_description *)buffer; DWORD total_size = sizeof(*desc); service_lock(service->service_entry); if (service->service_entry->description) total_size += lstrlenW(service->service_entry->description) * sizeof(WCHAR); *needed = total_size; if (size >= total_size) { if (service->service_entry->description) { lstrcpyW( desc->description, service->service_entry->description ); desc->size = total_size - FIELD_OFFSET(struct service_description, description); } else { desc->description[0] = 0; desc->size = 0; } } else err = ERROR_INSUFFICIENT_BUFFER; service_unlock(service->service_entry); } break; case SERVICE_CONFIG_PRESHUTDOWN_INFO: service_lock(service->service_entry); *needed = sizeof(SERVICE_PRESHUTDOWN_INFO); if (size >= *needed) ((LPSERVICE_PRESHUTDOWN_INFO)buffer)->dwPreshutdownTimeout = service->service_entry->preshutdown_timeout; else err = ERROR_INSUFFICIENT_BUFFER; service_unlock(service->service_entry); break; default: WINE_FIXME("level %u not implemented\n", level); err = ERROR_INVALID_LEVEL; break; } return err; } DWORD __cdecl svcctl_QueryServiceStatusEx( SC_RPC_HANDLE hService, SC_STATUS_TYPE InfoLevel, BYTE *lpBuffer, DWORD cbBufSize, LPDWORD pcbBytesNeeded) { struct sc_service_handle *service; DWORD err; LPSERVICE_STATUS_PROCESS pSvcStatusData; memset(lpBuffer, 0, cbBufSize); if ((err = validate_service_handle(hService, SERVICE_QUERY_STATUS, &service)) != 0) return err; if (InfoLevel != SC_STATUS_PROCESS_INFO) return ERROR_INVALID_LEVEL; pSvcStatusData = (LPSERVICE_STATUS_PROCESS) lpBuffer; if (pSvcStatusData == NULL) return ERROR_INVALID_PARAMETER; if (cbBufSize < sizeof(SERVICE_STATUS_PROCESS)) { if( pcbBytesNeeded != NULL) *pcbBytesNeeded = sizeof(SERVICE_STATUS_PROCESS); return ERROR_INSUFFICIENT_BUFFER; } service_lock(service->service_entry); fill_status_process(pSvcStatusData, service->service_entry); service_unlock(service->service_entry); return ERROR_SUCCESS; } /****************************************************************************** * service_accepts_control */ static BOOL service_accepts_control(const struct service_entry *service, DWORD dwControl) { DWORD a = service->status.dwControlsAccepted; if (dwControl >= 128 && dwControl <= 255) return TRUE; switch (dwControl) { case SERVICE_CONTROL_INTERROGATE: return TRUE; case SERVICE_CONTROL_STOP: if (a&SERVICE_ACCEPT_STOP) return TRUE; break; case SERVICE_CONTROL_SHUTDOWN: if (a&SERVICE_ACCEPT_SHUTDOWN) return TRUE; break; case SERVICE_CONTROL_PAUSE: case SERVICE_CONTROL_CONTINUE: if (a&SERVICE_ACCEPT_PAUSE_CONTINUE) return TRUE; break; case SERVICE_CONTROL_PARAMCHANGE: if (a&SERVICE_ACCEPT_PARAMCHANGE) return TRUE; break; case SERVICE_CONTROL_NETBINDADD: case SERVICE_CONTROL_NETBINDREMOVE: case SERVICE_CONTROL_NETBINDENABLE: case SERVICE_CONTROL_NETBINDDISABLE: if (a&SERVICE_ACCEPT_NETBINDCHANGE) return TRUE; case SERVICE_CONTROL_HARDWAREPROFILECHANGE: if (a&SERVICE_ACCEPT_HARDWAREPROFILECHANGE) return TRUE; break; case SERVICE_CONTROL_POWEREVENT: if (a&SERVICE_ACCEPT_POWEREVENT) return TRUE; break; case SERVICE_CONTROL_SESSIONCHANGE: if (a&SERVICE_ACCEPT_SESSIONCHANGE) return TRUE; break; } return FALSE; } /****************************************************************************** * process_send_command */ static BOOL process_send_command(struct process_entry *process, const void *data, DWORD size, DWORD *result) { OVERLAPPED overlapped; DWORD count, ret; BOOL r; overlapped.u.s.Offset = 0; overlapped.u.s.OffsetHigh = 0; overlapped.hEvent = process->overlapped_event; r = WriteFile(process->control_pipe, data, size, &count, &overlapped); if (!r && GetLastError() == ERROR_IO_PENDING) { ret = WaitForSingleObject(process->overlapped_event, service_pipe_timeout); if (ret == WAIT_TIMEOUT) { WINE_ERR("sending command timed out\n"); *result = ERROR_SERVICE_REQUEST_TIMEOUT; return FALSE; } r = GetOverlappedResult(process->control_pipe, &overlapped, &count, FALSE); } if (!r || count != size) { WINE_ERR("service protocol error - failed to write pipe!\n"); *result = (!r ? GetLastError() : ERROR_WRITE_FAULT); return FALSE; } r = ReadFile(process->control_pipe, result, sizeof *result, &count, &overlapped); if (!r && GetLastError() == ERROR_IO_PENDING) { ret = WaitForSingleObject(process->overlapped_event, service_pipe_timeout); if (ret == WAIT_TIMEOUT) { WINE_ERR("receiving command result timed out\n"); *result = ERROR_SERVICE_REQUEST_TIMEOUT; return FALSE; } r = GetOverlappedResult(process->control_pipe, &overlapped, &count, FALSE); } if (!r || count != sizeof *result) { WINE_ERR("service protocol error - failed to read pipe " "r = %d count = %d!\n", r, count); *result = (!r ? GetLastError() : ERROR_READ_FAULT); return FALSE; } return TRUE; } /****************************************************************************** * process_send_control */ BOOL process_send_control(struct process_entry *process, BOOL shared_process, const WCHAR *name, DWORD control, const BYTE *data, DWORD data_size, DWORD *result) { service_start_info *ssi; DWORD len; BOOL r; if (shared_process) { control |= SERVICE_CONTROL_FORWARD_FLAG; data = (BYTE *)name; data_size = (lstrlenW(name) + 1) * sizeof(WCHAR); name = emptyW; } /* calculate how much space we need to send the startup info */ len = (lstrlenW(name) + 1) * sizeof(WCHAR) + data_size; ssi = HeapAlloc(GetProcessHeap(),0,FIELD_OFFSET(service_start_info, data[len])); ssi->magic = SERVICE_PROTOCOL_MAGIC; ssi->control = control; ssi->total_size = FIELD_OFFSET(service_start_info, data[len]); ssi->name_size = lstrlenW(name) + 1; lstrcpyW((WCHAR *)ssi->data, name); if (data_size) memcpy(&ssi->data[ssi->name_size * sizeof(WCHAR)], data, data_size); r = process_send_command(process, ssi, ssi->total_size, result); HeapFree( GetProcessHeap(), 0, ssi ); return r; } DWORD __cdecl svcctl_StartServiceW( SC_RPC_HANDLE hService, DWORD dwNumServiceArgs, LPCWSTR *lpServiceArgVectors) { struct sc_service_handle *service; DWORD err; WINE_TRACE("(%p, %d, %p)\n", hService, dwNumServiceArgs, lpServiceArgVectors); if ((err = validate_service_handle(hService, SERVICE_START, &service)) != 0) return err; if (service->service_entry->config.dwStartType == SERVICE_DISABLED) return ERROR_SERVICE_DISABLED; if (!scmdatabase_lock_startup(service->service_entry->db, 3000)) return ERROR_SERVICE_DATABASE_LOCKED; err = service_start(service->service_entry, dwNumServiceArgs, lpServiceArgVectors); scmdatabase_unlock_startup(service->service_entry->db); return err; } DWORD __cdecl svcctl_ControlService( SC_RPC_HANDLE hService, DWORD dwControl, SERVICE_STATUS *lpServiceStatus) { DWORD access_required; struct sc_service_handle *service; struct process_entry *process; BOOL shared_process; DWORD result; WINE_TRACE("(%p, %d, %p)\n", hService, dwControl, lpServiceStatus); switch (dwControl) { case SERVICE_CONTROL_CONTINUE: case SERVICE_CONTROL_NETBINDADD: case SERVICE_CONTROL_NETBINDDISABLE: case SERVICE_CONTROL_NETBINDENABLE: case SERVICE_CONTROL_NETBINDREMOVE: case SERVICE_CONTROL_PARAMCHANGE: case SERVICE_CONTROL_PAUSE: access_required = SERVICE_PAUSE_CONTINUE; break; case SERVICE_CONTROL_INTERROGATE: access_required = SERVICE_INTERROGATE; break; case SERVICE_CONTROL_STOP: access_required = SERVICE_STOP; break; default: if (dwControl >= 128 && dwControl <= 255) access_required = SERVICE_USER_DEFINED_CONTROL; else return ERROR_INVALID_PARAMETER; } if ((result = validate_service_handle(hService, access_required, &service)) != 0) return result; service_lock(service->service_entry); result = ERROR_SUCCESS; switch (service->service_entry->status.dwCurrentState) { case SERVICE_STOPPED: result = ERROR_SERVICE_NOT_ACTIVE; break; case SERVICE_START_PENDING: if (dwControl==SERVICE_CONTROL_STOP) break; /* fall through */ case SERVICE_STOP_PENDING: result = ERROR_SERVICE_CANNOT_ACCEPT_CTRL; break; } if (result == ERROR_SUCCESS && service->service_entry->force_shutdown) { result = ERROR_SERVICE_CANNOT_ACCEPT_CTRL; if ((process = service->service_entry->process)) { service->service_entry->process = NULL; if (!--process->use_count) process_terminate(process); release_process(process); } } if (result != ERROR_SUCCESS) { if (lpServiceStatus) *lpServiceStatus = service->service_entry->status; service_unlock(service->service_entry); return result; } if (!service_accepts_control(service->service_entry, dwControl)) { service_unlock(service->service_entry); return ERROR_INVALID_SERVICE_CONTROL; } /* Remember that we tried to shutdown this service. When the service is * still running on the second invocation, it will be forcefully killed. */ if (dwControl == SERVICE_CONTROL_STOP) service->service_entry->force_shutdown = TRUE; /* Hold a reference to the process while sending the command. */ process = grab_process(service->service_entry->process); shared_process = service->service_entry->shared_process; service_unlock(service->service_entry); if (!process) return ERROR_SERVICE_CANNOT_ACCEPT_CTRL; result = WaitForSingleObject(process->control_mutex, 30000); if (result != WAIT_OBJECT_0) { release_process(process); return ERROR_SERVICE_REQUEST_TIMEOUT; } if (process_send_control(process, shared_process, service->service_entry->name, dwControl, NULL, 0, &result)) result = ERROR_SUCCESS; if (lpServiceStatus) { service_lock(service->service_entry); *lpServiceStatus = service->service_entry->status; service_unlock(service->service_entry); } ReleaseMutex(process->control_mutex); release_process(process); return result; } DWORD __cdecl svcctl_CloseServiceHandle( SC_RPC_HANDLE *handle) { WINE_TRACE("(&%p)\n", *handle); SC_RPC_HANDLE_destroy(*handle); *handle = NULL; return ERROR_SUCCESS; } void __RPC_USER SC_RPC_LOCK_rundown(SC_RPC_LOCK hLock) { } DWORD __cdecl svcctl_LockServiceDatabase(SC_RPC_HANDLE manager, SC_RPC_LOCK *lock) { TRACE("(%p, %p)\n", manager, lock); *lock = (SC_RPC_LOCK)0xdeadbeef; return ERROR_SUCCESS; } DWORD __cdecl svcctl_UnlockServiceDatabase(SC_RPC_LOCK *lock) { TRACE("(&%p)\n", *lock); *lock = NULL; return ERROR_SUCCESS; } static BOOL map_state(DWORD state, DWORD mask) { switch (state) { case SERVICE_START_PENDING: case SERVICE_STOP_PENDING: case SERVICE_RUNNING: case SERVICE_CONTINUE_PENDING: case SERVICE_PAUSE_PENDING: case SERVICE_PAUSED: if (SERVICE_ACTIVE & mask) return TRUE; break; case SERVICE_STOPPED: if (SERVICE_INACTIVE & mask) return TRUE; break; default: WINE_ERR("unknown state %u\n", state); break; } return FALSE; } DWORD __cdecl svcctl_EnumServicesStatusW( SC_RPC_HANDLE hmngr, DWORD type, DWORD state, BYTE *buffer, DWORD size, LPDWORD needed, LPDWORD returned, LPDWORD resume) { DWORD err, sz, total_size, num_services, offset; struct sc_manager_handle *manager; struct service_entry *service; struct enum_service_status *s; WINE_TRACE("(%p, 0x%x, 0x%x, %p, %u, %p, %p, %p)\n", hmngr, type, state, buffer, size, needed, returned, resume); if (!type || !state) return ERROR_INVALID_PARAMETER; if ((err = validate_scm_handle(hmngr, SC_MANAGER_ENUMERATE_SERVICE, &manager)) != ERROR_SUCCESS) return err; if (resume) WINE_FIXME("resume index not supported\n"); scmdatabase_lock(manager->db); total_size = num_services = 0; LIST_FOR_EACH_ENTRY(service, &manager->db->services, struct service_entry, entry) { if ((service->status.dwServiceType & type) && map_state(service->status.dwCurrentState, state)) { total_size += sizeof(*s); total_size += (lstrlenW(service->name) + 1) * sizeof(WCHAR); if (service->config.lpDisplayName) { total_size += (lstrlenW(service->config.lpDisplayName) + 1) * sizeof(WCHAR); } num_services++; } } *returned = 0; *needed = total_size; if (total_size > size) { scmdatabase_unlock(manager->db); return ERROR_MORE_DATA; } s = (struct enum_service_status *)buffer; offset = num_services * sizeof(struct enum_service_status); LIST_FOR_EACH_ENTRY(service, &manager->db->services, struct service_entry, entry) { if ((service->status.dwServiceType & type) && map_state(service->status.dwCurrentState, state)) { sz = (lstrlenW(service->name) + 1) * sizeof(WCHAR); memcpy(buffer + offset, service->name, sz); s->service_name = offset; offset += sz; if (!service->config.lpDisplayName) s->display_name = 0; else { sz = (lstrlenW(service->config.lpDisplayName) + 1) * sizeof(WCHAR); memcpy(buffer + offset, service->config.lpDisplayName, sz); s->display_name = offset; offset += sz; } s->service_status = service->status; s++; } } *returned = num_services; *needed = 0; scmdatabase_unlock(manager->db); return ERROR_SUCCESS; } static struct service_entry *find_service_by_group(struct scmdatabase *db, const WCHAR *group) { struct service_entry *service; LIST_FOR_EACH_ENTRY(service, &db->services, struct service_entry, entry) { if (service->config.lpLoadOrderGroup && !wcsicmp(group, service->config.lpLoadOrderGroup)) return service; } return NULL; } static BOOL match_group(const WCHAR *g1, const WCHAR *g2) { if (!g2) return TRUE; if (!g2[0] && (!g1 || !g1[0])) return TRUE; if (g1 && !lstrcmpW(g1, g2)) return TRUE; return FALSE; } DWORD __cdecl svcctl_EnumServicesStatusExA( SC_RPC_HANDLE scmanager, SC_ENUM_TYPE info_level, DWORD service_type, DWORD service_state, BYTE *buffer, DWORD buf_size, DWORD *needed_size, DWORD *services_count, DWORD *resume_index, LPCSTR groupname) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_EnumServicesStatusExW( SC_RPC_HANDLE hmngr, SC_ENUM_TYPE info_level, DWORD type, DWORD state, BYTE *buffer, DWORD size, LPDWORD needed, LPDWORD returned, DWORD *resume_handle, LPCWSTR group) { DWORD err, sz, total_size, num_services; DWORD_PTR offset; struct sc_manager_handle *manager; struct service_entry *service; struct enum_service_status_process *s; WINE_TRACE("(%p, 0x%x, 0x%x, %p, %u, %p, %p, %s)\n", hmngr, type, state, buffer, size, needed, returned, wine_dbgstr_w(group)); if (resume_handle) FIXME("resume handle not supported\n"); if (!type || !state) return ERROR_INVALID_PARAMETER; if ((err = validate_scm_handle(hmngr, SC_MANAGER_ENUMERATE_SERVICE, &manager)) != ERROR_SUCCESS) return err; scmdatabase_lock(manager->db); if (group && !find_service_by_group(manager->db, group)) { scmdatabase_unlock(manager->db); return ERROR_SERVICE_DOES_NOT_EXIST; } total_size = num_services = 0; LIST_FOR_EACH_ENTRY(service, &manager->db->services, struct service_entry, entry) { if ((service->status.dwServiceType & type) && map_state(service->status.dwCurrentState, state) && match_group(service->config.lpLoadOrderGroup, group)) { total_size += sizeof(*s); total_size += (lstrlenW(service->name) + 1) * sizeof(WCHAR); if (service->config.lpDisplayName) { total_size += (lstrlenW(service->config.lpDisplayName) + 1) * sizeof(WCHAR); } num_services++; } } *returned = 0; *needed = total_size; if (total_size > size) { scmdatabase_unlock(manager->db); return ERROR_MORE_DATA; } s = (struct enum_service_status_process *)buffer; offset = num_services * sizeof(*s); LIST_FOR_EACH_ENTRY(service, &manager->db->services, struct service_entry, entry) { if ((service->status.dwServiceType & type) && map_state(service->status.dwCurrentState, state) && match_group(service->config.lpLoadOrderGroup, group)) { sz = (lstrlenW(service->name) + 1) * sizeof(WCHAR); memcpy(buffer + offset, service->name, sz); s->service_name = offset; offset += sz; if (!service->config.lpDisplayName) s->display_name = 0; else { sz = (lstrlenW(service->config.lpDisplayName) + 1) * sizeof(WCHAR); memcpy(buffer + offset, service->config.lpDisplayName, sz); s->display_name = offset; offset += sz; } fill_status_process(&s->service_status_process, service); s++; } } *returned = num_services; *needed = 0; scmdatabase_unlock(manager->db); return ERROR_SUCCESS; } DWORD __cdecl svcctl_unknown43(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_CreateServiceWOW64A( SC_RPC_HANDLE scmanager, LPCSTR servicename, LPCSTR displayname, DWORD accessmask, DWORD service_type, DWORD start_type, DWORD error_control, LPCSTR imagepath, LPCSTR loadordergroup, DWORD *tagid, const BYTE *dependencies, DWORD depend_size, LPCSTR start_name, const BYTE *password, DWORD password_size, SC_RPC_HANDLE *service) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_CreateServiceWOW64W( SC_RPC_HANDLE scmanager, LPCWSTR servicename, LPCWSTR displayname, DWORD accessmask, DWORD service_type, DWORD start_type, DWORD error_control, LPCWSTR imagepath, LPCWSTR loadordergroup, DWORD *tagid, const BYTE *dependencies, DWORD depend_size, LPCWSTR start_name, const BYTE *password, DWORD password_size, SC_RPC_HANDLE *service) { WINE_TRACE("(%s, %s, 0x%x, %s)\n", wine_dbgstr_w(servicename), wine_dbgstr_w(displayname), accessmask, wine_dbgstr_w(imagepath)); return create_serviceW(scmanager, servicename, displayname, accessmask, service_type, start_type, error_control, imagepath, loadordergroup, tagid, dependencies, depend_size, start_name, password, password_size, service, TRUE); } DWORD __cdecl svcctl_unknown46(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_NotifyServiceStatusChange( SC_RPC_HANDLE handle, SC_RPC_NOTIFY_PARAMS params, GUID *clientprocessguid, GUID *scmprocessguid, BOOL *createremotequeue, SC_NOTIFY_RPC_HANDLE *hNotify) { DWORD err, mask; struct sc_manager_handle *manager = NULL; struct sc_service_handle *service = NULL; struct sc_notify_handle *notify; struct sc_handle *hdr = handle; WINE_TRACE("(%p, NotifyMask: 0x%x, %p, %p, %p, %p)\n", handle, params.u.params->dwNotifyMask, clientprocessguid, scmprocessguid, createremotequeue, hNotify); switch (hdr->type) { case SC_HTYPE_SERVICE: err = validate_service_handle(handle, SERVICE_QUERY_STATUS, &service); break; case SC_HTYPE_MANAGER: err = validate_scm_handle(handle, SC_MANAGER_ENUMERATE_SERVICE, &manager); break; default: err = ERROR_INVALID_HANDLE; break; } if (err != ERROR_SUCCESS) return err; if (manager) { WARN("Need support for service creation/deletion notifications\n"); return ERROR_CALL_NOT_IMPLEMENTED; } notify = HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, sizeof(*notify)); if (!notify) return ERROR_NOT_ENOUGH_SERVER_MEMORY; notify->hdr.type = SC_HTYPE_NOTIFY; notify->hdr.access = 0; notify->event = CreateEventW(NULL, TRUE, FALSE, NULL); notify->notify_mask = params.u.params->dwNotifyMask; service_lock(service->service_entry); if (service->notify) { service_unlock(service->service_entry); sc_notify_release(notify); return ERROR_ALREADY_REGISTERED; } mask = 1 << (service->service_entry->status.dwCurrentState - SERVICE_STOPPED); if (!service->status_notified && (notify->notify_mask & mask)) { fill_notify(notify, service->service_entry); service->status_notified = TRUE; } else { sc_notify_retain(notify); service->notify = notify; } sc_notify_retain(notify); *hNotify = ¬ify->hdr; service_unlock(service->service_entry); return ERROR_SUCCESS; } DWORD __cdecl svcctl_GetNotifyResults( SC_NOTIFY_RPC_HANDLE hNotify, SC_RPC_NOTIFY_PARAMS_LIST **pList) { DWORD err; struct sc_notify_handle *notify; WINE_TRACE("(%p, %p)\n", hNotify, pList); if (!pList) return ERROR_INVALID_PARAMETER; *pList = NULL; if ((err = validate_notify_handle(hNotify, 0, ¬ify)) != 0) return err; sc_notify_retain(notify); /* block until there is a result */ err = WaitForSingleObject(notify->event, INFINITE); if (err != WAIT_OBJECT_0) { sc_notify_release(notify); return err; } *pList = InterlockedExchangePointer((void**)¬ify->params_list, NULL); if (!*pList) { sc_notify_release(notify); return ERROR_REQUEST_ABORTED; } sc_notify_release(notify); return ERROR_SUCCESS; } DWORD __cdecl svcctl_CloseNotifyHandle( SC_NOTIFY_RPC_HANDLE *hNotify, BOOL *apc_fired) { struct sc_notify_handle *notify; DWORD err; WINE_TRACE("(%p, %p)\n", hNotify, apc_fired); if ((err = validate_notify_handle(*hNotify, 0, ¬ify)) != 0) return err; sc_notify_release(notify); return ERROR_SUCCESS; } DWORD __cdecl svcctl_ControlServiceExA( SC_RPC_HANDLE service, DWORD control, DWORD info_level, SC_RPC_SERVICE_CONTROL_IN_PARAMSA *in_params, SC_RPC_SERVICE_CONTROL_OUT_PARAMSA *out_params) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_ControlServiceExW( SC_RPC_HANDLE service, DWORD control, DWORD info_level, SC_RPC_SERVICE_CONTROL_IN_PARAMSW *in_params, SC_RPC_SERVICE_CONTROL_OUT_PARAMSW *out_params) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_unknown52(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_unknown53(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_unknown54(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_unknown55(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceConfigEx( SC_RPC_HANDLE service, DWORD info_level, SC_RPC_CONFIG_INFOW *info) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceObjectSecurity( SC_RPC_HANDLE service, SECURITY_INFORMATION info, BYTE *descriptor, DWORD buf_size, DWORD *needed_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_SetServiceObjectSecurity( SC_RPC_HANDLE service, SECURITY_INFORMATION info, BYTE *descriptor, DWORD buf_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceStatus( SC_RPC_HANDLE service, SERVICE_STATUS *status) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_NotifyBootConfigStatus( SVCCTL_HANDLEW machinename, DWORD boot_acceptable) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_SCSetServiceBitsW(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_EnumDependentServicesW( SC_RPC_HANDLE service, DWORD state, BYTE *services, DWORD buf_size, DWORD *needed_size, DWORD *services_ret) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceLockStatusW( SC_RPC_HANDLE scmanager, QUERY_SERVICE_LOCK_STATUSW *status, DWORD buf_size, DWORD *needed_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_SCSetServiceBitsA(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_ChangeServiceConfigA( SC_RPC_HANDLE service, DWORD service_type, DWORD start_type, DWORD error_control, LPSTR binarypath, LPSTR loadordergroup, DWORD *tagid, BYTE *dependencies, DWORD depend_size, LPSTR startname, BYTE *password, DWORD password_size, LPSTR displayname) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_CreateServiceA( SC_RPC_HANDLE scmanager, LPCSTR servicename, LPCSTR displayname, DWORD desiredaccess, DWORD service_type, DWORD start_type, DWORD error_control, LPCSTR binarypath, LPCSTR loadordergroup, DWORD *tagid, const BYTE *dependencies, DWORD depend_size, LPCSTR startname, const BYTE *password, DWORD password_size, SC_RPC_HANDLE *service) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_EnumDependentServicesA( SC_RPC_HANDLE service, DWORD state, BYTE *services, DWORD buf_size, DWORD *needed_size, DWORD *services_ret) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_EnumServicesStatusA( SC_RPC_HANDLE hmngr, DWORD type, DWORD state, BYTE *buffer, DWORD size, DWORD *needed, DWORD *returned, DWORD *resume) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_OpenSCManagerA( MACHINE_HANDLEA MachineName, LPCSTR DatabaseName, DWORD dwAccessMask, SC_RPC_HANDLE *handle) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_OpenServiceA( SC_RPC_HANDLE hSCManager, LPCSTR lpServiceName, DWORD dwDesiredAccess, SC_RPC_HANDLE *phService) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceConfigA( SC_RPC_HANDLE hService, QUERY_SERVICE_CONFIGA *config, DWORD buf_size, DWORD *needed_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceLockStatusA( SC_RPC_HANDLE scmanager, QUERY_SERVICE_LOCK_STATUSA *status, DWORD buf_size, DWORD *needed_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_StartServiceA( SC_RPC_HANDLE service, DWORD argc, LPCSTR *args) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_GetServiceDisplayNameA( SC_RPC_HANDLE hSCManager, LPCSTR servicename, CHAR buffer[], DWORD *buf_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_GetServiceKeyNameA( SC_RPC_HANDLE hSCManager, LPCSTR servicename, CHAR buffer[], DWORD *buf_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_GetCurrentGroupStateW(void) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_EnumServiceGroupW( SC_RPC_HANDLE scmanager, DWORD service_type, DWORD service_state, BYTE *buffer, DWORD buf_size, DWORD *needed_size, DWORD *returned_size, DWORD *resume_index, LPCWSTR groupname) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_ChangeServiceConfig2A( SC_RPC_HANDLE service, SC_RPC_CONFIG_INFOA info) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD __cdecl svcctl_QueryServiceConfig2A( SC_RPC_HANDLE service, DWORD info_level, BYTE *buffer, DWORD buf_size, DWORD *needed_size) { WINE_FIXME("\n"); return ERROR_CALL_NOT_IMPLEMENTED; } DWORD RPC_Init(void) { WCHAR transport[] = SVCCTL_TRANSPORT; WCHAR endpoint[] = SVCCTL_ENDPOINT; DWORD err; if (!(cleanup_group = CreateThreadpoolCleanupGroup())) { WINE_ERR("CreateThreadpoolCleanupGroup failed with error %u\n", GetLastError()); return GetLastError(); } if ((err = RpcServerUseProtseqEpW(transport, 0, endpoint, NULL)) != ERROR_SUCCESS) { WINE_ERR("RpcServerUseProtseq failed with error %u\n", err); return err; } if ((err = RpcServerRegisterIf(svcctl_v2_0_s_ifspec, 0, 0)) != ERROR_SUCCESS) { WINE_ERR("RpcServerRegisterIf failed with error %u\n", err); return err; } if ((err = RpcServerListen(1, RPC_C_LISTEN_MAX_CALLS_DEFAULT, TRUE)) != ERROR_SUCCESS) { WINE_ERR("RpcServerListen failed with error %u\n", err); return err; } exit_event = __wine_make_process_system(); return ERROR_SUCCESS; } void RPC_Stop(void) { RpcMgmtStopServerListening(NULL); RpcServerUnregisterIf(svcctl_v2_0_s_ifspec, NULL, TRUE); RpcMgmtWaitServerListen(); CloseThreadpoolCleanupGroupMembers(cleanup_group, TRUE, NULL); CloseThreadpoolCleanupGroup(cleanup_group); CloseHandle(exit_event); } void __RPC_USER SC_RPC_HANDLE_rundown(SC_RPC_HANDLE handle) { SC_RPC_HANDLE_destroy(handle); } void __RPC_USER SC_NOTIFY_RPC_HANDLE_rundown(SC_NOTIFY_RPC_HANDLE handle) { } void __RPC_FAR * __RPC_USER MIDL_user_allocate(SIZE_T len) { return HeapAlloc(GetProcessHeap(), 0, len); } void __RPC_USER MIDL_user_free(void __RPC_FAR * ptr) { HeapFree(GetProcessHeap(), 0, ptr); }