dnnodeinit.cpp.bak

SMS gateway. SMS protocol for CHINA mobile, unicom, lingtong. Using mysql to exchange message.

/**********************************************************************
  FileName            : DnNodeInit.cpp
  Description         : 下节点初始化函数集
  Version             : 1.0
  Date                : 2003年9月15日
  Author              : 刘荣辉
  Other               : 
***********************************************************************/

#include "DnNode.h"

//CDnNode::CDnNode()
//CDnNode::~CDnNode()
//int CDnNode::NodeInit();	//初始化（队列等参数）
//int CDnNode::GetSequence()	//互斥地获得当前流水号,并加1

//====================构造函数=======================
CDnNode::CDnNode()
{  
}
//====================虚构函数=======================
CDnNode::~CDnNode()
{
  delete RecvQ;
  delete SendQ;
  delete RspQ;
  pthread_mutex_destroy(&SeqId_Lock);
}
//====================下节点初始化=======================
int CDnNode::NodeInit()
{
  ToExit = 0;	//节点退出标识
  SeqId = 1;	//流水号
  SendThr = 0;	//发送线程号

	  printf("\n NodeInit =========11========= \n");
  //------------------队列初始化----------------------
  RecvQ = new FIFO_RecvQ(RecvQ_Size);   //收、发队列初始化
  RspQ = new FIFO_RecvQ(SendQ_Size*2);
  SendQ = new FIFO_SendQ(SendQ_Size);
	  printf("\n NodeInit =========22========= \n");
  SentQ.Map_Init(SentW_Size);	//已发送队列初始化,滑动窗口
	  printf("\n NodeInit =========33========= \n");
  pthread_mutex_init(&SeqId_Lock,NULL);
	  printf("\n NodeInit =========44========= \n");
  return 0;
}
//===========================获得当前流水号=================================
int CDnNode::GetSequence()	//互斥地获得当前流水号,并加1
{
  int temp;
  pthread_mutex_lock(&SeqId_Lock);
  temp = SeqId++;
  pthread_mutex_unlock(&SeqId_Lock);
  return temp ;	
}