[PATCH v2 0/5] MR10569: wineandroid: move ioctl handling to dedicated Java-only thread

[Twaik Yont (＠twaik)]

Move ioctl handling out of the Wine APC/unixlib execution path into a
dedicated Java-only thread without Wine context.

On Android 10+ a number of syscalls are restricted inside the activity
process via seccomp, while processes started via fork/exec are not
subject to the same limitations. Decoupling ioctl handling from the
Wine context is required to eventually run this code outside of the
activity process.

This change introduces a new transport and execution model where ioctl
dispatch no longer depends on Wine thread state, preparing for moving
the Android backend into a separate process.

The refactor is intentionally split into multiple bisect-safe commits
to keep intermediate states functional while gradually migrating the
dispatch path.

Since this is a fairly large chunk of work, I’d like to make sure we’re aligned before continuing.

--
  v2: wineandroid: drop old ioctl backend startup and switch to socket transport
      wineandroid: add socket-based ioctl backend (unused)
      wineandroid: move native window registration to surface_changed
      wineandroid: migrate ioctl dispatch logging to Android log
      wineandroid: Remove redundant backend DPI scaling.
 
https://gitlab.winehq.org/wine/wine/-/merge_requests/10569

[PATCH v2 1/5] wineandroid: Remove redundant backend DPI scaling.

[Twaik Yont]

From: Twaik Yont <[e-mail]>

Remove manual scaling from wineandroid.drv.

Wine now handles DPI and window sizing correctly, and applying an
additional scale factor in the Android backend leads to double scaling
and incorrect input coordinates.

Signed-off-by: Twaik Yont <[e-mail]>
---
 dlls/wineandroid.drv/WineActivity.java | 47 ++++++++------------------
 dlls/wineandroid.drv/android.h         |  4 +--
 dlls/wineandroid.drv/device.c          | 35 ++++++-------------
 dlls/wineandroid.drv/dllmain.c         |  3 +-
 dlls/wineandroid.drv/unixlib.h         |  8 -----
 dlls/wineandroid.drv/window.c          |  7 ++--
 6 files changed, 31 insertions(+), 73 deletions(-)

diff --git a/dlls/wineandroid.drv/WineActivity.java b/dlls/wineandroid.drv/WineActivity.java
index 2eee16b2dc1..fc0c13be396 100644
--- a/dlls/wineandroid.drv/WineActivity.java
+++ b/dlls/wineandroid.drv/WineActivity.java
@@ -338,7 +338,6 @@ protected class WineWindow
         protected int hwnd;
         protected int owner;
         protected int style;
-        protected float scale;
         protected boolean visible;
         protected Rect visible_rect;
         protected Rect client_rect;
@@ -351,7 +350,7 @@ protected class WineWindow
         protected WineWindowGroup window_group;
         protected WineWindowGroup client_group;
 
-        public WineWindow( int w, WineWindow parent, float scale )
+        public WineWindow( int w, WineWindow parent )
         {
             Log.i( LOGTAG, String.format( "create hwnd %08x", w ));
             hwnd = w;
@@ -360,7 +359,6 @@ public WineWindow( int w, WineWindow parent, float scale )
             visible = false;
             visible_rect = client_rect = new Rect( 0, 0, 0, 0 );
             this.parent = parent;
-            this.scale = scale;
             children = new ArrayList<WineWindow>();
             win_map.put( w, this );
             if (parent != null) parent.children.add( this );
@@ -410,10 +408,7 @@ public void destroy_window_groups()
         public View create_whole_view()
         {
             if (window_group == null) create_window_groups();
-            window_group.create_view( false ).layout( 0, 0,
-                                                      Math.round( (visible_rect.right - visible_rect.left) * scale ),
-                                                      Math.round( (visible_rect.bottom - visible_rect.top) * scale ));
-            window_group.set_scale( scale );
+            window_group.create_view( false ).layout( 0, 0, visible_rect.right - visible_rect.left, visible_rect.bottom - visible_rect.top );
             return window_group;
         }
 
@@ -510,11 +505,10 @@ public void pos_changed( int flags, int insert_after, int owner, int style,
                                          client_rect.bottom  - visible_rect.top );
         }
 
-        public void set_parent( WineWindow new_parent, float scale )
+        public void set_parent( WineWindow new_parent )
         {
             Log.i( LOGTAG, String.format( "set parent hwnd %08x parent %08x -> %08x",
                                           hwnd, parent.hwnd, new_parent.hwnd ));
-            this.scale = scale;
             if (window_group != null)
             {
                 if (visible) remove_view_from_parent();
@@ -572,8 +566,8 @@ else if (surftex != window_surftex)
 
         public void get_event_pos( MotionEvent event, int[] pos )
         {
-            pos[0] = Math.round( event.getX() * scale + window_group.getLeft() );
-            pos[1] = Math.round( event.getY() * scale + window_group.getTop() );
+            pos[0] = Math.round( event.getX() + window_group.getLeft() );
+            pos[1] = Math.round( event.getY() + window_group.getTop() );
         }
     }
 
@@ -596,10 +590,6 @@ protected class WineWindowGroup extends ViewGroup
         /* wrapper for layout() making sure that the view is not empty */
         public void set_layout( int left, int top, int right, int bottom )
         {
-            left   *= win.scale;
-            top    *= win.scale;
-            right  *= win.scale;
-            bottom *= win.scale;
             if (right <= left + 1) right = left + 2;
             if (bottom <= top + 1) bottom = top + 2;
             layout( left, top, right, bottom );
@@ -611,15 +601,6 @@ protected void onLayout( boolean changed, int left, int top, int right, int bott
             if (content_view != null) content_view.layout( 0, 0, right - left, bottom - top );
         }
 
-        public void set_scale( float scale )
-        {
-            if (content_view == null) return;
-            content_view.setPivotX( 0 );
-            content_view.setPivotY( 0 );
-            content_view.setScaleX( scale );
-            content_view.setScaleY( scale );
-        }
-
         public WineView create_view( boolean is_client )
         {
             if (content_view != null) return content_view;
@@ -765,7 +746,7 @@ protected class TopView extends ViewGroup
         public TopView( Context context )
         {
             super( context );
-            message_window = new WineWindow( WineWindow.HWND_MESSAGE, null, 1.0f );
+            message_window = new WineWindow( WineWindow.HWND_MESSAGE, null );
             message_window.create_window_groups();
         }
 
@@ -798,12 +779,12 @@ public void create_desktop_view()
         wine_config_changed( getResources().getConfiguration().densityDpi );
     }
 
-    public void create_window( int hwnd, boolean is_desktop, boolean opengl, int parent, float scale, int pid )
+    public void create_window( int hwnd, boolean is_desktop, boolean opengl, int parent )
     {
         WineWindow win = get_window( hwnd );
         if (win == null)
         {
-            win = new WineWindow( hwnd, is_desktop ? null : get_window( parent ), scale );
+            win = new WineWindow( hwnd, is_desktop ? null : get_window( parent ) );
             win.create_window_groups();
             if (win.parent == desktop_window) win.create_whole_view();
             if (is_desktop)
@@ -822,11 +803,11 @@ public void destroy_window( int hwnd )
         if (win != null) win.destroy();
     }
 
-    public void set_window_parent( int hwnd, int parent, float scale, int pid )
+    public void set_window_parent( int hwnd, int parent )
     {
         WineWindow win = get_window( hwnd );
         if (win == null) return;
-        win.set_parent( get_window( parent ), scale );
+        win.set_parent( get_window( parent ) );
         if (win.parent == desktop_window) win.create_whole_view();
     }
 
@@ -855,9 +836,9 @@ public void createDesktopView()
         runOnUiThread( new Runnable() { public void run() { create_desktop_view(); }} );
     }
 
-    public void createWindow( final int hwnd, final boolean is_desktop, final boolean opengl, final int parent, final float scale, final int pid )
+    public void createWindow( final int hwnd, final boolean is_desktop, final boolean opengl, final int parent )
     {
-        runOnUiThread( new Runnable() { public void run() { create_window( hwnd, is_desktop, opengl, parent, scale, pid ); }} );
+        runOnUiThread( new Runnable() { public void run() { create_window( hwnd, is_desktop, opengl, parent ); }} );
     }
 
     public void destroyWindow( final int hwnd )
@@ -865,9 +846,9 @@ public void destroyWindow( final int hwnd )
         runOnUiThread( new Runnable() { public void run() { destroy_window( hwnd ); }} );
     }
 
-    public void setParent( final int hwnd, final int parent, final float scale, final int pid )
+    public void setParent( final int hwnd, final int parent )
     {
-        runOnUiThread( new Runnable() { public void run() { set_window_parent( hwnd, parent, scale, pid ); }} );
+        runOnUiThread( new Runnable() { public void run() { set_window_parent( hwnd, parent ); }} );
     }
 
     public void setCursor( final int id, final int width, final int height,
diff --git a/dlls/wineandroid.drv/android.h b/dlls/wineandroid.drv/android.h
index 3107136cb7e..00061cf2812 100644
--- a/dlls/wineandroid.drv/android.h
+++ b/dlls/wineandroid.drv/android.h
@@ -62,13 +62,13 @@ extern UINT ANDROID_OpenGLInit( UINT version, const struct opengl_funcs *opengl_
 
 extern void start_android_device(void);
 extern void register_native_window( HWND hwnd, struct ANativeWindow *win, BOOL client );
-extern struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl, float scale );
+extern struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl );
 extern struct ANativeWindow *grab_ioctl_window( struct ANativeWindow *window );
 extern void release_ioctl_window( struct ANativeWindow *window );
 extern void destroy_ioctl_window( HWND hwnd, BOOL opengl );
 extern int ioctl_window_pos_changed( HWND hwnd, const struct window_rects *rects,
                                      UINT style, UINT flags, HWND after, HWND owner );
-extern int ioctl_set_window_parent( HWND hwnd, HWND parent, float scale );
+extern int ioctl_set_window_parent( HWND hwnd, HWND parent );
 extern int ioctl_set_capture( HWND hwnd );
 extern int ioctl_set_cursor( int id, int width, int height,
                              int hotspotx, int hotspoty, const unsigned int *bits );
diff --git a/dlls/wineandroid.drv/device.c b/dlls/wineandroid.drv/device.c
index 3d77033a980..bf362d7f5ac 100644
--- a/dlls/wineandroid.drv/device.c
+++ b/dlls/wineandroid.drv/device.c
@@ -132,7 +132,6 @@ struct ioctl_android_create_window
 {
     struct ioctl_header hdr;
     int                 parent;
-    float               scale;
     BOOL                is_desktop;
 };
 
@@ -156,6 +155,7 @@ struct ioctl_android_window_pos_changed
 struct ioctl_android_dequeueBuffer
 {
     struct ioctl_header hdr;
+    DWORD pid;
     HANDLE handle;
     int buffer_id;
     int generation;
@@ -199,7 +199,6 @@ struct ioctl_android_set_window_parent
 {
     struct ioctl_header hdr;
     int                 parent;
-    float               scale;
 };
 
 struct ioctl_android_set_capture
@@ -224,12 +223,6 @@ static inline BOOL is_in_desktop_process(void)
     return thread != NULL;
 }
 
-static inline DWORD current_client_id(void)
-{
-    DWORD client_id = NtUserGetThreadInfo()->driver_data;
-    return client_id ? client_id : GetCurrentProcessId();
-}
-
 #ifdef __i386__  /* the Java VM uses %fs/%gs for its own purposes, so we need to wrap the calls */
 
 static WORD orig_fs, java_fs;
@@ -610,7 +603,6 @@ static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, U
     jobject object;
     struct ioctl_android_create_window *res = data;
     struct native_win_data *win_data;
-    DWORD pid = current_client_id();
 
     if (in_size < sizeof(*res)) return STATUS_INVALID_PARAMETER;
 
@@ -619,10 +611,10 @@ static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, U
 
     TRACE( "hwnd %08x opengl %u parent %08x\n", res->hdr.hwnd, res->hdr.opengl, res->parent );
 
-    if (!(object = load_java_method( &method, "createWindow", "(IZZIFI)V" ))) return STATUS_NOT_SUPPORTED;
+    if (!(object = load_java_method( &method, "createWindow", "(IZZI)V" ))) return STATUS_NOT_SUPPORTED;
 
     wrap_java_call();
-    (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->is_desktop, res->hdr.opengl, res->parent, res->scale, pid );
+    (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->is_desktop, res->hdr.opengl, res->parent );
     unwrap_java_call();
     return STATUS_SUCCESS;
 }
