source: src/cleanUp.cpp@ 415ddd

Action_Thermostats Add_AtomRandomPerturbation Add_FitFragmentPartialChargesAction Add_RotateAroundBondAction Add_SelectAtomByNameAction Added_ParseSaveFragmentResults AddingActions_SaveParseParticleParameters Adding_Graph_to_ChangeBondActions Adding_MD_integration_tests Adding_ParticleName_to_Atom Adding_StructOpt_integration_tests AtomFragments Automaking_mpqc_open AutomationFragmentation_failures Candidate_v1.5.4 Candidate_v1.6.0 Candidate_v1.6.1 ChangeBugEmailaddress ChangingTestPorts ChemicalSpaceEvaluator CombiningParticlePotentialParsing Combining_Subpackages Debian_Package_split Debian_package_split_molecuildergui_only Disabling_MemDebug Docu_Python_wait EmpiricalPotential_contain_HomologyGraph EmpiricalPotential_contain_HomologyGraph_documentation Enable_parallel_make_install Enhance_userguide Enhanced_StructuralOptimization Enhanced_StructuralOptimization_continued Example_ManyWaysToTranslateAtom Exclude_Hydrogens_annealWithBondGraph FitPartialCharges_GlobalError Fix_BoundInBox_CenterInBox_MoleculeActions Fix_ChargeSampling_PBC Fix_ChronosMutex Fix_FitPartialCharges Fix_FitPotential_needs_atomicnumbers Fix_ForceAnnealing Fix_IndependentFragmentGrids Fix_ParseParticles Fix_ParseParticles_split_forward_backward_Actions Fix_PopActions Fix_QtFragmentList_sorted_selection Fix_Restrictedkeyset_FragmentMolecule Fix_StatusMsg Fix_StepWorldTime_single_argument Fix_Verbose_Codepatterns Fix_fitting_potentials Fixes ForceAnnealing_goodresults ForceAnnealing_oldresults ForceAnnealing_tocheck ForceAnnealing_with_BondGraph ForceAnnealing_with_BondGraph_continued ForceAnnealing_with_BondGraph_continued_betteresults ForceAnnealing_with_BondGraph_contraction-expansion FragmentAction_writes_AtomFragments FragmentMolecule_checks_bonddegrees GeometryObjects Gui_Fixes Gui_displays_atomic_force_velocity ImplicitCharges IndependentFragmentGrids IndependentFragmentGrids_IndividualZeroInstances IndependentFragmentGrids_IntegrationTest IndependentFragmentGrids_Sole_NN_Calculation JobMarket_RobustOnKillsSegFaults JobMarket_StableWorkerPool JobMarket_unresolvable_hostname_fix MoreRobust_FragmentAutomation ODR_violation_mpqc_open PartialCharges_OrthogonalSummation PdbParser_setsAtomName PythonUI_with_named_parameters QtGui_reactivate_TimeChanged_changes Recreated_GuiChecks Rewrite_FitPartialCharges RotateToPrincipalAxisSystem_UndoRedo SaturateAtoms_findBestMatching SaturateAtoms_singleDegree StoppableMakroAction Subpackage_CodePatterns Subpackage_JobMarket Subpackage_LinearAlgebra Subpackage_levmar Subpackage_mpqc_open Subpackage_vmg Switchable_LogView ThirdParty_MPQC_rebuilt_buildsystem TrajectoryDependenant_MaxOrder TremoloParser_IncreasedPrecision TremoloParser_MultipleTimesteps TremoloParser_setsAtomName Ubuntu_1604_changes stable
Last change on this file since 415ddd was 415ddd, checked in by Frederik Heber <heber@…>, 11 years ago

ActionQueue now contains a run thread.

  • otherwise the progress bar of the QtMainWindow cannot be seen as waitForResults() takes up all of the executing thread.
  • added mutex for operations modifying the queue.
  • added ActionQueue::run() and ::stop(), used by friend stopQueue().
  • insertAction() now makes use of a tempqueue that is added to true queue during run() instead of calling the actions directly.
  • new stopQueue() in cleanUp.hpp is used by module_exit in pyMoleCuilder and in main() before saveAll().
  • cleanup: printTiming() requires now list of action tokens and added new stopAndPurgeQueue() to place waiting for Actions to end into extra function.
  • added ActionQueue::wait() which allows for synchronization in python scripts, is ignored in session python scripts. Otherwise we wait for ActionQueue's queue to empty during execution of load-session which hangs.
  • DOCU: added note to python documentation.
  • added waitQueue() also to purgeStaticInstances().
  • static UIFactory::isFactoryPresent() added that allows checking whether we have a UI or are executed within a python script (i.e. pyMoleCuilder).
  • DOCU: Extended docu on threads and who this affects python scripts.
  • TESTFIX: changed regression tests on storing python sessions.
  • Property mode set to 100644
