[PATCH v2 2/3] wineusd.sys: Add new service to update user shared data continuously.

Rémi Bernon rbernon at codeweavers.com
Fri Apr 24 07:36:25 CDT 2020


On startup, every process will create a \Device\WineUsd\<PID> section
and will map it in place of its temporary user shared data. If creating
the section or mapping it fails, the process will continue as before
without having user shared data timestamp updates.

If it succeeds, it will then open the \Device\WineUsd\Control device to
notify the WineUsd service of a new process startup. The service then
opens the process section and maps it in its address space.

If the service is not yet started, then opening the device will fail and
the process will continue without having the timestamp updates until it
does.

On startup, the WineUsd service will go through the process list and try
to open the section to catch up.

Signed-off-by: Rémi Bernon <rbernon at codeweavers.com>
---
 configure.ac                      |   1 +
 dlls/wineusd.sys/Makefile.in      |   6 +
 dlls/wineusd.sys/wineusd.sys.spec |   1 +
 dlls/wineusd.sys/wineusd_main.c   | 290 ++++++++++++++++++++++++++++++
 include/wine/usd.h                |  27 +++
 loader/wine.inf.in                |  12 ++
 6 files changed, 337 insertions(+)
 create mode 100644 dlls/wineusd.sys/Makefile.in
 create mode 100644 dlls/wineusd.sys/wineusd.sys.spec
 create mode 100644 dlls/wineusd.sys/wineusd_main.c
 create mode 100644 include/wine/usd.h

diff --git a/configure.ac b/configure.ac
index fb775d7a73c..038b4175a6f 100644
--- a/configure.ac
+++ b/configure.ac
@@ -3779,6 +3779,7 @@ WINE_CONFIG_MAKEFILE(dlls/wineps.drv)
 WINE_CONFIG_MAKEFILE(dlls/wineps16.drv16,enable_win16)
 WINE_CONFIG_MAKEFILE(dlls/winepulse.drv)
 WINE_CONFIG_MAKEFILE(dlls/wineqtdecoder)
+WINE_CONFIG_MAKEFILE(dlls/wineusd.sys)
 WINE_CONFIG_MAKEFILE(dlls/winevulkan)
 WINE_CONFIG_MAKEFILE(dlls/winex11.drv)
 WINE_CONFIG_MAKEFILE(dlls/wing.dll16,enable_win16)