@@ -720,7 +712,7 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
         int sv[2] = { -1, -1 };
         HANDLE local = 0;
         OBJECT_ATTRIBUTES attr = { .Length = sizeof(attr) };
-        CLIENT_ID cid = { .UniqueProcess = UlongToHandle( current_client_id() ) };
+        CLIENT_ID cid = { .UniqueProcess = UlongToHandle( res->pid ) };
         HANDLE process;
 
         if (!ahb)
@@ -950,7 +942,6 @@ static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size
     jobject object;
     struct ioctl_android_set_window_parent *res = data;
     struct native_win_data *win_data;
-    DWORD pid = current_client_id();
 
     if (in_size < sizeof(*res)) return STATUS_INVALID_PARAMETER;
 
@@ -958,10 +949,10 @@ static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size
 
     TRACE( "hwnd %08x parent %08x\n", res->hdr.hwnd, res->parent );
 
-    if (!(object = load_java_method( &method, "setParent", "(IIFI)V" ))) return STATUS_NOT_SUPPORTED;
+    if (!(object = load_java_method( &method, "setParent", "(II)V" ))) return STATUS_NOT_SUPPORTED;
 
     wrap_java_call();
-    (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->parent, res->scale, pid );
+    (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->parent );
     unwrap_java_call();
     return STATUS_SUCCESS;
 }
@@ -1037,8 +1028,7 @@ static const ioctl_func ioctl_funcs[] =
 
 NTSTATUS android_dispatch_ioctl( void *arg )
 {
-    struct ioctl_params *params = arg;
-    IRP *irp = params->irp;
+    IRP *irp = arg;
     IO_STACK_LOCATION *irpsp = IoGetCurrentIrpStackLocation( irp );
     DWORD code = (irpsp->Parameters.DeviceIoControl.IoControlCode - ANDROID_IOCTL(0)) >> 2;
 
@@ -1051,11 +1041,9 @@ NTSTATUS android_dispatch_ioctl( void *arg )
         if (in_size >= sizeof(*header))
         {
             irp->IoStatus.Information = 0;
-            NtUserGetThreadInfo()->driver_data = params->client_id;
             irp->IoStatus.Status = func( irp->AssociatedIrp.SystemBuffer, in_size,
                                          irpsp->Parameters.DeviceIoControl.OutputBufferLength,
                                          &irp->IoStatus.Information );
-            NtUserGetThreadInfo()->driver_data = 0;
         }
         else irp->IoStatus.Status = STATUS_INVALID_PARAMETER;
     }
@@ -1158,11 +1146,12 @@ static int dequeueBuffer( struct ANativeWindow *window, struct ANativeWindowBuff
 
     res.hdr.hwnd = HandleToLong( win->hwnd );
     res.hdr.opengl = win->opengl;
+    res.pid = GetCurrentProcessId();
     res.handle = 0;
     res.buffer_id = -1;
     res.generation = 0;
 
-    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, sizeof(res.hdr), &res, &size );
+    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, size, &res, &size );
     if (ret) return ret;
     if (size < sizeof(res)) return -EINVAL;
 
@@ -1430,7 +1419,7 @@ static int perform( ANativeWindow *window, int operation, ... )
     return android_ioctl( IOCTL_PERFORM, &perf, sizeof(perf), NULL, NULL );
 }
 
-struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl, float scale )
+struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl )
 {
     struct ioctl_android_create_window req;
     struct native_win_wrapper *win = calloc( 1, sizeof(*win) );
@@ -1459,7 +1448,6 @@ struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl, float scale )
     req.hdr.hwnd = HandleToLong( win->hwnd );
     req.hdr.opengl = win->opengl;
     req.parent = get_ioctl_win_parent( NtUserGetAncestor( hwnd, GA_PARENT ));
-    req.scale = scale;
     req.is_desktop = hwnd == desktop_window;
     android_ioctl( IOCTL_CREATE_WINDOW, &req, sizeof(req), NULL, NULL );
 
@@ -1514,14 +1502,13 @@ int ioctl_window_pos_changed( HWND hwnd, const struct window_rects *rects,
     return android_ioctl( IOCTL_WINDOW_POS_CHANGED, &req, sizeof(req), NULL, NULL );
 }
 
-int ioctl_set_window_parent( HWND hwnd, HWND parent, float scale )
+int ioctl_set_window_parent( HWND hwnd, HWND parent )
 {
     struct ioctl_android_set_window_parent req;
 
     req.hdr.hwnd = HandleToLong( hwnd );
     req.hdr.opengl = FALSE;
     req.parent = get_ioctl_win_parent( parent );
-    req.scale = scale;
     return android_ioctl( IOCTL_SET_WINDOW_PARENT, &req, sizeof(req), NULL, NULL );
 }
 
diff --git a/dlls/wineandroid.drv/dllmain.c b/dlls/wineandroid.drv/dllmain.c
index d9cd94338a0..7f6d04e83df 100644
--- a/dlls/wineandroid.drv/dllmain.c
+++ b/dlls/wineandroid.drv/dllmain.c
@@ -37,8 +37,7 @@ static HANDLE stop_event;
 
 static NTSTATUS WINAPI ioctl_callback( DEVICE_OBJECT *device, IRP *irp )
 {
-    struct ioctl_params params = { .irp = irp, .client_id = HandleToUlong(PsGetCurrentProcessId()) };
-    NTSTATUS status = ANDROID_CALL( dispatch_ioctl, ¶ms );
+    NTSTATUS status = ANDROID_CALL( dispatch_ioctl, irp );
     IoCompleteRequest( irp, IO_NO_INCREMENT );
     return status;
 }
diff --git a/dlls/wineandroid.drv/unixlib.h b/dlls/wineandroid.drv/unixlib.h
index 46c59f8f201..39a4df58283 100644
--- a/dlls/wineandroid.drv/unixlib.h
+++ b/dlls/wineandroid.drv/unixlib.h
@@ -39,14 +39,6 @@ struct init_params
 };
 
 
-/* android_ioctl params */
-struct ioctl_params
-{
-    struct _IRP *irp;
-    DWORD client_id;
-};
-
-
 /* android_register_window params */
 struct register_window_params
 {
diff --git a/dlls/wineandroid.drv/window.c b/dlls/wineandroid.drv/window.c
index 41439c2f697..97eb3004ba8 100644
--- a/dlls/wineandroid.drv/window.c
+++ b/dlls/wineandroid.drv/window.c
@@ -99,8 +99,7 @@ static struct android_win_data *alloc_win_data( HWND hwnd )
     if ((data = calloc( 1, sizeof(*data) )))
     {
         data->hwnd = hwnd;
-        data->window = create_ioctl_window( hwnd, FALSE,
-                                            (float)NtUserGetWinMonitorDpi( hwnd, MDT_RAW_DPI ) / NtUserGetDpiForWindow( hwnd ));
+        data->window = create_ioctl_window( hwnd, FALSE );
         pthread_mutex_lock( &win_data_mutex );
         win_data_context[context_idx(hwnd)] = data;
     }
@@ -1105,7 +1104,7 @@ void ANDROID_SetParent( HWND hwnd, HWND parent, HWND old_parent )
     TRACE( "win %p parent %p -> %p\n", hwnd, old_parent, parent );
 
     data->parent = (parent == NtUserGetDesktopWindow()) ? 0 : parent;
-    ioctl_set_window_parent( hwnd, parent, (float)NtUserGetWinMonitorDpi( hwnd, MDT_RAW_DPI ) / NtUserGetDpiForWindow( hwnd ));
+    ioctl_set_window_parent( hwnd, parent );
     release_win_data( data );
 }
 
@@ -1214,7 +1213,7 @@ ANativeWindow *get_client_window( HWND hwnd )
     ANativeWindow *client;
 
     if (!(data = get_win_data( hwnd ))) return NULL;
-    if (!data->client) data->client = create_ioctl_window( hwnd, TRUE, 1.0f );
+    if (!data->client) data->client = create_ioctl_window( hwnd, TRUE );
     client = grab_ioctl_window( data->client );
     release_win_data( data );
 
-- 
GitLab


https://gitlab.winehq.org/wine/wine/-/merge_requests/10569

[PATCH v2 2/5] wineandroid: migrate ioctl dispatch logging to Android log

[Twaik Yont]

From: Twaik Yont <[e-mail]>

Route ioctl dispatch related logging in device.c through
__android_log_print and map WINEDEBUG levels to Android log priorities.

Initialize a per-module verbosity level from the Wine debug channel and
use it to filter logcat output, preserving the effective debug level
without relying on Wine debug macros at call sites.

This prepares the ioctl dispatch path for execution outside of the Wine
context (e.g. on the Android activity thread), where the standard Wine
debug infrastructure is not available.

Signed-off-by: Twaik Yont <[e-mail]>
---
 dlls/wineandroid.drv/android.h |  1 +
 dlls/wineandroid.drv/device.c  | 89 ++++++++++++++++++++++++----------
 dlls/wineandroid.drv/init.c    |  1 +
 3 files changed, 66 insertions(+), 25 deletions(-)

diff --git a/dlls/wineandroid.drv/android.h b/dlls/wineandroid.drv/android.h
index 00061cf2812..8cec766f1eb 100644
--- a/dlls/wineandroid.drv/android.h
+++ b/dlls/wineandroid.drv/android.h
@@ -119,6 +119,7 @@ enum android_window_messages
     WM_ANDROID_REFRESH = WM_WINE_FIRST_DRIVER_MSG,
 };
 
+extern void init_android_log_verbosity(void);
 extern void init_ahardwarebuffers(void);
 extern HWND get_capture_window(void);
 extern void init_monitors( int width, int height );
diff --git a/dlls/wineandroid.drv/device.c b/dlls/wineandroid.drv/device.c
index bf362d7f5ac..a19fd0074e1 100644
--- a/dlls/wineandroid.drv/device.c
+++ b/dlls/wineandroid.drv/device.c
@@ -48,6 +48,45 @@
 
 WINE_DEFAULT_DEBUG_CHANNEL(android);
 