File size: 7.2 KB
Line 
1/*
2 * Project: MoleCuilder
3 * Description: creates and alters molecular systems
4 * Copyright (C) 2010-2012 University of Bonn. All rights reserved.
5 * Copyright (C) 2013 Frederik Heber. All rights reserved.
6 *
7 *
8 * This file is part of MoleCuilder.
9 *
10 * MoleCuilder is free software: you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation, either version 2 of the License, or
13 * (at your option) any later version.
14 *
15 * MoleCuilder is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with MoleCuilder. If not, see <http://www.gnu.org/licenses/>.
22 */
23
24/*
25 * cleanUp.cpp
26 *
27 * Created on: Oct 28, 2011
28 * Author: heber
29 */
30
31// include config.h
32#ifdef HAVE_CONFIG_H
33#include <config.h>
34#endif
35
36#include <iostream>
37#include <iomanip>
38
39#include "CodePatterns/MemDebug.hpp"
40
41#include "cleanUp.hpp"
42
43#include "Atom/AtomObserver.hpp"
44
45#include "CodePatterns/Chronos.hpp"
46#include "CodePatterns/errorlogger.hpp"
47#include "CodePatterns/logger.hpp"
48#include "CodePatterns/Observer/ObserverLog.hpp"
49
50#include "Actions/ActionQueue.hpp"
51#include "Actions/OptionRegistry.hpp"
52
53#include "RandomNumbers/RandomNumberDistributionFactory.hpp"
54#include "RandomNumbers/RandomNumberEngineFactory.hpp"
55#include "RandomNumbers/RandomNumberGeneratorFactory.hpp"
56
57#include "Parser/ChangeTracker.hpp"
58#include "Parser/FormatParserStorage.hpp"
59#include "Parser/XmlParser.hpp"
60
61#include "Shapes/ShapeFactory.hpp"
62#include "Shapes/ShapeRegistry.hpp"
63
64#include "UIElements/CommandLineUI/CommandLineParser.hpp"
65#include "UIElements/Menu/MenuDescription.hpp"
66#include "UIElements/UIFactory.hpp"
67#include "World.hpp"
68#include "WorldTime.hpp"
69
70/** In this function all dynamicly allocated member variables to static/global
71 * variables are added to the ignore list of Memory/MemDebug.
72 *
73 * Use this to prevent their listing in the Memory::getState() at the end of the
74 * program. Check with valgrind that truely no memory leak occurs!
75 */
76void AddStaticEntitiestoIgnoreList()
77{
78 // zeroVec and unitVec are global variables (on the stack) but vectorContent
79 // within is situated on the heap and has to be ignored
80 Memory::ignore(zeroVec.get());
81 Memory::ignore(unitVec[0].get());
82 Memory::ignore(unitVec[1].get());
83 Memory::ignore(unitVec[2].get());
84
85 // XmlParser has static instance that uses vectorContent as well
86 Memory::ignore(FormatParser< xml >::defaultAtomInfo.field.get());
87}
88
89/** purges all static (singleton) instances in correct order of dependency.
90 *
91 */
92void purgeStaticInstances()
93{
94 // make sure that ActionQueue is already purged!
95
96 Chronos::purgeInstance();
97 RandomNumberDistributionFactory::purgeInstance();
98 RandomNumberEngineFactory::purgeInstance();
99 RandomNumberGeneratorFactory::purgeInstance();
100 ShapeFactory::purgeInstance();
101 ShapeRegistry::purgeInstance();
102 FormatParserStorage::purgeInstance();
103 ChangeTracker::purgeInstance();
104 World::purgeInstance();
105 AtomObserver::purgeInstance();
106 MenuDescription::purgeInstance();
107 UIFactory::purgeInstance();
108 CommandLineParser::purgeInstance();
109 logger::purgeInstance();
110 errorLogger::purgeInstance();
111 WorldTime::purgeInstance();
112}
113
114void stopAndPurgeQueue()
115{
116 // adding a wait here such that ActionQueue's run_thread is done any may stop
117 waitQueue();
118 MoleCuilder::ActionQueue::purgeInstance();
119 MoleCuilder::OptionRegistry::purgeInstance();
120}
121
122void printTimings(const MoleCuilder::ActionQueue::ActionTokens_t &tokens);
123
124/** Cleans all singleton instances in an orderly fashion.
125 * C++ does not guarantee any specific sequence of removal of single instances
126 * which have static/global variables. Some singletons depend on others hence we
127 * ascertain a specific ordering here, which is is used via the atexit() hook.
128 */
129void cleanUp()
130{
131 // stop queue
132 const MoleCuilder::ActionQueue::ActionTokens_t tokens = MoleCuilder::ActionQueue::getInstance().getListOfActions();
133 stopAndPurgeQueue();
134 // give timings per Action, requires still present Chronos
135 printTimings(tokens);
136
137 // purge static instances from memory
138 purgeStaticInstances();
139 // put some static variables' dynamic contents on the Memory::ignore map to avoid their
140 // admonishing lateron
141 AddStaticEntitiestoIgnoreList();
142#ifdef LOG_OBSERVER
143 cout << observerLog().getLog();
144#endif
145#ifndef NDEBUG
146 // CodePatterns always initializes observerLog except with NDEBUG
147 ObserverLog::purgeInstance();
148#endif
149 Memory::getState();
150}
151
152/** We give a list of all times per action and a total time.
153 *
154 * We require a list of Action tokens such that we do not access the ActionQueue.
155 * Timings are printed when Actions have all been performed, hence the queue should
156 * already be purged and we cannot access it anymore.
157 *
158 * \param tokens
159 */
160void printTimings(const MoleCuilder::ActionQueue::ActionTokens_t &tokens)
161{
162// const MoleCuilder::ActionQueue::ActionTokens_t tokens = MoleCuilder::ActionQueue::getInstance().getListOfActions();
163 const Chronos &Chron = Chronos::getInstance();
164 if (!DoLog(2)) {
165 std::cout << "(Non-zero) Times used per Action [seconds]:" << std::endl;
166 for (MoleCuilder::ActionQueue::ActionTokens_t::const_iterator iter = tokens.begin();
167 iter != tokens.end(); ++iter)
168 if (Chron.getTime(*iter) != 0.) { // dont give if action has not been used
169 std::cout << " " << setiosflags(ios::left) << setw(24) << setfill('.') << *iter;
170 std::cout << setiosflags(ios::left)
171#ifdef HAVE_SYS_TIMES_H
172 << setprecision(3)
173#else
174 << setprecision(9)
175#endif
176 << fixed << Chron.getTime(*iter) << std::endl;
177 }
178 } else {
179 std::cout << "Measured times [seconds]:" << std::endl;
180 const Chronos::TimekeepingMap &timemap = Chron.getTimekeepingMap();
181 for (Chronos::TimekeepingMap::const_iterator iter = timemap.begin();
182 iter != timemap.end();
183 ++iter) {
184 std::cout << " " << setiosflags(ios::left) << setw(24) << setfill('.') << iter->first;
185 std::cout << setiosflags(ios::left)
186#ifdef HAVE_SYS_TIMES_H
187 << setprecision(3)
188#else
189 << setprecision(9)
190#endif
191 << fixed << iter->second << std::endl;
192 }
193 }
194 std::cout << "Total Time: " << Chron.SumUpTotalTime() << " seconds" << std::endl;
195 std::cout << "Total Actions called: " << Chron.SumUpTotalFunctions() << std::endl;
196}
197
198/** Dump current memory chunks.
199 *
200 */
201void dumpMemory()
202{
203 ofstream ost("molecuilder.memdump");
204 Memory::dumpMemory(ost);
205}
206
207/** Save the current World to output files and exit.
208 *
209 * @return retrieved from World::getExitFlag()
210 */
211int saveAll()
212{
213 FormatParserStorage::getInstance().SaveAll();
214 ChangeTracker::getInstance().saveStatus();
215
216 int ExitFlag = World::getInstance().getExitFlag();
217 return (ExitFlag == 1 ? 0 : ExitFlag);
218}
219
220/** Stops the queue such that all Actions are done.
221 *
222 */
223void stopQueue()
224{
225 MoleCuilder::ActionQueue::getInstance().stop();
226}
227
228/** Waits for the queue to idle.
229 *
230 */
231void waitQueue()
232{
233 MoleCuilder::ActionQueue::getInstance().wait();
234}
Note: See TracBrowser for help on using the repository browser.