Annotation of embedaddon/strongswan/src/libcharon/network/socket_manager.c, revision 1.1
1.1 ! misho 1: /*
! 2: * Copyright (C) 2010-2012 Tobias Brunner
! 3: * HSR Hochschule fuer Technik Rapperswil
! 4: * Copyright (C) 2010 Martin Willi
! 5: * Copyright (C) 2010 revosec AG
! 6: *
! 7: * This program is free software; you can redistribute it and/or modify it
! 8: * under the terms of the GNU General Public License as published by the
! 9: * Free Software Foundation; either version 2 of the License, or (at your
! 10: * option) any later version. See <http://www.fsf.org/copyleft/gpl.txt>.
! 11: *
! 12: * This program is distributed in the hope that it will be useful, but
! 13: * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
! 14: * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
! 15: * for more details.
! 16: */
! 17:
! 18: #include "socket_manager.h"
! 19:
! 20: #include <daemon.h>
! 21: #include <threading/thread.h>
! 22: #include <threading/rwlock.h>
! 23: #include <collections/linked_list.h>
! 24:
! 25: typedef struct private_socket_manager_t private_socket_manager_t;
! 26:
! 27: /**
! 28: * Private data of an socket_manager_t object.
! 29: */
! 30: struct private_socket_manager_t {
! 31:
! 32: /**
! 33: * Public socket_manager_t interface.
! 34: */
! 35: socket_manager_t public;
! 36:
! 37: /**
! 38: * List of registered socket constructors
! 39: */
! 40: linked_list_t *sockets;
! 41:
! 42: /**
! 43: * Instantiated socket implementation
! 44: */
! 45: socket_t *socket;
! 46:
! 47: /**
! 48: * The constructor used to create the current socket
! 49: */
! 50: socket_constructor_t create;
! 51:
! 52: /**
! 53: * Lock for sockets list
! 54: */
! 55: rwlock_t *lock;
! 56: };
! 57:
! 58: METHOD(socket_manager_t, receiver, status_t,
! 59: private_socket_manager_t *this, packet_t **packet)
! 60: {
! 61: status_t status;
! 62: this->lock->read_lock(this->lock);
! 63: if (!this->socket)
! 64: {
! 65: DBG1(DBG_NET, "no socket implementation registered, receiving failed");
! 66: this->lock->unlock(this->lock);
! 67: return NOT_SUPPORTED;
! 68: }
! 69: /* receive is blocking and the thread can be cancelled */
! 70: thread_cleanup_push((thread_cleanup_t)this->lock->unlock, this->lock);
! 71: status = this->socket->receive(this->socket, packet);
! 72: thread_cleanup_pop(TRUE);
! 73: return status;
! 74: }
! 75:
! 76: METHOD(socket_manager_t, sender, status_t,
! 77: private_socket_manager_t *this, packet_t *packet)
! 78: {
! 79: status_t status;
! 80: this->lock->read_lock(this->lock);
! 81: if (!this->socket)
! 82: {
! 83: DBG1(DBG_NET, "no socket implementation registered, sending failed");
! 84: this->lock->unlock(this->lock);
! 85: return NOT_SUPPORTED;
! 86: }
! 87: status = this->socket->send(this->socket, packet);
! 88: this->lock->unlock(this->lock);
! 89: return status;
! 90: }
! 91:
! 92: METHOD(socket_manager_t, get_port, uint16_t,
! 93: private_socket_manager_t *this, bool nat_t)
! 94: {
! 95: uint16_t port = 0;
! 96: this->lock->read_lock(this->lock);
! 97: if (this->socket)
! 98: {
! 99: port = this->socket->get_port(this->socket, nat_t);
! 100: }
! 101: this->lock->unlock(this->lock);
! 102: return port;
! 103: }
! 104:
! 105: METHOD(socket_manager_t, supported_families, socket_family_t,
! 106: private_socket_manager_t *this)
! 107: {
! 108: socket_family_t families = SOCKET_FAMILY_NONE;
! 109: this->lock->read_lock(this->lock);
! 110: if (this->socket)
! 111: {
! 112: families = this->socket->supported_families(this->socket);
! 113: }
! 114: this->lock->unlock(this->lock);
! 115: return families;
! 116: }
! 117:
! 118: static void create_socket(private_socket_manager_t *this)
! 119: {
! 120: socket_constructor_t create;
! 121: /* remove constructors in order to avoid trying to create broken ones
! 122: * multiple times */
! 123: while (this->sockets->remove_first(this->sockets,
! 124: (void**)&create) == SUCCESS)
! 125: {
! 126: this->socket = create();
! 127: if (this->socket)
! 128: {
! 129: this->create = create;
! 130: break;
! 131: }
! 132: }
! 133: }
! 134:
! 135: METHOD(socket_manager_t, add_socket, void,
! 136: private_socket_manager_t *this, socket_constructor_t create)
! 137: {
! 138: this->lock->write_lock(this->lock);
! 139: this->sockets->insert_last(this->sockets, create);
! 140: if (!this->socket)
! 141: {
! 142: create_socket(this);
! 143: }
! 144: this->lock->unlock(this->lock);
! 145: }
! 146:
! 147: METHOD(socket_manager_t, remove_socket, void,
! 148: private_socket_manager_t *this, socket_constructor_t create)
! 149: {
! 150: this->lock->write_lock(this->lock);
! 151: this->sockets->remove(this->sockets, create, NULL);
! 152: if (this->create == create)
! 153: {
! 154: this->socket->destroy(this->socket);
! 155: this->socket = NULL;
! 156: this->create = NULL;
! 157: create_socket(this);
! 158: }
! 159: this->lock->unlock(this->lock);
! 160: }
! 161:
! 162: METHOD(socket_manager_t, destroy, void,
! 163: private_socket_manager_t *this)
! 164: {
! 165: DESTROY_IF(this->socket);
! 166: this->sockets->destroy(this->sockets);
! 167: this->lock->destroy(this->lock);
! 168: free(this);
! 169: }
! 170:
! 171: /**
! 172: * See header
! 173: */
! 174: socket_manager_t *socket_manager_create()
! 175: {
! 176: private_socket_manager_t *this;
! 177:
! 178: INIT(this,
! 179: .public = {
! 180: .send = _sender,
! 181: .receive = _receiver,
! 182: .get_port = _get_port,
! 183: .supported_families = _supported_families,
! 184: .add_socket = _add_socket,
! 185: .remove_socket = _remove_socket,
! 186: .destroy = _destroy,
! 187: },
! 188: .sockets = linked_list_create(),
! 189: .lock = rwlock_create(RWLOCK_TYPE_DEFAULT),
! 190: );
! 191:
! 192: return &this->public;
! 193: }
! 194:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to socket_manager.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / strongswan / src / libcharon / network