+static int android_log_verbosity = ANDROID_LOG_VERBOSE;
+
+void init_android_log_verbosity(void)
+{
+    struct __wine_debug_channel *ch = &__wine_dbch_android;
+
+    if (__WINE_IS_DEBUG_ON(_TRACE, ch))
+        android_log_verbosity = ANDROID_LOG_VERBOSE;
+    else if (__WINE_IS_DEBUG_ON(_FIXME, ch))
+        android_log_verbosity = ANDROID_LOG_WARN;
+    else if (__WINE_IS_DEBUG_ON(_WARN, ch))
+        android_log_verbosity = ANDROID_LOG_WARN;
+    else if (__WINE_IS_DEBUG_ON(_ERR, ch))
+        android_log_verbosity = ANDROID_LOG_ERROR;
+    else
+        android_log_verbosity = ANDROID_LOG_SILENT;
+}
+
+#define __LOG(prio, ...) \
+    do { if ((ANDROID_LOG_ ## prio) >= android_log_verbosity) \
+        p__android_log_print( ANDROID_LOG_ ## prio, "wine", __VA_ARGS__ ); } while (0)
+#define _INFO(...) __LOG(INFO, __VA_ARGS__)
+#define _DEBUG(...) __LOG(DEBUG, __VA_ARGS__)
+#define _WARN(...) __LOG(WARN, __VA_ARGS__)
+#define _FIXME(...) __LOG(WARN, "FIXME: " __VA_ARGS__)
+#define _TRACE(...) __LOG(VERBOSE, __VA_ARGS__)
+#define _ERR(...) __LOG(ERROR, __VA_ARGS__)
+static inline const char *_wine_dbgstr_rect( const RECT *rect )
+{
+    enum { N = 4 };
+    static __thread char buf[N][64];
+    static __thread int idx;
+    char *ret = buf[idx++ % N];
+
+    if (!rect) return "(null)";
+    snprintf( ret, 64, "(%d,%d)-(%d,%d)", (int)rect->left, (int)rect->top, (int)rect->right, (int)rect->bottom );
+    return ret;
+}
+
 #define DECL_FUNCPTR(f) static typeof(f) * p##f = NULL
 
 struct AHardwareBuffer* ANativeWindowBuffer_getHardwareBuffer(struct ANativeWindowBuffer* anwb) __INTRODUCED_IN(26);
@@ -273,7 +312,7 @@ static struct native_win_data *get_native_win_data( HWND hwnd, BOOL opengl )
     struct native_win_data *data = data_map[data_map_idx( hwnd, opengl )];
 
     if (data && data->hwnd == hwnd && !data->opengl == !opengl) return data;
-    WARN( "unknown win %p opengl %u\n", hwnd, opengl );
+    _WARN( "unknown win %p opengl %u\n", hwnd, opengl );
     return NULL;
 }
 
@@ -373,7 +412,7 @@ static int register_buffer( struct native_win_data *win, struct AHardwareBuffer
         i = win->buffer_lru[NB_CACHED_BUFFERS - 1];
         assert( i < NB_CACHED_BUFFERS );
 
-        TRACE( "%p %p evicting buffer %p id %d from cache\n",
+        _TRACE( "%p %p evicting buffer %p id %d from cache\n",
                win->hwnd, win->parent, win->buffers[i], i );
         pAHardwareBuffer_release(win->buffers[i]);
     }
@@ -382,7 +421,7 @@ static int register_buffer( struct native_win_data *win, struct AHardwareBuffer
 
     pAHardwareBuffer_acquire(buffer);
     *is_new = 1;
-    TRACE( "%p %p %p -> %d\n", win->hwnd, win->parent, buffer, i );
+    _TRACE( "%p %p %p -> %d\n", win->hwnd, win->parent, buffer, i );
 
 done:
     insert_buffer_lru( win, i );
@@ -393,7 +432,7 @@ static struct ANativeWindowBuffer *get_registered_buffer( struct native_win_data
 {
     if (id < 0 || id >= NB_CACHED_BUFFERS || !win->buffers[id])
     {
-        ERR( "unknown buffer %d for %p %p\n", id, win->hwnd, win->parent );
+        _ERR( "unknown buffer %d for %p %p\n", id, win->hwnd, win->parent );
         return NULL;
     }
     return anwb_from_ahb(win->buffers[id]);
@@ -429,7 +468,7 @@ static struct native_win_data *create_native_win_data( HWND hwnd, BOOL opengl )
 
     if (data)
     {
-        WARN( "data for %p not freed correctly\n", data->hwnd );
+        _WARN( "data for %p not freed correctly\n", data->hwnd );
         free_native_win_data( data );
     }
     if (!(data = calloc( 1, sizeof(*data) ))) return NULL;
@@ -456,7 +495,7 @@ NTSTATUS android_register_window( void *arg )
     {
         pANativeWindow_release( win );
         if (data) NtUserPostMessage( hwnd, WM_ANDROID_REFRESH, opengl, 0 );
-        TRACE( "%p -> %p win %p (unchanged)\n", hwnd, data, win );
+        _TRACE( "%p -> %p win %p (unchanged)\n", hwnd, data, win );
         return 0;
     }
 
@@ -469,7 +508,7 @@ NTSTATUS android_register_window( void *arg )
     win->setSwapInterval( win, data->swap_interval );
     unwrap_java_call();
     NtUserPostMessage( hwnd, WM_ANDROID_REFRESH, opengl, 0 );
-    TRACE( "%p -> %p win %p\n", hwnd, data, win );
+    _TRACE( "%p -> %p win %p\n", hwnd, data, win );
     return 0;
 }
 
@@ -535,7 +574,7 @@ static NTSTATUS android_error_to_status( int err )
     case -EBADMSG:     return STATUS_INVALID_DEVICE_REQUEST;
     case -EWOULDBLOCK: return STATUS_DEVICE_NOT_READY;
     default:
-        FIXME( "unmapped error %d\n", err );
+        _FIXME( "unmapped error %d\n", err );
         return STATUS_UNSUCCESSFUL;
     }
 }
@@ -559,7 +598,7 @@ static int status_to_android_error( unsigned int status )
     case STATUS_INVALID_DEVICE_REQUEST: return -EBADMSG;
     case STATUS_DEVICE_NOT_READY:       return -EWOULDBLOCK;
     default:
-        FIXME( "unmapped status %08x\n", status );
+        _FIXME( "unmapped status %08x\n", status );
         return -EINVAL;
     }
 }
@@ -578,7 +617,7 @@ static jobject load_java_method( jmethodID *method, const char *name, const char
         unwrap_java_call();
         if (!*method)
         {
-            FIXME( "method %s not found\n", name );
+            _FIXME( "method %s not found\n", name );
             return NULL;
         }
     }
@@ -609,7 +648,7 @@ static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, U
     if (!(win_data = create_native_win_data( LongToHandle(res->hdr.hwnd), res->hdr.opengl )))
         return STATUS_NO_MEMORY;
 
-    TRACE( "hwnd %08x opengl %u parent %08x\n", res->hdr.hwnd, res->hdr.opengl, res->parent );
+    _TRACE( "hwnd %08x opengl %u parent %08x\n", res->hdr.hwnd, res->hdr.opengl, res->parent );
 
     if (!(object = load_java_method( &method, "createWindow", "(IZZI)V" ))) return STATUS_NOT_SUPPORTED;
 
@@ -630,7 +669,7 @@ static NTSTATUS destroyWindow_ioctl( void *data, DWORD in_size, DWORD out_size,
 
     win_data = get_ioctl_native_win_data( &res->hdr );
 
-    TRACE( "hwnd %08x opengl %u\n", res->hdr.hwnd, res->hdr.opengl );
+    _TRACE( "hwnd %08x opengl %u\n", res->hdr.hwnd, res->hdr.opengl );
 
     if (!(object = load_java_method( &method, "destroyWindow", "(I)V" ))) return STATUS_NOT_SUPPORTED;
 
@@ -649,9 +688,9 @@ static NTSTATUS windowPosChanged_ioctl( void *data, DWORD in_size, DWORD out_siz
 
     if (in_size < sizeof(*res)) return STATUS_INVALID_PARAMETER;
 
-    TRACE( "hwnd %08x win %s client %s visible %s style %08x flags %08x after %08x owner %08x\n",
-           res->hdr.hwnd, wine_dbgstr_rect(&res->window_rect), wine_dbgstr_rect(&res->client_rect),
-           wine_dbgstr_rect(&res->visible_rect), res->style, res->flags, res->after, res->owner );
+    _TRACE( "hwnd %08x win %s client %s visible %s style %08x flags %08x after %08x owner %08x\n",
+           res->hdr.hwnd, _wine_dbgstr_rect(&res->window_rect), _wine_dbgstr_rect(&res->client_rect),
+           _wine_dbgstr_rect(&res->visible_rect), res->style, res->flags, res->after, res->owner );
 
     if (!(object = load_java_method( &method, "windowPosChanged", "(IIIIIIIIIIIIIIIII)V" )))
         return STATUS_NOT_SUPPORTED;
@@ -690,17 +729,17 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
     unwrap_java_call();
     if (ret)
     {
-        ERR( "%08x failed %d\n", res->hdr.hwnd, ret );
+        _ERR( "%08x failed %d\n", res->hdr.hwnd, ret );
         return android_error_to_status( ret );
     }
 
     if (!buffer)
     {
-        TRACE( "got invalid buffer\n" );
+        _TRACE( "got invalid buffer\n" );
         return STATUS_UNSUCCESSFUL;
     }
 
-    TRACE( "%08x got buffer %p fence %d\n", res->hdr.hwnd, buffer, fence );
+    _TRACE( "%08x got buffer %p fence %d\n", res->hdr.hwnd, buffer, fence );
     ahb = pANativeWindowBuffer_getHardwareBuffer( buffer );
 
     res->buffer_id = register_buffer( win_data, ahb, &is_new );
@@ -780,7 +819,7 @@ static NTSTATUS cancelBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, U
 
     if (!(buffer = get_registered_buffer( win_data, res->buffer_id ))) return STATUS_INVALID_HANDLE;
 
-    TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
+    _TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
     wrap_java_call();
     ret = parent->cancelBuffer( parent, buffer, -1 );
     unwrap_java_call();
@@ -803,7 +842,7 @@ static NTSTATUS queueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, UL
 
     if (!(buffer = get_registered_buffer( win_data, res->buffer_id ))) return STATUS_INVALID_HANDLE;
 
-    TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
+    _TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
     wrap_java_call();
     ret = parent->queueBuffer( parent, buffer, -1 );
     unwrap_java_call();
@@ -911,7 +950,7 @@ static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_
     }
     case NATIVE_WINDOW_LOCK:
     default:
-        FIXME( "unsupported perform op %d\n", res->operation );
+        _FIXME( "unsupported perform op %d\n", res->operation );
         break;
     }
     return android_error_to_status( ret );
@@ -947,7 +986,7 @@ static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size
 
     if (!(win_data = get_ioctl_native_win_data( &res->hdr ))) return STATUS_INVALID_HANDLE;
 
-    TRACE( "hwnd %08x parent %08x\n", res->hdr.hwnd, res->parent );
+    _TRACE( "hwnd %08x parent %08x\n", res->hdr.hwnd, res->parent );
 
     if (!(object = load_java_method( &method, "setParent", "(II)V" ))) return STATUS_NOT_SUPPORTED;
 
@@ -965,7 +1004,7 @@ static NTSTATUS setCapture_ioctl( void *data, DWORD in_size, DWORD out_size, ULO
 
     if (res->hdr.hwnd && !get_ioctl_native_win_data( &res->hdr )) return STATUS_INVALID_HANDLE;
 
-    TRACE( "hwnd %08x\n", res->hdr.hwnd );
+    _TRACE( "hwnd %08x\n", res->hdr.hwnd );
 
     InterlockedExchangePointer( (void **)&capture_window, LongToHandle( res->hdr.hwnd ));
     return STATUS_SUCCESS;
@@ -987,7 +1026,7 @@ static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULON
     if (in_size != offsetof( struct ioctl_android_set_cursor, bits[size] ))
         return STATUS_INVALID_PARAMETER;
 
-    TRACE( "hwnd %08x size %d\n", res->hdr.hwnd, size );
+    _TRACE( "hwnd %08x size %d\n", res->hdr.hwnd, size );
 
     if (!(object = load_java_method( &method, "setCursor", "(IIIII[I)V" )))
         return STATUS_NOT_SUPPORTED;
@@ -1049,7 +1088,7 @@ NTSTATUS android_dispatch_ioctl( void *arg )
     }
     else
     {
-        FIXME( "ioctl %x not supported\n", irpsp->Parameters.DeviceIoControl.IoControlCode );
+        _FIXME( "ioctl %x not supported\n", irpsp->Parameters.DeviceIoControl.IoControlCode );
         irp->IoStatus.Status = STATUS_NOT_SUPPORTED;
     }
     return STATUS_SUCCESS;
diff --git a/dlls/wineandroid.drv/init.c b/dlls/wineandroid.drv/init.c
index 303655cde58..e8cb360d032 100644
--- a/dlls/wineandroid.drv/init.c
+++ b/dlls/wineandroid.drv/init.c
@@ -386,6 +386,7 @@ static HRESULT android_init( void *arg )
 
     object = *p_java_object;
 
+    init_android_log_verbosity();
     init_ahardwarebuffers();
 
     pthread_mutexattr_init( &attr );
-- 
GitLab


https://gitlab.winehq.org/wine/wine/-/merge_requests/10569

[PATCH v2 3/5] wineandroid: move native window registration to surface_changed

[Twaik Yont]

From: Twaik Yont <[e-mail]>

Move native window registration from the APC/unixlib callback path to
the direct JNI surface_changed callback.

Keep WM_ANDROID_REFRESH posted from process_events() after updating the
native window state.

Add a temporary serialization lock around ioctl dispatch and native
window registration to keep intermediate migration commits bisectable
while moving this code away from the old APC execution path.

Signed-off-by: Twaik Yont <[e-mail]>
---
 dlls/wineandroid.drv/android.h |  2 -
 dlls/wineandroid.drv/device.c  | 95 ++++++++++++++++++----------------
 dlls/wineandroid.drv/dllmain.c |  8 ---
 dlls/wineandroid.drv/init.c    |  3 --
 dlls/wineandroid.drv/unixlib.h | 11 ----
 dlls/wineandroid.drv/window.c  |  3 +-
 6 files changed, 51 insertions(+), 71 deletions(-)

diff --git a/dlls/wineandroid.drv/android.h b/dlls/wineandroid.drv/android.h
index 8cec766f1eb..f87c561d2e2 100644
--- a/dlls/wineandroid.drv/android.h
+++ b/dlls/wineandroid.drv/android.h
@@ -105,8 +105,6 @@ extern BOOL has_client_surface( HWND hwnd );
 extern NTSTATUS android_dispatch_ioctl( void *arg );
 extern NTSTATUS android_java_init( void *arg );
 extern NTSTATUS android_java_uninit( void *arg );
-extern NTSTATUS android_register_window( void *arg );
-extern PNTAPCFUNC register_window_callback;
 extern UINT64 start_device_callback;
 
 extern unsigned int screen_width;
diff --git a/dlls/wineandroid.drv/device.c b/dlls/wineandroid.drv/device.c
index a19fd0074e1..544b63a21da 100644
--- a/dlls/wineandroid.drv/device.c
+++ b/dlls/wineandroid.drv/device.c
@@ -109,6 +109,8 @@ static JNIEnv *jni_env;
 static HWND capture_window;
 static HWND desktop_window;
 
+static pthread_mutex_t dispatch_ioctl_lock = PTHREAD_MUTEX_INITIALIZER; // Temporary lock for bisect-safe serialization of dispatch-related state during the APC-to-JNI registration migration.
+
 #define ANDROIDCONTROLTYPE  ((ULONG)'A')
 #define ANDROID_IOCTL(n) CTL_CODE(ANDROIDCONTROLTYPE, n, METHOD_BUFFERED, FILE_READ_ACCESS)
 
@@ -395,6 +397,7 @@ static void insert_buffer_lru( struct native_win_data *win, int index )
     win->buffer_lru[0] = index;
 }
 
+/* Called from JNI surface_changed() on the Java thread */
 static int register_buffer( struct native_win_data *win, struct AHardwareBuffer *buffer, int *is_new )
 {
     unsigned int i;
@@ -481,41 +484,36 @@ static struct native_win_data *create_native_win_data( HWND hwnd, BOOL opengl )
     return data;
 }
 
-NTSTATUS android_register_window( void *arg )
+/* register a native window received from the Java side for use in ioctls */
+void register_native_window( HWND hwnd, struct ANativeWindow *win, BOOL opengl )
 {
-    struct register_window_params *params = arg;
-    HWND hwnd = (HWND)params->arg1;
-    struct ANativeWindow *win = (struct ANativeWindow *)params->arg2;
-    BOOL opengl = params->arg3;
-    struct native_win_data *data = get_native_win_data( hwnd, opengl );
+    struct native_win_data *data = NULL;
+
+    pthread_mutex_lock(&dispatch_ioctl_lock);
+    data = get_native_win_data( hwnd, opengl );
 
-    if (!win) return 0;  /* do nothing and hold on to the window until we get a new surface */
+    if (!win) {
+        pthread_mutex_unlock(&dispatch_ioctl_lock);
+        return;  /* do nothing and hold on to the window until we get a new surface */
+    }
 
     if (!data || data->parent == win)
     {
         pANativeWindow_release( win );
-        if (data) NtUserPostMessage( hwnd, WM_ANDROID_REFRESH, opengl, 0 );
         _TRACE( "%p -> %p win %p (unchanged)\n", hwnd, data, win );
-        return 0;
+        pthread_mutex_unlock(&dispatch_ioctl_lock);
+        return;
     }
 
     release_native_window( data );
     data->parent = win;
     data->generation++;
-    wrap_java_call();
     if (data->api) win->perform( win, NATIVE_WINDOW_API_CONNECT, data->api );
     win->perform( win, NATIVE_WINDOW_SET_BUFFERS_FORMAT, data->buffer_format );
     win->setSwapInterval( win, data->swap_interval );
-    unwrap_java_call();
-    NtUserPostMessage( hwnd, WM_ANDROID_REFRESH, opengl, 0 );
     _TRACE( "%p -> %p win %p\n", hwnd, data, win );
-    return 0;
-}
-
-/* register a native window received from the Java side for use in ioctls */
-void register_native_window( HWND hwnd, struct ANativeWindow *win, BOOL opengl )
-{
-    NtQueueApcThread( thread, register_window_callback, (ULONG_PTR)hwnd, (ULONG_PTR)win, opengl );
+    pthread_mutex_unlock(&dispatch_ioctl_lock);
+    return;
 }
 
 #define LOAD_FUNCPTR(lib, func) do { \
@@ -636,7 +634,7 @@ static void create_desktop_view(void)
     unwrap_java_call();
 }
 
