diff --git a/xs/platforms/lin_xs.c b/xs/platforms/lin_xs.c index 3cb229cfbb..fa6356e84f 100644 --- a/xs/platforms/lin_xs.c +++ b/xs/platforms/lin_xs.c @@ -71,6 +71,7 @@ void fxDeleteMachinePlatform(txMachine* the) void fxQueuePromiseJobs(txMachine* the) { + the->promiseJobsFlag = 1; GSource* idle_source = g_idle_source_new(); g_source_set_callback(idle_source, fxQueuePromiseJobsCallback, the, NULL); g_source_set_priority(idle_source, G_PRIORITY_DEFAULT); diff --git a/xs/platforms/lin_xs.h b/xs/platforms/lin_xs.h index a86bea0533..2f5bf25113 100644 --- a/xs/platforms/lin_xs.h +++ b/xs/platforms/lin_xs.h @@ -87,6 +87,7 @@ extern void fxQueueWorkerJob(void* machine, void* job); void* waiterCondition; \ void* waiterData; \ void* waiterLink; \ + gboolean promiseJobsFlag; \ GMainContext* workerContext; \ GMutex workerMutex; \ txWorkerJob* workerQueue;