108 lines
3.8 KiB
Plaintext
108 lines
3.8 KiB
Plaintext
|
# ****************************************************************************
|
||
|
|
# CUI
|
||
|
|
#
|
||
|
|
# The Advanced Framework for Simulation, Integration, and Modeling (AFSIM)
|
||
|
|
#
|
||
|
|
# The use, dissemination or disclosure of data in this file is subject to
|
||
|
|
# limitation or restriction. See accompanying README and LICENSE for details.
|
||
|
|
# ****************************************************************************
|
||
|
|
|
||
|
|
|
||
|
|
#creates "jam-target" jobs from threats in tracklist
|
||
|
|
#does not perform any jobs
|
||
|
|
#dost not bid on any jobs
|
||
|
|
|
||
|
|
processor AIJC-thinker WSF_RIPR_PROCESSOR
|
||
|
|
|
||
|
|
update_interval 5.0 seconds
|
||
|
|
#script_debug_writes on
|
||
|
|
|
||
|
|
script_variables
|
||
|
|
Map<string, int> mTargetNameJobIdMap = Map<string, int>();
|
||
|
|
Map<int, string> mJobIdTargetNameMap = Map<int, string>();
|
||
|
|
int mMaxJobWinners = 1;
|
||
|
|
end_script_variables
|
||
|
|
|
||
|
|
|
||
|
|
on_initialize
|
||
|
|
//SetJobAllocationMode(2);
|
||
|
|
end_on_initialize
|
||
|
|
|
||
|
|
##deprecated
|
||
|
|
#query_bid
|
||
|
|
# return -MATH.DOUBLE_MAX();
|
||
|
|
#end_query_bid
|
||
|
|
|
||
|
|
|
||
|
|
on_update
|
||
|
|
Map<string, int> updatedJobs = Map<string, int>();
|
||
|
|
//simply create jam jobs for each threat we know about
|
||
|
|
//this agent considers itself the highest level commander for any of it's subordinates
|
||
|
|
WsfLocalTrackList localTracks = PLATFORM.MasterTrackList();
|
||
|
|
|
||
|
|
string comment = "Num Tracks: " + (string)localTracks.Count();
|
||
|
|
//PLATFORM.Comment(comment);
|
||
|
|
|
||
|
|
foreach (WsfTrack track in localTracks)
|
||
|
|
{
|
||
|
|
if (mTargetNameJobIdMap.Exists(track.TargetName()))
|
||
|
|
{
|
||
|
|
//update existing job
|
||
|
|
double currentPriority = 1.0;
|
||
|
|
int jobId = mTargetNameJobIdMap.Get(track.TargetName());
|
||
|
|
WsfRIPRJob job = GetJobById(jobId);
|
||
|
|
job.Priority( currentPriority );
|
||
|
|
//job.SetData("TrackId", track.TrackId() ); //redundant, this shouldn't change anything
|
||
|
|
job.SetData("targetTrackName", track.TargetName()); //redundant, this shouldn't change anything
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
//create new job
|
||
|
|
double initialPriority = 1.0;
|
||
|
|
WsfRIPRJob temp;
|
||
|
|
temp = temp.Create( PROCESSOR,
|
||
|
|
"jam-target",
|
||
|
|
"jam-target-" + track.TargetName(),
|
||
|
|
initialPriority,
|
||
|
|
mMaxJobWinners );
|
||
|
|
//temp.SetData("TrackId", track.TrackId() );
|
||
|
|
temp.SetData("targetTrackName", track.TargetName());
|
||
|
|
|
||
|
|
AddJob(temp);
|
||
|
|
mTargetNameJobIdMap.Set(track.TargetName(), temp.GetId());
|
||
|
|
mJobIdTargetNameMap.Set(temp.GetId(), track.TargetName());
|
||
|
|
writeln_d("~~~ ", PLATFORM.Name(), " job change, ADD: ", temp.Name() );
|
||
|
|
|
||
|
|
comment = "create job: " + temp.GetDescription();
|
||
|
|
PLATFORM.Comment(comment);
|
||
|
|
}
|
||
|
|
//either way the job was updated or created, record that fact
|
||
|
|
updatedJobs.Set( track.TargetName(), 1 );
|
||
|
|
}
|
||
|
|
|
||
|
|
//now make sure the right jobs are removed
|
||
|
|
//the targets for previous jobs might not exist anymore
|
||
|
|
//remove any jobs that are for non-existent tracks
|
||
|
|
Array<WsfRIPRJob> jobs = GetJobs();
|
||
|
|
foreach (WsfRIPRJob x in jobs)
|
||
|
|
{
|
||
|
|
string name = (string)x.GetData("targetTrackName");
|
||
|
|
if (updatedJobs[name] != 1)
|
||
|
|
{
|
||
|
|
int jid = x.GetId();
|
||
|
|
writeln_d("--- ", PLATFORM.Name(), " job change, REMOVE: ", x.GetDescription());
|
||
|
|
|
||
|
|
comment = "delete job: " + x.GetDescription();
|
||
|
|
PLATFORM.Comment(comment);
|
||
|
|
|
||
|
|
string tName = mJobIdTargetNameMap[jid]; //this should match the job's data: "targetTrackName"
|
||
|
|
mTargetNameJobIdMap.Erase(name);
|
||
|
|
mJobIdTargetNameMap.Erase(jid);
|
||
|
|
RemoveJob(x);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
end_on_update
|
||
|
|
|
||
|
|
|
||
|
|
end_processor
|