ldplspfsm.c

技术文件名称：MPLSv1.0软件模块测试规程

        resend_time = ldp_get_random(MPLS_RANDOM_TIME_RANGE,abort_time);
	    MPLS_SET_TIMER(resend_time,(void *)ldp_req_timout,LspCBVar,ldptime_q,LspCBVar->timerid);  /* lixia mod 2003-11-6 */
	}
	
	/*向下游节点发送request*/
	wait_lsplblmsg_append(LspCBVar,pEntry,MPLS_NULL,MPLS_NULL,MPLS_LBLREQ_MSGTYPE);   
	
}
/*add by fengjun for guangzhou */

short ProcLblReq_status1(mplsLdpSession_t *session,void *pEntry, mplsLdpLspCB *LspCBVar, void * inputEvent)
{
	/* 发学路由请求,子状态切为FEC_INDEX_REQ_AWAITED */
	mplsLdpLblReqMsg_t 	*lblReqMsg;
	FecMsg              fecMsg;
	
	lblReqMsg  = (mplsLdpLblReqMsg_t *)inputEvent; 	
	MPLS_MEMSET(&fecMsg,0,sizeof(FecMsg));

    if (LspCBVar->subStatus != IDLE)
    	return LDP_FALSE;
	
	if((LspCBVar->lspType == LDP_HOP_LSP)&&(LspCBVar->nodeType == MPLS_NODE_INTERM))
	{
		/*ATM---ATM:请求预留资源(子状态切为BANDWITH_REQ_AWAITED)*/	
		LspCBVar->subStatus = BANDWITH_REQ_AWAITED;
		
              if(LspCBVar->lspType == LDP_HOP_LSP)
                   return       Xcbandwithreq(LspCBVar,pEntry);
          /*add by fengjun for guangzhou 
                  return wait_xc_append(LspCBVar,pEntry,0x0);
          add by fengjun for guangzhou */
	      else
		  return CR_wait_xc_append(LspCBVar,pEntry,0x0);
	}
	else
	{
		/*发学路由请求,学习建路业务板信息，子状态切为FEC_INDEX_REQ_AWAITED*/
		fecMsg.OperateType    = INQUIRE_TYPE;
	    seg_fec_msg(&fecMsg,lblReqMsg);
	    fecMsg.Fec.lspIndex	  = LspCBVar->lspIndex;
		LspCBVar->subStatus   = FEC_INDEX_REQ_AWAITED;
		#if 1
		ldp_inquirertepro(&fecMsg,session->ifIndex);
		ProcFecInquire(&fecMsg);
		#endif
		#ifdef __BGS10_MPLS_DEBUG
			printf("==== Module %d,MPLS_PSEND MPLS_FEC_STUDY INQUIRE ====",selfLdpPid.module);
		#endif
		return LDP_TRUE;    
	}
	
}/*ProcLblReq_status1*/

short ProcRouteAdd_status1(void *pEntry, mplsLdpLspCB *LspCBVar)
{
	/* 发学路由请求,子状态切为FEC_INDEX_REQ_AWAITED */
	FecMsg              fecMsg;
	mplsLdpFecEntry		*fecEntry;
	
	fecEntry = (mplsLdpFecEntry *)pEntry;
	MPLS_MEMSET(&fecMsg,0,sizeof(FecMsg));

    if ((LspCBVar->subStatus != IDLE)||
    	(LspCBVar->nodeType != MPLS_NODE_INGRESS))
    	return LDP_FALSE;
		
	/*发学路由请求,学习建路业务板信息，子状态切为FEC_INDEX_REQ_AWAITED*/
    fecMsg.OperateType    = INQUIRE_TYPE;
    fecMsg.Fec.TlvExists.flags.fecTlvExists = 1;
    fecMsg.Fec.fecElemNum = 1;
    fecMsg.Fec.fecElArray[0].addressEl.address = fecEntry->fec_key.mplsFecAddr;
    fecMsg.Fec.fecElArray[0].addressEl.preLen  = fecEntry->fec_key.mplsLdpFecAddrLen;
	fecMsg.Fec.fecElArray[0].addressEl.addressFam = fecEntry->mplsFecAddrFamily;
	fecMsg.Fec.fecElArray[0].addressEl.type = fecEntry->mplsLdpFecType;
    fecMsg.Fec.lspIndex	  = LspCBVar->lspIndex;
	LspCBVar->subStatus   = FEC_INDEX_REQ_AWAITED;
	#if 1
	ldp_inquirertepro(&fecMsg,0xffff);
	ProcFecInquire(&fecMsg);
	#endif
	#ifdef __BGS10_MPLS_DEBUG
		printf("==== MPLS_PSEND MPLS_FEC_STUDY INQUIRE,FEC %x,lspIndex %x ====",
		              fecEntry->fec_key.mplsFecAddr,LspCBVar->lspIndex);
	#endif
	return LDP_TRUE;    

	
}/*ProcRouteAdd_status1*/

