| /dports/science/dakota/dakota-6.13.0-release-public.src-UI/src/ |
| H A D | ProcessHandleApplicInterface.cpp | 334 analysis_id = start + i*step; in asynchronous_local_analyses()
338 driver_argument_list(analysis_id); in asynchronous_local_analyses()
340 analysisProcessIdMap[pid] = analysis_id; in asynchronous_local_analyses()
358 analysis_id = start + send_cntr*step; in asynchronous_local_analyses()
362 driver_argument_list(analysis_id); in asynchronous_local_analyses()
386 pid_t pid, proc_gp; int analysis_id; in serve_analyses_asynch() local
408 while (mpi_test_flag && analysis_id && in serve_analyses_asynch()
416 analysis_id = status.MPI_TAG; in serve_analyses_asynch()
418 if (analysis_id) { in serve_analyses_asynch()
420 driver_argument_list(analysis_id); in serve_analyses_asynch()
[all …]
|
| H A D | ProcessHandleApplicInterface.hpp | 50 int synchronous_local_analysis(int analysis_id);
72 virtual size_t test_local_analyses_send(int analysis_id) = 0;
112 void driver_argument_list(int analysis_id);
161 synchronous_local_analysis(int analysis_id) in synchronous_local_analysis() argument
164 Cout << "Blocking fork to analysis " << analysis_id << std::endl; // flush buf in synchronous_local_analysis()
166 driver_argument_list(analysis_id); in synchronous_local_analysis()
215 inline void ProcessHandleApplicInterface::driver_argument_list(int analysis_id) in driver_argument_list() argument
217 std::string tag_str = "." + std::to_string(analysis_id); in driver_argument_list()
218 argList[0] = programNames[analysis_id-1]; in driver_argument_list()
|
| H A D | SysCallApplicInterface.hpp | 50 int synchronous_local_analysis(int analysis_id);
78 void spawn_analysis_to_shell(int analysis_id, bool block_flag);
115 inline int SysCallApplicInterface::synchronous_local_analysis(int analysis_id) in synchronous_local_analysis() argument
117 spawn_analysis_to_shell(analysis_id, BLOCK); in synchronous_local_analysis()
|
| H A D | ProcessApplicInterface.hpp | 270 for (int analysis_id=start; analysis_id<=end; analysis_id+=step) in synchronous_local_analyses() local
271 synchronous_local_analysis(analysis_id); in synchronous_local_analyses()
|
| H A D | ForkApplicInterface.cpp | 90 size_t ForkApplicInterface::test_local_analyses_send(int analysis_id) in test_local_analyses_send() argument
102 analysis_id = an_it->second; in test_local_analyses_send()
104 Cout << "Analysis " << analysis_id << " has completed" << std::endl; in test_local_analyses_send()
109 parallelLib.send_ea(rtn_code, 0, analysis_id); in test_local_analyses_send()
|
| H A D | GridApplicInterface.hpp | 81 int synchronous_local_analysis(int analysis_id) in synchronous_local_analysis() argument
86 spawn_analysis_to_shell(analysis_id, BLOCK); in synchronous_local_analysis()
|
| H A D | SpawnApplicInterface.cpp | 222 size_t SpawnApplicInterface::test_local_analyses_send(int analysis_id) in test_local_analyses_send() argument
241 analysis_id = an_it->second; in test_local_analyses_send()
243 Cout << "Analysis " << analysis_id << " has completed" << std::endl; in test_local_analyses_send()
248 parallelLib.send_ea(rtn_code, 0, analysis_id); in test_local_analyses_send()
|
| H A D | DirectApplicInterface.hpp | 98 int synchronous_local_analysis(int analysis_id);
229 inline int DirectApplicInterface::synchronous_local_analysis(int analysis_id) in synchronous_local_analysis() argument
231 analysisDriverIndex = analysis_id-1; in synchronous_local_analysis()
|
| H A D | ApplicationInterface.cpp | 2558 int i, server_id, analysis_id; in master_dynamic_schedule_analyses() local
2561 analysis_id = i+1; in master_dynamic_schedule_analyses()
2569 parallelLib.isend_ea(analysis_id, server_id, analysis_id, send_request); in master_dynamic_schedule_analyses()
2595 analysis_id = send_cntr+1; in master_dynamic_schedule_analyses()
2603 parallelLib.isend_ea(analysis_id, server_id, analysis_id, in master_dynamic_schedule_analyses()
2625 analysis_id = 0; // termination flag for servers in master_dynamic_schedule_analyses()
2627 parallelLib.isend_ea(analysis_id, i+1, 0, send_request); in master_dynamic_schedule_analyses()
2641 int analysis_id = 1; in serve_analyses_synch() local
2644 while (analysis_id) { in serve_analyses_synch()
2655 parallelLib.bcast_a(analysis_id); in serve_analyses_synch()
[all …]
|
| H A D | SysCallApplicInterface.cpp | 330 spawn_analysis_to_shell(int analysis_id, bool block_flag) in spawn_analysis_to_shell() argument
336 "." + std::to_string(analysis_id) : "" ); in spawn_analysis_to_shell()
343 shell << substitute_params_and_results(programNames[analysis_id-1], params_file, in spawn_analysis_to_shell()
|
| H A D | SpawnApplicInterface.hpp | 54 size_t test_local_analyses_send(int analysis_id);
|
| H A D | ForkApplicInterface.hpp | 57 size_t test_local_analyses_send(int analysis_id);
|
| H A D | ApplicationInterface.hpp | 201 virtual int synchronous_local_analysis(int analysis_id);
639 synchronous_local_analysis(int analysis_id) in synchronous_local_analysis() argument
|
| /dports/biology/py-ont-fast5-api/ont_fast5_api-release_4.0.0/ont_fast5_api/analysis_tools/ |
| H A D | base_tool.py | 14 def analysis_id(self): member in BaseTool
60 self.handle.add_analysis(self.analysis_id, group_name, meta, config)
62 if 'component' in attrs and attrs['component'] != self.analysis_id:
63 … raise ValueError('Component {} is not {}'.format(attrs.get('component'), self.analysis_id))
|
| H A D | basecall_2d.py | 12 analysis_id = 'basecall_2d' variable in Basecall2DTools
|
| H A D | basecall_1d.py | 12 analysis_id = 'basecall_1d' variable in Basecall1DTools
|
| H A D | event_detection.py | 13 analysis_id = 'event_detection' variable in EventDetectionTools
|
| H A D | segmentation.py | 13 analysis_id = 'segmentation' variable in SegmentationTools
|