-static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     static jmethodID method;
     jobject object;
@@ -658,7 +656,7 @@ static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, U
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS destroyWindow_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS destroyWindow_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     static jmethodID method;
     jobject object;
@@ -680,7 +678,7 @@ static NTSTATUS destroyWindow_ioctl( void *data, DWORD in_size, DWORD out_size,
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS windowPosChanged_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS windowPosChanged_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     static jmethodID method;
     jobject object;
@@ -704,7 +702,7 @@ static NTSTATUS windowPosChanged_ioctl( void *data, DWORD in_size, DWORD out_siz
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ANativeWindow *parent;
     struct ioctl_android_dequeueBuffer *res = data;
@@ -803,7 +801,7 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS cancelBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS cancelBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_cancelBuffer *res = data;
     struct ANativeWindow *parent;
@@ -826,7 +824,7 @@ static NTSTATUS cancelBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, U
     return android_error_to_status( ret );
 }
 
-static NTSTATUS queueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS queueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_queueBuffer *res = data;
     struct ANativeWindow *parent;
@@ -849,7 +847,7 @@ static NTSTATUS queueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, UL
     return android_error_to_status( ret );
 }
 
-static NTSTATUS query_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS query_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_query *res = data;
     struct ANativeWindow *parent;
@@ -869,7 +867,7 @@ static NTSTATUS query_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PT
     return android_error_to_status( ret );
 }
 
-static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_perform *res = data;
     struct ANativeWindow *parent;
@@ -956,7 +954,7 @@ static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_
     return android_error_to_status( ret );
 }
 
-static NTSTATUS setSwapInterval_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS setSwapInterval_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_set_swap_interval *res = data;
     struct ANativeWindow *parent;
@@ -975,7 +973,7 @@ static NTSTATUS setSwapInterval_ioctl( void *data, DWORD in_size, DWORD out_size
     return android_error_to_status( ret );
 }
 
-static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     static jmethodID method;
     jobject object;
@@ -996,7 +994,7 @@ static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS setCapture_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS setCapture_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     struct ioctl_android_set_capture *res = data;
 
@@ -1010,7 +1008,7 @@ static NTSTATUS setCapture_ioctl( void *data, DWORD in_size, DWORD out_size, ULO
     return STATUS_SUCCESS;
 }
 
-static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size )
+static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
 {
     static jmethodID method;
     jobject object;
@@ -1048,7 +1046,7 @@ static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULON
     return STATUS_SUCCESS;
 }
 
-typedef NTSTATUS (*ioctl_func)( void *in, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size );
+typedef NTSTATUS (*ioctl_func)( void *in, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd );
 static const ioctl_func ioctl_funcs[] =
 {
     createWindow_ioctl,         /* IOCTL_CREATE_WINDOW */
@@ -1076,13 +1074,16 @@ NTSTATUS android_dispatch_ioctl( void *arg )
         struct ioctl_header *header = irp->AssociatedIrp.SystemBuffer;
         DWORD in_size = irpsp->Parameters.DeviceIoControl.InputBufferLength;
         ioctl_func func = ioctl_funcs[code];
+        int reply_fd = -1;
 
         if (in_size >= sizeof(*header))
         {
             irp->IoStatus.Information = 0;
+            pthread_mutex_lock(&dispatch_ioctl_lock);
             irp->IoStatus.Status = func( irp->AssociatedIrp.SystemBuffer, in_size,
                                          irpsp->Parameters.DeviceIoControl.OutputBufferLength,
-                                         &irp->IoStatus.Information );
+                                         &irp->IoStatus.Information, &reply_fd );
+            pthread_mutex_unlock(&dispatch_ioctl_lock);
         }
         else irp->IoStatus.Status = STATUS_INVALID_PARAMETER;
     }
@@ -1130,7 +1131,7 @@ void start_android_device(void)
 /* Client-side ioctl support */
 
 
-static int android_ioctl( enum android_ioctl code, void *in, DWORD in_size, void *out, DWORD *out_size )
+static int android_ioctl( enum android_ioctl code, void *in, DWORD in_size, void *out, DWORD *out_size, int *recv_fd )
 {
     static const WCHAR deviceW[] = { '\\','D','e','v','i','c','e','\\','W','i','n','e','A','n','d','r','o','i','d', 0 };
     static HANDLE device;
@@ -1153,6 +1154,8 @@ static int android_ioctl( enum android_ioctl code, void *in, DWORD in_size, void
         if (InterlockedCompareExchangePointer( &device, file, NULL )) NtClose( file );
     }
 
+    if (recv_fd) *recv_fd = -1;
+
     status = NtDeviceIoControlFile( device, NULL, NULL, NULL, &iosb, ANDROID_IOCTL(code),
                                     in, in_size, out, out_size ? *out_size : 0 );
     if (status == STATUS_FILE_DELETED)
@@ -1190,7 +1193,7 @@ static int dequeueBuffer( struct ANativeWindow *window, struct ANativeWindowBuff
     res.buffer_id = -1;
     res.generation = 0;
 
-    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, size, &res, &size );
+    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, size, &res, &size, NULL );
     if (ret) return ret;
     if (size < sizeof(res)) return -EINVAL;
 
@@ -1246,7 +1249,7 @@ static int cancelBuffer( struct ANativeWindow *window, struct ANativeWindowBuffe
     cancel.hdr.hwnd = HandleToLong( win->hwnd );
     cancel.hdr.opengl = win->opengl;
     wait_fence_and_close( fence );
-    return android_ioctl( IOCTL_CANCEL_BUFFER, &cancel, sizeof(cancel), NULL, NULL );
+    return android_ioctl( IOCTL_CANCEL_BUFFER, &cancel, sizeof(cancel), NULL, NULL, NULL );
 }
 
 static int queueBuffer( struct ANativeWindow *window, struct ANativeWindowBuffer *buffer, int fence )
@@ -1265,7 +1268,7 @@ static int queueBuffer( struct ANativeWindow *window, struct ANativeWindowBuffer
     queue.hdr.hwnd = HandleToLong( win->hwnd );
     queue.hdr.opengl = win->opengl;
     wait_fence_and_close( fence );
-    return android_ioctl( IOCTL_QUEUE_BUFFER, &queue, sizeof(queue), NULL, NULL );
+    return android_ioctl( IOCTL_QUEUE_BUFFER, &queue, sizeof(queue), NULL, NULL, NULL );
 }
 
 static int dequeueBuffer_DEPRECATED( struct ANativeWindow *window, struct ANativeWindowBuffer **buffer )
@@ -1300,7 +1303,7 @@ static int setSwapInterval( struct ANativeWindow *window, int interval )
     swap.hdr.hwnd = HandleToLong( win->hwnd );
     swap.hdr.opengl = win->opengl;
     swap.interval = interval;
