diff options
Diffstat (limited to 'Source')
| -rw-r--r-- | Source/charon/receiver.c | 119 | ||||
| -rw-r--r-- | Source/charon/receiver.h | 47 |
2 files changed, 166 insertions, 0 deletions
diff --git a/Source/charon/receiver.c b/Source/charon/receiver.c new file mode 100644 index 000000000..a4df3e71a --- /dev/null +++ b/Source/charon/receiver.c @@ -0,0 +1,119 @@ +/** + * @file receiver.c + * + * @brief Implements the Receiver Thread encapsulated in the receiver_t-object + * + */ + +/* + * Copyright (C) 2005 Jan Hutter, Martin Willi + * Hochschule fuer Technik Rapperswil + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>. + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY + * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * for more details. + */ + +#include <stdlib.h> +#include <pthread.h> +#include <freeswan.h> +#include <pluto/constants.h> +#include <pluto/defs.h> + +#include "receiver.h" +#include "socket.h" +#include "packet.h" +#include "job.h" +#include "job_queue.h" +#include "globals.h" + +/** + * Private data of a receiver object + */ +typedef struct private_receiver_s private_receiver_t; + +struct private_receiver_s { + /** + * Public part of a receiver object + */ + receiver_t public; + + /** + * Assigned thread to the receiver_t-object + */ + pthread_t assigned_thread; + +}; + +/** + * Thread function started at creation of the receiver object + * + * @param this assigned receiver object + * @return SUCCESS if thread_function ended successfully, FAILED otherwise + */ +static void receiver_thread_function(private_receiver_t * this) +{ + /* cancellation disabled by default */ + pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL); + packet_t * current_packet; + job_t * current_job; + + while (1) + { + while (global_socket->receive(global_socket,¤t_packet) == SUCCESS) + { + current_job = job_create(INCOMING_PACKET,current_packet); + if (current_job == NULL) + { + /* job could no be created */ + /* TODO LOG it */ + } + + if ( global_job_queue->add(global_job_queue,current_job) != SUCCESS) + { + /* Packet could not be sent */ + /* TODO LOG it */ + } + + } + /* NOT GOOD !!!!!! */ + /* TODO LOG it */ + } + + +} + +/** + * Implementation of receiver_t's destroy function + */ +static status_t destroy(private_receiver_t *this) +{ + pthread_cancel(this->assigned_thread); + + pthread_join(this->assigned_thread, NULL); + + pfree(this); + return SUCCESS; +} + + +receiver_t * receiver_create() +{ + private_receiver_t *this = alloc_thing(private_receiver_t,"private_receiver_t"); + + this->public.destroy = (status_t(*)(receiver_t*)) destroy; + if (pthread_create(&(this->assigned_thread), NULL, (void*(*)(void*))receiver_thread_function, this) != 0) + { + /* thread could not be created */ + pfree(this); + return NULL; + } + + return &(this->public); +} diff --git a/Source/charon/receiver.h b/Source/charon/receiver.h new file mode 100644 index 000000000..56a966fc7 --- /dev/null +++ b/Source/charon/receiver.h @@ -0,0 +1,47 @@ +/** + * @file receiver.h + * + * @brief Implements the Receiver Thread encapsulated in the receiver_t-object + * + */ + +/* + * Copyright (C) 2005 Jan Hutter, Martin Willi + * Hochschule fuer Technik Rapperswil + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>. + * + * This program is distributed in the hope that it will be useful, but + * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY + * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License + * for more details. + */ + +#ifndef RECEIVER_H_ +#define RECEIVER_H_ + +#include "types.h" + +/** + * @brief A Receiver object which receives packets on the socket and adds them to the job-queue + */ +typedef struct receiver_s receiver_t; + +struct receiver_s { + + /** + * @brief Destroys a receiver object + * + * @param receiver receiver object + * @return SUCCESSFUL if succeeded, FAILED otherwise + */ + status_t (*destroy) (receiver_t *receiver); +}; + + +receiver_t * receiver_create(); + +#endif /*RECEIVER_H_*/ |