freeDiameter: libfdcore/server.c annotate

annotate libfdcore/server.c @ 1327:82b386714795

Set callback data also when only setting expire callback (and not answer callback as well). It is used when calling the expire callback, so not setting it makes no sense.

author	Thomas Klausner <tk@giga.or.at>
date	Mon, 27 Nov 2017 15:21:20 +0100
parents	9ff57791a5ab
children

rev	line source
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	1 /*********************************************************************************************************
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	2 * Software License Agreement (BSD License) *
740 4a9f08d6b6ba Updated my mail address Sebastien Decugis <sdecugis@nict.go.jp> parents: 706 diff changeset	3 * Author: Sebastien Decugis <sdecugis@freediameter.net> *
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	4 * *
931 155d45d06530 Updated copyright information Sebastien Decugis <sdecugis@freediameter.net> parents: 928 diff changeset	5 * Copyright (c) 2013, WIDE Project and NICT *
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	6 * All rights reserved. *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	7 * *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	8 * Redistribution and use of this software in source and binary forms, with or without modification, are *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	9 * permitted provided that the following conditions are met: *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	10 * *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	11 * * Redistributions of source code must retain the above *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	12 * copyright notice, this list of conditions and the *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	13 * following disclaimer. *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	14 * *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	15 * * Redistributions in binary form must reproduce the above *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	16 * copyright notice, this list of conditions and the *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	17 * following disclaimer in the documentation and/or other *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	18 * materials provided with the distribution. *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	19 * *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	20 * * Neither the name of the WIDE Project or NICT nor the *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	21 * names of its contributors may be used to endorse or *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	22 * promote products derived from this software without *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	23 * specific prior written permission of WIDE Project and *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	24 * NICT. *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	25 * *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	26 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	27 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	28 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	30 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	31 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	32 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	34 *********************************************************************************************************/
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	35
658 f198d16fa7f4 Initial commit for 1.1.0: Sebastien Decugis <sdecugis@nict.go.jp> parents: 590 diff changeset	36 #include "fdcore-internal.h"
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	37
686 f83d9878bf66 Fixed in case of termination of several modules (before initialization completed) Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	38 /* Server (listening) part of the framework */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	39
686 f83d9878bf66 Fixed in case of termination of several modules (before initialization completed) Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	40 static struct fd_list FD_SERVERS = FD_LIST_INITIALIZER(FD_SERVERS); /* The list of all server objects */
f83d9878bf66 Fixed in case of termination of several modules (before initialization completed) Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	41 /* We don't need to protect this list, it is only accessed from the main framework thread. */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	42
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	43 enum s_state {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	44 NOT_CREATED=0,
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	45 RUNNING,
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	46 TERMINATED,
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	47 ERROR /* an error occurred, this is not a valid status */
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	48 };
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	49
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	50 /* Servers information */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	51 struct server {
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	52 struct fd_list chain; /* link in the FD_SERVERS list */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	53
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	54 struct cnxctx * conn; /* server connection context (listening socket) */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	55 int proto; /* IPPROTO_TCP or IPPROTO_SCTP */
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	56 int secur; /* TLS is started immediatly after connection ? 0: no; 1: RFU; 2: yes (TLS/TCP or TLS/SCTP) */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	57
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	58 pthread_t thr; /* The thread waiting for new connections (will store the data in the clients fifo) */
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	59 enum s_state state; /* state of the thread */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	60
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	61 struct fifo pending; / FIFO of struct cnxctx */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	62 struct pool_workers {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	63 struct server * s; /* pointer to the parent server structure */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	64 int id; /* The worker id for logs */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	65 pthread_t worker; /* The thread */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	66 } workers; / array of cnf_thr_srv items */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	67 };
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	68
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	69
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	70 /* Micro functions to read/change the status thread-safely */
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	71 static pthread_mutex_t s_lock = PTHREAD_MUTEX_INITIALIZER;
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	72 static enum s_state get_status(struct server * s)
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	73 {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	74 enum s_state r;
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	75 CHECK_POSIX_DO( pthread_mutex_lock(&s_lock), return ERROR );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	76 r = s->state;
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	77 CHECK_POSIX_DO( pthread_mutex_unlock(&s_lock), return ERROR );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	78 return r;
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	79 }
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	80 static void set_status(struct server * s, enum s_state st)
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	81 {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	82 CHECK_POSIX_DO( pthread_mutex_lock(&s_lock), return );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	83 s->state = st;
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	84 CHECK_POSIX_DO( pthread_mutex_unlock(&s_lock), return );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	85 }
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	86
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	87
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	88 /* dump one item of the server->pending fifo */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	89 static DECLARE_FD_DUMP_PROTOTYPE(dump_cnx, void * item) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	90 struct cnxctx * c = item;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	91 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " '%s'", fd_cnx_getid(c)), return NULL);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	92 return *buf;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	93 }
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	94
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	95 /* Dump all servers information */
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	96 DECLARE_FD_DUMP_PROTOTYPE(fd_servers_dump, int details)
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	97 {
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	98 struct fd_list * li;
1093 44f3e48dfe27 Align the behavior of all fd_dump functions wrt final \n Sebastien Decugis <sdecugis@freediameter.net>* parents: 1085 diff changeset	99
44f3e48dfe27 Align the behavior of all fd_dump functions wrt final \n Sebastien Decugis <sdecugis@freediameter.net>* parents: 1085 diff changeset	100 FD_DUMP_HANDLE_OFFSET();
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	101
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	102 for (li = FD_SERVERS.next; li != &FD_SERVERS; li = li->next) {
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	103 struct server * s = (struct server *)li;
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	104 enum s_state st = get_status(s);
1085 7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	105
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	106 if (details) {
1181 22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	107 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, "{server}(@%p)'%s': %s, %s(%d), %s", s, fd_cnx_getid(s->conn),
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	108 IPPROTO_NAME( s->proto ),
1181 22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	109 s->secur ? "Secur" : "NotSecur", s->secur,
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	110 (st == NOT_CREATED) ? "Thread not created" :
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	111 ((st == RUNNING) ? "Thread running" :
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	112 ((st == TERMINATED) ? "Thread terminated" :
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	113 "Thread status unknown"))), return NULL);
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	114 /* Dump the client list of this server */
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	115 CHECK_MALLOC_DO( fd_fifo_dump(FD_DUMP_STD_PARAMS, "pending connections", s->pending, dump_cnx), return NULL );
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	116
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	117 if (li->next != &FD_SERVERS) {
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	118 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, "\n"), return NULL);
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	119 }
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	120 } else {
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	121 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, "'%s'(%s,%s) ", fd_cnx_getid(s->conn),
eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	122 IPPROTO_NAME( s->proto ), s->secur ? "Secur" : "NotSecur"), return NULL);
1093 44f3e48dfe27 Align the behavior of all fd_dump functions wrt final \n Sebastien Decugis <sdecugis@freediameter.net>* parents: 1085 diff changeset	123 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	124 }
1085 7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	125
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	126 return *buf;
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	127 }
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	128
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	129
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	130 /* The thread in the pool for handling new clients connecting to a server */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	131 static void * client_worker(void * arg)
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	132 {
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	133 struct pool_workers * pw = arg;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	134 struct server * s = pw->s;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	135 struct cnxctx * c = NULL;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	136 int fatal = 0;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	137 struct timespec ts;
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	138 struct fd_cnx_rcvdata rcv_data;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	139 struct fd_msg_pmdl * pmdl = NULL;
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	140 struct msg * msg = NULL;
b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	141 struct msg_hdr *hdr = NULL;
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	142 struct fd_pei pei;
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	143
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	144 TRACE_ENTRY("%p", arg);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	145
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	146 /* Set the thread name */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	147 {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	148 char buf[48];
1196 9ff57791a5ab Fix worker name as the connection is not created yet Sebastien Decugis <sdecugis@freediameter.net> parents: 1192 diff changeset	149 snprintf(buf, sizeof(buf), "Worker#%d[%s%s]", pw->id, IPPROTO_NAME(s->proto), s->secur?", Sec" : "");
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	150 fd_log_threadname ( buf );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	151 }
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	152
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	153 /* Loop until canceled / error */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	154 next_client:
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	155 LOG_A("Ready to process next incoming connection");
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	156
1192 48759e3f7611 Reject more quickly invalid messages if possible Sebastien Decugis <sdecugis@freediameter.net> parents: 1190 diff changeset	157 memset(&rcv_data, 0, sizeof(rcv_data));
48759e3f7611 Reject more quickly invalid messages if possible Sebastien Decugis <sdecugis@freediameter.net> parents: 1190 diff changeset	158
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	159 /* Get the next connection */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	160 CHECK_FCT_DO( fd_fifo_get( s->pending, &c ), { fatal = 1; goto cleanup; } );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	161
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	162 /* Handshake if we are a secure server port, or start clear otherwise */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	163 if (s->secur) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	164 LOG_D("Starting handshake with %s", fd_cnx_getid(c));
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	165
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	166 int ret = fd_cnx_handshake(c, GNUTLS_SERVER, (s->secur == 1) ? ALGO_HANDSHAKE_DEFAULT : ALGO_HANDSHAKE_3436, NULL, NULL);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	167 if (ret != 0) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	168 char buf[1024];
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	169 snprintf(buf, sizeof(buf), "TLS handshake failed for connection '%s', connection closed.", fd_cnx_getid(c));
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	170
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	171 fd_hook_call(HOOK_PEER_CONNECT_FAILED, NULL, NULL, buf, NULL);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	172
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	173 goto cleanup;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	174 }
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	175 } else {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	176 CHECK_FCT_DO( fd_cnx_start_clear(c, 0), goto cleanup );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	177 }
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	178
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	179 /* Set the timeout to receive the first message */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	180 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &ts), { fatal = 1; goto cleanup; } );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	181 ts.tv_sec += INCNX_TIMEOUT;
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	182
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	183 /* Receive the first Diameter message on the connection -- cleanup in case of timeout */
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	184 CHECK_FCT_DO( fd_cnx_receive(c, &ts, &rcv_data.buffer, &rcv_data.length),
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	185 {
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	186 char buf[1024];
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	187
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	188 switch (__ret__) {
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	189 case ETIMEDOUT:
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	190 snprintf(buf, sizeof(buf), "Client '%s' did not send CER within %ds, connection aborted.", fd_cnx_getid(c), INCNX_TIMEOUT);
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	191 fd_hook_call(HOOK_PEER_CONNECT_FAILED, NULL, NULL, buf, NULL);
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	192 break;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	193
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	194 case ENOTCONN:
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	195 snprintf(buf, sizeof(buf), "Connection from '%s' in error before CER was received.", fd_cnx_getid(c));
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	196 fd_hook_call(HOOK_PEER_CONNECT_FAILED, NULL, NULL, buf, NULL);
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	197 break;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	198
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	199 default:
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	200 snprintf(buf, sizeof(buf), "Connection from '%s': unspecified error, connection aborted.", fd_cnx_getid(c));
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	201 fd_hook_call(HOOK_PEER_CONNECT_FAILED, NULL, NULL, buf, NULL);
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	202 }
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	203 goto cleanup;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	204 } );
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	205
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	206 TRACE_DEBUG(FULL, "Received %zdb from new client '%s'", rcv_data.length, fd_cnx_getid(c));
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	207
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	208 pmdl = fd_msg_pmdl_get_inbuf(rcv_data.buffer, rcv_data.length);
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	209
b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	210 /* Try parsing this message */
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	211 CHECK_FCT_DO( fd_msg_parse_buffer( &rcv_data.buffer, rcv_data.length, &msg ),
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	212 { /* Parsing failed */
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	213 fd_hook_call(HOOK_MESSAGE_PARSING_ERROR, NULL, NULL, &rcv_data, pmdl );
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	214 goto cleanup;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	215 } );
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	216
901 a3eed6420b5b Log incoming messages on new connections too Sebastien Decugis <sdecugis@freediameter.net> parents: 740 diff changeset	217 /* Log incoming message */
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	218 fd_hook_associate(msg, pmdl);
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	219 fd_hook_call(HOOK_MESSAGE_RECEIVED, msg, NULL, fd_cnx_getid(c), fd_msg_pmdl_get(msg));
901 a3eed6420b5b Log incoming messages on new connections too Sebastien Decugis <sdecugis@freediameter.net> parents: 740 diff changeset	220
28 3628f7d2ba88 some new functions backbones Sebastien Decugis <sdecugis@nict.go.jp> parents: 27 diff changeset	221 /* We expect a CER, it must parse with our dictionary and rules */
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	222 CHECK_FCT_DO( fd_msg_parse_rules( msg, fd_g_config->cnf_dict, &pei ),
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	223 { /* Parsing failed -- trace details */
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	224 char buf[1024];
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	225
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	226 fd_hook_call(HOOK_MESSAGE_PARSING_ERROR, msg, NULL, pei.pei_message ?: pei.pei_errcode, fd_msg_pmdl_get(msg));
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	227
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	228 snprintf(buf, sizeof(buf), "Error parsing CER from '%s', connection aborted.", fd_cnx_getid(c));
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	229 fd_hook_call(HOOK_PEER_CONNECT_FAILED, NULL, NULL, buf, NULL);
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	230
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	231 goto cleanup;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	232 } );
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	233
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	234 /* Now check we received a CER */
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	235 CHECK_FCT_DO( fd_msg_hdr ( msg, &hdr ), { fatal = 1; goto cleanup; } );
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	236 CHECK_PARAMS_DO( (hdr->msg_appl == 0) && (hdr->msg_flags & CMD_FLAG_REQUEST) && (hdr->msg_code == CC_CAPABILITIES_EXCHANGE),
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	237 { /* Parsing failed -- trace details */
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	238 char buf[1024];
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	239 snprintf(buf, sizeof(buf), "Expected CER from '%s', received a different message, connection aborted.", fd_cnx_getid(c));
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	240 fd_hook_call(HOOK_PEER_CONNECT_FAILED, msg, NULL, buf, NULL);
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	241 goto cleanup;
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	242 } );
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	243
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	244 /* Finally, pass the information to the peers module which will handle it in a separate thread */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	245 pthread_cleanup_push((void *)fd_cnx_destroy, c);
29 5ba91682f0bc Added a test for cnxctx (tbc) and fixed some bugs Sebastien Decugis <sdecugis@nict.go.jp> parents: 28 diff changeset	246 pthread_cleanup_push((void *)fd_msg_free, msg);
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	247 CHECK_FCT_DO( fd_peer_handle_newCER( &msg, &c ), );
29 5ba91682f0bc Added a test for cnxctx (tbc) and fixed some bugs Sebastien Decugis <sdecugis@nict.go.jp> parents: 28 diff changeset	248 pthread_cleanup_pop(0);
5ba91682f0bc Added a test for cnxctx (tbc) and fixed some bugs Sebastien Decugis <sdecugis@nict.go.jp> parents: 28 diff changeset	249 pthread_cleanup_pop(0);
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	250
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	251 cleanup:
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 686 diff changeset	252 /* Cleanup the parsed message if any */
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 686 diff changeset	253 if (msg) {
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 686 diff changeset	254 CHECK_FCT_DO( fd_msg_free(msg), /* continue */);
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	255 msg = NULL;
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 686 diff changeset	256 }
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 686 diff changeset	257
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	258 /* Close the connection if needed */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	259 if (c != NULL) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	260 fd_cnx_destroy(c);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	261 c = NULL;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	262 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	263
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	264 /* Cleanup the received buffer if any */
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	265 free(rcv_data.buffer);
26 b4684b76c6ab Fix erroneous %g specifiers for size_t (correct is %z) Sebastien Decugis <sdecugis@nict.go.jp> parents: 25 diff changeset	266
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	267
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	268 if (!fatal)
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	269 goto next_client;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	270
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	271 LOG_E("Worker thread exiting.");
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	272 return NULL;
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	273 }
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	274
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	275 /* The thread managing a server */
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	276 static void * serv_th(void * arg)
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	277 {
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	278 struct server s = (struct server )arg;
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	279
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	280 CHECK_PARAMS_DO(s, goto error);
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	281 fd_log_threadname ( fd_cnx_getid(s->conn) );
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	282
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	283 set_status(s, RUNNING);
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	284
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	285 /* Accept incoming connections */
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	286 CHECK_FCT_DO( fd_cnx_serv_listen(s->conn), goto error );
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	287
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	288 do {
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	289 struct cnxctx * conn = NULL;
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	290
1061 be24c7453aa6 Fix comment Sebastien Decugis <sdecugis@freediameter.net> parents: 979 diff changeset	291 /* Wait for a new client or cancel */
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	292 CHECK_MALLOC_DO( conn = fd_cnx_serv_accept(s->conn), break );
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	293
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	294 /* Store this connection in the fifo for processing by the worker pool. Will block when the fifo is full */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	295 pthread_cleanup_push((void *)fd_cnx_destroy, conn);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	296 CHECK_FCT_DO( fd_fifo_post( s->pending, &conn ), break );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	297 pthread_cleanup_pop(0);
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	298
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	299 } while (1);
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	300 error:
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	301 if (s)
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	302 set_status(s, TERMINATED);
1103 d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	303
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	304 /* Send error signal to the core */
d8591b1c56cd Implemented a few hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1093 diff changeset	305 LOG_F( "An error occurred in server module! Thread is terminating...");
1190 6a1042d8075b Replace FDEV_TERMINATE events with calls to fd_core_shutdown to handle the core state properly Sebastien Decugis <sdecugis@freediameter.net> parents: 1189 diff changeset	306 CHECK_FCT_DO(fd_core_shutdown(), );
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	307
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	308 return NULL;
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	309 }
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	310
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	311
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	312 /* Create a new server structure */
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	313 static struct server * new_serv( int proto, int secur )
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	314 {
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	315 struct server * new;
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	316 int i;
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	317
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	318 /* New server structure */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	319 CHECK_MALLOC_DO( new = malloc(sizeof(struct server)), return NULL );
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	320
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	321 memset(new, 0, sizeof(struct server));
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	322 fd_list_init(&new->chain, new);
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	323 new->proto = proto;
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	324 new->secur = secur;
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	325
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	326 CHECK_FCT_DO( fd_fifo_new(&new->pending, 5), return NULL);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	327 CHECK_MALLOC_DO( new->workers = calloc( fd_g_config->cnf_thr_srv, sizeof(struct pool_workers) ), return NULL );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	328
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	329 for (i = 0; i < fd_g_config->cnf_thr_srv; i++) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	330 /* Create the pool */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	331 new->workers[i].s = new;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	332 new->workers[i].id = i;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	333 CHECK_POSIX_DO( pthread_create( &new->workers[i].worker, NULL, client_worker, &new->workers[i]), return NULL );
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	334 }
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	335
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	336 return new;
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	337 }
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	338
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	339 /* Start all the servers */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	340 int fd_servers_start()
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	341 {
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	342 struct server * s;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	343
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	344 int empty_conf_ep = FD_IS_LIST_EMPTY(&fd_g_config->cnf_endpoints);
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	345
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	346 /* SCTP */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	347 if (!fd_g_config->cnf_flags.no_sctp) {
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	348 #ifdef DISABLE_SCTP
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	349 ASSERT(0);
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	350 #else /* DISABLE_SCTP */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	351
590 da93c7a5e1d0 Fix SCTP port when ListenOn is set (Patch by Vlada) - closes #20 Sebastien Decugis <sdecugis@nict.go.jp> parents: 456 diff changeset	352 /* Create the server on unsecure port */
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	353 if (fd_g_config->cnf_port) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	354 CHECK_MALLOC( s = new_serv(IPPROTO_SCTP, 0) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	355 CHECK_MALLOC( s->conn = fd_cnx_serv_sctp(fd_g_config->cnf_port, empty_conf_ep ? NULL : &fd_g_config->cnf_endpoints) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	356 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	357 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	358 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	359
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	360 /* Create the server on secure port */
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	361 if (fd_g_config->cnf_port_tls) {
1187 436e4342ecd0 Rollback to using TLS/SCTP in release 1.2.0. DTLS dev to happen in freeDiameter-dtls branch Sebastien Decugis <sdecugis@freediameter.net> parents: 1181 diff changeset	362 CHECK_MALLOC( s = new_serv(IPPROTO_SCTP, 2 /* Change when DTLS is introduced */) );
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	363 CHECK_MALLOC( s->conn = fd_cnx_serv_sctp(fd_g_config->cnf_port_tls, empty_conf_ep ? NULL : &fd_g_config->cnf_endpoints) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	364 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	365 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	366 }
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	367
1181 22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	368 /* Create the other server on 3436 secure port */
1187 436e4342ecd0 Rollback to using TLS/SCTP in release 1.2.0. DTLS dev to happen in freeDiameter-dtls branch Sebastien Decugis <sdecugis@freediameter.net> parents: 1181 diff changeset	369 /*if (fd_g_config->cnf_port_3436) {
1181 22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	370 CHECK_MALLOC( s = new_serv(IPPROTO_SCTP, 2) );
22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	371 CHECK_MALLOC( s->conn = fd_cnx_serv_sctp(fd_g_config->cnf_port_3436, empty_conf_ep ? NULL : &fd_g_config->cnf_endpoints) );
22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	372 fd_list_insert_before( &FD_SERVERS, &s->chain );
22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	373 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
1187 436e4342ecd0 Rollback to using TLS/SCTP in release 1.2.0. DTLS dev to happen in freeDiameter-dtls branch Sebastien Decugis <sdecugis@freediameter.net> parents: 1181 diff changeset	374 }*/
1181 22de21feec64 Preparing for DTLS support Sebastien Decugis <sdecugis@freediameter.net> parents: 1136 diff changeset	375
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	376 #endif /* DISABLE_SCTP */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	377 }
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	378
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	379 /* TCP */
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	380 if (!fd_g_config->cnf_flags.no_tcp) {
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	381
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	382 if (empty_conf_ep) {
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	383 /* Bind TCP servers on [0.0.0.0] */
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	384 if (!fd_g_config->cnf_flags.no_ip4) {
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	385
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	386 if (fd_g_config->cnf_port) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	387 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 0) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	388 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port, AF_INET, NULL) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	389 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	390 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	391 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	392
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	393 if (fd_g_config->cnf_port_tls) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	394 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 1) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	395 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port_tls, AF_INET, NULL) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	396 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	397 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	398 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	399 }
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	400
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	401 /* Bind TCP servers on [::] */
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	402 if (!fd_g_config->cnf_flags.no_ip6) {
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	403
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	404 if (fd_g_config->cnf_port) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	405 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 0) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	406 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port, AF_INET6, NULL) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	407 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	408 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	409 }
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	410
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	411 if (fd_g_config->cnf_port_tls) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	412 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 1) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	413 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port_tls, AF_INET6, NULL) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	414 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	415 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	416 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	417 }
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	418 } else {
bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	419 /* Create all endpoints -- check flags */
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	420 struct fd_list * li;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	421 for (li = fd_g_config->cnf_endpoints.next; li != &fd_g_config->cnf_endpoints; li = li->next) {
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	422 struct fd_endpoint * ep = (struct fd_endpoint *)li;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	423 sSA * sa = (sSA *) &ep->ss;
24 bd83ce9328ed Cleanups and completed sctp code (not finished) Sebastien Decugis <sdecugis@nict.go.jp> parents: 22 diff changeset	424 if (! (ep->flags & EP_FL_CONF))
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	425 continue;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	426 if (fd_g_config->cnf_flags.no_ip4 && (sa->sa_family == AF_INET))
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	427 continue;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	428 if (fd_g_config->cnf_flags.no_ip6 && (sa->sa_family == AF_INET6))
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	429 continue;
0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	430
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	431 if (fd_g_config->cnf_port) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	432 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 0) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	433 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port, sa->sa_family, ep) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	434 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	435 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	436 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	437
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	438 if (fd_g_config->cnf_port_tls) {
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	439 CHECK_MALLOC( s = new_serv(IPPROTO_TCP, 1) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	440 CHECK_MALLOC( s->conn = fd_cnx_serv_tcp(fd_g_config->cnf_port_tls, sa->sa_family, ep) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	441 fd_list_insert_before( &FD_SERVERS, &s->chain );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	442 CHECK_POSIX( pthread_create( &s->thr, NULL, serv_th, s ) );
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	443 }
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	444 }
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	445 }
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	446 }
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	447
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	448 /* Now, if we had an empty list of local adresses (no address configured), try to read the real addresses from the kernel */
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	449 if (empty_conf_ep) {
378 41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	450 CHECK_FCT(fd_cnx_get_local_eps(&fd_g_config->cnf_endpoints));
41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	451 if (FD_IS_LIST_EMPTY(&fd_g_config->cnf_endpoints)) {
979 b90cb4c07160 Remove more newlines. Thomas Klausner <tk@giga.or.at> parents: 974 diff changeset	452 TRACE_DEBUG(INFO, "Unable to find the address(es) of the local system. "
b90cb4c07160 Remove more newlines. Thomas Klausner <tk@giga.or.at> parents: 974 diff changeset	453 "Please use \"ListenOn\" parameter in the configuration. "
b90cb4c07160 Remove more newlines. Thomas Klausner <tk@giga.or.at> parents: 974 diff changeset	454 "This information is required to generate the CER/CEA messages.");
378 41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	455 return EINVAL;
41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	456 }
41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	457 }
1085 7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	458
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	459 {
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	460 char * buf = NULL;
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	461 size_t len = 0, offset = 0;
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	462 CHECK_MALLOC_DO( fd_dump_extend( &buf, &len, &offset , "Local server address(es): "), );
1113 eb4ce68b6e5c Added calls to remaining hooks Sebastien Decugis <sdecugis@freediameter.net> parents: 1103 diff changeset	463 CHECK_MALLOC_DO( fd_ep_dump( &buf, &len, &offset, 0, 0, &fd_g_config->cnf_endpoints ), );
1085 7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	464 LOG_N("%s", buf ?: "Error dumping addresses");
7d7266115a34 Cleaning of the traces in progress Sebastien Decugis <sdecugis@freediameter.net> parents: 1078 diff changeset	465 free(buf);
378 41e3c2a3721c Replaced old mechanism to discover local addresses by a call to getifaddrs, lot cleaner! Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	466 }
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	467 return 0;
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	468 }
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	469
277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	470 /* Terminate all the servers */
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	471 int fd_servers_stop()
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	472 {
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	473 TRACE_ENTRY("");
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	474
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	475 TRACE_DEBUG(INFO, "Shutting down server sockets...");
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	476
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	477 /* Loop on all servers */
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	478 while (!FD_IS_LIST_EMPTY(&FD_SERVERS)) {
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	479 struct server * s = (struct server *)(FD_SERVERS.next);
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	480 int i;
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	481 struct cnxctx * c;
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	482
21 bef197f6826f Backup before week-end, cnxctx and server in progress Sebastien Decugis <sdecugis@nict.go.jp> parents: 20 diff changeset	483 /* cancel thread */
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	484 CHECK_FCT_DO( fd_thr_term(&s->thr), /* continue */);
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	485
22 0b3b46da2c12 Progress on server code Sebastien Decugis <sdecugis@nict.go.jp> parents: 21 diff changeset	486 /* destroy server connection context */
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	487 fd_cnx_destroy(s->conn);
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	488
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	489 /* cancel and destroy all worker threads */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	490 for (i = 0; i < fd_g_config->cnf_thr_srv; i++) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	491 /* Destroy worker thread */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	492 CHECK_FCT_DO( fd_thr_term(&s->workers[i].worker), /* continue */);
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	493 }
1189 50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	494 free(s->workers);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	495
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	496 /* Close any pending connection */
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	497 while ( fd_fifo_tryget( s->pending, &c ) == 0 ) {
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	498 fd_cnx_destroy(c);
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	499 }
50bf33dc8fe0 Limit number of incoming connections under processing to configurable value Sebastien Decugis <sdecugis@freediameter.net> parents: 1187 diff changeset	500 CHECK_FCT_DO( fd_fifo_del(&s->pending), );
123 960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	501
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	502 /* Now destroy the server object */
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	503 fd_list_unlink(&s->chain);
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	504 free(s);
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	505 }
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	506
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	507 /* We're done! */
960fa8048805 Merged routing and dispatch files for similarities Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	508 return 0;
20 277ec00d793e Backup before typhoon... Progress on server side Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	509 }

Mercurial > hg > freeDiameter

annotate libfdcore/server.c @ 1327:82b386714795