MeshCentral/MeshAgent
1
0
Fork 0
mirror of https://github.com/Ylianst/MeshAgent synced 2026-01-09 20:13:56 +00:00
Code Issues Releases Wiki Activity

Updated DescriptorEvents to not use APC

Browse Source
This commit is contained in:
Bryan Roe
2019-11-26 16:04:49 -08:00
parent 06e08d809a
commit 847bb0aeb0
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
microscript/ILibDuktape_Polyfills.c
View File

@@ -58,6 +58,7 @@ typedef struct ILibDuktape_DescriptorEvents_WindowsWaitHandle
{ {
HANDLE waitHandle; HANDLE waitHandle;
HANDLE eventThread; HANDLE eventThread;
void *chain;
duk_context *ctx; duk_context *ctx;
void *object; void *object;
}ILibDuktape_DescriptorEvents_WindowsWaitHandle; }ILibDuktape_DescriptorEvents_WindowsWaitHandle;
@@ -2317,7 +2318,7 @@ duk_ret_t ILibDuktape_DescriptorEvents_Remove(duk_context *ctx)
return(0); return(0);
} }
#ifdef WIN32 #ifdef WIN32
void __stdcall ILibDuktape_DescriptorEvents_WaitHandleAPC(ULONG_PTR user) void ILibDuktape_DescriptorEvents_WaitHandle_EventThread(void *chain, void *user)
{ {
if (!ILibMemory_CanaryOK((void*)user)) { return; } if (!ILibMemory_CanaryOK((void*)user)) { return; }
ILibDuktape_DescriptorEvents_WindowsWaitHandle *v = (ILibDuktape_DescriptorEvents_WindowsWaitHandle*)user; ILibDuktape_DescriptorEvents_WindowsWaitHandle *v = (ILibDuktape_DescriptorEvents_WindowsWaitHandle*)user;
@@ -2330,7 +2331,8 @@ void __stdcall ILibDuktape_DescriptorEvents_WaitHandleAPC(ULONG_PTR user)
void __stdcall ILibDuktape_DescriptorEvents_WaitHandleSignaled(void *user, BOOLEAN TimerOrWaitFired) void __stdcall ILibDuktape_DescriptorEvents_WaitHandleSignaled(void *user, BOOLEAN TimerOrWaitFired)
{ {
if (!ILibMemory_CanaryOK(user)) { return; } if (!ILibMemory_CanaryOK(user)) { return; }
QueueUserAPC((PAPCFUNC)ILibDuktape_DescriptorEvents_WaitHandleAPC, ((ILibDuktape_DescriptorEvents_WindowsWaitHandle*)user)->eventThread, (ULONG_PTR)user); ILibDuktape_DescriptorEvents_WindowsWaitHandle *v = (ILibDuktape_DescriptorEvents_WindowsWaitHandle*)user;
ILibChain_RunOnMicrostackThreadEx(v->chain, ILibDuktape_DescriptorEvents_WaitHandle_EventThread, user);
} }
#endif #endif
duk_ret_t ILibDuktape_DescriptorEvents_Add(duk_context *ctx) duk_ret_t ILibDuktape_DescriptorEvents_Add(duk_context *ctx)
@@ -2349,7 +2351,8 @@ duk_ret_t ILibDuktape_DescriptorEvents_Add(duk_context *ctx)
ILibDuktape_EventEmitter_CreateEventEx(e, "signaled"); ILibDuktape_EventEmitter_CreateEventEx(e, "signaled");
v->ctx = ctx; v->ctx = ctx;
v->object = duk_get_heapptr(ctx, -1); v->object = duk_get_heapptr(ctx, -1);
v->eventThread = ILibChain_GetMicrostackThreadHandle(Duktape_GetChain(ctx)); v->chain = Duktape_GetChain(ctx);
v->eventThread = ILibChain_GetMicrostackThreadHandle(v->chain);
if (RegisterWaitForSingleObject(&(v->waitHandle), h, ILibDuktape_DescriptorEvents_WaitHandleSignaled, (void*)v, INFINITE, WT_EXECUTEINPERSISTENTTHREAD | WT_EXECUTEONLYONCE) == 0) if (RegisterWaitForSingleObject(&(v->waitHandle), h, ILibDuktape_DescriptorEvents_WaitHandleSignaled, (void*)v, INFINITE, WT_EXECUTEINPERSISTENTTHREAD | WT_EXECUTEONLYONCE) == 0)
{ {
return(ILibDuktape_Error(ctx, "Error(%d) Calling RegisterWaitForSingleObject() ", GetLastError())); return(ILibDuktape_Error(ctx, "Error(%d) Calling RegisterWaitForSingleObject() ", GetLastError()));