- removed strongswan includes, we are now self-contained ;-)

diff --git a/Source/charon/configuration.c b/Source/charon/configuration.c
index 46e961c..ae57b5c 100644 (file)
--- a/Source/charon/configuration.c
+++ b/Source/charon/configuration.c
@@ -23,9 +23,6 @@
  */
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "types.h"

diff --git a/Source/charon/daemon.c b/Source/charon/daemon.c
index fb50c8e..269cf75 100644 (file)
--- a/Source/charon/daemon.c
+++ b/Source/charon/daemon.c
@@ -21,9 +21,6 @@
  */
  
 #include <stdio.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
  
 #include "types.h"
 #include "tester.h"

diff --git a/Source/charon/encodings.c b/Source/charon/encodings.c
index 26170bd..99b2722 100644 (file)
--- a/Source/charon/encodings.c
+++ b/Source/charon/encodings.c
@@ -25,9 +25,12 @@
  * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
  * for more details.
  */
- 
- #include "encodings.h"
- #include "encodings/ike_header.h" 
+
+#include <stdlib.h>
+
+#include "types.h" 
+#include "encodings.h"
+#include "encodings/ike_header.h" 
 
 extern payload_info_t ike_header_info;
 

diff --git a/Source/charon/encodings.h b/Source/charon/encodings.h
index 232ec13..7eda87c 100644 (file)
--- a/Source/charon/encodings.h
+++ b/Source/charon/encodings.h
@@ -29,9 +29,8 @@
 #ifndef ENCODINGS_H_
 #define ENCODINGS_H_
 
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
+#include "types.h"
+
 
 /**
  * @brief All different kinds of encoding types. 

diff --git a/Source/charon/encodings/ike_header.h b/Source/charon/encodings/ike_header.h
index 58b4348..22978a7 100644 (file)
--- a/Source/charon/encodings/ike_header.h
+++ b/Source/charon/encodings/ike_header.h
@@ -25,9 +25,6 @@
 #ifndef IKE_HEADER_H_
 #define IKE_HEADER_H_
 
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 /**
  * Data structure to hold the data of an IKEv2-Header

diff --git a/Source/charon/event_queue.c b/Source/charon/event_queue.c
index 120efd2..a6c1197 100644 (file)
--- a/Source/charon/event_queue.c
+++ b/Source/charon/event_queue.c
@@ -20,9 +20,6 @@
  * for more details.
  */
 
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 #include <pthread.h>
 #include <stdlib.h>
 

diff --git a/Source/charon/generator.c b/Source/charon/generator.c
index 83c4b4a..5d852c5 100644 (file)
--- a/Source/charon/generator.c
+++ b/Source/charon/generator.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <string.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "types.h"

diff --git a/Source/charon/ike_sa_id.c b/Source/charon/ike_sa_id.c
index 3634c82..800dba8 100644 (file)
--- a/Source/charon/ike_sa_id.c
+++ b/Source/charon/ike_sa_id.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <string.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "types.h"

diff --git a/Source/charon/ike_sa_id.h b/Source/charon/ike_sa_id.h
index eaaa811..9d50495 100644 (file)
--- a/Source/charon/ike_sa_id.h
+++ b/Source/charon/ike_sa_id.h
@@ -24,10 +24,6 @@
 #ifndef IKE_SA_ID_H_
 #define IKE_SA_ID_H_
 
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
-
 #include "types.h"
 
 /**

diff --git a/Source/charon/job.c b/Source/charon/job.c
index 5332cc8..557961d 100644 (file)
--- a/Source/charon/job.c
+++ b/Source/charon/job.c
@@ -21,9 +21,6 @@
  */
 
 #include <stdlib.h>
- #include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
  #include "job.h"

diff --git a/Source/charon/job_queue.c b/Source/charon/job_queue.c
index aeb0da9..d14289b 100644 (file)
--- a/Source/charon/job_queue.c
+++ b/Source/charon/job_queue.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <pthread.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "job_queue.h"

diff --git a/Source/charon/linked_list.c b/Source/charon/linked_list.c
index 0361165..e1a5157 100644 (file)
--- a/Source/charon/linked_list.c
+++ b/Source/charon/linked_list.c
@@ -21,9 +21,6 @@
  */
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "linked_list.h"

diff --git a/Source/charon/linked_list.h b/Source/charon/linked_list.h
index 8a8dbc2..2b900a4 100644 (file)
--- a/Source/charon/linked_list.h
+++ b/Source/charon/linked_list.h
@@ -23,10 +23,6 @@
 #ifndef LINKED_LIST_H_
 #define LINKED_LIST_H_
 
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
-
 #include "types.h"
 
 /**

diff --git a/Source/charon/logger.h b/Source/charon/logger.h
index 076944b..7833120 100644 (file)
--- a/Source/charon/logger.h
+++ b/Source/charon/logger.h
@@ -23,11 +23,6 @@
 #ifndef LOGGER_H_
 #define LOGGER_H_
 
-
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
-
 #include "types.h"
 
 /**

diff --git a/Source/charon/message.c b/Source/charon/message.c
index 1651d9d..1dc5a15 100644 (file)
--- a/Source/charon/message.c
+++ b/Source/charon/message.c
@@ -21,9 +21,6 @@
  */
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "types.h"

diff --git a/Source/charon/packet.h b/Source/charon/packet.h
index ca8ea13..8e5f9e9 100644 (file)
--- a/Source/charon/packet.h
+++ b/Source/charon/packet.h
@@ -31,9 +31,6 @@
 #include <netinet/in.h>
 #include <arpa/inet.h>
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 
 /**

diff --git a/Source/charon/parser.c b/Source/charon/parser.c
index dd9d649..0f4af57 100644 (file)
--- a/Source/charon/parser.c
+++ b/Source/charon/parser.c
@@ -21,9 +21,6 @@
  */
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "types.h"