-    return android_ioctl( IOCTL_SET_SWAP_INT, &swap, sizeof(swap), NULL, NULL );
+    return android_ioctl( IOCTL_SET_SWAP_INT, &swap, sizeof(swap), NULL, NULL, NULL );
 }
 
 static int query( const ANativeWindow *window, int what, int *value )
@@ -1313,7 +1316,7 @@ static int query( const ANativeWindow *window, int what, int *value )
     query.hdr.hwnd = HandleToLong( win->hwnd );
     query.hdr.opengl = win->opengl;
     query.what = what;
-    ret = android_ioctl( IOCTL_QUERY, &query, sizeof(query), &query, &size );
+    ret = android_ioctl( IOCTL_QUERY, &query, sizeof(query), &query, &size, NULL );
     TRACE( "hwnd %p what %d got %d -> %p\n", win->hwnd, what, query.value, value );
     if (!ret) *value = query.value;
     return ret;
@@ -1455,7 +1458,7 @@ static int perform( ANativeWindow *window, int operation, ... )
         break;
     }
     va_end( args );
-    return android_ioctl( IOCTL_PERFORM, &perf, sizeof(perf), NULL, NULL );
+    return android_ioctl( IOCTL_PERFORM, &perf, sizeof(perf), NULL, NULL, NULL );
 }
 
 struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl )
@@ -1488,7 +1491,7 @@ struct ANativeWindow *create_ioctl_window( HWND hwnd, BOOL opengl )
     req.hdr.opengl = win->opengl;
     req.parent = get_ioctl_win_parent( NtUserGetAncestor( hwnd, GA_PARENT ));
     req.is_desktop = hwnd == desktop_window;
-    android_ioctl( IOCTL_CREATE_WINDOW, &req, sizeof(req), NULL, NULL );
+    android_ioctl( IOCTL_CREATE_WINDOW, &req, sizeof(req), NULL, NULL, NULL );
 
     return &win->win;
 }
@@ -1521,7 +1524,7 @@ void destroy_ioctl_window( HWND hwnd, BOOL opengl )
 
     req.hdr.hwnd = HandleToLong( hwnd );
     req.hdr.opengl = opengl;
-    android_ioctl( IOCTL_DESTROY_WINDOW, &req, sizeof(req), NULL, NULL );
+    android_ioctl( IOCTL_DESTROY_WINDOW, &req, sizeof(req), NULL, NULL, NULL );
 }
 
 int ioctl_window_pos_changed( HWND hwnd, const struct window_rects *rects,
@@ -1538,7 +1541,7 @@ int ioctl_window_pos_changed( HWND hwnd, const struct window_rects *rects,
     req.flags        = flags;
     req.after        = HandleToLong( after );
     req.owner        = HandleToLong( owner );
-    return android_ioctl( IOCTL_WINDOW_POS_CHANGED, &req, sizeof(req), NULL, NULL );
+    return android_ioctl( IOCTL_WINDOW_POS_CHANGED, &req, sizeof(req), NULL, NULL, NULL );
 }
 
 int ioctl_set_window_parent( HWND hwnd, HWND parent )
@@ -1548,7 +1551,7 @@ int ioctl_set_window_parent( HWND hwnd, HWND parent )
     req.hdr.hwnd = HandleToLong( hwnd );
     req.hdr.opengl = FALSE;
     req.parent = get_ioctl_win_parent( parent );
-    return android_ioctl( IOCTL_SET_WINDOW_PARENT, &req, sizeof(req), NULL, NULL );
+    return android_ioctl( IOCTL_SET_WINDOW_PARENT, &req, sizeof(req), NULL, NULL, NULL );
 }
 
 int ioctl_set_capture( HWND hwnd )
@@ -1557,7 +1560,7 @@ int ioctl_set_capture( HWND hwnd )
 
     req.hdr.hwnd  = HandleToLong( hwnd );
     req.hdr.opengl = FALSE;
-    return android_ioctl( IOCTL_SET_CAPTURE, &req, sizeof(req), NULL, NULL );
+    return android_ioctl( IOCTL_SET_CAPTURE, &req, sizeof(req), NULL, NULL, NULL );
 }
 
 int ioctl_set_cursor( int id, int width, int height,
@@ -1576,7 +1579,7 @@ int ioctl_set_cursor( int id, int width, int height,
     req->hotspotx = hotspotx;
     req->hotspoty = hotspoty;
     memcpy( req->bits, bits, width * height * sizeof(req->bits[0]) );
-    ret = android_ioctl( IOCTL_SET_CURSOR, req, size, NULL, NULL );
+    ret = android_ioctl( IOCTL_SET_CURSOR, req, size, NULL, NULL, NULL );
     free( req );
     return ret;
 }
diff --git a/dlls/wineandroid.drv/dllmain.c b/dlls/wineandroid.drv/dllmain.c
index 7f6d04e83df..d1775c4f4e4 100644
--- a/dlls/wineandroid.drv/dllmain.c
+++ b/dlls/wineandroid.drv/dllmain.c
@@ -90,13 +90,6 @@ static NTSTATUS WINAPI android_start_device(void *param, ULONG size)
 }
 
 
-static void CALLBACK register_window_callback( ULONG_PTR arg1, ULONG_PTR arg2, ULONG_PTR arg3 )
-{
-    struct register_window_params params = { .arg1 = arg1, .arg2 = arg2, .arg3 = arg3 };
-    ANDROID_CALL( register_window, ¶ms );
-}
-
-
 /***********************************************************************
  *       dll initialisation routine
  */
@@ -109,7 +102,6 @@ BOOL WINAPI DllMain( HINSTANCE inst, DWORD reason, LPVOID reserved )
     DisableThreadLibraryCalls( inst );
     if (__wine_init_unix_call()) return FALSE;
 
-    params.register_window_callback = register_window_callback;
     params.start_device_callback = (UINT_PTR)android_start_device;
     return !ANDROID_CALL( init, ¶ms );
 }
diff --git a/dlls/wineandroid.drv/init.c b/dlls/wineandroid.drv/init.c
index e8cb360d032..f4faaca2216 100644
--- a/dlls/wineandroid.drv/init.c
+++ b/dlls/wineandroid.drv/init.c
@@ -48,7 +48,6 @@ static const unsigned int screen_bpp = 32;  /* we don't support other modes */
 static RECT monitor_rc_work;
 static int device_init_done;
 
-PNTAPCFUNC register_window_callback;
 UINT64 start_device_callback;
 
 typedef struct
@@ -394,7 +393,6 @@ static HRESULT android_init( void *arg )
     pthread_mutex_init( &win_data_mutex, &attr );
     pthread_mutexattr_destroy( &attr );
 
-    register_window_callback = params->register_window_callback;
     start_device_callback = params->start_device_callback;
 
     if ((java_vm = *p_java_vm))  /* running under Java */
@@ -423,7 +421,6 @@ const unixlib_entry_t __wine_unix_call_funcs[] =
     android_init,
     android_java_init,
     android_java_uninit,
-    android_register_window,
 };
 
 
diff --git a/dlls/wineandroid.drv/unixlib.h b/dlls/wineandroid.drv/unixlib.h
index 39a4df58283..bc15911ebd9 100644
--- a/dlls/wineandroid.drv/unixlib.h
+++ b/dlls/wineandroid.drv/unixlib.h
@@ -25,7 +25,6 @@ enum android_funcs
     unix_init,
     unix_java_init,
     unix_java_uninit,
-    unix_register_window,
     unix_funcs_count
 };
 
@@ -34,15 +33,5 @@ enum android_funcs
 /* android_init params */
 struct init_params
 {
-    PNTAPCFUNC register_window_callback;
     UINT64 start_device_callback;
 };
-
-
-/* android_register_window params */
-struct register_window_params
-{
-    UINT_PTR arg1;
-    UINT_PTR arg2;
-    UINT_PTR arg3;
-};
diff --git a/dlls/wineandroid.drv/window.c b/dlls/wineandroid.drv/window.c
index 97eb3004ba8..3c6a32a08a7 100644
--- a/dlls/wineandroid.drv/window.c
+++ b/dlls/wineandroid.drv/window.c
@@ -251,6 +251,7 @@ void surface_changed( JNIEnv *env, jobject obj, jint win, jobject surface, jbool
         data.surface.height = height;
         p__android_log_print( ANDROID_LOG_INFO, "wine", "surface_changed: %p %s %ux%u",
                               data.surface.hwnd, client ? "client" : "whole", width, height );
+        register_native_window( data.surface.hwnd, data.surface.window, data.surface.client );
     }
     data.type = SURFACE_CHANGED;
     send_event( &data );
@@ -456,7 +457,7 @@ static int process_events( DWORD mask )
                   event->data.surface.window, event->data.surface.client ? "client" : "whole",
                   event->data.surface.width, event->data.surface.height );
 
-            register_native_window( event->data.surface.hwnd, event->data.surface.window, event->data.surface.client );
+            NtUserPostMessage( event->data.surface.hwnd, WM_ANDROID_REFRESH, event->data.surface.client, 0 );
             break;
 
         case MOTION_EVENT:
-- 
GitLab


https://gitlab.winehq.org/wine/wine/-/merge_requests/10569

[PATCH v2 4/5] wineandroid: add socket-based ioctl backend (unused)

[Twaik Yont]

From: Twaik Yont <[e-mail]>

Add a socket-based backend for android ioctl dispatch.

This introduces a listener thread implementation based on a Unix
seqpacket socket with epoll, along with a new android_ioctl_new()
client-side path supporting regular replies and optional file
descriptor passing via SCM_RIGHTS.

The new backend is not wired up yet and is currently unused. Existing
ioctl handling remains unchanged.

This is a preparatory step for migrating ioctl dispatch to a
socket-based transport.

Signed-off-by: Twaik Yont <[e-mail]>
---
 dlls/wineandroid.drv/device.c | 224 ++++++++++++++++++++++++++++++++++
 1 file changed, 224 insertions(+)

diff --git a/dlls/wineandroid.drv/device.c b/dlls/wineandroid.drv/device.c
index 544b63a21da..6e37c370d53 100644
--- a/dlls/wineandroid.drv/device.c
+++ b/dlls/wineandroid.drv/device.c
@@ -32,6 +32,9 @@
 #include <stdarg.h>
 #include <sys/ioctl.h>
 #include <sys/socket.h>
+#include <sys/un.h>
+#include <sys/epoll.h>
+#include <sys/uio.h>
 #include <unistd.h>
 
 #include "ntstatus.h"
@@ -163,6 +166,14 @@ struct native_win_wrapper
     LONG                          ref;
 };
 
+#define IPC_SOCKET_NAME "\0\\Device\\WineAndroid"
+#define IPC_SOCKET_ADDR_LEN ((socklen_t)(offsetof(struct sockaddr_un, sun_path) + sizeof(IPC_SOCKET_NAME) - 1))
+
+static const struct sockaddr_un ipc_addr = {
+    .sun_family = AF_UNIX,
+    .sun_path = IPC_SOCKET_NAME,
+};
+
 struct ioctl_header
 {
     int  hwnd;
@@ -1118,6 +1129,159 @@ NTSTATUS android_java_uninit( void *arg )
     return STATUS_SUCCESS;
 }
 
