// TemplateFederate.cpp: implementation of the TemplateFederate class.
//
//////////////////////////////////////////////////////////////////////
#include "stdafx.h"
#include "handles.h"
#include "TemplateFederate.h"
#include "ship.h"
#include "detonation.h"
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
TemplateFederate::TemplateFederate()
{
m_lookahead=1.0;
m_timeStep=1.0;
pShipHandels_struct = (struct struct_ship_objectClass_handles *)
malloc(sizeof(struct struct_ship_objectClass_handles));
pDetonationHandles_struct = (struct struct_Detonation_interactionClass_handles *)
malloc(sizeof(struct struct_Detonation_interactionClass_handles));
}
TemplateFederate::~TemplateFederate()
{
free(pShipHandels_struct);
free(pDetonationHandles_struct);
}
void TemplateFederate::run(int argc, char **args)
{
//创建并加入联邦
CreateAndJoin();
//时间设置，时间受限和时间调节
//先设置时间受限，再设置时间调节
setTimeConstrained(true);
setTimeRegulation(true);
// setTimeConstrained(true);
//对象类与交互类的发布与定购
PublishAndSubscribe();
//登记对象
RegisterObject();
CShip *cship = new CShip();//创建ship类型实例
IDetonation *idetonation = new IDetonation();//创建交互类实例
cout << endl;
cout << "//**********************************************************************//" << endl;
cout << "//****************************进入仿真主循环******************************//" << endl;
cout << "//**********************************************************************//";
cout << endl << "按任意键进入仿真主循环... ..." << endl << endl;
getchar();
//这里只循环120次
//用户可根据实际需要确定退出仿真的条件
int i=0;
while(i<120)
{
i++;
cout << "当前仿真时间为" << "m_currTime = " ;
char ctmp[20];
m_currTime.getPrintableString(ctmp);
cout << ctmp << endl;
cout << "1、对登记的对象实例进行外部更新;" << endl;
updateAttributeValues(cship);
cout << "2、发送交互;" << endl;
sendInteraction(idetonation);
cout << "3、重新计算ship实例和交互实例的内部状态" << endl;
cship->Compute();
idetonation->Compute();
cout << "4、申请时间推进，申请时间为: " ;
m_bIsTimeGranted=false;
requestTimeAdvance(m_currTime+m_timeStep);
cout << "5、等待时间推进授予，接收RTI回调函数 " << endl;
while(!m_bIsTimeGranted){
//休眠等待时间推进申请被授予
Sleep(500);
}
//这里的Sleep()是为里便于在显示器上观察输出结果
Sleep(1000);
cout << endl;
cout << endl;
cout << "... ... ... ... ... 新循环开始 ... ... ... ... ..." << endl;
}
cout << "6、退出联邦、销毁联邦" << endl << endl;
resignAndDestroy("HLATemplate");
}
void TemplateFederate::CreateAndJoin()
{
//创建联邦，第一个参数为创建的联邦名，第二个为相应的fed文件名
//如果联邦已经存在，_rtiAmbassador获取存在的联邦大使句柄
try{
_rtiAmbassador.createFederationExecution("HLATemplate", "SeaWar1.fed");
} catch (RTI::FederationExecutionAlreadyExists) {
cerr << "FED_HW: 联邦执行已经存在" << endl;
} catch (RTI::CouldNotOpenFED){
cerr << "FED_HW:不能打开fed文件";
return ;
}catch (RTI::ErrorReadingFED){
cerr << "FED_HW:无法读取fed文件";
return ;
}catch (RTI::ConcurrentAccessAttempted){
cerr << "FED_HW:Concurrent access attempted";
return ;
}
cout << "第一步：联邦创建成功" << endl;
//加入联邦,第一个参数为联邦成员类型，第二个参数为上一步创建的联邦名
//由于可能在上一步的创建工作还没完成时就申请加入联邦，所以需要反复试图加入
//试50次
int tries=0;
bool m_joined=false;;
while((!m_joined)&&(tries<50)){
tries++;
try{
_federateHandle=_rtiAmbassador.joinFederationExecution("Ship", "HLATemplate", this);//加入联邦
} catch (RTI::FederateAlreadyExecutionMember){
m_joined=true;
} catch (RTI::FederationExecutionDoesNotExist){
if(tries==50){
cout << "Can not join federation, program closed" << endl;
return;
}else{
Sleep(5);
}
cout << "FederationExecutionDoesNotExist" << endl;
} catch (RTI::SaveInProgress){
cerr << "SaveInProgress" << endl;
} catch (RTI::RestoreInProgress){
cerr << "RestoreInProgress" << endl;
} catch (RTI::RTIinternalError){
cerr << "RTIinternalError" << endl;
} catch (RTI::ConcurrentAccessAttempted){
cerr << "ConcurrentAccessAttempted" << endl;
}
}
cout << "第二步，加入联邦，" ;
cout << "联邦成员句柄为： " << _federateHandle << endl;
}
void TemplateFederate::setTimeConstrained(bool m_bConstrained)
{
try{
//如果m_bConstrained为真，设置时间受限，否则取消时间受限
if( m_bConstrained )
{
cout << endl << "第三步，设置时间受限." << endl;
_rtiAmbassador.enableTimeConstrained();
}
else
{
//取消时间受限
_rtiAmbassador.disableTimeConstrained();
}
}catch(RTI::TimeRegulationAlreadyEnabled){
cout << "TimeRegulationAlreadyEnabled " << endl;
}catch(RTI::RestoreInProgress){
cout << "RestoreInProgress " << endl;
}catch(RTI::SaveInProgress){
cout << " SaveInProgress" << endl;
}catch(RTI::EnableTimeRegulationPending){
cout << "EnableTimeRegulationPending " << endl;
}catch(RTI::FederateNotExecutionMember){
cout << "FederateNotExecutionMember " << endl;
}catch(RTI::ConcurrentAccessAttempted){
cout << "ConcurrentAccessAttempted " << endl;
}catch(RTI::InvalidLookahead){
cout << " InvalidLookahead" << endl;
}catch(RTI::InvalidFederationTime){
cout << " InvalidFederationTime" << endl;
}catch(RTI::TimeAdvanceAlreadyInProgress){
cout << " TimeAdvanceAlreadyInProgress" << endl;
}catch(RTI::RTIinternalError){
cout << "RTIinternalError " << endl;
}
}
void TemplateFederate::setTimeRegulation(bool m_bRegulation)
{
try{
//查询联邦成员的当前时间，用变量m_currTime存储，用于设置时间调节
// _rtiAmbassador.queryLBTS(m_currTime);
_rtiAmbassador.queryFederateTime(m_currTime);
if ( m_currTime.isPositiveInfinity() )
{
m_currTime = 0.0;
}
else
{
// m_currTime -= m_lookahead;
}
char tmp[20];
m_currTime.getPrintableString(tmp);
cout << tmp << endl << endl;
//如果m_bRegulation为真，设置时间调节，否则取消时间调节
if( m_bRegulation )
{
cout <<"第四步，设置时间调节,当前仿真时间为：";
_rtiAmbassador.enableTimeRegulation( m_currTime, m_lookahead );
Sleep(5);
_rtiAmbassador.queryFederateTime(m_currTime);
}
else
{
_rtiAmbassador.disableTimeRegulation();
}
// char tmp[20];
m_currTime.getPrintableString(tmp);
cout << tmp << endl << endl;
}catch(RTI::TimeRegulationAlreadyEnabled){
cout << "TimeRegulationAlreadyEnabled " << endl;
}catch(RTI::RestoreInProgress){
cout << "RestoreInProgress " << endl;
}catch(RTI::SaveInProgress){
cout << " SaveInProgress" << endl;
}catch(RTI::EnableTimeRegulationPending){
cout << "EnableTimeRegulationPending " << endl;
}catch(RTI::FederateNotExecutionMember){
cout << "FederateNotExecutionMember " << endl;
}catch(RTI::ConcurrentAccessAttempted){
cout << "ConcurrentAccessAttempted " << endl;
}catch(RTI::InvalidLookahead){
cout << " InvalidLookahead" << endl;
}catch(RTI::InvalidFederationTime){
cout << " InvalidFederationTime" << endl;
}catch(RTI::TimeAdvanceAlreadyInProgress){
cout << " TimeAdvanceAlreadyInProgress" << endl;
}catch(RTI::RTIinternalError){
cout << "RTIinternalError " << endl;
}
}
void TemplateFederate::PublishAndSubscribe()
{
cout << endl << "第五步，发布和定购对象类和交互类" << endl;
/////////////////////////////////////////////////////////////////////////////////////
/////////////////////////////////////////对象类//////////////////////////////////////
/////////////////////////////////////////////////////////////////////////////////////
//1、获取要定购或发布的对象
HLA通用模板程序.rar （42个子文件） 
HLA通用模板程序 
StdAfx.h 881B BaseFederateAmbassador.h 12KB template_project.ncb 73KB handles.h 858B Platform.h 4KB template_project.dsp 5KB Detonation.cpp 730B template_project.opt 57KB BaseFederateAmbassador.cpp 12KB templateFederate.h 4KB Debug vc60.pdb 268KB CPlatform.sbr 0B template_project.bsc 1.33MB templateFederate.obj 111KB BaseFederateAmbassador.sbr 0B template_project.obj 4KB vc60.idb 177KB templateFederate.sbr 0B Detonation.sbr 0B StdAfx.sbr 519KB template_project.sbr 0B template_project.ilk 358KB template_project.pch 3.01MB CShip.sbr 0B template_project.pdb 657KB
template_project.exe 248KB StdAfx.obj 58KB BaseFederateAmbassador.obj 31KB Detonation.obj 6KB CPlatform.obj 11KB CShip.obj 6KB Datatypes.h 2KB template_project.cpp 371B CShip.cpp 602B Ship.h 2KB template_project.plg 266B SeaWar1.fed 10KB templateFederate.cpp 24KB StdAfx.cpp 303B template_project.dsw 557B CPlatform.cpp 1KB Detonation.h 2KB资源评论
sunnnny9242020-03-27#include <RTI.hh>找不到是怎么回事呀，编译报错
cloudy8806302019-06-18好好好好好好
