newapitest.h

用c/c++实现的一个CMPP API

/*
* Copyright (c) 2001-2002 The Aspire Technologies Ltd.
* All rights reserved.
*
* THE CODE AND INFORMATION IS ONLY SUBJECT TO LOW-LEVEL DESIGN
* OF THE PRODUCT, DISTRIBUTION IN ANY FORMS OR MODIFICATION BY
* ANY MEANS WITHOUT PERMISSION FROM THE AUTHOR IS ABSOLUTELY
* FORBIDDEN.
*
* ================================================================*/
//
// newapitest.h
//
// Author: HOUZH
// Created on November 20, 2002
//
////////////////////////////////////////////////////////////////////

#ifndef _NEWAPITEST_H_
#define _NEWAPITEST_H_
#include "os.h"


#define  MaxConnectPairs  10
#define  ShowInterval    5
#define  MaxSendThreadNum 50
#define  MaxRecvThreadNum 50

#define  NO_PACK    0
#define  I_RECEIPT  1
#define  SENDFAIL    -3

#define  M_INITING  1
#define  M_INITED   2
#define  M_EXIT     3

typedef struct _recSubmit
{
    int  nNeedReply;
    int  nMsgLevel;
    int  nFeeUserType;
    char sFeeTermId[21+ 1];   
    int  TP_pid;
    int  TP_udhi;
    int  nMsgFormat;
    
    char sFeeType[2+1];
    char sFeeCode[6 +1];
    char sValidTime[17 +1];
    char sAtTime[17 +1 ];
    char sDestTermId[21 +1];

}RecSubmit;

typedef struct _recConnect
{
    int        nConnNo;
    
	int        CONNFD;
	int        nBufferSize;
	
	int        nConnectFlag;
	
	pthread_t  nSendThreadId[MaxSendThreadNum];        //发送线程ID
	pthread_t  nRecvThreadId[MaxRecvThreadNum];	     //接收线程ID
	int        nSendThreadNum ;
	int        nRecvThreadNum ;

    long        nSendSubmitNum;     //发送Submit包数
    
    char       sHostAddr[16 +1];
    int        nHostPort;
    char       Spid[6+1];
    char       sMsgSrc[6 + 1];
    char       SpPwd[20 +1];   
    char       sSrcTermId[21 +1];
    char       sServiceId[10 +1 ] ;
    int        nTimeOut;
    char       sContentFile[256];
    char       sConfigFile[256];
    
    int        nMsgLen;
    char       sMsgContent[1024];
    
	//统计
	long        nRecvDeliverNum[MaxSendThreadNum];          //接收MO数
	long        nRecvReceiptNum[MaxSendThreadNum];          //接收回执数	
	long        nSendSuccNum[MaxSendThreadNum];
	
       int        nSendFailNum[MaxSendThreadNum];
       int        nSendFailTimeOut[MaxSendThreadNum];
    
	time_t     timetSendBegin	;    //发送开始时间
	time_t     timetSendEnd;         //结束发包时间
	time_t     timetRecvBegin	;    //接收开始时间
	time_t     timetRecvEnd;         //接收结束时间

	
	
}RecConnect;
typedef struct  _recThreadPara
{
    int nConnNo;
    int nThreadNo;
    
}RecThreadPara;
typedef struct _recConfig
{
    int  nNrOfConnect;
    int  nShowPacket;
    int  nMaxTimeOut;    
    int  nHighLevel;    
   
}RecConfig;

#endif