diff --git a/dlls/wineusd.sys/Makefile.in b/dlls/wineusd.sys/Makefile.in
new file mode 100644
index 00000000000..0792860c09b
--- /dev/null
+++ b/dlls/wineusd.sys/Makefile.in
@@ -0,0 +1,6 @@
+MODULE        = wineusd.sys
+IMPORTS       = ntoskrnl
+EXTRADLLFLAGS = -Wl,--subsystem,native -mno-cygwin
+
+C_SRCS = \
+	wineusd_main.c
diff --git a/dlls/wineusd.sys/wineusd.sys.spec b/dlls/wineusd.sys/wineusd.sys.spec
new file mode 100644
index 00000000000..76421d7e35b
--- /dev/null
+++ b/dlls/wineusd.sys/wineusd.sys.spec
@@ -0,0 +1 @@
+# nothing to export
diff --git a/dlls/wineusd.sys/wineusd_main.c b/dlls/wineusd.sys/wineusd_main.c
new file mode 100644
index 00000000000..58b6d1eb38b
--- /dev/null
+++ b/dlls/wineusd.sys/wineusd_main.c
@@ -0,0 +1,290 @@
+/*
+ * User shared data update service
+ *
+ * Copyright 2019 Rémi Bernon for CodeWeavers
+ *
+ * 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 <assert.h>
+#include <stdarg.h>
+#include "ntstatus.h"
+#define WIN32_NO_STATUS
+#include "winternl.h"
+#include "winioctl.h"
+#include "ddk/wdm.h"
+#include "wine/debug.h"
+#include "wine/heap.h"
+#include "wine/list.h"
+#include "wine/usd.h"
+
+static HANDLE directory_obj;
+static DEVICE_OBJECT *device_obj;
+
+WINE_DEFAULT_DEBUG_CHANNEL(wineusd);
+
+#define DECLARE_CRITICAL_SECTION(cs) \
+    static CRITICAL_SECTION cs; \
+    static CRITICAL_SECTION_DEBUG cs##_debug = \
+    { 0, 0, &cs, { &cs##_debug.ProcessLocksList, &cs##_debug.ProcessLocksList }, \
+      0, 0, { (DWORD_PTR)(__FILE__ ": " # cs) }}; \
+    static CRITICAL_SECTION cs = { &cs##_debug, -1, 0, 0, 0, 0 };
+
+DECLARE_CRITICAL_SECTION(wineusd_cs);
+
+static struct list wineusd_entries = LIST_INIT(wineusd_entries);
+static HANDLE wineusd_thread, wineusd_thread_stop;
+
+struct wineusd_entry
+{
+    struct list link;
+    ULONG32     pid;
+    HANDLE      section;
+    void       *page;
+};
+
+static NTSTATUS wineusd_create(HANDLE pid, struct wineusd_entry **entry_ptr)
+{
+    static const WCHAR section_formatW[] = {'\\','D','e','v','i','c','e','\\','W','i','n','e','U','s','d','\\','%','0','8','x',0};
+    struct wineusd_entry *entry;
+    OBJECT_ATTRIBUTES attr = {sizeof(attr)};
+    UNICODE_STRING string;
+    NTSTATUS status;
+    SIZE_T size = 0;
+    WCHAR section_nameW[64];
+
+    LIST_FOR_EACH_ENTRY(entry, &wineusd_entries, struct wineusd_entry, link)
+        if (entry->pid == HandleToUlong(PsGetCurrentProcessId()))
+            goto done;
+
+    if (!(entry = heap_alloc_zero(sizeof(*entry))))
+        return STATUS_NO_MEMORY;
+    entry->pid = HandleToUlong(pid);
+
+    swprintf(section_nameW, ARRAY_SIZE(section_nameW), section_formatW, entry->pid);
+    RtlInitUnicodeString(&string, section_nameW);
+    InitializeObjectAttributes(&attr, &string, 0, NULL, NULL);
+    if ((status = NtOpenSection(&entry->section, SECTION_ALL_ACCESS, &attr)))
+    {
+        /* the main process may be starting up, we should get notified later again */
+        WARN("Failed to open section for process %08x, status: %x.\n", entry->pid, status);
+        goto error;
+    }
+
+    entry->page = NULL;
+    size = 0;
+    if ((status = NtMapViewOfSection(entry->section, NtCurrentProcess(), &entry->page, 0, 0, 0,
+                                     &size, ViewShare, 0, PAGE_READWRITE)))
+    {
+        ERR("Failed to map section to driver memory, status: %x.\n", status);
+        goto error;
+    }
+
+    list_add_head(&wineusd_entries, &entry->link);
+    TRACE("Created user shared data for process %08x.\n", entry->pid);
+
+done:
+    *entry_ptr = entry;
+    return STATUS_SUCCESS;
+
+error:
+    if (entry && entry->section) NtClose(entry->section);
+    if (entry) heap_free(entry);
+    return status;
+}
+
+static void wineusd_close(struct wineusd_entry *entry)
+{
+    TRACE("Closing user shared data for process %08x.\n", entry->pid);
+
+    list_remove(&entry->link);
+    NtUnmapViewOfSection(NtCurrentProcess(), entry->page);
+    NtClose(entry->section);
+    heap_free(entry);
+}
+
+static NTSTATUS wineusd_initialize(void)
+{
+    SYSTEM_PROCESS_INFORMATION *spi;
+    struct wineusd_entry *entry;
+    NTSTATUS status;
+    ULONG size = 0x4000;
+    char *buffer;
+
+    if (!(buffer = heap_alloc(size)))
+        return STATUS_NO_MEMORY;
+
+    while ((status = NtQuerySystemInformation(SystemProcessInformation, buffer, size, NULL))
+           == STATUS_INFO_LENGTH_MISMATCH)
+    {
+        size *= 2;
+        if (!(buffer = heap_realloc(buffer, size)))
+            return STATUS_NO_MEMORY;
+    }
+
+    if (status)
+    {
+        ERR("Failed to list existing processes, status:%x\n", status);
+        goto done;
+    }
+
+    spi = (SYSTEM_PROCESS_INFORMATION*)buffer;
+    do
+    {
+        wineusd_create(spi->UniqueProcessId, &entry);
+        if (spi->NextEntryOffset == 0) break;
+        spi = (SYSTEM_PROCESS_INFORMATION *)((char *)spi + spi->NextEntryOffset);
+    }
+    while ((char *)spi < buffer + size);
+
+done:
+    if (buffer) heap_free(buffer);
+    return status;
+}
+
+static DWORD WINAPI wineusd_thread_proc(void *arg)
+{
+    struct wineusd_entry *entry;
+    ULARGE_INTEGER interrupt;
+    ULARGE_INTEGER tick;
+    LARGE_INTEGER now;
+    NTSTATUS status;
+
+    EnterCriticalSection(&wineusd_cs);
+    if ((status = wineusd_initialize()))
+        WARN("Failed to initialize process list, status:%x\n", status);
+    LeaveCriticalSection(&wineusd_cs);
+
+    TRACE("Started user shared data thread.\n");
+
+    while (WaitForSingleObject(wineusd_thread_stop, 16) == WAIT_TIMEOUT)
+    {
+        NtQuerySystemTime(&now);
+        RtlQueryUnbiasedInterruptTime(&interrupt.QuadPart);
+
+        tick = interrupt;
+        tick.QuadPart /= 10000;
+
+        EnterCriticalSection(&wineusd_cs);
+        LIST_FOR_EACH_ENTRY(entry, &wineusd_entries, struct wineusd_entry, link)
+        {
+            KSHARED_USER_DATA *usd = entry->page;
+
+            usd->SystemTime.High2Time = now.u.HighPart;
+            usd->SystemTime.LowPart   = now.u.LowPart;
+            usd->SystemTime.High1Time = now.u.HighPart;
+
+            usd->InterruptTime.High2Time = interrupt.HighPart;
+            usd->InterruptTime.LowPart   = interrupt.LowPart;
+            usd->InterruptTime.High1Time = interrupt.HighPart;
+
+            usd->TickCount.High2Time  = tick.HighPart;
+            usd->TickCount.LowPart    = tick.LowPart;
+            usd->TickCount.High1Time  = tick.HighPart;
+            usd->TickCountLowDeprecated = tick.LowPart;
+            usd->TickCountMultiplier    = 1 << 24;
+        }
+        LeaveCriticalSection(&wineusd_cs);
+    }
+
+    TRACE("Stopped user shared data thread.\n");
+
+    return 0;
+}
+
+static NTSTATUS WINAPI wineusd_dispatch_create(DEVICE_OBJECT *device, IRP *irp)
+{
+    struct wineusd_entry *entry = NULL;
+    IO_STACK_LOCATION *stack = IoGetCurrentIrpStackLocation(irp);
+    NTSTATUS status = STATUS_SUCCESS;
+
+    EnterCriticalSection(&wineusd_cs);
+    status = wineusd_create(PsGetCurrentProcessId(), &entry);
+    LeaveCriticalSection(&wineusd_cs);
+
+    stack->FileObject->FsContext = entry;
+    irp->IoStatus.Status = status;
+    IoCompleteRequest(irp, IO_NO_INCREMENT);
+    return status;
+}
+
+static NTSTATUS WINAPI wineusd_dispatch_close(DEVICE_OBJECT *device, IRP *irp)
+{
+    IO_STACK_LOCATION *stack = IoGetCurrentIrpStackLocation(irp);
+    struct wineusd_entry *entry = stack->FileObject->FsContext;
+
+    if (entry)
+    {
+        EnterCriticalSection(&wineusd_cs);
+        wineusd_close(entry);
+        LeaveCriticalSection(&wineusd_cs);
+    }
+
+    irp->IoStatus.Status = STATUS_SUCCESS;
+    IoCompleteRequest(irp, IO_NO_INCREMENT);
+    return STATUS_SUCCESS;
+}
+
+static void WINAPI wineusd_unload(DRIVER_OBJECT *driver)
+{
+    struct wineusd_entry *entry, *cursor;
+
+    SetEvent(wineusd_thread_stop);
+    WaitForSingleObject(wineusd_thread, INFINITE);
+    CloseHandle(wineusd_thread);
+    CloseHandle(wineusd_thread_stop);
+
+    EnterCriticalSection(&wineusd_cs);
+    LIST_FOR_EACH_ENTRY_SAFE(entry, cursor, &wineusd_entries, struct wineusd_entry, link)
+        wineusd_close(entry);
+
+    IoDeleteDevice(device_obj);
+    NtClose(directory_obj);
+    LeaveCriticalSection(&wineusd_cs);
+}
+
+NTSTATUS WINAPI DriverEntry(DRIVER_OBJECT *driver, UNICODE_STRING *path)
+{
+    static const WCHAR directory_nameW[] = {'\\','D','e','v','i','c','e','\\','W','i','n','e','U','s','d',0};
+    static const WCHAR device_nameW[] = {'\\','D','e','v','i','c','e','\\','W','i','n','e','U','s','d','\\','C','o','n','t','r','o','l',0};
+    OBJECT_ATTRIBUTES attr = {sizeof(attr)};
+    UNICODE_STRING string;
+    NTSTATUS status;
+
+    TRACE("Driver %p, path %s.\n", driver, debugstr_w(path->Buffer));
+
+    RtlInitUnicodeString(&string, directory_nameW);
+    InitializeObjectAttributes(&attr, &string, 0, NULL, NULL);
+    if ((status = NtCreateDirectoryObject(&directory_obj, 0, &attr)) &&
+        status != STATUS_OBJECT_NAME_COLLISION)
+        ERR("Failed to create directory, status: %x\n", status);
+
+    RtlInitUnicodeString(&string, device_nameW);
+    if ((status = IoCreateDevice(driver, 0, &string, FILE_DEVICE_UNKNOWN, 0, FALSE, &device_obj)))
+    {
+        ERR("Failed to create user shared data device, status: %x\n", status);
+        NtClose(directory_obj);
+        return status;
+    }
+
+    driver->MajorFunction[IRP_MJ_CREATE] = wineusd_dispatch_create;
+    driver->MajorFunction[IRP_MJ_CLOSE] = wineusd_dispatch_close;
+    driver->DriverUnload = wineusd_unload;
+
+    wineusd_thread_stop = CreateEventW(NULL, FALSE, FALSE, NULL);
+    wineusd_thread = CreateThread(NULL, 0, wineusd_thread_proc, NULL, 0, NULL);
+
+    return STATUS_SUCCESS;
+}
diff --git a/include/wine/usd.h b/include/wine/usd.h
new file mode 100644
index 00000000000..e92efa5e29e
--- /dev/null
+++ b/include/wine/usd.h
@@ -0,0 +1,27 @@
+/*
+ * Copyright 2019 Rémi Bernon for CodeWeavers
+ *
+ * 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
+ */
+
+#ifndef __WINE_WINE_USD_H
+#define __WINE_WINE_USD_H
+
+#include <windef.h>
+#include <winioctl.h>
+
+#define IOCTL_WINEUSD_INITIALIZE CTL_CODE(FILE_DEVICE_UNKNOWN, 0x800, METHOD_BUFFERED, FILE_ANY_ACCESS)
+
+#endif /* __WINE_WINE_USD_H */
diff --git a/loader/wine.inf.in b/loader/wine.inf.in
index d321c4c8268..67f19dea9c0 100644
--- a/loader/wine.inf.in
+++ b/loader/wine.inf.in
@@ -161,6 +161,7 @@ AddService=FontCache3.0.0.0,0,WPFFontCacheService
 AddService=LanmanServer,0,LanmanServerService
 AddService=FontCache,0,FontCacheService
 AddService=Schedule,0,TaskSchedulerService