+static void *ioctl_thread_proc(void *arg)
+{
+    JavaVM *java_vm;
+    int listen_fd, epoll_fd;
+
+    if (!(java_vm = *p_java_vm)) return NULL;  /* not running under Java */
+    init_java_thread( java_vm );
+    create_desktop_view();
+
+    listen_fd = socket( AF_UNIX, SOCK_SEQPACKET, 0 );
+    if (listen_fd < 0) {
+        _ERR( "Failed to open server socket: %s\n", strerror(errno) );
+        return NULL;
+    }
+
+    if (bind( listen_fd, (const struct sockaddr *)&ipc_addr, IPC_SOCKET_ADDR_LEN ) < 0 ||
+        listen( listen_fd, 32 ) < 0)
+    {
+        _ERR( "Failed to bind server socket: %s\n", strerror(errno) );
+        close( listen_fd );
+        return NULL;
+    }
+
+    epoll_fd = epoll_create1( EPOLL_CLOEXEC );
+    if (epoll_fd < 0)
+    {
+        _ERR( "Failed to create server epoll: %s\n", strerror(errno) );
+        close( listen_fd );
+        return NULL;
+    }
+
+    if (epoll_ctl( epoll_fd, EPOLL_CTL_ADD, listen_fd,
+                   &(struct epoll_event){ .events = EPOLLIN, .data.fd = listen_fd } ) < 0)
+    {
+        close( epoll_fd );
+        close( listen_fd );
+        return NULL;
+    }
+
+    for (;;)
+    {
+        struct epoll_event events[16];
+        int i, count = epoll_wait( epoll_fd, events, ARRAY_SIZE(events), -1 );
+
+        if (count < 0)
+        {
+            if (errno == EINTR) continue;
+            break;
+        }
+
+        for (i = 0; i < count; i++)
+        {
+            int fd = events[i].data.fd;
+
+            if (fd == listen_fd)
+            {
+                int client = accept( listen_fd, NULL, NULL );
+                if (client < 0)
+                {
+                    if (errno == EINTR) continue;
+                    continue;
+                }
+
+                if (epoll_ctl( epoll_fd, EPOLL_CTL_ADD, client,
+                               &(struct epoll_event){ .events = EPOLLIN, .data.fd = client } ) < 0)
+                    close( client );
+                continue;
+            }
+
+            if (events[i].events & (EPOLLHUP | EPOLLERR))
+            {
+                epoll_ctl( epoll_fd, EPOLL_CTL_DEL, fd, NULL );
+                close( fd );
+                continue;
+            }
+
+            for (;;)
+            {
+                char buffer[1024], control[CMSG_SPACE(sizeof(int))];
+                int code = 0, status = -EINVAL, reply_fd = -1;
+                ULONG_PTR reply_size = 0;
+                ssize_t ret;
+                struct iovec iov[2] = { { &code, sizeof(code) }, { buffer, sizeof(buffer) } };
+                struct iovec reply_iov[2] = { { &status, sizeof(status) }, { buffer, 0 } };
+                struct msghdr msg = { NULL, 0, iov, 2, NULL, 0, 0 };
+                struct msghdr reply = { NULL, 0, reply_iov, 2, NULL, 0, 0 };
+                struct cmsghdr *cmsg;
+
+                ret = recvmsg( fd, &msg, MSG_DONTWAIT );
+                if (ret < 0)
+                {
+                    if (errno == EINTR) continue;
+                    if (errno == EAGAIN || errno == EWOULDBLOCK) break;
+                    epoll_ctl( epoll_fd, EPOLL_CTL_DEL, fd, NULL );
+                    close( fd );
+                    break;
+                }
+
+                if (!ret || ret < sizeof(code))
+                {
+                    epoll_ctl( epoll_fd, EPOLL_CTL_DEL, fd, NULL );
+                    close( fd );
+                    break;
+                }
+
+                ret -= sizeof(code);
+
+                if ((unsigned int)code < NB_IOCTLS)
+                {
+                    if (ret >= sizeof(struct ioctl_header)) {
+                        pthread_mutex_lock(&dispatch_ioctl_lock);
+                        status = status_to_android_error (ioctl_funcs[code]( buffer, ret, sizeof(buffer), &reply_size, &reply_fd ));
+                        pthread_mutex_unlock(&dispatch_ioctl_lock);
+                    }
+                }
+                else
+                {
+                    _FIXME( "ioctl %x not supported\n", code );
+                    status = -ENOTSUP;
+                }
+
+                reply_iov[1].iov_len = reply_size;
+                if (reply_fd != -1)
+                {
+                    reply.msg_control = control;
+                    reply.msg_controllen = sizeof(control);
+                    cmsg = CMSG_FIRSTHDR( &reply );
+                    cmsg->cmsg_level = SOL_SOCKET;
+                    cmsg->cmsg_type = SCM_RIGHTS;
+                    cmsg->cmsg_len = CMSG_LEN(sizeof(reply_fd));
+                    memcpy( CMSG_DATA(cmsg), &reply_fd, sizeof(reply_fd) );
+                    reply.msg_controllen = cmsg->cmsg_len;
+                }
+
+                if (sendmsg( fd, &reply, 0 ) < 0)
+                {
+                    if (reply_fd != -1) close( reply_fd );
+                    epoll_ctl( epoll_fd, EPOLL_CTL_DEL, fd, NULL );
+                    close( fd );
+                    break;
+                }
+
+                if (reply_fd != -1) close( reply_fd );
+            }
+        }
+    }
+
+    close( epoll_fd );
+    close( listen_fd );
+    (*java_vm)->DetachCurrentThread( java_vm );
+    return NULL;
+}
+
 void start_android_device(void)
 {
     void *ret_ptr;
@@ -1167,6 +1331,66 @@ static int android_ioctl( enum android_ioctl code, void *in, DWORD in_size, void
     return status_to_android_error( status );
 }
 
+static int android_ioctl_new( enum android_ioctl code, void *in, DWORD in_size, void *out, DWORD *out_size, int *recv_fd )
+{
+    static int device_fd = -1;
+    static pthread_mutex_t device_mutex = PTHREAD_MUTEX_INITIALIZER;
+    int status, err = -ENOENT;
+    ssize_t ret;
+    char control[CMSG_SPACE(sizeof(int))];
+    struct iovec iov[2] = { { &status, sizeof(status) }, { out, out_size ? *out_size : 0 } };
+    struct msghdr msg = { NULL, 0, iov, (out && out_size) ? 2 : 1,
+                          recv_fd ? control : NULL, recv_fd ? sizeof(control) : 0, 0 };
+    struct cmsghdr *cmsg;
+
+    pthread_mutex_lock( &device_mutex );
+
+    if (recv_fd) *recv_fd = -1;
+
+    if (device_fd == -1)
+    {
+        device_fd = socket( AF_UNIX, SOCK_SEQPACKET, 0 );
+        if (device_fd < 0) goto done;
+        if (connect( device_fd, (const struct sockaddr *)&ipc_addr, IPC_SOCKET_ADDR_LEN ) < 0)
+        {
+            close( device_fd );
+            device_fd = -1;
+            goto done;
+        }
+    }
+
+    ret = writev( device_fd, (struct iovec[]){ { &code, sizeof(code) }, { in, in_size } }, 2 );
+    if (ret <= 0 || ret != sizeof(code) + in_size) goto disconnected;
+
+    ret = recvmsg( device_fd, &msg, 0 );
+    if (ret <= 0 || ret < sizeof(status)) goto disconnected;
+
+    if (out && out_size) *out_size = ret - sizeof(status);
+    err = status;
+
+    if (recv_fd)
+        for (cmsg = CMSG_FIRSTHDR( &msg ); cmsg; cmsg = CMSG_NXTHDR( &msg, cmsg ))
+            if (cmsg->cmsg_level == SOL_SOCKET && cmsg->cmsg_type == SCM_RIGHTS &&
+                cmsg->cmsg_len >= CMSG_LEN(sizeof(int)))
+            {
+                memcpy( recv_fd, CMSG_DATA(cmsg), sizeof(int) );
+                break;
+            }
+
+    goto done;
+
+disconnected:
+    close( device_fd );
+    device_fd = -1;
+    WARN( "parent process is gone\n" );
+    NtTerminateProcess( 0, 1 );
+    err = -ENOENT;
+
+done:
+    pthread_mutex_unlock( &device_mutex );
+    return err;
+}
+
 static void win_incRef( struct android_native_base_t *base )
 {
     struct native_win_wrapper *win = (struct native_win_wrapper *)base;
-- 
GitLab


https://gitlab.winehq.org/wine/wine/-/merge_requests/10569

[PATCH v2 5/5] wineandroid: drop old ioctl backend startup and switch to socket transport

[Twaik Yont]

From: Twaik Yont <[e-mail]>

Remove the legacy ioctl backend startup via KeUserDispatchCallback and
switch fully to the socket-based transport.

A dedicated listener thread is now started directly with pthread_create,
and the desktop process is tracked via an explicit in_desktop_process
flag.

dequeueBuffer is updated to use file descriptor passing via SCM_RIGHTS,
and all handle-based duplication logic is removed.

The old ioctl implementation is kept as android_ioctl_old() but is no
longer used.

This completes the transition away from the legacy backend startup path.

Signed-off-by: Twaik Yont <[e-mail]>
---
 dlls/wineandroid.drv/android.h |   7 -
 dlls/wineandroid.drv/device.c  | 250 ++-------------------------------
 dlls/wineandroid.drv/dllmain.c |  74 +---------
 dlls/wineandroid.drv/init.c    |   7 -
 dlls/wineandroid.drv/unixlib.h |  11 --
 5 files changed, 14 insertions(+), 335 deletions(-)

diff --git a/dlls/wineandroid.drv/android.h b/dlls/wineandroid.drv/android.h
index f87c561d2e2..6cd1de21e29 100644
--- a/dlls/wineandroid.drv/android.h
+++ b/dlls/wineandroid.drv/android.h
@@ -100,13 +100,6 @@ extern void ANDROID_WindowPosChanged( HWND hwnd, HWND insert_after, HWND owner_h
 extern ANativeWindow *get_client_window( HWND hwnd );
 extern BOOL has_client_surface( HWND hwnd );
 
-/* unixlib interface */
-
-extern NTSTATUS android_dispatch_ioctl( void *arg );
-extern NTSTATUS android_java_init( void *arg );
-extern NTSTATUS android_java_uninit( void *arg );
-extern UINT64 start_device_callback;
-
 extern unsigned int screen_width;
 extern unsigned int screen_height;
 extern RECT virtual_screen_rect;
diff --git a/dlls/wineandroid.drv/device.c b/dlls/wineandroid.drv/device.c
index 6e37c370d53..36e5ad5bb90 100644
--- a/dlls/wineandroid.drv/device.c
+++ b/dlls/wineandroid.drv/device.c
@@ -107,7 +107,6 @@ DECL_FUNCPTR( ANativeWindowBuffer_getHardwareBuffer );
 #define SYNC_IOC_WAIT _IOW('>', 0, __s32)
 #endif
 
-static HANDLE thread;
 static JNIEnv *jni_env;
 static HWND capture_window;
 static HWND desktop_window;
@@ -207,8 +206,6 @@ struct ioctl_android_window_pos_changed
 struct ioctl_android_dequeueBuffer
 {
     struct ioctl_header hdr;
-    DWORD pid;
-    HANDLE handle;
     int buffer_id;
     int generation;
 };
@@ -269,49 +266,6 @@ struct ioctl_android_set_cursor
     int                 bits[1];
 };
 
-
-static inline BOOL is_in_desktop_process(void)
-{
-    return thread != NULL;
-}
-
-#ifdef __i386__  /* the Java VM uses %fs/%gs for its own purposes, so we need to wrap the calls */
-
-static WORD orig_fs, java_fs;
-static inline void wrap_java_call(void)   { __asm__( "mov %0,%%fs" :: "r" (java_fs) ); }
-static inline void unwrap_java_call(void) { __asm__( "mov %0,%%fs" :: "r" (orig_fs) ); }
-static inline void init_java_thread( JavaVM *java_vm )
-{
-    java_fs = *p_java_gdt_sel;
-    __asm__( "mov %%fs,%0" : "=r" (orig_fs) );
-    __asm__( "mov %0,%%fs" :: "r" (java_fs) );
-    (*java_vm)->AttachCurrentThread( java_vm, &jni_env, 0 );
-    if (!*p_java_gdt_sel) __asm__( "mov %%fs,%0" : "=r" (java_fs) );
-    __asm__( "mov %0,%%fs" :: "r" (orig_fs) );
-}
-
-#elif defined(__x86_64__)
-
-#include <asm/prctl.h>
-#include <asm/unistd.h>
-static void *orig_teb, *java_teb;
-static inline int arch_prctl( int func, void *ptr ) { return syscall( __NR_arch_prctl, func, ptr ); }
-static inline void wrap_java_call(void)   { arch_prctl( ARCH_SET_GS, java_teb ); }
-static inline void unwrap_java_call(void) { arch_prctl( ARCH_SET_GS, orig_teb ); }
-static inline void init_java_thread( JavaVM *java_vm )
-{
-    arch_prctl( ARCH_GET_GS, &orig_teb );
-    (*java_vm)->AttachCurrentThread( java_vm, &jni_env, 0 );
-    arch_prctl( ARCH_GET_GS, &java_teb );
-    arch_prctl( ARCH_SET_GS, orig_teb );
-}
-
-#else
-static inline void wrap_java_call(void) { }
-static inline void unwrap_java_call(void) { }
-static inline void init_java_thread( JavaVM *java_vm ) { (*java_vm)->AttachCurrentThread( java_vm, &jni_env, 0 ); }
-#endif  /* __i386__ */
-
 static struct native_win_data *data_map[65536];
 
 static unsigned int data_map_idx( HWND hwnd, BOOL opengl )
@@ -620,10 +574,8 @@ static jobject load_java_method( jmethodID *method, const char *name, const char
     {
         jclass class;
 
-        wrap_java_call();
         class = (*jni_env)->GetObjectClass( jni_env, object );
         *method = (*jni_env)->GetMethodID( jni_env, class, name, args );
-        unwrap_java_call();
         if (!*method)
         {
             _FIXME( "method %s not found\n", name );
@@ -640,9 +592,7 @@ static void create_desktop_view(void)
 
     if (!(object = load_java_method( &method, "createDesktopView", "()V" ))) return;
 
-    wrap_java_call();
     (*jni_env)->CallVoidMethod( jni_env, object, method );
-    unwrap_java_call();
 }
 
 static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PTR *ret_size, int *reply_fd )
@@ -661,9 +611,7 @@ static NTSTATUS createWindow_ioctl( void *data, DWORD in_size, DWORD out_size, U
 
     if (!(object = load_java_method( &method, "createWindow", "(IZZI)V" ))) return STATUS_NOT_SUPPORTED;
 
-    wrap_java_call();
     (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->is_desktop, res->hdr.opengl, res->parent );
-    unwrap_java_call();
     return STATUS_SUCCESS;
 }
 
@@ -682,9 +630,7 @@ static NTSTATUS destroyWindow_ioctl( void *data, DWORD in_size, DWORD out_size,
 
     if (!(object = load_java_method( &method, "destroyWindow", "(I)V" ))) return STATUS_NOT_SUPPORTED;
 
-    wrap_java_call();
     (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd );
-    unwrap_java_call();
     if (win_data) free_native_win_data( win_data );
     return STATUS_SUCCESS;
 }
@@ -704,12 +650,10 @@ static NTSTATUS windowPosChanged_ioctl( void *data, DWORD in_size, DWORD out_siz
     if (!(object = load_java_method( &method, "windowPosChanged", "(IIIIIIIIIIIIIIIII)V" )))
         return STATUS_NOT_SUPPORTED;
 
-    wrap_java_call();
     (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->flags, res->after, res->owner, res->style,
                                 res->window_rect.left, res->window_rect.top, res->window_rect.right, res->window_rect.bottom,
                                 res->client_rect.left, res->client_rect.top, res->client_rect.right, res->client_rect.bottom,
                                 res->visible_rect.left, res->visible_rect.top, res->visible_rect.right, res->visible_rect.bottom );
-    unwrap_java_call();
     return STATUS_SUCCESS;
 }
 
@@ -728,14 +672,11 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
     if (!(win_data = get_ioctl_native_win_data( &res->hdr ))) return STATUS_INVALID_HANDLE;
     if (!(parent = win_data->parent)) return STATUS_DEVICE_NOT_READY;
 
-    res->handle = 0;
     res->buffer_id = -1;
     res->generation = 0;
     *ret_size = sizeof(*res);
 
-    wrap_java_call();
     ret = parent->dequeueBuffer( parent, &buffer, &fence );
-    unwrap_java_call();
     if (ret)
     {
         _ERR( "%08x failed %d\n", res->hdr.hwnd, ret );
@@ -753,15 +694,10 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
 
     res->buffer_id = register_buffer( win_data, ahb, &is_new );
     res->generation = win_data->generation;
-    res->handle = 0;
 
     if (is_new)
     {
         int sv[2] = { -1, -1 };
-        HANDLE local = 0;
-        OBJECT_ATTRIBUTES attr = { .Length = sizeof(attr) };
-        CLIENT_ID cid = { .UniqueProcess = UlongToHandle( res->pid ) };
-        HANDLE process;
 
         if (!ahb)
         {
@@ -775,37 +711,16 @@ static NTSTATUS dequeueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size,
             return STATUS_UNSUCCESSFUL;
         }
 
-        if (NtOpenProcess( &process, PROCESS_DUP_HANDLE, &attr, &cid ))
-        {
-            close( sv[0] );
-            close( sv[1] );
-            wait_fence_and_close( fence );
-            return STATUS_UNSUCCESSFUL;
-        }
-
-        if (!wine_server_fd_to_handle( dup(sv[1]), GENERIC_READ | SYNCHRONIZE, 0, &local ))
-        {
-            NTSTATUS status = NtDuplicateObject( GetCurrentProcess(), local, process, &res->handle, 0, 0, DUPLICATE_SAME_ACCESS | DUPLICATE_CLOSE_SOURCE );
-            if (status && local) NtClose( local );
-        }
-
-        NtClose( process );
-        close( sv[1] );
-
-        if (!res->handle)
-        {
-            close( sv[0] );
-            wait_fence_and_close( fence );
-            return STATUS_UNSUCCESSFUL;
-        }
-
         ret = pAHardwareBuffer_sendHandleToUnixSocket( ahb, sv[0] );
         close( sv[0] );
         if (ret)
         {
+            close( sv[1] );
             wait_fence_and_close( fence );
             return android_error_to_status( ret );
         }
+
+        *reply_fd = sv[1];
     }
 
     wait_fence_and_close( fence );
@@ -829,9 +744,7 @@ static NTSTATUS cancelBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, U
     if (!(buffer = get_registered_buffer( win_data, res->buffer_id ))) return STATUS_INVALID_HANDLE;
 
     _TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
-    wrap_java_call();
     ret = parent->cancelBuffer( parent, buffer, -1 );
-    unwrap_java_call();
     return android_error_to_status( ret );
 }
 
@@ -852,9 +765,7 @@ static NTSTATUS queueBuffer_ioctl( void *data, DWORD in_size, DWORD out_size, UL
     if (!(buffer = get_registered_buffer( win_data, res->buffer_id ))) return STATUS_INVALID_HANDLE;
 
     _TRACE( "%08x buffer %p\n", res->hdr.hwnd, buffer );
-    wrap_java_call();
     ret = parent->queueBuffer( parent, buffer, -1 );
-    unwrap_java_call();
     return android_error_to_status( ret );
 }
 
@@ -872,9 +783,7 @@ static NTSTATUS query_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_PT
     if (!(parent = win_data->parent)) return STATUS_DEVICE_NOT_READY;
 
     *ret_size = sizeof( *res );
-    wrap_java_call();
     ret = parent->query( parent, res->what, &res->value );
-    unwrap_java_call();
     return android_error_to_status( ret );
 }
 
@@ -893,57 +802,39 @@ static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_
     switch (res->operation)
     {
     case NATIVE_WINDOW_SET_BUFFERS_FORMAT:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0] );
-        unwrap_java_call();
         if (!ret) win_data->buffer_format = res->args[0];
         break;
     case NATIVE_WINDOW_API_CONNECT:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0] );
