$extrastylesheet
Dakota
Version 6.2
|
Derived application interface class which spawns simulation codes using grid services such as Condor or Globus. More...
Public Member Functions | |
GridApplicInterface (const ProblemDescDB &problem_db) | |
constructor | |
~GridApplicInterface () | |
destructor | |
void | derived_map (const Variables &vars, const ActiveSet &set, Response &response, int fn_eval_id) |
Called by map() and other functions to execute the simulation in synchronous mode. The portion of performing an evaluation that is specific to a derived class. | |
void | derived_map_asynch (const ParamResponsePair &pair) |
Called by map() and other functions to execute the simulation in asynchronous mode. The portion of performing an asynchronous evaluation that is specific to a derived class. | |
void | wait_local_evaluations (PRPQueue &prp_queue) |
void | test_local_evaluations (PRPQueue &prp_queue) |
Convenience function for common code between wait and nowait case. | |
int | synchronous_local_analysis (int analysis_id) |
Protected Member Functions | |
bool | grid_file_test (const String &root_file) |
test file(s) for existence based on root_file name | |
Protected Attributes | |
IntSet | idSet |
Set of function evaluation id's for active asynchronous system call evaluations. | |
IntShortMap | failCountMap |
map linking function evaluation id's to number of response read failures | |
start_grid_computing_t | start_grid_computing |
handle to dynamically linked start_grid_computing function | |
perform_analysis_t | perform_analysis |
handle to dynamically linked perform_analysis grid function | |
get_jobs_completed_t | get_jobs_completed |
handle to dynamically linked get_jobs_completed grid function | |
stop_grid_computing_t | stop_grid_computing |
handle to dynamically linked stop_grid_computing function |
Derived application interface class which spawns simulation codes using grid services such as Condor or Globus.
This class is currently a modified copy of SysCallApplicInterface adapted for use with an external grid dervices library which was dynamically linked using dlopen() services.
void wait_local_evaluations | ( | PRPQueue & | prp_queue | ) | [inline, virtual] |
Check for completion of active asynch jobs (tracked with sysCallSet). Wait for at least one completion and complete all jobs that have returned. This satisifies a "fairness" principle, in the sense that a completed job will _always_ be processed (whereas accepting only a single completion could always accept the same completion - the case of very inexpensive fn. evals. - and starve some servers).
Reimplemented from SysCallApplicInterface.
References ApplicationInterface::completionSet, and GridApplicInterface::test_local_evaluations().
Referenced by GridApplicInterface::derived_map().
int synchronous_local_analysis | ( | int | analysis_id | ) | [inline, virtual] |
This code provides the derived function used by ApplicationInterface::serve_analyses_synch().
TODO - allow local analyses?????
Reimplemented from SysCallApplicInterface.
References SysCallApplicInterface::spawn_analysis_to_shell().