+AddService=WineUsd,0,WineUsdService
 AddService=Winmgmt,0,WinmgmtService
 AddService=wuauserv,0,wuauService
 
@@ -178,6 +179,7 @@ AddService=FontCache3.0.0.0,0,WPFFontCacheService
 AddService=LanmanServer,0,LanmanServerService
 AddService=FontCache,0,FontCacheService
 AddService=Schedule,0,TaskSchedulerService
+AddService=WineUsd,0,WineUsdService
 AddService=Winmgmt,0,WinmgmtService
 AddService=wuauserv,0,wuauService
 
@@ -195,6 +197,7 @@ AddService=FontCache3.0.0.0,0,WPFFontCacheService
 AddService=LanmanServer,0,LanmanServerService
 AddService=FontCache,0,FontCacheService
 AddService=Schedule,0,TaskSchedulerService
+AddService=WineUsd,0,WineUsdService
 AddService=Winmgmt,0,WinmgmtService
 AddService=wuauserv,0,wuauService
 
@@ -212,6 +215,7 @@ AddService=FontCache3.0.0.0,0,WPFFontCacheService
 AddService=LanmanServer,0,LanmanServerService
 AddService=FontCache,0,FontCacheService
 AddService=Schedule,0,TaskSchedulerService
+AddService=WineUsd,0,WineUsdService
 AddService=Winmgmt,0,WinmgmtService
 AddService=wuauserv,0,wuauService
 
@@ -3637,6 +3641,14 @@ ServiceType=32
 StartType=3
 ErrorControl=1
 
+[WineUsdService]
+Description="User shared data update service"
+DisplayName="Wine User Shared Data"
+ServiceBinary="%12%\WineUsd.sys"
+ServiceType=1
+StartType=0
+ErrorControl=1
+
 [WinmgmtService]
 Description="Provides access to Windows Management Instrumentation"
 DisplayName="Windows Management Instrumentation Service"
-- 
2.26.1




More information about the wine-devel mailing list