-        unwrap_java_call();
         if (!ret) win_data->api = res->args[0];
         break;
     case NATIVE_WINDOW_API_DISCONNECT:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0] );
-        unwrap_java_call();
         if (!ret) win_data->api = 0;
         break;
     case NATIVE_WINDOW_SET_USAGE:
     case NATIVE_WINDOW_SET_BUFFERS_TRANSFORM:
     case NATIVE_WINDOW_SET_SCALING_MODE:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0] );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_SET_BUFFER_COUNT:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, (size_t)res->args[0] );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_SET_BUFFERS_DIMENSIONS:
     case NATIVE_WINDOW_SET_BUFFERS_USER_DIMENSIONS:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0], res->args[1] );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_SET_BUFFERS_GEOMETRY:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0], res->args[1], res->args[2] );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_SET_BUFFERS_TIMESTAMP:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, res->args[0] | ((int64_t)res->args[1] << 32) );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_CONNECT:
     case NATIVE_WINDOW_DISCONNECT:
     case NATIVE_WINDOW_UNLOCK_AND_POST:
-        wrap_java_call();
         ret = parent->perform( parent, res->operation );
-        unwrap_java_call();
         break;
     case NATIVE_WINDOW_SET_CROP:
     {
@@ -952,9 +843,7 @@ static NTSTATUS perform_ioctl( void *data, DWORD in_size, DWORD out_size, ULONG_
         rect.top    = res->args[1];
         rect.right  = res->args[2];
         rect.bottom = res->args[3];
-        wrap_java_call();
         ret = parent->perform( parent, res->operation, &rect );
-        unwrap_java_call();
         break;
     }
     case NATIVE_WINDOW_LOCK:
@@ -978,9 +867,7 @@ static NTSTATUS setSwapInterval_ioctl( void *data, DWORD in_size, DWORD out_size
     win_data->swap_interval = res->interval;
 
     if (!(parent = win_data->parent)) return STATUS_SUCCESS;
-    wrap_java_call();
     ret = parent->setSwapInterval( parent, res->interval );
-    unwrap_java_call();
     return android_error_to_status( ret );
 }
 
@@ -999,9 +886,7 @@ static NTSTATUS setWindowParent_ioctl( void *data, DWORD in_size, DWORD out_size
 
     if (!(object = load_java_method( &method, "setParent", "(II)V" ))) return STATUS_NOT_SUPPORTED;
 
-    wrap_java_call();
     (*jni_env)->CallVoidMethod( jni_env, object, method, res->hdr.hwnd, res->parent );
-    unwrap_java_call();
     return STATUS_SUCCESS;
 }
 
@@ -1040,8 +925,6 @@ static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULON
     if (!(object = load_java_method( &method, "setCursor", "(IIIII[I)V" )))
         return STATUS_NOT_SUPPORTED;
 
-    wrap_java_call();
-
     if (size)
     {
         jintArray array = (*jni_env)->NewIntArray( jni_env, size );
@@ -1052,8 +935,6 @@ static NTSTATUS setCursor_ioctl( void *data, DWORD in_size, DWORD out_size, ULON
     }
     else (*jni_env)->CallVoidMethod( jni_env, object, method, res->id, 0, 0, 0, 0, 0 );
 
-    unwrap_java_call();
-
     return STATUS_SUCCESS;
 }
 
@@ -1074,68 +955,13 @@ static const ioctl_func ioctl_funcs[] =
     setCursor_ioctl,            /* IOCTL_SET_CURSOR */
 };
 
