freeDiameter: libfdcore/p

annotate libfdcore/p_dw.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	4ffbc9f1e922

rev	line source
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	1 /*********************************************************************************************************
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	2 * Software License Agreement (BSD License) *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	3 * Author: Sebastien Decugis <sdecugis@nict.go.jp> *
1498b3c7304c Backup 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 *
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	6 * All rights reserved. *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	7 * *
1498b3c7304c Backup 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 *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	9 * permitted provided that the following conditions are met: *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	10 * *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	11 * * Redistributions of source code must retain the above *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	12 * copyright notice, this list of conditions and the *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	13 * following disclaimer. *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	14 * *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	15 * * Redistributions in binary form must reproduce the above *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	16 * copyright notice, this list of conditions and the *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	17 * following disclaimer in the documentation and/or other *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	18 * materials provided with the distribution. *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	19 * *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	20 * * Neither the name of the WIDE Project or NICT nor the *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	21 * names of its contributors may be used to endorse or *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	22 * promote products derived from this software without *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	23 * specific prior written permission of WIDE Project and *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	24 * NICT. *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	25 * *
1498b3c7304c Backup 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 *
1498b3c7304c Backup 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 *
1498b3c7304c Backup 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 *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	29 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
1498b3c7304c Backup 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 *
1498b3c7304c Backup 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 *
1498b3c7304c Backup 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 *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	33 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	34 *********************************************************************************************************/
1498b3c7304c Backup 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: 454 diff changeset	36 #include "fdcore-internal.h"
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	37
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	38 /* This file contains code to handle Device Watchdog messages (DWR and DWA) */
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	39
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	40 /* Check the value of Origin-State-Id is consistent in a DWR or DWA -- we just log if it is not the case */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	41 static void check_state_id(struct msg * msg, struct fd_peer * peer)
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	42 {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	43 struct avp * osi;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	44 /* Check if the request contains the Origin-State-Id */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	45 CHECK_FCT_DO( fd_msg_search_avp ( msg, fd_dict_avp_OSI, &osi ), return );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	46 if (osi) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	47 /* Check the value is consistent with the saved one */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	48 struct avp_hdr * hdr;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	49 CHECK_FCT_DO( fd_msg_avp_hdr( osi, &hdr ), return );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	50 if (hdr->avp_value == NULL) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	51 /* This is a sanity check */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	52 TRACE_DEBUG(NONE, "BUG: Unset value in Origin-State-Id in DWR / DWA");
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	53 fd_msg_dump_one(NONE, osi);
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	54 ASSERT(0); /* To check if this really happens, and understand why... */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	55 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	56
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	57 if (peer->p_hdr.info.runtime.pir_orstate != hdr->avp_value->u32) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	58 fd_log_debug("Received a new Origin-State-Id from peer %s! (%x / %x)\n",
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	59 peer->p_hdr.info.pi_diamid,
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	60 hdr->avp_value->u32,
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	61 peer->p_hdr.info.runtime.pir_orstate );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	62 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	63 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	64 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	65
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	66 /* Create and send a DWR */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	67 static int send_DWR(struct fd_peer * peer)
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	68 {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	69 struct msg * msg = NULL;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	70
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	71 /* Create a new DWR instance */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	72 CHECK_FCT( fd_msg_new ( fd_dict_cmd_DWR, MSGFL_ALLOC_ETEID, &msg ) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	73
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	74 /* Add the content of the message (only the origin) */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	75 CHECK_FCT( fd_msg_add_origin ( msg, 1 ) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	76
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	77 /* Now send this message */
229 965f5971dc23 Broadcast CEA over all streams to avoid possible race condition Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	78 CHECK_FCT( fd_out_send(&msg, NULL, peer, FD_CNX_ORDERED) );
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	79
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	80 /* And mark the pending DW */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	81 peer->p_flags.pf_dw_pending = 1;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	82
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	83 return 0;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	84 }
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	85
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	86 /* Handle an incoming message */
40 7e1deaa89540 Some progress on the PSM Sebastien Decugis <sdecugis@nict.go.jp> parents: 36 diff changeset	87 int fd_p_dw_handle(struct msg ** msg, int req, struct fd_peer * peer)
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	88 {
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	89 int reset_tmr = 0;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	90
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	91 TRACE_ENTRY("%p %d %p", msg, req, peer);
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	92
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	93 /* Check the value of OSI for information */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	94 check_state_id(*msg, peer);
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	95
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	96 if (req) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	97 /* If we receive a DWR, send back a DWA */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	98 CHECK_FCT( fd_msg_new_answer_from_req ( fd_g_config->cnf_dict, msg, 0 ) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	99 CHECK_FCT( fd_msg_rescode_set( *msg, "DIAMETER_SUCCESS", NULL, NULL, 0 ) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	100 CHECK_FCT( fd_msg_add_origin ( *msg, 1 ) );
229 965f5971dc23 Broadcast CEA over all streams to avoid possible race condition Sebastien Decugis <sdecugis@nict.go.jp> parents: 74 diff changeset	101 CHECK_FCT( fd_out_send( msg, peer->p_cnxctx, peer, FD_CNX_ORDERED) );
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	102
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	103 } else {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	104 /* Just discard the DWA */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	105 CHECK_FCT_DO( fd_msg_free(msg), / continue */ );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	106 *msg = NULL;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	107
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	108 /* And clear the pending DW flag */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	109 peer->p_flags.pf_dw_pending = 0;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	110 }
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	111
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	112 /* Now update timeout */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	113 if (req) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	114 /* Update timeout only if we did not already send a DWR ourselves */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	115 reset_tmr = !peer->p_flags.pf_dw_pending;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	116 } else {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	117 /* Reset the timer */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	118 reset_tmr = 1;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	119 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	120 if (reset_tmr) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	121 fd_psm_next_timeout(peer, 1, peer->p_hdr.info.config.pic_twtimer ?: fd_g_config->cnf_timer_tw);
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	122 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	123
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	124 /* If we are in REOPEN state, increment the counter */
454 f1484823cb4a Small hack which might spear some concurrency problems and is quite harmless Sebastien Decugis <sdecugis@nict.go.jp> parents: 258 diff changeset	125 fd_cpu_flush_cache();
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	126 if (peer->p_hdr.info.runtime.pir_state == STATE_REOPEN) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	127 peer->p_flags.pf_reopen_cnt += 1;
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	128
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	129 if (peer->p_flags.pf_reopen_cnt) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	130 /* Send a new DWR */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	131 CHECK_FCT( send_DWR(peer) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	132 } else {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	133 /* Move to OPEN state */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	134 CHECK_FCT( fd_psm_change_state(peer, STATE_OPEN) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	135 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	136 }
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	137
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	138 return 0;
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	139 }
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	140
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	141 /* Handle a timeout in the PSM (OPEN or REOPEN state only) */
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	142 int fd_p_dw_timeout(struct fd_peer * peer)
1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	143 {
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 66 diff changeset	144 TRACE_ENTRY("%p", peer);
9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 66 diff changeset	145
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	146 if (peer->p_flags.pf_dw_pending) {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	147 /* We have sent a DWR and received no answer during TwTimer */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	148 CHECK_FCT( fd_psm_change_state(peer, STATE_SUSPECT) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	149 fd_psm_next_timeout(peer, 0, 2 * (peer->p_hdr.info.config.pic_twtimer ?: fd_g_config->cnf_timer_tw) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	150 } else {
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	151 /* The timeout has expired, send a DWR */
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	152 CHECK_FCT( send_DWR(peer) );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	153 fd_psm_next_timeout(peer, 0, peer->p_hdr.info.config.pic_twtimer ?: fd_g_config->cnf_timer_tw );
dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	154 }
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	155
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	156 return 0;
36 1498b3c7304c Backup Sebastien Decugis <sdecugis@nict.go.jp> parents: diff changeset	157 }
43 2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	158
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	159 /* Handle DW exchanges after the peer has come alive again */
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	160 int fd_p_dw_reopen(struct fd_peer * peer)
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	161 {
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 66 diff changeset	162 TRACE_ENTRY("%p", peer);
9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 66 diff changeset	163
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	164 peer->p_flags.pf_reopen_cnt = 1;
74 9dcb1bd11a07 Some cleanups Sebastien Decugis <sdecugis@nict.go.jp> parents: 66 diff changeset	165 peer->p_flags.pf_cnx_pb = 0;
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	166 CHECK_FCT( send_DWR(peer) );
43 2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	167
66 dcbd5b5ee55c Added handling for DWR/DWA Sebastien Decugis <sdecugis@nict.go.jp> parents: 43 diff changeset	168 return 0;
43 2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	169 }
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	170
2db15632a63d Added a large part of connection establishment logic, to test Sebastien Decugis <sdecugis@nict.go.jp> parents: 40 diff changeset	171

Mercurial > hg > freeDiameter

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