aboutsummaryrefslogtreecommitdiffstats
path: root/src/libstrongswan/processing
diff options
context:
space:
mode:
Diffstat (limited to 'src/libstrongswan/processing')
-rw-r--r--src/libstrongswan/processing/jobs/callback_job.c5
-rw-r--r--src/libstrongswan/processing/scheduler.c5
2 files changed, 4 insertions, 6 deletions
diff --git a/src/libstrongswan/processing/jobs/callback_job.c b/src/libstrongswan/processing/jobs/callback_job.c
index 4c9a7fdac..556cbd907 100644
--- a/src/libstrongswan/processing/jobs/callback_job.c
+++ b/src/libstrongswan/processing/jobs/callback_job.c
@@ -18,7 +18,6 @@
#include <semaphore.h>
-#include <hydra.h>
#include <threading/thread.h>
#include <threading/condvar.h>
#include <threading/mutex.h>
@@ -227,8 +226,8 @@ static void execute(private_callback_job_t *this)
thread_cancellation_point();
if (requeue)
{
- hydra->processor->queue_job(hydra->processor,
- &this->public.job_interface);
+ lib->processor->queue_job(lib->processor,
+ &this->public.job_interface);
}
thread_cleanup_pop(cleanup);
}
diff --git a/src/libstrongswan/processing/scheduler.c b/src/libstrongswan/processing/scheduler.c
index 8a58e4570..e23f04598 100644
--- a/src/libstrongswan/processing/scheduler.c
+++ b/src/libstrongswan/processing/scheduler.c
@@ -19,7 +19,6 @@
#include "scheduler.h"
-#include <hydra.h>
#include <debug.h>
#include <processing/processor.h>
#include <processing/jobs/callback_job.h>
@@ -200,7 +199,7 @@ static job_requeue_t schedule(private_scheduler_t * this)
remove_event(this);
this->mutex->unlock(this->mutex);
DBG2(DBG_JOB, "got event, queuing job for execution");
- hydra->processor->queue_job(hydra->processor, event->job);
+ lib->processor->queue_job(lib->processor, event->job);
free(event);
return JOB_REQUEUE_DIRECT;
}
@@ -352,7 +351,7 @@ scheduler_t * scheduler_create()
this->condvar = condvar_create(CONDVAR_TYPE_DEFAULT);
this->job = callback_job_create((callback_job_cb_t)schedule, this, NULL, NULL);
- hydra->processor->queue_job(hydra->processor, (job_t*)this->job);
+ lib->processor->queue_job(lib->processor, (job_t*)this->job);
return &this->public;
}