wine/wine-staging
0
0
Fork 0
mirror of https://gitlab.winehq.org/wine/wine-staging.git synced 2025-09-12 18:50:20 -07:00
Code Issues Packages Projects Releases Wiki Activity

Added patch to avoid race-conditions with long running threadpool tasks.

Browse Source
This commit is contained in:
Sebastian Lackner
2015-07-29 20:59:04 +02:00
parent 76e7b82e31
commit 8728442a9a
5 changed files with 125 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
patches/ntdll-Threadpool/0001-ntdll-Mark-newly-spawned-worker-threads-as-busy-to-a.patch Normal file
View File

@@ -0,0 +1,66 @@
From b6b846e842cf3d526dfe7b0a4a3f61a6139ab587 Mon Sep 17 00:00:00 2001
From: Sebastian Lackner <sebastian@fds-team.de>
Date: Wed, 29 Jul 2015 20:57:24 +0200
Subject: ntdll: Mark newly spawned worker threads as busy to avoid problems
with long-running tasks.
---
dlls/ntdll/threadpool.c | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/dlls/ntdll/threadpool.c b/dlls/ntdll/threadpool.c
index ad4951f..8605a22 100644
--- a/dlls/ntdll/threadpool.c
+++ b/dlls/ntdll/threadpool.c
@@ -379,6 +379,8 @@ NTSTATUS WINAPI RtlQueueWorkItem( PRTL_WORK_ITEM_ROUTINE function, PVOID context
struct rtl_work_item *item;
NTSTATUS status;
+ TRACE( "%p %p %u\n", function, context, flags );
+
item = RtlAllocateHeap( GetProcessHeap(), 0, sizeof(*item) );
if (!item)
return STATUS_NO_MEMORY;
@@ -1716,6 +1718,7 @@ static NTSTATUS tp_threadpool_lock( struct threadpool **out, TP_CALLBACK_ENVIRON
{
interlocked_inc( &pool->refcount );
pool->num_workers++;
+ pool->num_busy_workers++;
NtClose( thread );
}
}
@@ -1915,6 +1918,7 @@ static void tp_object_submit( struct threadpool_object *object, BOOL signaled )
{
interlocked_inc( &pool->refcount );
pool->num_workers++;
+ pool->num_busy_workers++;
NtClose( thread );
}
}
@@ -2070,6 +2074,7 @@ static void CALLBACK threadpool_worker_proc( void *param )
TRACE( "starting worker thread for pool %p\n", pool );
RtlEnterCriticalSection( &pool->cs );
+ pool->num_busy_workers--;
for (;;)
{
while ((ptr = list_head( &pool->pool )))
@@ -2412,6 +2417,7 @@ NTSTATUS WINAPI TpCallbackMayRunLong( TP_CALLBACK_INSTANCE *instance )
{
interlocked_inc( &pool->refcount );
pool->num_workers++;
+ pool->num_busy_workers++;
NtClose( thread );
}
}
@@ -2699,6 +2705,7 @@ BOOL WINAPI TpSetPoolMinThreads( TP_POOL *pool, DWORD minimum )
interlocked_inc( &this->refcount );
this->num_workers++;
+ this->num_busy_workers++;
NtClose( thread );
}
--
2.4.5

1
patches/ntdll-Threadpool/definition Normal file
View File

@@ -0,0 +1 @@
Fixes: Avoid race-conditions with long running threadpool tasks