diff --git a/Source/charon/receiver.c b/Source/charon/receiver.c
index abbb5cf..93a4adb 100644 (file)
--- a/Source/charon/receiver.c
+++ b/Source/charon/receiver.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <pthread.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "receiver.h"

diff --git a/Source/charon/scheduler.c b/Source/charon/scheduler.c
index 7a00bc8..f8692fb 100644 (file)
--- a/Source/charon/scheduler.c
+++ b/Source/charon/scheduler.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <pthread.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "scheduler.h"

diff --git a/Source/charon/sender.c b/Source/charon/sender.c
index 20d301f..a0118bf 100644 (file)
--- a/Source/charon/sender.c
+++ b/Source/charon/sender.c
@@ -22,9 +22,6 @@
 
 #include <stdlib.h>
 #include <pthread.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "sender.h"

diff --git a/Source/charon/socket.c b/Source/charon/socket.c
index 5b6ad2f..e650cd8 100644 (file)
--- a/Source/charon/socket.c
+++ b/Source/charon/socket.c
@@ -28,9 +28,6 @@
 #include <string.h>
 #include <unistd.h>
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "allocator.h"
 #include "socket.h"

diff --git a/Source/charon/tester.c b/Source/charon/tester.c
index 09c0989..938ca46 100644 (file)
--- a/Source/charon/tester.c
+++ b/Source/charon/tester.c
@@ -22,9 +22,6 @@
 
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 #include <string.h>
 #include <pthread.h>
 #include <sys/time.h>

diff --git a/Source/charon/tester.h b/Source/charon/tester.h
index 498ab41..3a90baa 100644 (file)
--- a/Source/charon/tester.h
+++ b/Source/charon/tester.h
@@ -24,12 +24,10 @@
 #define TESTER_H_ 
 
 #include <stdio.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "types.h"
 
+
 /**
  * @brief Specifies a test
  */

diff --git a/Source/charon/tests/generator_test.c b/Source/charon/tests/generator_test.c
index 228d501..2f6fa47 100644 (file)
--- a/Source/charon/tests/generator_test.c
+++ b/Source/charon/tests/generator_test.c
@@ -21,9 +21,6 @@
  */
  
 #include <string.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 
 #include "../allocator.h"
 #include "generator_test.h"

diff --git a/Source/charon/tests/job_queue_test.c b/Source/charon/tests/job_queue_test.c
index 8ea291b..63fbb45 100644 (file)
--- a/Source/charon/tests/job_queue_test.c
+++ b/Source/charon/tests/job_queue_test.c
@@ -22,9 +22,6 @@
 
 
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 #include <pthread.h>
 #include <unistd.h>
 

diff --git a/Source/charon/thread_pool.c b/Source/charon/thread_pool.c
index ec3d05c..0231d1f 100644 (file)
--- a/Source/charon/thread_pool.c
+++ b/Source/charon/thread_pool.c
@@ -21,12 +21,12 @@
  */
  
 #include <stdlib.h>
-#include <freeswan.h>
-#include <pluto/constants.h>
-#include <pluto/defs.h>
 #include <pthread.h>
+#include <string.h>
+#include <errno.h>
  
 #include "allocator.h"
+#include "logger.h"
 #include "thread_pool.h"
 #include "job_queue.h"
 #include "globals.h"
@@ -47,6 +47,10 @@ typedef struct {
         * array of thread ids
         */
        pthread_t *threads;
+       /**
+        * logger of the threadpool
+        */
+       logger_t *logger;
 } private_thread_pool_t;
 
 
@@ -83,13 +87,15 @@ static status_t destroy(private_thread_pool_t *this)
 {      
        int current;
        /* flag thread for termination */
-       for (current = 0; current < this->pool_size; current++) {               
+       for (current = 0; current < this->pool_size; current++) {
+               this->logger->log(this->logger, CONTROL, "cancelling thread %u", this->threads[current]);
                pthread_cancel(this->threads[current]);
        }
        
        /* wait for all threads */
        for (current = 0; current < this->pool_size; current++) {
                pthread_join(this->threads[current], NULL);
+               this->logger->log(this->logger, CONTROL, "thread %u terminated", this->threads[current]);
        }       
 
        /* free mem */
@@ -113,19 +119,23 @@ thread_pool_t *thread_pool_create(size_t pool_size)
        
        this->pool_size = pool_size;
        this->threads = allocator_alloc(sizeof(pthread_t) * pool_size);
-
+       this->logger = logger_create("thread_pool", 0);
        
        /* try to create as many threads as possible, up tu pool_size */
        for (current = 0; current < pool_size; current++) {
-               if (pthread_create(&(this->threads[current]), NULL, (void*(*)(void*))job_processing, this)) {
-                       /* did we get any? */
-                       if (current == 0) {
-
+               if (pthread_create(&(this->threads[current]), NULL, (void*(*)(void*))job_processing, this)) 
+               {
+                       /* did we get any? */   
+                       if (current == 0) 
+                       {
+                               this->logger->log(this->logger, CONTROL, "could not create any thread: %s\n", strerror(errno));
                                allocator_free(this->threads);
                                allocator_free(this);
                                return NULL;
                        }
                        /* not all threads could be created, but at least one :-/ */
+                       this->logger->log(this->logger, CONTROL, "could only create %d from requested %d threads: %s\n", current, pool_size, strerror(errno));
+                               
                        this->pool_size = current;
                        return (thread_pool_t*)this;
                }