/*2003.1.28 Huyonghong 对聚合，更新下游模块和端口 */
short ProcFecInquireOk (void * inputEvent)
{
	/*1.如果查路由失败，发notify，删除lspCB*/
	/*2.由路由判断是否egress*/
		/*2.1.egress:分配下游标记，上游标记，请求建立PVC，主状态切为RESPONSE_AWAITED，
		  子状态切为CREATE_PVC_REQ_AWAITED*/
		/*2.2.非egress:请求预留资源(子状态切为BANDWITH_REQ_AWAITED)*/	
	FecMsg              *fecMsg;
	mplsLdpFecEntry		*pFecEntry = NULL;
	mplsLdpCrLsp		*pCrEntry = NULL;
	char 				*pEntry = NULL;
	mplsLdpLspCB 		*LspCBVar = NULL;
	mplsLdpLspCB        *LspCV    = NULL;
	mplsLdpLspCB       * lspCb_t  = MPLS_NULL;
	mpls_sb_list        * sb_list;
        unsigned short		preLen;
	short               rtcode=0;
	unsigned long       nexthop;
	STRUC_MPLS_AD_RLSPVC_REQ pvclabel;
	release_pvc_tab_t   *rel_pvc = MPLS_NULL;
	unsigned long        module = 0 ;
		
		
	MPLS_MEMSET(&pvclabel, 0, sizeof(STRUC_MPLS_AD_RLSPVC_REQ));
	p_s_f = MPLS_NULL;   /*2004-5-11 lixia mod for label req fail*/
	fecMsg  = (FecMsg *)inputEvent;
	preLen = fecMsg->Fec.fecElemTypes[0] == MPLS_HOSTADR_FEC ? \
						32: fecMsg->Fec.fecElArray[0].addressEl.preLen;

	/*查找lspCB*/
	if(fecMsg->Fec.TlvExists.flags.lspidTlvExists == 1)
	{
		pCrEntry = (mplsLdpCrLsp *)ldp_search_crentry_from_lspidtlv(fecMsg->Fec.lspidTlv);
		if(pCrEntry == NULL)
			return LDP_FALSE;
		pEntry = (char *)pCrEntry;
		LspCBVar = &(pCrEntry->crlspCb);
	}
	else
	{
		pFecEntry = ldp_search_fecentry(preLen,
										fecMsg->Fec.fecElArray[0].addressEl.address);
		if(pFecEntry == NULL)
		{
            DEBUG_OUT(DEBUG_OWNER_MPLS, DEBUG_LEVEL_MPLS_LSP,"ProcFecInquireOk,ldp_search_fecentry fail\n");
		    MPLS_ERR_LOG("ldp_search_fecentry fail");
			return LDP_FALSE;
		}
		pEntry = (char *)pFecEntry;
		LspCBVar = ldp_search_lspcb_from_index(pFecEntry,fecMsg->Fec.lspIndex);
		if(LspCBVar == NULL)
		{
            DEBUG_OUT(DEBUG_OWNER_MPLS, DEBUG_LEVEL_MPLS_LSP,"ProcFecInquireOk,ldp_search_lspcb_from_index fail\n");
		    MPLS_ERR_LOG("ldp_search_lspcb_from_index fail");
			return LDP_FALSE;
	    }
	}
    	
	/* 查找路由成功 */
	/*取到建路业务板信息，填到LspCB中*/
	if(ldp_fec2lspCB(LspCBVar,fecMsg) == LDP_FALSE)
	{
        DEBUG_OUT(DEBUG_OWNER_MPLS, DEBUG_LEVEL_MPLS_LSP,"ProcFecInquireOk,ldp_fec2lspCB fail\n");
	    MPLS_ERR_LOG("ldp_fec2lspCB fail");
		return LDP_FALSE;
	}
	if(LspCBVar->nodeType != MPLS_NODE_INTERM)
	{
		sb_list = MPLS_NULL;
		MPLS_SB_SEARCH(fecMsg->Fec.sbModule,fecMsg->Fec.sbPort,sb_list);
		if(!sb_list)
		{
			MPLS_SB_CREATE(fecMsg->Fec.sbModule,fecMsg->Fec.sbPort,sb_list)
		}
		if(sb_list)
		{
			if(LspCBVar->nodeType == MPLS_NODE_EGRESS)
			{
				MPLS_INSERT_INTO_DOWN_LSP_LIST(sb_list->lsp_down_cb_list,LspCBVar,LspCBVar);
			}
			else if(LspCBVar->nodeType == MPLS_NODE_INGRESS)
			{
				MPLS_INSERT_INTO_UP_LSP_LIST(sb_list->lsp_up_cb_list,LspCBVar,LspCBVar);
			}
		}
	}
	/*判断是否egress*/
	if(LspCBVar->nodeType == MPLS_NODE_EGRESS)
	{
        /************************************************************/
		/* wengqing add for fec aggregate 
		*/
		/************************************************************/
    /* 当存在FEC聚合时，同一FEC可能使用同一标记,Label Release无法区分，此处为了防止这种情况，
    加以防止；当存在相同路径向量时，不接纳新的Label Request*/    

		if(LspCBVar->lspType == LDP_HOP_LSP)
		{
		    pFecEntry = (mplsLdpFecEntry *)(LspCBVar->selffec);
		    MPLS_WALK_LSP_BEGIN(pFecEntry,LspCV,t_lspCb)
        	if(LspCV != MPLS_NULL && LspCV != LspCBVar) /* for protect */
        	{
        		#ifdef __BGS10_MPLS_DEBUG
        	    printf(" !!!!!!!! input protect !!!!!!!!!!!!!");
        	    #endif
        	    if((LspCV->pAttr.hopcount     == LspCBVar->pAttr.hopcount)    && \
    			   (LspCV->pAttr.len          == LspCBVar->pAttr.len)         && \
    			   (!MPLS_MEMCMP(LspCV->pAttr.pAttr,LspCBVar->pAttr.pAttr,LspCBVar->pAttr.len))
    			   )
    			{
    			    sb_list = MPLS_NULL;
        	        MPLS_SB_SEARCH(LspCBVar->downAtmLabel.module,\
        	                    LspCBVar->downAtmLabel.port,sb_list);
            		if(!sb_list)
            		{
            			MPLS_REMOVE_FROM_SESSION_DOWN_LSP_LIST(g_down_lsp_list,LspCBVar);
            		}
            		else
            		{
            		    MPLS_REMOVE_FROM_SESSION_DOWN_LSP_LIST_A(sb_list->lsp_down_cb_list,LspCBVar);
            		    if(!(sb_list->lsp_down_cb_list.first ||sb_list->lsp_up_cb_list.first))
            		        MPLS_SB_DELETE(LspCBVar->downAtmLabel.module,\
        	                    LspCBVar->downAtmLabel.port,sb_list)
            		}
            		LspCBVar->errorcode = PROTECTERROR;
            		SndNotMsg(LspCBVar->upSessionIndex,INTERNALERROR,LspCBVar->upMsgid,\
			        	    MPLS_LBLREQ_MSGTYPE);
    		        if(LspCBVar->waitflag & 0xe0)
    		        {
    		        	LspCBVar->waitflag |= 0x1;
    		        }
    		        else
    		        {
    		        	ldp_del_lspCB((char *)pFecEntry,LspCBVar);  
    		        }			
    		        /* 保护多块时，防止建立不起来 */	
    		        if(!(LspCV->waitflag & 0x1))
    		        {
    		        	/* 2003.4.23 wengqing 增加保护，如果ldpcb的链表乱掉，将该链表加入到待删除链中 */
    		        	#if MPLS_PROTECT
    		        	if(LspCV->up_lsp_session_list.prev)
						{
							if((LspCV->up_lsp_session_list.prev)->up_lsp_session_list.next != LspCV)
							{
			//					LspCV->up_lsp_session_list.prev = MPLS_NULL;
								lspCb_t = LspCV;
								while(lspCb_t->up_lsp_session_list.next)
								{
									lspCb_t = lspCb_t->up_lsp_session_list.next;
								}
								lspcb_scan ++;
								/*MPLS_INSERT_INTO_UP_LSP_LIST(g_up_lsp_list,
											 LspCV, \
											 lspCb_t);*/
								MplsInsertIntoupGlobalList(g_up_lsp_list,LspCV->upSessionIndex,LspCV,lspCb_t);
								return LDP_FALSE;
							}
						}
						else if(LspCV->down_lsp_session_list.prev)
						{
							if((LspCV->down_lsp_session_list.prev)->down_lsp_session_list.next != LspCV)
							{
			//					LspCV->down_lsp_session_list.prev = MPLS_NULL;
								lspCb_t = LspCV;
								while(lspCb_t->down_lsp_session_list.next)
								{
									lspCb_t = lspCb_t->down_lsp_session_list.next;
								}
								lspcb_scan ++;
								/*MPLS_INSERT_INTO_DOWN_LSP_LIST(g_down_lsp_list,
											 LspCV, \
											 lspCb_t);*/
							    MplsInsertIntodownGlobalList(g_down_lsp_list,LspCV->downSessionIndex,LspCV,lspCb_t);
								return LDP_FALSE;
							}
						}
    		        	#endif
						LspCBFsm(MPLS_NULL,MPLS_ROUTE_DELETE,MPLS_NULL,LspCV->lspType, \
				         LspCV->selffec,LspCV);	
				    }	
    				return LDP_FALSE;
    			}
        	}
        	MPLS_WALK_LSP_END(fec,LspCV,t_lspCb)		    
		}

		
		if(LspCBVar->lspType == LDP_HOP_LSP && aggr_enable != 0 && \
		   LspCBVar->pAttr.len > 0)
		{
			if(pFecEntry->owner == MPLS_OWNER_POLICY ||
			  ((pFecEntry->owner &MPLS_OWNER_ROUTE)&&
			  (pFecEntry->pRes & MPLS_EGRESS_TO_POLICY)))
			{
			if(LspCBVar->downAtmLabel.module)
			        nexthop = LspCBVar->downAtmLabel.module;
		        else
		            nexthop = LspCBVar->downAtmLabel.port;
			}
			else
			{
				nexthop = 0xffffffff;
			}		  
			p_s_f = MPLS_NULL;
			for(p_s_f = aggr_body.first; p_s_f; p_s_f = p_s_f->next)
			{
				if( (p_s_f->upAtmLabel.module == LspCBVar->upAtmLabel.module) && \
				    (p_s_f->upAtmLabel.port   == LspCBVar->upAtmLabel.port) && \
				    (p_s_f->attr.hopcount     == LspCBVar->pAttr.hopcount)    && \
				    (p_s_f->attr.len          == LspCBVar->pAttr.len)         && \
				    (!MPLS_MEMCMP(p_s_f->attr.pAttr,LspCBVar->pAttr.pAttr,LspCBVar->pAttr.len))&& \
				    ( p_s_f->nexthop == nexthop))
				    break;
			}		
			if(p_s_f)
			{
				if(p_s_f->upAtmLabel.vpi == 0 && p_s_f->upAtmLabel.vci == 0)
				{
					LspCBVar->errorcode = EGRESS_CRPVCFAIL;
					SndNotMsg(LspCBVar->upSessionIndex,INTERNALERROR,LspCBVar->upMsgid,\
			        	    MPLS_LBLREQ_MSGTYPE);
			        printf("in ProcFecInquireOk,vpi,vci is 0, the first pvc not established !!!!! \n");
			        DEBUG_OUT(DEBUG_OWNER_MPLS, DEBUG_LEVEL_MPLS_LSP,"in ProcFecInquireOk,vpi,vci is 0, the first pvc not established !!!!! \n");
			        if(LspCBVar->waitflag & 0xe0)
			        {
			        	LspCBVar->waitflag |= 0x1;
			        }
			        else
			        {
			        	ldp_del_lspCB(pEntry,LspCBVar);  
			        }			
					return LDP_FALSE;
				}
				else
				{
					LspCBVar->upAtmLabel.vpi = p_s_f->upAtmLabel.vpi;
					LspCBVar->upAtmLabel.vci = p_s_f->upAtmLabel.vci;
					
					/* update down module and port */
					if(LspCBVar->downAtmLabel.module != p_s_f->downAtmLabel.module||
					       LspCBVar->downAtmLabel.port != p_s_f->downAtmLabel.port)
					{
						sb_list = MPLS_NULL;
		    	        MPLS_SB_SEARCH(LspCBVar->downAtmLabel.module,\
		    	                    LspCBVar->downAtmLabel.port,sb_list);
		        		if(!sb_list)
		        		{
		        			MPLS_REMOVE_FROM_SESSION_DOWN_LSP_LIST(g_down_lsp_list,LspCBVar);
		        		}
		        		else
		        		{
		        		    MPLS_REMOVE_FROM_SESSION_DOWN_LSP_LIST_A(sb_list->lsp_down_cb_list,LspCBVar);
		        		    if(!(sb_list->lsp_down_cb_list.first ||sb_list->lsp_up_cb_list.first))
		        		        MPLS_SB_DELETE(LspCBVar->downAtmLabel.module,\
		    	                    LspCBVar->downAtmLabel.port,sb_list)
		        		}
		        		/* refresh lspcb */
						LspCBVar->downAtmLabel.module = p_s_f->downAtmLabel.module;