freeDiameter: libfdcore/p

annotate libfdcore/p_sr.c @ 662:2e94ef0515d7 1.1.0-rc1

Updated copyright information

author	Sebastien Decugis <sdecugis@nict.go.jp>
date	Fri, 14 Jan 2011 16:27:21 +0900
parents	f198d16fa7f4
children	8c3dc8584dab

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) *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	3 * Author: Sebastien Decugis <sdecugis@nict.go.jp> *
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	4 * *
662 2e94ef0515d7 Updated copyright information Sebastien Decugis <sdecugis@nict.go.jp> parents: 658 diff changeset	5 * Copyright (c) 2011, 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
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	38 #ifndef SR_DEBUG_LVL
9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	39 #define SR_DEBUG_LVL ANNOYING
9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	40 #endif /* SR_DEBUG_LVL */
9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	41
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	42 /* Structure to store a sent request */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	43 struct sentreq {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	44 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	45 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	46 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	47 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	48 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	49 };
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	50
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	51 /* 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	52 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	53 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	54 struct fd_list * li;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	55 *match = 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	56 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	57 uint32_t * nexthbh = li->o;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	58 if (*nexthbh < hbh)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	59 continue;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	60 if (*nexthbh == hbh)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	61 *match = 1;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	62 break;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	63 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	64 return li;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	65 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	66
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	67 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	68 {
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	69 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	70 struct timespec now;
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	71 if (!TRACE_BOOL(SR_DEBUG_LVL))
73 02db4d794ccf Lower trace level Sebastien Decugis <sdecugis@nict.go.jp> parents: 71 diff changeset	72 return;
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), );
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	74 fd_log_debug("%sSentReq list @%p:\n", text, srlist);
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;
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	78 fd_log_debug(" - Next req (%x): [since %ld.%06ld sec]\n", *nexthbh,
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	79 (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	80 (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);
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 73 diff changeset	81 fd_msg_dump_one(SR_DEBUG_LVL + 1, sr->req);
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	82 }
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	83 }
cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	84
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	85 /* (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	86 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	87 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	88 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	89
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	90 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	91 void * data;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	92
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	93 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	94 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	95
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	96 /* 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	97 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	98
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	99 /* Log */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	100 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	101
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	102 /* 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	103 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	104 ASSERT(anscb);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	105
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	106 /* Call it */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	107 (*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	108
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	109 /* 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	110 if (expired_req) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	111 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	112 }
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 /* Finish */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	115 return NULL;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	116 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	117
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	118 /* thread that handles messages expiring. The thread is started / stopped only when needed */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	119 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	120 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	121 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	122 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	123
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	124 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	125 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	126
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	127 /* 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	128 {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	129 char buf[48];
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	130 sprintf(buf, "ReqExp/%.s", (int)sizeof(buf) - 8, ((struct fd_peer )(srlist->exp.o))->p_hdr.info.pi_diamid);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	131 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	132 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	133
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	134 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	135 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	136
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	137 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	138 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	139
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	140 do {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	141 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	142 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	143 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	144
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	145 /* 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	146 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	147 /* 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	148 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	149 /* 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	150 continue;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	151 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	152
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	153 /* 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	154 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	155 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	156 ASSERT(t);
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 /* 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	159 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	160
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	161 /* 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	162 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	163
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	164 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	165 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	166 /* 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	167
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	168 /* 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	169 continue;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	170 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	171
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	172 /* 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	173 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	174 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	175 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	176 free(first);
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 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	179
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	180 /* loop */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	181 } while (1);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	182 error:
650 7e9a5e9aad64 Fix compilation warning Sebastien Decugis <sdecugis@nict.go.jp> parents: 649 diff changeset	183 ; /* 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	184 pthread_cleanup_pop( 1 );
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	185 return NULL;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	186 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	187
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	188
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	189 /* 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	190 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	191 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	192 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	193 struct fd_list * next;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	194 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	195 struct timespec * ts;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	196
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 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	198 CHECK_PARAMS(srlist && req && *req && hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	199
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	200 CHECK_MALLOC( sr = malloc(sizeof(struct sentreq)) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	201 memset(sr, 0, sizeof(struct sentreq));
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	202 fd_list_init(&sr->chain, hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	203 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	204 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	205 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	206 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	207
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	208 /* Search the place in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	209 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	210 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	211 if (match) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	212 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	213 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	214 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	215 return EINVAL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	216 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	217
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	218 /* Save in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	219 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	220 fd_list_insert_before(next, &sr->chain);
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	221 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	222
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	223 /* 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	224 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	225 if (ts) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	226 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	227 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	228
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	229 /* 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	230 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	231 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	232 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	233 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	234 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	235 break;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	236 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	237
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	238 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	239
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	240 /* 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	241 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	242 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	243 } else {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	244 /* 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	245 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	246 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	247 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	248 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	249 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	250
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	251 CHECK_POSIX( pthread_mutex_unlock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	252 return 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	253 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	254
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	255 /* Fetch a request by hbh */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	256 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	257 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	258 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	259 int match;
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 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	262 CHECK_PARAMS(srlist && req);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	263
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	264 /* Search the request in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	265 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	266 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	267 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	268 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	269 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	270 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	271 } 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	272 /* 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	273 ((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	274 /* Unlink */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	275 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	276 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	277 *req = sr->req;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	278 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	279 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	280 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	281
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	282 /* 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	283
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	284 /* Done */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	285 return 0;
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
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	288 /* Failover requests (free or requeue routables) */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	289 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	290 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	291 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	292 while (!FD_IS_LIST_EMPTY(&srlist->srs)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	293 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	294 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	295 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	296 if (fd_msg_is_routable(sr->req)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	297 struct msg_hdr * hdr = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	298
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	299 /* Set the 'T' flag */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	300 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	301 if (hdr)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	302 hdr->msg_flags \|= CMD_FLAG_RETRANSMIT;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	303
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	304 /* Requeue for sending to another peer */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	305 CHECK_FCT_DO(fd_fifo_post(fd_g_outgoing, &sr->req),
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	306 CHECK_FCT_DO(fd_msg_free(sr->req), /* What can we do more? */));
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	307 } else {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	308 /* Just free the request... */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	309 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	310 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	311 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	312 }
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	313 /* 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	314 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	315
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	316 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	317
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	318 /* 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	319 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	320 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	321

Mercurial > hg > freeDiameter

annotate libfdcore/p_sr.c @ 662:2e94ef0515d7 1.1.0-rc1