freeDiameter: libfdcore/p

annotate libfdcore/p_sr.c @ 882:ae96ae28f3dd 1.1.5

Limit python version to avoid using python3 (not compatible)

author	Sebastien Decugis <sdecugis@freediameter.net>
date	Sat, 03 Nov 2012 18:45:41 +0100
parents	1d2721778c7a
children	4158151cc694

rev	line source
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	1 /*********************************************************************************************************
0e2b57789361 Backup for the WE, some warnings remaining 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> *
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	4 * *
837 1d2721778c7a Updated copyright information Sebastien Decugis <sdecugis@freediameter.net> parents: 824 diff changeset	5 * Copyright (c) 2012, WIDE Project and NICT *
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	6 * All rights reserved. *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	7 * *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	9 * permitted provided that the following conditions are met: *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	10 * *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	11 * * Redistributions of source code must retain the above *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	12 * copyright notice, this list of conditions and the *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	13 * following disclaimer. *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	14 * *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	15 * * Redistributions in binary form must reproduce the above *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	16 * copyright notice, this list of conditions and the *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	17 * following disclaimer in the documentation and/or other *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	18 * materials provided with the distribution. *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	19 * *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	20 * * Neither the name of the WIDE Project or NICT nor the *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	21 * names of its contributors may be used to endorse or *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	22 * promote products derived from this software without *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	23 * specific prior written permission of WIDE Project and *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	24 * NICT. *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	25 * *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining 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 *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	34 *********************************************************************************************************/
0e2b57789361 Backup for the WE, some warnings remaining 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: 650 diff changeset	36 #include "fdcore-internal.h"
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	37
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	38 /* Structure to store a sent request */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	39 struct sentreq {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	40 struct fd_list chain; /* the "o" field points directly to the hop-by-hop of the request (uint32_t ) /
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	41 struct msg req; / A request that was sent and not yet answered. */
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	42 uint32_t prevhbh;/* The value to set in the hbh header when the message is retrieved */
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	43 struct fd_list expire; /* the list of expiring requests */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	44 struct timespec added_on; /* the time the request was added */
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	45 };
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	46
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	47 /* Find an element in the hbh list, or the following one */
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	48 static struct fd_list * find_or_next(struct fd_list * srlist, uint32_t hbh, int * match)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	49 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	50 struct fd_list * li;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	51 *match = 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	52 for (li = srlist->next; li != srlist; li = li->next) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	53 uint32_t * nexthbh = li->o;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	54 if (*nexthbh < hbh)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	55 continue;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	56 if (*nexthbh == hbh)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	57 *match = 1;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	58 break;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	59 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	60 return li;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	61 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	62
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	63 static void srl_dump(const char * text, struct fd_list * srlist)
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	64 {
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	65 struct fd_list * li;
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	66 struct timespec now;
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	67
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	68 if (!TRACE_BOOL(ANNOYING))
73 02db4d794ccf Lower trace level Sebastien Decugis <sdecugis@nict.go.jp> parents: 71 diff changeset	69 return;
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	70
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	71 fd_log_debug("%sSentReq list @%p:\n", text, srlist);
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	72
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	73 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &now), );
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	74
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	75 for (li = srlist->next; li != srlist; li = li->next) {
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	76 struct sentreq * sr = (struct sentreq *)li;
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	77 uint32_t * nexthbh = li->o;
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	78
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	79 fd_log_debug(" - Next req (hbh:%x): [since %ld.%06ld sec]\n", *nexthbh,
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	80 (now.tv_nsec >= sr->added_on.tv_nsec) ? (now.tv_sec - sr->added_on.tv_sec) : (now.tv_sec - sr->added_on.tv_sec - 1),
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	81 (now.tv_nsec >= sr->added_on.tv_nsec) ? (now.tv_nsec - sr->added_on.tv_nsec) / 1000 : (now.tv_nsec - sr->added_on.tv_nsec + 1000000000) / 1000);
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	82
4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	83 fd_msg_dump_one(ANNOYING + 1, sr->req);
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	84 }
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	85 }
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	86
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	87 /* (detached) thread that calls the anscb on expired messages.
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	88 We do it in a separate thread to avoid blocking the reception of new messages during this time */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	89 static void * call_anscb_expire(void * arg) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	90 struct msg * expired_req = arg;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	91
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	92 void (anscb)(void , struct msg **);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	93 void * data;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	94
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	95 TRACE_ENTRY("%p", arg);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	96 CHECK_PARAMS_DO( arg, return NULL );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	97
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	98 /* Set the thread name */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	99 fd_log_threadname ( "Expired req cb." );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	100
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	101 /* Log */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	102 TRACE_DEBUG(INFO, "The expiration timer for a request has been reached, abording this attempt now & calling cb...");
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	103
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	104 /* Retrieve callback in the message */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	105 CHECK_FCT_DO( fd_msg_anscb_get( expired_req, &anscb, &data ), return NULL);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	106 ASSERT(anscb);
824 89c5849b0832 Allow retransmission of messages on timeout Sebastien Decugis <sdecugis@freediameter.net> parents: 740 diff changeset	107
89c5849b0832 Allow retransmission of messages on timeout Sebastien Decugis <sdecugis@freediameter.net> parents: 740 diff changeset	108 /* Clean up this data from the message */
89c5849b0832 Allow retransmission of messages on timeout Sebastien Decugis <sdecugis@freediameter.net> parents: 740 diff changeset	109 CHECK_FCT_DO( fd_msg_anscb_associate( expired_req, NULL, NULL, NULL ), return NULL);
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	110
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	111 /* Call it */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	112 (*anscb)(data, &expired_req);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	113
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	114 /* If the callback did not dispose of the message, do it now */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	115 if (expired_req) {
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	116 fd_msg_log(FD_MSG_LOG_DROPPED, expired_req, "Expiration period completed without an answer, and the expiry callback did not dispose of the message.");
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	117 CHECK_FCT_DO( fd_msg_free(expired_req), /* ignore */ );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	118 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	119
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	120 /* Finish */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	121 return NULL;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	122 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	123
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	124 /* thread that handles messages expiring. The thread is started only when needed */
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	125 static void * sr_expiry_th(void * arg) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	126 struct sr_list * srlist = arg;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	127 struct msg * expired_req;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	128 pthread_attr_t detached;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	129
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	130 TRACE_ENTRY("%p", arg);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	131 CHECK_PARAMS_DO( arg, return NULL );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	132
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	133 /* Set the thread name */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	134 {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	135 char buf[48];
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	136 snprintf(buf, sizeof(buf), "ReqExp/%s", ((struct fd_peer *)(srlist->exp.o))->p_hdr.info.pi_diamid);
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	137 fd_log_threadname ( buf );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	138 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	139
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	140 CHECK_POSIX_DO( pthread_attr_init(&detached), return NULL );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	141 CHECK_POSIX_DO( pthread_attr_setdetachstate(&detached, PTHREAD_CREATE_DETACHED), return NULL );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	142
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	143 CHECK_POSIX_DO( pthread_mutex_lock(&srlist->mtx), return NULL );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	144 pthread_cleanup_push( fd_cleanup_mutex, &srlist->mtx );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	145
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	146 do {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	147 struct timespec now, *t;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	148 struct sentreq * first;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	149 pthread_t th;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	150
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	151 /* Check if there are expiring requests available */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	152 if (FD_IS_LIST_EMPTY(&srlist->exp)) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	153 /* Just wait for a change or cancelation */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	154 CHECK_POSIX_DO( pthread_cond_wait( &srlist->cnd, &srlist->mtx ), goto error );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	155 /* Restart the loop on wakeup */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	156 continue;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	157 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	158
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	159 /* Get the pointer to the request that expires first */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	160 first = (struct sentreq *)(srlist->exp.next->o);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	161 t = fd_msg_anscb_gettimeout( first->req );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	162 ASSERT(t);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	163
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	164 /* Get the current time */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	165 CHECK_SYS_DO( clock_gettime(CLOCK_REALTIME, &now), goto error );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	166
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	167 /* If first request is not expired, we just wait until it happens */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	168 if ( TS_IS_INFERIOR( &now, t ) ) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	169
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	170 CHECK_POSIX_DO2( pthread_cond_timedwait( &srlist->cnd, &srlist->mtx, t ),
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	171 ETIMEDOUT, /* ETIMEDOUT is a normal return value, continue */,
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	172 /* on other error, */ goto error );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	173
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	174 /* on wakeup, loop */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	175 continue;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	176 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	177
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	178 /* Now, the first request in the list is expired; remove it and call the anscb for it in a new thread */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	179 fd_list_unlink(&first->chain);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	180 fd_list_unlink(&first->expire);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	181 expired_req = first->req;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	182 free(first);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	183
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	184 CHECK_POSIX_DO( pthread_create( &th, &detached, call_anscb_expire, expired_req ), goto error );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	185
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	186 /* loop */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	187 } while (1);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	188 error:
650 7e9a5e9aad64 Fix compilation warning Sebastien Decugis <sdecugis@nict.go.jp> parents: 649 diff changeset	189 ; /* pthread_cleanup_pop sometimes expands as "} ..." and the label beofre this cause some compilers to complain... */
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	190 pthread_cleanup_pop( 1 );
691 78b665400097 Cleanup all pthread_cleanup_push / pop pairs so that pop is always called after push, or ASSERT(0) is some grave errors Sebastien Decugis <sdecugis@nict.go.jp> parents: 688 diff changeset	191 ASSERT(0); /* we have encountered a problem, maybe time to signal the framework to terminate? */
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	192 return NULL;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	193 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	194
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	195
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	196 /* Store a new sent request */
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	197 int fd_p_sr_store(struct sr_list * srlist, struct msg *req, uint32_t hbhloc, uint32_t hbh_restore)
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	198 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	199 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	200 struct fd_list * next;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	201 int match;
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	202 struct timespec * ts;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	203
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	204 TRACE_ENTRY("%p %p %p %x", srlist, req, hbhloc, hbh_restore);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	205 CHECK_PARAMS(srlist && req && *req && hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	206
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	207 CHECK_MALLOC( sr = malloc(sizeof(struct sentreq)) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	208 memset(sr, 0, sizeof(struct sentreq));
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	209 fd_list_init(&sr->chain, hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	210 sr->req = *req;
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	211 sr->prevhbh = hbh_restore;
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	212 fd_list_init(&sr->expire, sr);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	213 CHECK_SYS( clock_gettime(CLOCK_REALTIME, &sr->added_on) );
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	214
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	215 /* Search the place in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	216 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	217 next = find_or_next(&srlist->srs, *hbhloc, &match);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	218 if (match) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	219 TRACE_DEBUG(INFO, "A request with the same hop-by-hop Id was already sent: error");
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	220 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	221 CHECK_POSIX_DO( pthread_mutex_unlock(&srlist->mtx), /* ignore */ );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	222 return EINVAL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	223 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	224
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	225 /* Save in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	226 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	227 fd_list_insert_before(next, &sr->chain);
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	228 srl_dump("Saved new request, ", &srlist->srs);
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	229
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	230 /* In case of request with a timeout, also store in the timeout list */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	231 ts = fd_msg_anscb_gettimeout( sr->req );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	232 if (ts) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	233 struct fd_list * li;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	234 struct timespec * t;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	235
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	236 /* browse srlist->exp from the end */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	237 for (li = srlist->exp.prev; li != &srlist->exp; li = li->prev) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	238 struct sentreq * s = (struct sentreq *)(li->o);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	239 t = fd_msg_anscb_gettimeout( s->req );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	240 ASSERT( t ); /* sanity */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	241 if (TS_IS_INFERIOR(t, ts))
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	242 break;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	243 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	244
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	245 fd_list_insert_after(li, &sr->expire);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	246
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	247 /* if the thread does not exist yet, create it */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	248 if (srlist->thr == (pthread_t)NULL) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	249 CHECK_POSIX_DO( pthread_create(&srlist->thr, NULL, sr_expiry_th, srlist), /* continue anyway */);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	250 } else {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	251 /* or, if added in first position, signal the condvar to update the sleep time of the thread */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	252 if (li == &srlist->exp) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	253 CHECK_POSIX_DO( pthread_cond_signal(&srlist->cnd), /* continue anyway */);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	254 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	255 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	256 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	257
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	258 CHECK_POSIX( pthread_mutex_unlock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	259 return 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	260 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	261
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	262 /* Fetch a request by hbh */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	263 int fd_p_sr_fetch(struct sr_list * srlist, uint32_t hbh, struct msg **req)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	264 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	265 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	266 int match;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	267
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	268 TRACE_ENTRY("%p %x %p", srlist, hbh, req);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	269 CHECK_PARAMS(srlist && req);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	270
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	271 /* Search the request in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	272 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	273 srl_dump("Fetching a request, ", &srlist->srs);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	274 sr = (struct sentreq *)find_or_next(&srlist->srs, hbh, &match);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	275 if (!match) {
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	276 TRACE_DEBUG(INFO, "There is no saved request with this hop-by-hop id (%x)", hbh);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	277 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	278 } else {
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	279 /* Restore hop-by-hop id */
4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	280 ((uint32_t )sr->chain.o) = sr->prevhbh;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	281 /* Unlink */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	282 fd_list_unlink(&sr->chain);
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	283 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	284 *req = sr->req;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	285 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	286 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	287 CHECK_POSIX( pthread_mutex_unlock(&srlist->mtx) );
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	288
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	289 /* do not stop the expire thread here, it might cause creating/destroying it very often otherwise */
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	290
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	291 /* Done */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	292 return 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	293 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	294
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	295 /* Failover requests (free or requeue routables) */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	296 void fd_p_sr_failover(struct sr_list * srlist)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	297 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	298 CHECK_POSIX_DO( pthread_mutex_lock(&srlist->mtx), /* continue anyway */ );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	299 while (!FD_IS_LIST_EMPTY(&srlist->srs)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	300 struct sentreq * sr = (struct sentreq *)(srlist->srs.next);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	301 fd_list_unlink(&sr->chain);
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	302 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	303 if (fd_msg_is_routable(sr->req)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	304 struct msg_hdr * hdr = NULL;
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	305 int ret;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	306
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	307 /* Set the 'T' flag */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	308 CHECK_FCT_DO(fd_msg_hdr(sr->req, &hdr), /* continue */);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	309 if (hdr)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	310 hdr->msg_flags \|= CMD_FLAG_RETRANSMIT;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	311
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	312 /* Requeue for sending to another peer */
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	313 CHECK_FCT_DO( ret = fd_fifo_post(fd_g_outgoing, &sr->req),
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	314 {
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	315 fd_msg_log( FD_MSG_LOG_DROPPED, sr->req, "Internal error: error while requeuing during failover: %s", strerror(ret) );
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	316 CHECK_FCT_DO(fd_msg_free(sr->req), /* What can we do more? */)
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	317 });
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	318 } else {
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	319 /* Just free the request. */
706 4ffbc9f1e922 Large UNTESTED commit with the following changes: Sebastien Decugis <sdecugis@nict.go.jp> parents: 691 diff changeset	320 fd_msg_log( FD_MSG_LOG_DROPPED, sr->req, "Sent & unanswered local message discarded during failover." );
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	321 CHECK_FCT_DO(fd_msg_free(sr->req), /* Ignore */);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	322 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	323 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	324 }
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	325 /* The list of expiring requests must be empty now */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	326 ASSERT( FD_IS_LIST_EMPTY(&srlist->exp) );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	327
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	328 CHECK_POSIX_DO( pthread_mutex_unlock(&srlist->mtx), /* continue anyway */ );
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	329
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	330 /* Terminate the expiry thread (must be done when the lock can be taken) */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	331 CHECK_FCT_DO( fd_thr_term(&srlist->thr), /* ignore error */ );
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	332 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	333

Mercurial > hg > freeDiameter

annotate libfdcore/p_sr.c @ 882:ae96ae28f3dd 1.1.5