-NTSTATUS android_dispatch_ioctl( void *arg )
-{
-    IRP *irp = arg;
-    IO_STACK_LOCATION *irpsp = IoGetCurrentIrpStackLocation( irp );
-    DWORD code = (irpsp->Parameters.DeviceIoControl.IoControlCode - ANDROID_IOCTL(0)) >> 2;
-
-    if (code < NB_IOCTLS)
-    {
-        struct ioctl_header *header = irp->AssociatedIrp.SystemBuffer;
-        DWORD in_size = irpsp->Parameters.DeviceIoControl.InputBufferLength;
-        ioctl_func func = ioctl_funcs[code];
-        int reply_fd = -1;
-
-        if (in_size >= sizeof(*header))
-        {
-            irp->IoStatus.Information = 0;
-            pthread_mutex_lock(&dispatch_ioctl_lock);
-            irp->IoStatus.Status = func( irp->AssociatedIrp.SystemBuffer, in_size,
-                                         irpsp->Parameters.DeviceIoControl.OutputBufferLength,
-                                         &irp->IoStatus.Information, &reply_fd );
-            pthread_mutex_unlock(&dispatch_ioctl_lock);
-        }
-        else irp->IoStatus.Status = STATUS_INVALID_PARAMETER;
-    }
-    else
-    {
-        _FIXME( "ioctl %x not supported\n", irpsp->Parameters.DeviceIoControl.IoControlCode );
-        irp->IoStatus.Status = STATUS_NOT_SUPPORTED;
-    }
-    return STATUS_SUCCESS;
-}
-
-NTSTATUS android_java_init( void *arg )
-{
-    JavaVM *java_vm;
-
-    if (!(java_vm = *p_java_vm)) return STATUS_UNSUCCESSFUL;  /* not running under Java */
-
-    init_java_thread( java_vm );
-    create_desktop_view();
-    return STATUS_SUCCESS;
-}
-
-NTSTATUS android_java_uninit( void *arg )
-{
-    JavaVM *java_vm;
-
-    if (!(java_vm = *p_java_vm)) return STATUS_UNSUCCESSFUL;  /* not running under Java */
-
-    wrap_java_call();
-    (*java_vm)->DetachCurrentThread( java_vm );
-    unwrap_java_call();
-    return STATUS_SUCCESS;
-}
-
 static void *ioctl_thread_proc(void *arg)
 {
     JavaVM *java_vm;
     int listen_fd, epoll_fd;
 
     if (!(java_vm = *p_java_vm)) return NULL;  /* not running under Java */
-    init_java_thread( java_vm );
+    (*java_vm)->AttachCurrentThread( java_vm, &jni_env, 0 );
     create_desktop_view();
 
     listen_fd = socket( AF_UNIX, SOCK_SEQPACKET, 0 );
@@ -1284,11 +1110,10 @@ static void *ioctl_thread_proc(void *arg)
 
 void start_android_device(void)
 {
-    void *ret_ptr;
-    ULONG ret_len;
-    struct dispatch_callback_params params = {.callback = start_device_callback};
-    if (KeUserDispatchCallback( ¶ms, sizeof(params), &ret_ptr, &ret_len )) return;
-    if (ret_len == sizeof(thread)) thread = *(HANDLE *)ret_ptr;
+    pthread_t t;
+
+    if (pthread_create( &t, NULL, ioctl_thread_proc, NULL ) == 0)
+        pthread_detach( t );
 }
 
 
@@ -1296,42 +1121,6 @@ void start_android_device(void)
 
 
 static int android_ioctl( enum android_ioctl code, void *in, DWORD in_size, void *out, DWORD *out_size, int *recv_fd )
-{
-    static const WCHAR deviceW[] = { '\\','D','e','v','i','c','e','\\','W','i','n','e','A','n','d','r','o','i','d', 0 };
-    static HANDLE device;
-    IO_STATUS_BLOCK iosb;
-    NTSTATUS status;
-
-    if (!device)
-    {
-        OBJECT_ATTRIBUTES attr;
-        UNICODE_STRING name = RTL_CONSTANT_STRING( deviceW );
-        IO_STATUS_BLOCK io;
-        NTSTATUS status;
-        HANDLE file;
-
-        InitializeObjectAttributes( &attr, &name, OBJ_CASE_INSENSITIVE, NULL, NULL );
-        status = NtCreateFile( &file, GENERIC_READ | SYNCHRONIZE, &attr, &io, NULL, 0,
-                               FILE_SHARE_READ | FILE_SHARE_WRITE, FILE_OPEN,
-                               FILE_NON_DIRECTORY_FILE, NULL, 0 );
-        if (status) return -ENOENT;
-        if (InterlockedCompareExchangePointer( &device, file, NULL )) NtClose( file );
-    }
-
-    if (recv_fd) *recv_fd = -1;
-
-    status = NtDeviceIoControlFile( device, NULL, NULL, NULL, &iosb, ANDROID_IOCTL(code),
-                                    in, in_size, out, out_size ? *out_size : 0 );
-    if (status == STATUS_FILE_DELETED)
-    {
-        WARN( "parent process is gone\n" );
-        NtTerminateProcess( 0, 1 );
-    }
-    if (out_size) *out_size = iosb.Information;
-    return status_to_android_error( status );
-}
-
-static int android_ioctl_new( enum android_ioctl code, void *in, DWORD in_size, void *out, DWORD *out_size, int *recv_fd )
 {
     static int device_fd = -1;
     static pthread_mutex_t device_mutex = PTHREAD_MUTEX_INITIALIZER;
@@ -1408,35 +1197,25 @@ static int dequeueBuffer( struct ANativeWindow *window, struct ANativeWindowBuff
     struct native_win_wrapper *win = (struct native_win_wrapper *)window;
     struct ioctl_android_dequeueBuffer res = {0};
     DWORD size = sizeof(res);
-    int ret;
+    int ret, buffer_fd = -1;
 
     res.hdr.hwnd = HandleToLong( win->hwnd );
     res.hdr.opengl = win->opengl;
-    res.pid = GetCurrentProcessId();
-    res.handle = 0;
     res.buffer_id = -1;
     res.generation = 0;
 
-    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, size, &res, &size, NULL );
+    ret = android_ioctl( IOCTL_DEQUEUE_BUFFER, &res, size, &res, &size, &buffer_fd );
     if (ret) return ret;
     if (size < sizeof(res)) return -EINVAL;
 
     if (res.buffer_id < 0 || res.buffer_id >= NB_CACHED_BUFFERS) return -EINVAL;
 
-    if (res.handle)
+    if (buffer_fd != -1)
     {
         AHardwareBuffer *ahb = NULL;
-        int fd;
 
-        if (wine_server_handle_to_fd( res.handle, GENERIC_READ | SYNCHRONIZE, &fd, NULL ))
-        {
-            NtClose( res.handle );
-            return -EINVAL;
-        }
-        NtClose( res.handle );
-
-        ret = pAHardwareBuffer_recvHandleFromUnixSocket( fd, &ahb );
-        close( fd );
+        ret = pAHardwareBuffer_recvHandleFromUnixSocket( buffer_fd, &ahb );
+        close( buffer_fd );
         if (ret) return ret;
 
         if (win->buffers[res.buffer_id].self)
@@ -1813,8 +1592,5 @@ int ioctl_set_cursor( int id, int width, int height,
  */
 void ANDROID_SetDesktopWindow( HWND hwnd )
 {
-    if (!is_in_desktop_process())
-        return;
-    TRACE( "%p\n", hwnd );
     desktop_window = hwnd;
 }
diff --git a/dlls/wineandroid.drv/dllmain.c b/dlls/wineandroid.drv/dllmain.c
index d1775c4f4e4..bbf546c9552 100644
--- a/dlls/wineandroid.drv/dllmain.c
+++ b/dlls/wineandroid.drv/dllmain.c
@@ -19,89 +19,17 @@
  */
 
 #include <stdarg.h>
-#include "ntstatus.h"
 #include "windef.h"
 #include "winbase.h"
-#include "winternl.h"
-#include "winioctl.h"
-#include "ddk/wdm.h"
 #include "unixlib.h"
-#include "wine/debug.h"
-
-WINE_DEFAULT_DEBUG_CHANNEL(android);
-
-
-extern NTSTATUS CDECL wine_ntoskrnl_main_loop( HANDLE stop_event );
-static HANDLE stop_event;
-
-
-static NTSTATUS WINAPI ioctl_callback( DEVICE_OBJECT *device, IRP *irp )
-{
-    NTSTATUS status = ANDROID_CALL( dispatch_ioctl, irp );
-    IoCompleteRequest( irp, IO_NO_INCREMENT );
-    return status;
-}
-
-static NTSTATUS CALLBACK init_android_driver( DRIVER_OBJECT *driver, UNICODE_STRING *name )
-{
-    UNICODE_STRING nameW = RTL_CONSTANT_STRING( L"\\Device\\WineAndroid" );
-    DEVICE_OBJECT *device;
-
-    driver->MajorFunction[IRP_MJ_DEVICE_CONTROL] = ioctl_callback;
-
-    return IoCreateDevice( driver, 0, &nameW, 0, 0, FALSE, &device );
-}
-
-static DWORD CALLBACK device_thread( void *arg )
-{
-    HANDLE start_event = arg;
-    UNICODE_STRING nameW = RTL_CONSTANT_STRING( L"\\Driver\\WineAndroid" );
-    NTSTATUS status;
-    DWORD ret;
-
-    TRACE( "starting process %lx\n", GetCurrentProcessId() );
-
-    if (ANDROID_CALL( java_init, NULL )) return 0;  /* not running under Java */
-
-    if ((status = IoCreateDriver( &nameW, init_android_driver )))
-    {
-        FIXME( "failed to create driver error %lx\n", status );
-        return status;
-    }
-
-    stop_event = CreateEventW( NULL, TRUE, FALSE, NULL );
-    SetEvent( start_event );
-
-    ret = wine_ntoskrnl_main_loop( stop_event );
-
-    ANDROID_CALL( java_uninit, NULL );
-    return ret;
-}
-
-static NTSTATUS WINAPI android_start_device(void *param, ULONG size)
-{
-    HANDLE handles[2];
-
-    handles[0] = CreateEventW( NULL, TRUE, FALSE, NULL );
-    handles[1] = CreateThread( NULL, 0, device_thread, handles[0], 0, NULL );
-    WaitForMultipleObjects( 2, handles, FALSE, INFINITE );
-    CloseHandle( handles[0] );
-    return NtCallbackReturn( &handles[1], sizeof(handles[1]), STATUS_SUCCESS );
-}
-
 
 /***********************************************************************
  *       dll initialisation routine
  */
 BOOL WINAPI DllMain( HINSTANCE inst, DWORD reason, LPVOID reserved )
 {
-    struct init_params params;
-
     if (reason != DLL_PROCESS_ATTACH) return TRUE;
 
     DisableThreadLibraryCalls( inst );
-    if (__wine_init_unix_call()) return FALSE;
-
-    params.start_device_callback = (UINT_PTR)android_start_device;
-    return !ANDROID_CALL( init, ¶ms );
+    return !__wine_init_unix_call() && !WINE_UNIX_CALL( unix_init, NULL );
 }
diff --git a/dlls/wineandroid.drv/init.c b/dlls/wineandroid.drv/init.c
index f4faaca2216..14f4596e331 100644
--- a/dlls/wineandroid.drv/init.c
+++ b/dlls/wineandroid.drv/init.c
@@ -369,7 +369,6 @@ unsigned short *p_java_gdt_sel = NULL;
 
 static HRESULT android_init( void *arg )
 {
-    struct init_params *params = arg;
     pthread_mutexattr_t attr;
     jclass class;
     jobject object;
@@ -393,8 +392,6 @@ static HRESULT android_init( void *arg )
     pthread_mutex_init( &win_data_mutex, &attr );
     pthread_mutexattr_destroy( &attr );
 
-    start_device_callback = params->start_device_callback;
-
     if ((java_vm = *p_java_vm))  /* running under Java */
     {
 #ifdef __i386__
@@ -417,11 +414,7 @@ static HRESULT android_init( void *arg )
 
 const unixlib_entry_t __wine_unix_call_funcs[] =
 {
-    android_dispatch_ioctl,
     android_init,
-    android_java_init,
-    android_java_uninit,
 };
 
-
 C_ASSERT( ARRAYSIZE(__wine_unix_call_funcs) == unix_funcs_count );
diff --git a/dlls/wineandroid.drv/unixlib.h b/dlls/wineandroid.drv/unixlib.h
index bc15911ebd9..ec11eb67d18 100644
--- a/dlls/wineandroid.drv/unixlib.h
+++ b/dlls/wineandroid.drv/unixlib.h
@@ -21,17 +21,6 @@
 
 enum android_funcs
 {
-    unix_dispatch_ioctl,
     unix_init,
-    unix_java_init,
-    unix_java_uninit,
     unix_funcs_count
 };
-
-#define ANDROID_CALL(func, params) WINE_UNIX_CALL( unix_ ## func, params )
-
-/* android_init params */
-struct init_params
-{
-    UINT64 start_device_callback;
-};
-- 
GitLab

https://gitlab.winehq.org/wine/wine/-/merge_requests/10569