freeDiameter: libfdcore/p

annotate libfdcore/p_sr.c @ 691:78b665400097

Cleanup all pthread_cleanup_push / pop pairs so that pop is always called after push, or ASSERT(0) is some grave errors

author	Sebastien Decugis <sdecugis@nict.go.jp>
date	Thu, 20 Jan 2011 19:44:27 +0900
parents	8c3dc8584dab
children	4ffbc9f1e922

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) {
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	111 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	112 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	113 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	114
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	115 /* Finish */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	116 return NULL;
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
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	119 /* thread that handles messages expiring. The thread is started / cancelled 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	120 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	121 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	122 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	123 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	124
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	125 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	126 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	127
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	128 /* 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	129 {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	130 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	131 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	132 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	133 }
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 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	136 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	137
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	138 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	139 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	140
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	141 do {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	142 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	143 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	144 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	145
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	146 /* 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	147 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	148 /* 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	149 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	150 /* 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	151 continue;
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
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	154 /* 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	155 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	156 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	157 ASSERT(t);
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 current time */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	160 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	161
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	162 /* 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	163 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	164
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	165 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	166 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	167 /* 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	168
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	169 /* 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	170 continue;
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
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	173 /* 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	174 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	175 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	176 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	177 free(first);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	178
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	179 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	180
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	181 /* loop */
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	182 } while (1);
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	183 error:
650 7e9a5e9aad64 Fix compilation warning Sebastien Decugis <sdecugis@nict.go.jp> parents: 649 diff changeset	184 ; /* 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	185 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	186 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	187 return NULL;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	188 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	189
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	190
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	191 /* 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	192 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	193 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	194 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	195 struct fd_list * next;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	196 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	197 struct timespec * ts;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	198
165 4679ff581d6a Fix invalid restore of the hop-by-hop id on forwarded answers Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	199 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	200 CHECK_PARAMS(srlist && req && *req && hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	201
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	202 CHECK_MALLOC( sr = malloc(sizeof(struct sentreq)) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	203 memset(sr, 0, sizeof(struct sentreq));
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	204 fd_list_init(&sr->chain, hbhloc);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	205 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	206 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	207 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	208 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	209
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	210 /* Search the place in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	211 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	212 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	213 if (match) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	214 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	215 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	216 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	217 return EINVAL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	218 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	219
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	220 /* Save in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	221 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	222 fd_list_insert_before(next, &sr->chain);
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	223 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	224
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	225 /* 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	226 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	227 if (ts) {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	228 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	229 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	230
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	231 /* 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	232 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	233 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	234 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	235 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	236 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	237 break;
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	238 }
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 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	241
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	242 /* 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	243 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	244 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	245 } else {
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	246 /* 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	247 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	248 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	249 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	250 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	251 }
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	252
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	253 CHECK_POSIX( pthread_mutex_unlock(&srlist->mtx) );
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	254 return 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	255 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	256
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	257 /* Fetch a request by hbh */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	258 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	259 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	260 struct sentreq * sr;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	261 int match;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	262
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	263 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	264 CHECK_PARAMS(srlist && req);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	265
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	266 /* Search the request in the list */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	267 CHECK_POSIX( pthread_mutex_lock(&srlist->mtx) );
71 cba30013d8f5 Added debug messages Sebastien Decugis <sdecugis@nict.go.jp> parents: 34 diff changeset	268 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	269 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	270 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	271 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	272 *req = NULL;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	273 } 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	274 /* 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	275 ((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	276 /* Unlink */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	277 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	278 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	279 *req = sr->req;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	280 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	281 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	282 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	283
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	284 /* 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	285
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	286 /* Done */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	287 return 0;
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	288 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	289
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	290 /* Failover requests (free or requeue routables) */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	291 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	292 {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	293 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	294 while (!FD_IS_LIST_EMPTY(&srlist->srs)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	295 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	296 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	297 fd_list_unlink(&sr->expire);
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	298 if (fd_msg_is_routable(sr->req)) {
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	299 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	300 int ret;
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	301
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	302 /* Set the 'T' flag */
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	303 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	304 if (hdr)
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	305 hdr->msg_flags \|= CMD_FLAG_RETRANSMIT;
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 /* 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	308 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	309 {
8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	310 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	311 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	312 });
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	313 } else {
688 8c3dc8584dab Prepared capability for messages logging to separate files / folders Sebastien Decugis <sdecugis@nict.go.jp> parents: 662 diff changeset	314 /* Just free the request. */
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, "Local message discarded during failover" );
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	316 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	317 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	318 free(sr);
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	319 }
649 5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	320 /* 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	321 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	322
34 0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	323 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	324
5e5d8152c229 Implemented fd_msg_send_timeout to close #10. Not tested yet. Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	325 /* 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	326 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	327 }
0e2b57789361 Backup for the WE, some warnings remaining Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	328

Mercurial > hg > freeDiameter

annotate libfdcore/p_sr.c @ 691:78b665400097