transacmng.h

内容正如其名

/******************************************************************************
  Copyright(C) 2005,2006 Frank ZHANG

  All Rights Reserved.
    
  This program is free software; you can redistribute it and/or modify it
  under the terms of the GNU General Public License as published by the Free
  Software Foundation; either version 2 of the License, or (at your option)
  any later version.

  This program is distributed in the hope that it will be useful, but WITHOUT
  ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 
  FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for 
  more details.
    
  You should have received a copy of the GNU General Public License along with
  this program; if not, write to the Free Software Foundation, Inc., 59 Temple
  Place, Suite 330, Boston, MA 02111-1307 USA.
 
 ******************************************************************************
 
  If you want to distribute this software with modifications under any terms
  other than the GPL or distribute the software linked with proprietary
  applications that are not distributed in full compliance with the GNU Public
  License, a Commercial License is needed.
  
  Commercial licensing and support of this software are available at a fee. For
  more information, See http://www.openmgcp.org
 
 ******************************************************************************/

/******************************************************************************
*      Authors                   :  Frank ZHANG
*      Description               :  Transaction Manger module
*
*
*      Date of creation          :  08/20/2005
*
*
*      History                   :
*      2005/08/20 Frank ZHANG    : - Creation
******************************************************************************/
#ifndef __TRANSACMNG_H__
#define __TRANSACMNG_H__

#include "abnf.h"

#ifdef __cplusplus
extern "C" {
#endif

#define TICK_TIMER_VALUE 100  /* 100 ms */

/* Timer and counter default value for retransmission */
#define DEF_COUNTERMAX1   5      /* Threshold of current address is unreachable */
#define DEF_COUNTERMAX2   7      /* Threshold of all CA are unavailable */
#define DEF_TIMERMAXRTO   4000   /* Max value of RTO */
#define DEF_TIMERINITRTO  200    /* Initial value of RTO */
#define DEF_TIMERMAX      20000  /* Retransmission cease threshold */
#define DEF_TIMERHIST     30000  /* The duration response retained after send, and
                                    also used to determine disconnected threshold */
#define DEF_TIMERLONGTR   5000   /* RTO value if provision response received */

#define DEF_LOW_WATERMARK 50     /* Low mark bellow which send 100 response */      
#define DEF_HIG_WATERMARK 60     /* Low mark bellow which send 101 response */


/* RTO info */
#define RTO_MAX            4000       /* Max RTO value, 4s */
#define RTO_DEFAULT        200        /* Default RTO value, 200ms */

/* Abnf encode buffer size, that is to say the max MGCP datagram size, according
 * to RFC3435, at least 4000 bytes is mandatory to be supported*/
#define ABNF_ENCODE_BUF_LEN 5000

int FindMgcpCmdOutByTranID(void *pTranCmdOut, void *pTransacID);
int FindMgcpRspAckOutByTranID(void *pRspAckOut, void *pTransacID);
int FindMgcpCmdInByTranID(void *pCmdIn, void *pTransacID);
int FindMgcpRspOutByTranID(void *pRspOut, void *pTransacID);
int FindMgcpRspOutWaitAckByTranID(void *pRspOut, void *pTransacID);
int FindMgcpRspACKByTranID(void *pRspAck, void *pTransacID);
int FindMgcpCmdOutByCmdID(void *pCmdOut, void *pCommandID);
void BuildPiggybackedCommands(H_MGCP_TRANSAC_MANAGER pTransacMng, TMGCPMsgList *pAbnfMsgList,
                              MGCP_MSG_LIST *pMsgList, WORD wNum, DWORD *pCmdID);
void FillAbnfMgcpCmdOut(H_MGCP_TRANSAC_MANAGER pTransacMng, TMGCPMsgList *pAbnfMsgList,
                        TRANSAC_CMD_OUT *pTranMgcpCmdOut);
void FillAbnfMgcpRspOut(H_MGCP_TRANSAC_MANAGER pTransacMng, TMGCPMsgList *pAbnfMsgList,
                        MGCP_RSP_OUT *pMgcpRspOut, BOOL bNeedAck);
void SendMgcpCmdOut(H_MGCP_TRANSAC_MANAGER pTransacMng, TRANSAC_CMD_OUT *pTranMgcpCmdOut);
void SendMgcpRspAckOut(H_MGCP_TRANSAC_MANAGER pTransacMng, DWORD dwTranID);
void SendMgcpRspOut(H_MGCP_TRANSAC_MANAGER pTransacMng, MGCP_RSP_OUT *pMgcpRspOut , BOOL bNeedAck);
void RemovePiggyBackingCmdID(DWORD dwCommandID, MGCP_MSG_LIST *pMsgList);
void SendProvisonalResponse(DWORD dwTransactionId, DWORD dwRspCode, int iSocket_fd,
                            DWORD dwDesAddress, WORD wDesPort);
void ProcessTransacIncomingMgcpCmd(H_MGCP_TRANSAC_MANAGER pTransacMng, MGCP_INCOMING_COMMAND *pMgcpCmd);
void ProcessTransacIncomingMgcpRsp(H_MGCP_TRANSAC_MANAGER pTransacMng, MGCP_INCOMING_RESPONSE *pMgcpRsp);
void ProcessOutGoingMgcpCmd(H_MGCP_TRANSAC_MANAGER pTransacMng, MGCP_CMD_OUT *pCmdOut);
void ProcessOutGoingMgcpRsp(H_MGCP_TRANSAC_MANAGER pTransacMng, MGCP_RSP_OUT *pRspOut);
void ProcessUpdataNotifiedEntityMsg(H_MGCP_TRANSAC_MANAGER pTransacMng, MSG_DATA_UPDATE_NE *pMsgData);
void ProcessResponseOutTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng, SLIST *pRspOutList);
void ProcessResponseWaitAckTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng, SLIST *pRspWaitingAckList);
void ProcessAckedResponseTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng);
void ProcessResponsetAckTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng);
BOOL CheckDNSToGetMoreCA(NOTIFIED_ENTITY *pNotifiedEntity);
void ProcessCommandOutTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng);
void ProcessPiggyBackCommandOutTimeOut(H_MGCP_TRANSAC_MANAGER pTransacMng);
void ProcessTimeOutMsg(H_MGCP_TRANSAC_MANAGER pTransacMng);
void* RxTask(void *pTransacMng);
void* TxTask(void *pTransacMng);
LONG TransationManagerCreate(H_MGCP_TRANSAC_MANAGER *ppTranMng, H_MGCP_STACK pStack);
void TransacMngTimeOutCbk(void *pArg);
LONG TransationManagerStart(H_MGCP_TRANSAC_MANAGER pTranMng);
void TransationManagerDestroy(H_MGCP_TRANSAC_MANAGER pTranMng);
LONG SendMsgToTransationManager(H_MGCP_TRANSAC_MANAGER pTranMng, MGCP_STACK_MSG *pMSG);


#ifdef __cplusplus
}
#endif

#endif