Source/charon/scheduler.c

   1 /**
   2  * @file scheduler.c
   3  *
   4  * @brief implements the scheduler, looks for jobs in event-queue
   5  *
   6  */
   7
   8 /*
   9  * Copyright (C) 2005 Jan Hutter, Martin Willi
  10  * Hochschule fuer Technik Rapperswil
  11  *
  12  * This program is free software; you can redistribute it and/or modify it
  13  * under the terms of the GNU General Public License as published by the
  14  * Free Software Foundation; either version 2 of the License, or (at your
  15  * option) any later version.  See <http://www.fsf.org/copyleft/gpl.txt>.
  16  *
  17  * This program is distributed in the hope that it will be useful, but
  18  * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
  19  * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  20  * for more details.
  21  */
  22
  23 #include <stdlib.h>
  24 #include <pthread.h>
  25 #include <freeswan.h>
  26 #include <pluto/constants.h>
  27 #include <pluto/defs.h>
  28
  29 #include "scheduler.h"
  30 #include "job_queue.h"
  31 #include "globals.h"
  32
  33 /**
  34  * Private data of a scheduler object
  35  */
  36 typedef struct private_scheduler_s private_scheduler_t;
  37
  38 struct private_scheduler_s {
  39         /**
  40          * Public part of a scheduler object
  41          */
  42          scheduler_t public;
  43
  44          /**
  45           * Assigned thread to the scheduler_t-object
  46           */
  47          pthread_t assigned_thread;
  48
  49 };
  50
  51 /**
  52  * Thread function started at creation of the scheduler object
  53  *
  54  * @param this assigned scheduler object
  55  * @return SUCCESS if thread_function ended successfully, FAILED otherwise
  56  */
  57 static void scheduler_thread_function(private_scheduler_t * this)
  58 {
  59         /* cancellation disabled by default */
  60         pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
  61         job_t *current_job;
  62
  63         for (;;)
  64         {
  65                 /* get a job, this block until one is available */
  66                 global_event_queue->get(global_event_queue, &current_job);
  67                 /* queue the job in the job queue, workers will eat them */
  68                 global_job_queue->add(global_job_queue, current_job);
  69         }
  70 }
  71
  72 /**
  73  * Implementation of scheduler_t's destroy function
  74  */
  75 static status_t destroy(private_scheduler_t *this)
  76 {
  77         pthread_cancel(this->assigned_thread);
  78
  79         pthread_join(this->assigned_thread, NULL);
  80
  81         pfree(this);
  82         return SUCCESS;
  83 }
  84
  85
  86 scheduler_t * scheduler_create()
  87 {
  88         private_scheduler_t *this = alloc_thing(private_scheduler_t,"private_scheduler_t");
  89
  90         this->public.destroy = (status_t(*)(scheduler_t*)) destroy;
  91         if (pthread_create(&(this->assigned_thread), NULL, (void*(*)(void*))scheduler_thread_function, this) != 0)
  92         {
  93                 /* thread could not be created  */
  94                 pfree(this);
  95                 return NULL;
  96         }
  97
  98         return &(this->public);
  99 }