watcher: use processors new execute_job() to notify FDs

Just queueing is problematic, as all threads might be busy waiting for events
that the queued (but never executed) job delivers.

diff --git a/src/libstrongswan/processing/watcher.c b/src/libstrongswan/processing/watcher.c
index 9e02a1b4938175e58f086eb5402cf2059dbbcef1..69cb3c8f5370aa932a4a197ec3a2be5b4e7fb183 100644 (file)
--- a/src/libstrongswan/processing/watcher.c
+++ b/src/libstrongswan/processing/watcher.c
@@ -325,15 +325,7 @@ static job_requeue_t watch(private_watcher_t *this)
                                while (this->jobs->remove_first(this->jobs,
                                                                                                (void**)&job) == SUCCESS)
                                {
-                                       if (lib->processor->get_threads(lib->processor))
-                                       {
-                                               lib->processor->queue_job(lib->processor, job);
-                                       }
-                                       else
-                                       {
-                                               job->execute(job);
-                                               job->destroy(job);
-                                       }
+                                       lib->processor->execute_job(lib->processor, job);
                                }
                                /* we temporarily disable a notified FD, rebuild FDSET */
                                return JOB_REQUEUE_DIRECT;