From 3f297c9d46003b7d2431f7fe872dd0e3a8ef1572 Mon Sep 17 00:00:00 2001 From: KSkwarczynski Date: Thu, 1 Aug 2024 14:37:34 +0000 Subject: [PATCH] deploy: 8556125bbe8fb8f9c1734460d2646f0f90ff15f4 --- FitterBase_8cpp_source.html | 4 +- GetPenaltyTerm_8cpp.html | 4 +- GetPenaltyTerm_8cpp_source.html | 4 +- MCMCProcessor_8cpp_source.html | 6 +- Monitor_8cpp_source.html | 519 ++++++++++++++++---------------- Monitor_8h.html | 1 + Monitor_8h_source.html | 54 ++-- RHat_8cpp.html | 2 +- RHat_8cpp_source.html | 2 +- classFitterBase.html | 4 +- classMCMCProcessor.html | 6 +- classmanager.html | 2 +- manager_8cpp_source.html | 2 +- namespaceMaCh3Utils.html | 437 ++++++++++++++------------- 14 files changed, 530 insertions(+), 517 deletions(-) diff --git a/FitterBase_8cpp_source.html b/FitterBase_8cpp_source.html index 13249a40..1aed8437 100644 --- a/FitterBase_8cpp_source.html +++ b/FitterBase_8cpp_source.html @@ -1633,8 +1633,8 @@
manager::GetMaCh3Modes
MaCh3Modes * GetMaCh3Modes() const
Return pointer to MaCh3 modes.
Definition manager.h:50
manager::raw
YAML::Node const & raw()
Return config.
Definition manager.h:48
samplePDFBase
Class responsible for handling implementation of samples used in analysis, reweighting and returning ...
Definition samplePDFBase.h:28
-
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:217
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:221
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
diff --git a/GetPenaltyTerm_8cpp.html b/GetPenaltyTerm_8cpp.html index 9fd1f816..af66e410 100644 --- a/GetPenaltyTerm_8cpp.html +++ b/GetPenaltyTerm_8cpp.html @@ -415,7 +415,7 @@

isFlat
std::vector< bool > isFlat
Definition GetPenaltyTerm.cpp:39
MACH3LOG_INFO
#define MACH3LOG_INFO
Definition MaCh3Logger.h:16
GetFromManager
Type GetFromManager(const YAML::Node &node, Type defval)
Get content of config file if node is not found take default value specified.
Definition YamlHelper.h:21
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
@@ -570,7 +570,7 @@

396}
MACH3LOG_ERROR
#define MACH3LOG_ERROR
Definition MaCh3Logger.h:18
TMacroToYAML
YAML::Node TMacroToYAML(const TMacro &macro)
KS: Convert a ROOT TMacro object to a YAML node.
Definition YamlHelper.h:147
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
diff --git a/GetPenaltyTerm_8cpp_source.html b/GetPenaltyTerm_8cpp_source.html index a360d70c..d55a2d19 100644 --- a/GetPenaltyTerm_8cpp_source.html +++ b/GetPenaltyTerm_8cpp_source.html @@ -503,8 +503,8 @@
TMacroToYAML
YAML::Node TMacroToYAML(const TMacro &macro)
KS: Convert a ROOT TMacro object to a YAML node.
Definition YamlHelper.h:147
MaCh3Exception
Custom exception class for MaCh3 errors.
Definition MaCh3Exception.h:12
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
diff --git a/MCMCProcessor_8cpp_source.html b/MCMCProcessor_8cpp_source.html index 0d12276d..109d9efe 100644 --- a/MCMCProcessor_8cpp_source.html +++ b/MCMCProcessor_8cpp_source.html @@ -4949,9 +4949,9 @@
RunGPU_AutoCorr
__host__ void RunGPU_AutoCorr(float *ParStep_gpu, float *ParamSums_gpu, float *NumeratorSum_gpu, float *DenomSum_gpu, float *NumeratorSum_cpu, float *DenomSum_cpu)
KS: This call the main kernel responsible for calculating LagL and later copy results back to CPU.
Definition gpuMCMCProcessorUtils.cu:163
CleanupGPU_AutoCorr
__host__ void CleanupGPU_AutoCorr(float *ParStep_gpu, float *NumeratorSum_gpu, float *ParamSums_gpu, float *DenomSum_gpu)
KS: free memory on gpu.
Definition gpuMCMCProcessorUtils.cu:201
-
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:173
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:177
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
diff --git a/Monitor_8cpp_source.html b/Monitor_8cpp_source.html index 5823f9e0..578454f0 100644 --- a/Monitor_8cpp_source.html +++ b/Monitor_8cpp_source.html @@ -138,290 +138,295 @@
49 //KS: Find MaCh3 version based on header file. There could be better way to just include version.h but as long as we don't have to hardcode version I am content
50 std::string MaCh3_VERSION = "";
51
-
52 std::string file = std::string(std::getenv("MaCh3_ROOT")) + "/version.h";
-
53 // Open the version.h file
-
54 std::ifstream versionFile(file);
+
52 if(std::getenv("MaCh3_ROOT") == nullptr){
+
53 throw MaCh3Exception(__FILE__, __LINE__, "Error: you haven't sourced setup.MaCh3.sh in core!");
+
54 }
55
-
56 // Check if the file is opened successfully
-
57 if (!versionFile.is_open()) {
-
58 MACH3LOG_ERROR("Error: Couldn't open version.h {}", file);
-
59 throw;
-
60 }
-
61
-
62 std::string line;
-
63 const std::string searchKey = "MaCh3_VERSION=";
-
64
-
65 // Read each line from the file
-
66 while (std::getline(versionFile, line)) {
-
67 // Search for the line containing MaCh3_VERSION
-
68 auto pos = line.find(searchKey);
-
69 if (pos != std::string::npos) {
-
70 // Extract the version string
-
71 MaCh3_VERSION = line.substr(pos + searchKey.length());
-
72 MaCh3_VERSION.erase(0, MaCh3_VERSION.find_first_not_of("\"")); // Remove leading quote
-
73 MaCh3_VERSION.erase(MaCh3_VERSION.find_last_not_of("\";") + 1); // Remove trailing quote and semicolon
-
74 break; // Stop searching once found
-
75 }
-
76 }
-
77 // Close the file
-
78 versionFile.close();
-
79
-
80 return MaCh3_VERSION;
-
81}
- -
82
+
56 std::string file = std::string(std::getenv("MaCh3_ROOT")) + "/version.h";
+
57 // Open the version.h file
+
58 std::ifstream versionFile(file);
+
59
+
60 // Check if the file is opened successfully
+
61 if (!versionFile.is_open()) {
+
62 MACH3LOG_ERROR("Error: Couldn't open version.h {}", file);
+
63 throw;
+
64 }
+
65
+
66 std::string line;
+
67 const std::string searchKey = "MaCh3_VERSION=";
+
68
+
69 // Read each line from the file
+
70 while (std::getline(versionFile, line)) {
+
71 // Search for the line containing MaCh3_VERSION
+
72 auto pos = line.find(searchKey);
+
73 if (pos != std::string::npos) {
+
74 // Extract the version string
+
75 MaCh3_VERSION = line.substr(pos + searchKey.length());
+
76 MaCh3_VERSION.erase(0, MaCh3_VERSION.find_first_not_of("\"")); // Remove leading quote
+
77 MaCh3_VERSION.erase(MaCh3_VERSION.find_last_not_of("\";") + 1); // Remove trailing quote and semicolon
+
78 break; // Stop searching once found
+
79 }
+
80 }
+
81 // Close the file
+
82 versionFile.close();
83
-
84// ************************
-
85// KS: Find out more about operational system
-
-
86void GetOSInfo() {
-
87// ************************
-
88
-
89 MACH3LOG_INFO("Operating System Information:");
-
90
-
91 // Distribution and version
-
92 MACH3LOG_INFO("Distribution: {}", TerminalToString("lsb_release -d | awk -F':' '{print $2}'"));
-
93 MACH3LOG_INFO("Kernel Version: {}", TerminalToString("uname -r"));
-
94}
+
84 return MaCh3_VERSION;
+
85}
-
95
-
96
-
97// ************************
-
98//KS: Simple function retrieving CPU info
-
-
99void GetCPUInfo(){
-
100// ************************
-
101
-
102 //KS: Use -m 1 to limit to only one grep because in one computing node there is a lot of CPU which are the same
-
103 MACH3LOG_INFO("Using following CPU:");
-
104
-
105 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 name"));
-
106 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 MHz"));
-
107 //KS: Below code is convoluted because I mostly work on English based Linux but sometimes on Polish based Linux, this ensures it works on both. We can add support for other languages if needed
-
108 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -i Archit"));
-
109 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1d |L1d:'"));
-
110 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1i |L1i:'"));
-
111 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L2 |L2:'"));
-
112 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L3 |L3:'"));
-
113 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'Thread.* per core:|Wątków na rdzeń:'"));
-
114 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E '^CPU(:|\\(s\\)):?\\s+[0-9]+'"));
-
115
-
116 //KS: /proc/cpuinfo and lscpu holds much more info I have limited it but one can expand it if needed
-
117}
+
86
+
87
+
88// ************************
+
89// KS: Find out more about operational system
+
+
90void GetOSInfo() {
+
91// ************************
+
92
+
93 MACH3LOG_INFO("Operating System Information:");
+
94
+
95 // Distribution and version
+
96 MACH3LOG_INFO("Distribution: {}", TerminalToString("lsb_release -d | awk -F':' '{print $2}'"));
+
97 MACH3LOG_INFO("Kernel Version: {}", TerminalToString("uname -r"));
+
98}
-
118
+
99
+
100
+
101// ************************
+
102//KS: Simple function retrieving CPU info
+
+
103void GetCPUInfo(){
+
104// ************************
+
105
+
106 //KS: Use -m 1 to limit to only one grep because in one computing node there is a lot of CPU which are the same
+
107 MACH3LOG_INFO("Using following CPU:");
+
108
+
109 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 name"));
+
110 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 MHz"));
+
111 //KS: Below code is convoluted because I mostly work on English based Linux but sometimes on Polish based Linux, this ensures it works on both. We can add support for other languages if needed
+
112 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -i Archit"));
+
113 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1d |L1d:'"));
+
114 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1i |L1i:'"));
+
115 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L2 |L2:'"));
+
116 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L3 |L3:'"));
+
117 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'Thread.* per core:|Wątków na rdzeń:'"));
+
118 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E '^CPU(:|\\(s\\)):?\\s+[0-9]+'"));
119
-
120// ************************
-
121//KS: Simple function retrieving GPU info
-
-
122void GetGPUInfo(){
-
123// ************************
-
124
-
125#ifdef CUDA
-
126 MACH3LOG_INFO("Using following GPU:");
-
127 // Print GPU name
-
128 MACH3LOG_INFO("GPU Name: {}", TerminalToString("nvidia-smi --query-gpu=name --format=csv,noheader"));
-
129 // Print number of GPUs
-
130 MACH3LOG_INFO("Number of GPUs: {}", TerminalToString("nvidia-smi --query-gpu=count --format=csv,noheader"));
-
131 // Print total VRAM
-
132 MACH3LOG_INFO("Total VRAM: {} MB", TerminalToString("nvidia-smi --query-gpu=memory.total --format=csv,noheader,nounits"));
-
133 // Print Driver Version
-
134 MACH3LOG_INFO("Driver Version: {}", TerminalToString("nvidia-smi --query-gpu=driver_version --format=csv,noheader"));
-
135 // Print N GPU thread
-
136 MACH3LOG_INFO("Currently used GPU has: {} threads", GetNumGPUThreads());
-
137#endif
-
138 return;
-
139}
+
120 //KS: /proc/cpuinfo and lscpu holds much more info I have limited it but one can expand it if needed
+
121}
-
140
-
141// ************************
-
142// KS: Find out about Disk usage
-
-
143void GetDiskUsage() {
-
144// ************************
-
145 MACH3LOG_INFO("Disk Usage:");
-
146
-
147 // Get disk usage
-
148 MACH3LOG_INFO("{}", TerminalToString("df -h --total | grep total"));
-
149}
+
122
+
123
+
124// ************************
+
125//KS: Simple function retrieving GPU info
+
+
126void GetGPUInfo(){
+
127// ************************
+
128
+
129#ifdef CUDA
+
130 MACH3LOG_INFO("Using following GPU:");
+
131 // Print GPU name
+
132 MACH3LOG_INFO("GPU Name: {}", TerminalToString("nvidia-smi --query-gpu=name --format=csv,noheader"));
+
133 // Print number of GPUs
+
134 MACH3LOG_INFO("Number of GPUs: {}", TerminalToString("nvidia-smi --query-gpu=count --format=csv,noheader"));
+
135 // Print total VRAM
+
136 MACH3LOG_INFO("Total VRAM: {} MB", TerminalToString("nvidia-smi --query-gpu=memory.total --format=csv,noheader,nounits"));
+
137 // Print Driver Version
+
138 MACH3LOG_INFO("Driver Version: {}", TerminalToString("nvidia-smi --query-gpu=driver_version --format=csv,noheader"));
+
139 // Print N GPU thread
+
140 MACH3LOG_INFO("Currently used GPU has: {} threads", GetNumGPUThreads());
+
141#endif
+
142 return;
+
143}
+
144
+
145// ************************
+
146// KS: Find out about Disk usage
+
+
147void GetDiskUsage() {
+
148// ************************
+
149 MACH3LOG_INFO("Disk Usage:");
150
-
151
-
152// ************************
-
153// KS: Convoluted code to grab output from terminal to string
-
-
154std::string TerminalToString(const char* cmd) {
-
155// ************************
-
156
-
157 std::array<char, 128> buffer;
-
158 std::string result;
-
159 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd, "r"), pclose);
-
160 if (!pipe) {
-
161 throw std::runtime_error("popen() failed!");
-
162 }
-
163 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) {
-
164 result += buffer.data();
-
165 }
-
166 // Remove trailing newline characters
-
167 result.erase(std::remove(result.begin(), result.end(), '\n'), result.end());
-
168 return result;
-
169}
+
151 // Get disk usage
+
152 MACH3LOG_INFO("{}", TerminalToString("df -h --total | grep total"));
+
153}
-
170
-
171// ************************
-
172//KS: Simple to retrieve speed of get entry inspired by
-
-
173void EstimateDataTransferRate(TChain* chain, const int entry){
-
174// ************************
-
175
-
176 TStopwatch timer;
-
177
-
178 timer.Start();
-
179 Int_t bytesProcessed{ chain->GetEntry(entry) };
-
180
-
181 timer.Stop();
-
182
-
183 Double_t timeInSeconds = timer.RealTime();
-
184 Double_t dataRateMBps = (double(bytesProcessed) / (1024.0 * 1024.0)) / timeInSeconds;
-
185
-
186 MACH3LOG_INFO("Data transfer: {} B, rate: {:.2f} MB/s", bytesProcessed, dataRateMBps);
-
187}
+
154
+
155
+
156// ************************
+
157// KS: Convoluted code to grab output from terminal to string
+
+
158std::string TerminalToString(const char* cmd) {
+
159// ************************
+
160
+
161 std::array<char, 128> buffer;
+
162 std::string result;
+
163 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd, "r"), pclose);
+
164 if (!pipe) {
+
165 throw std::runtime_error("popen() failed!");
+
166 }
+
167 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) {
+
168 result += buffer.data();
+
169 }
+
170 // Remove trailing newline characters
+
171 result.erase(std::remove(result.begin(), result.end(), '\n'), result.end());
+
172 return result;
+
173}
-
188
+
174
+
175// ************************
+
176//KS: Simple to retrieve speed of get entry inspired by
+
+
177void EstimateDataTransferRate(TChain* chain, const int entry){
+
178// ************************
+
179
+
180 TStopwatch timer;
+
181
+
182 timer.Start();
+
183 Int_t bytesProcessed{ chain->GetEntry(entry) };
+
184
+
185 timer.Stop();
+
186
+
187 Double_t timeInSeconds = timer.RealTime();
+
188 Double_t dataRateMBps = (double(bytesProcessed) / (1024.0 * 1024.0)) / timeInSeconds;
189
-
190
-
191// ************************
-
192//KS: Simply print progress bar
-
-
193void PrintProgressBar(const int Done, const int All){
-
194// ************************
-
195
-
196 double progress = double((double(Done)/double(All)));
-
197 const int barWidth = 20;
-
198 std::ostringstream progressBar;
-
199
-
200 progressBar << "[";
-
201 int pos = barWidth * progress;
-
202 for (int i = 0; i < barWidth; ++i) {
-
203 if (i < pos)
-
204 progressBar << "=";
-
205 else if (i == pos)
-
206 progressBar << ">";
-
207 else
-
208 progressBar << " ";
-
209 }
-
210
-
211 progressBar << "] " << std::setw(3) << Done <<"/"<< All<<" ("<<static_cast<int>(progress * 100.0)<<"%)\r";
-
212 MACH3LOG_INFO("{}", progressBar.str());
-
213}
+
190 MACH3LOG_INFO("Data transfer: {} B, rate: {:.2f} MB/s", bytesProcessed, dataRateMBps);
+
191}
+
192
+
193
+
194
+
195// ************************
+
196//KS: Simply print progress bar
+
+
197void PrintProgressBar(const int Done, const int All){
+
198// ************************
+
199
+
200 double progress = double((double(Done)/double(All)));
+
201 const int barWidth = 20;
+
202 std::ostringstream progressBar;
+
203
+
204 progressBar << "[";
+
205 int pos = barWidth * progress;
+
206 for (int i = 0; i < barWidth; ++i) {
+
207 if (i < pos)
+
208 progressBar << "=";
+
209 else if (i == pos)
+
210 progressBar << ">";
+
211 else
+
212 progressBar << " ";
+
213 }
214
-
215// ***************************************************************************
-
216//CW: Get memory, which is probably silly
-
-
217int getValue(std::string Type){ //Note: this value is in KB!
-
218// ***************************************************************************
-
219 std::ifstream file("/proc/self/status");
-
220 int result = -1;
-
221 std::string line;
-
222
-
223 if (Type == "VmSize")
-
224 {
-
225 while (std::getline(file, line))
-
226 {
-
227 if (line.compare(0, 7, "VmSize:") == 0)
-
228 {
-
229 result = parseLine(line.substr(7));
-
230 break;
-
231 }
-
232 }
-
233 }
-
234 else if (Type == "VmRSS")
-
235 {
-
236 while (std::getline(file, line))
-
237 {
-
238 if (line.compare(0, 6, "VmRSS:") == 0)
-
239 {
-
240 result = parseLine(line.substr(6));
-
241 break;
-
242 }
-
243 }
-
244 }
-
245 else if (Type == "MemTotal")
-
246 {
-
247 std::ifstream meminfo("/proc/meminfo");
-
248 while (std::getline(meminfo, line))
-
249 {
-
250 if (line.find("MemTotal:") != std::string::npos) {
-
251 result = parseLine(line.substr(9));
-
252 break;
-
253 }
-
254 }
-
255 }
-
256 else
-
257 {
-
258 std::cerr << "Not supported getValue: " << Type << std::endl;
-
259 std::cerr << __FILE__ << ":" << __LINE__ << std::endl;
-
260 throw;
-
261 }
-
262
-
263 return result;
-
264}
+
215 progressBar << "] " << std::setw(3) << Done <<"/"<< All<<" ("<<static_cast<int>(progress * 100.0)<<"%)\r";
+
216 MACH3LOG_INFO("{}", progressBar.str());
+
217}
-
265
-
266// ***************************************************************************
-
267//CW: Get memory, which is probably silly
-
-
268int parseLine(const std::string& line){
-
269// ***************************************************************************
-
270 std::istringstream iss(line);
-
271 int value;
-
272 iss >> value;
-
273 return value;
-
274}
+
218
+
219// ***************************************************************************
+
220//CW: Get memory, which is probably silly
+
+
221int getValue(std::string Type){ //Note: this value is in KB!
+
222// ***************************************************************************
+
223 std::ifstream file("/proc/self/status");
+
224 int result = -1;
+
225 std::string line;
+
226
+
227 if (Type == "VmSize")
+
228 {
+
229 while (std::getline(file, line))
+
230 {
+
231 if (line.compare(0, 7, "VmSize:") == 0)
+
232 {
+
233 result = parseLine(line.substr(7));
+
234 break;
+
235 }
+
236 }
+
237 }
+
238 else if (Type == "VmRSS")
+
239 {
+
240 while (std::getline(file, line))
+
241 {
+
242 if (line.compare(0, 6, "VmRSS:") == 0)
+
243 {
+
244 result = parseLine(line.substr(6));
+
245 break;
+
246 }
+
247 }
+
248 }
+
249 else if (Type == "MemTotal")
+
250 {
+
251 std::ifstream meminfo("/proc/meminfo");
+
252 while (std::getline(meminfo, line))
+
253 {
+
254 if (line.find("MemTotal:") != std::string::npos) {
+
255 result = parseLine(line.substr(9));
+
256 break;
+
257 }
+
258 }
+
259 }
+
260 else
+
261 {
+
262 std::cerr << "Not supported getValue: " << Type << std::endl;
+
263 std::cerr << __FILE__ << ":" << __LINE__ << std::endl;
+
264 throw;
+
265 }
+
266
+
267 return result;
+
268}
-
275
-
276
-
277// ***************************************************************************
-
278//KS: Print Yaml config using logger
-
-
279void PrintConfig(const YAML::Node& node){
-
280// ***************************************************************************
-
281 std::stringstream ss;
-
282 ss << node;
-
283 std::string yamlString = ss.str();
-
284
-
285 std::istringstream iss(yamlString);
-
286 std::string line;
-
287 while (std::getline(iss, line)) {
-
288 MACH3LOG_INFO("{}", line);
-
289 }
-
290}
+
269
+
270// ***************************************************************************
+
271//CW: Get memory, which is probably silly
+
+
272int parseLine(const std::string& line){
+
273// ***************************************************************************
+
274 std::istringstream iss(line);
+
275 int value;
+
276 iss >> value;
+
277 return value;
+
278}
-
291
-
292
-
293
+
279
+
280
+
281// ***************************************************************************
+
282//KS: Print Yaml config using logger
+
+
283void PrintConfig(const YAML::Node& node){
+
284// ***************************************************************************
+
285 std::stringstream ss;
+
286 ss << node;
+
287 std::string yamlString = ss.str();
+
288
+
289 std::istringstream iss(yamlString);
+
290 std::string line;
+
291 while (std::getline(iss, line)) {
+
292 MACH3LOG_INFO("{}", line);
+
293 }
294}
+
295
+
296
+
297
+
298}
+
MACH3LOG_ERROR
#define MACH3LOG_ERROR
Definition MaCh3Logger.h:18
MACH3LOG_INFO
#define MACH3LOG_INFO
Definition MaCh3Logger.h:16
GetFromManager
Type GetFromManager(const YAML::Node &node, Type defval)
Get content of config file if node is not found take default value specified.
Definition YamlHelper.h:21
+
MaCh3Exception
Custom exception class for MaCh3 errors.
Definition MaCh3Exception.h:12
GetNumGPUThreads
int GetNumGPUThreads(const int Device)
KS: Get number of GPU threads for currently used GPU.
Definition gpuUtils.cu:110
-
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:86
-
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:217
-
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:173
+
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:90
+
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:221
+
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:177
MaCh3Utils::GetMaCh3Version
std::string GetMaCh3Version()
KS: Get version of MaCh3.
Definition Monitor.cpp:46
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
-
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:143
-
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:99
-
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:122
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
+
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:147
+
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:103
+
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:126
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
-
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:154
-
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:268
+
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:158
+
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:272
diff --git a/Monitor_8h.html b/Monitor_8h.html index 23f1d5aa..608aaad6 100644 --- a/Monitor_8h.html +++ b/Monitor_8h.html @@ -93,6 +93,7 @@ #include "TStopwatch.h"
#include "manager/MaCh3Logger.h"
#include "samplePDF/Structs.h"
+#include "manager/MaCh3Exception.h"
#include "manager/YamlHelper.h"

Go to the source code of this file.

diff --git a/Monitor_8h_source.html b/Monitor_8h_source.html index 237ebe7d..a8fcb732 100644 --- a/Monitor_8h_source.html +++ b/Monitor_8h_source.html @@ -102,39 +102,41 @@
17// MaCh3 includes
18#include "manager/MaCh3Logger.h"
19#include "samplePDF/Structs.h"
-
20#include "manager/YamlHelper.h"
-
21
-
22namespace MaCh3Utils {
-
24 void MaCh3Welcome();
-
26 void GetOSInfo();
-
28 void GetCPUInfo();
-
30 void GetGPUInfo();
-
32 std::string TerminalToString(const char* cmd);
-
34 void EstimateDataTransferRate(TChain* chain, const int entry);
-
36 void GetDiskUsage();
-
38 void PrintProgressBar(const int Done, const int All);
-
40 std::string GetMaCh3Version();
-
42 int getValue(std::string Type);
-
44 int parseLine(const std::string& line);
-
46 void PrintConfig(const YAML::Node& node);
-
47}
+
20#include "manager/MaCh3Exception.h"
+
21#include "manager/YamlHelper.h"
+
22
+
23namespace MaCh3Utils {
+
25 void MaCh3Welcome();
+
27 void GetOSInfo();
+
29 void GetCPUInfo();
+
31 void GetGPUInfo();
+
33 std::string TerminalToString(const char* cmd);
+
35 void EstimateDataTransferRate(TChain* chain, const int entry);
+
37 void GetDiskUsage();
+
39 void PrintProgressBar(const int Done, const int All);
+
41 std::string GetMaCh3Version();
+
43 int getValue(std::string Type);
+
45 int parseLine(const std::string& line);
+
47 void PrintConfig(const YAML::Node& node);
+
48}
+
GetFromManager
Type GetFromManager(const YAML::Node &node, Type defval)
Get content of config file if node is not found take default value specified.
Definition YamlHelper.h:21
-
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:86
-
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:217
-
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:173
+
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:90
+
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:221
+
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:177
MaCh3Utils::GetMaCh3Version
std::string GetMaCh3Version()
KS: Get version of MaCh3.
Definition Monitor.cpp:46
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
-
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:143
-
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:99
-
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:122
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
+
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:147
+
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:103
+
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:126
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
-
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:154
-
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:268
+
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:158
+
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:272
diff --git a/RHat_8cpp.html b/RHat_8cpp.html index f0a648b6..94c620bb 100644 --- a/RHat_8cpp.html +++ b/RHat_8cpp.html @@ -922,7 +922,7 @@

ValidPar
std::vector< bool > ValidPar
Definition RHat.cpp:44

BranchNames
std::vector< TString > BranchNames
Definition RHat.cpp:42
CalcMedian
double CalcMedian(double arr[], int size)
Definition RHat.cpp:841
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
im
#define im
Definition probGpu.cu:70
diff --git a/RHat_8cpp_source.html b/RHat_8cpp_source.html index 8a71892a..70d0ddc9 100644 --- a/RHat_8cpp_source.html +++ b/RHat_8cpp_source.html @@ -1001,7 +1001,7 @@
GetFromManager
Type GetFromManager(const YAML::Node &node, Type defval)
Get content of config file if node is not found take default value specified.
Definition YamlHelper.h:21
MaCh3Exception
Custom exception class for MaCh3 errors.
Definition MaCh3Exception.h:12
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
im
#define im
Definition probGpu.cu:70
diff --git a/classFitterBase.html b/classFitterBase.html index 4137c67e..9be1ae14 100644 --- a/classFitterBase.html +++ b/classFitterBase.html @@ -1314,7 +1314,7 @@

1066 delete Sample_2DLLH;
1067}
FitterBase::SaveSettings
void SaveSettings()
Save the settings that the MCMC was run with.
Definition FitterBase.cpp:103
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
@@ -2231,7 +2231,7 @@

164 SettingsSaved = true;
165}
manager::SaveSettings
void SaveSettings(TFile *const OutputFile)
Add manager useful information's to TFile, in most cases to Fitter.
Definition manager.cpp:58
-
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:217
+
MaCh3Utils::getValue
int getValue(std::string Type)
CW: Get info like RAM.
Definition Monitor.cpp:221
diff --git a/classMCMCProcessor.html b/classMCMCProcessor.html index e554b643..46b185ca 100644 --- a/classMCMCProcessor.html +++ b/classMCMCProcessor.html @@ -1456,8 +1456,8 @@

1210 clock.Stop();
1211 MACH3LOG_INFO("Caching steps took {:.2f}s to finish for {} steps", clock.RealTime(), nEntries );
1212}
-
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:173
-
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:193
+
MaCh3Utils::EstimateDataTransferRate
void EstimateDataTransferRate(TChain *chain, const int entry)
KS: Check what CPU you are using.
Definition Monitor.cpp:177
+
MaCh3Utils::PrintProgressBar
void PrintProgressBar(const int Done, const int All)
KS: Simply print progress bar.
Definition Monitor.cpp:197
@@ -2359,7 +2359,7 @@

kFDDetPar
@ kFDDetPar
Definition MCMCProcessor.h:52
MACH3LOG_WARN
#define MACH3LOG_WARN
Definition MaCh3Logger.h:17
TMacroToYAML
YAML::Node TMacroToYAML(const TMacro &macro)
KS: Convert a ROOT TMacro object to a YAML node.
Definition YamlHelper.h:147
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
diff --git a/classmanager.html b/classmanager.html index 795fb0c3..05c287d4 100644 --- a/classmanager.html +++ b/classmanager.html @@ -223,7 +223,7 @@

manager::config
YAML::Node config
The YAML node containing the configuration data.
Definition manager.h:55
manager::mc_stat_llh
int mc_stat_llh
The likelihood type defined in the configuration.
Definition manager.h:59
manager::Modes
MaCh3Modes * Modes
MaCh3 Modes.
Definition manager.h:61
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
diff --git a/manager_8cpp_source.html b/manager_8cpp_source.html index ef0090b9..277917c7 100644 --- a/manager_8cpp_source.html +++ b/manager_8cpp_source.html @@ -223,7 +223,7 @@
manager::Modes
MaCh3Modes * Modes
MaCh3 Modes.
Definition manager.h:61
manager::~manager
virtual ~manager()
Destroys the manager object.
Definition manager.cpp:47
-
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:279
+
MaCh3Utils::PrintConfig
void PrintConfig(const YAML::Node &node)
KS: Print Yaml config using logger.
Definition Monitor.cpp:283
MaCh3Utils::MaCh3Welcome
void MaCh3Welcome()
KS: Prints welcome message with MaCh3 logo.
Definition Monitor.cpp:11
diff --git a/namespaceMaCh3Utils.html b/namespaceMaCh3Utils.html index 6b74fd4e..b53b2089 100644 --- a/namespaceMaCh3Utils.html +++ b/namespaceMaCh3Utils.html @@ -170,22 +170,22 @@

Definition at line 173 of file Monitor.cpp.

-
173 {
-
174// ************************
-
175
-
176 TStopwatch timer;
-
177
-
178 timer.Start();
-
179 Int_t bytesProcessed{ chain->GetEntry(entry) };
-
180
-
181 timer.Stop();
-
182
-
183 Double_t timeInSeconds = timer.RealTime();
-
184 Double_t dataRateMBps = (double(bytesProcessed) / (1024.0 * 1024.0)) / timeInSeconds;
-
185
-
186 MACH3LOG_INFO("Data transfer: {} B, rate: {:.2f} MB/s", bytesProcessed, dataRateMBps);
-
187}
+

Definition at line 177 of file Monitor.cpp.

+
177 {
+
178// ************************
+
179
+
180 TStopwatch timer;
+
181
+
182 timer.Start();
+
183 Int_t bytesProcessed{ chain->GetEntry(entry) };
+
184
+
185 timer.Stop();
+
186
+
187 Double_t timeInSeconds = timer.RealTime();
+
188 Double_t dataRateMBps = (double(bytesProcessed) / (1024.0 * 1024.0)) / timeInSeconds;
+
189
+
190 MACH3LOG_INFO("Data transfer: {} B, rate: {:.2f} MB/s", bytesProcessed, dataRateMBps);
+
191}
MACH3LOG_INFO
#define MACH3LOG_INFO
Definition MaCh3Logger.h:16
GetFromManager
Type GetFromManager(const YAML::Node &node, Type defval)
Get content of config file if node is not found take default value specified.
Definition YamlHelper.h:21
@@ -208,27 +208,27 @@

Definition at line 99 of file Monitor.cpp.

-
99 {
-
100// ************************
-
101
-
102 //KS: Use -m 1 to limit to only one grep because in one computing node there is a lot of CPU which are the same
-
103 MACH3LOG_INFO("Using following CPU:");
-
104
-
105 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 name"));
-
106 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 MHz"));
-
107 //KS: Below code is convoluted because I mostly work on English based Linux but sometimes on Polish based Linux, this ensures it works on both. We can add support for other languages if needed
-
108 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -i Archit"));
-
109 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1d |L1d:'"));
-
110 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1i |L1i:'"));
-
111 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L2 |L2:'"));
-
112 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L3 |L3:'"));
-
113 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'Thread.* per core:|Wątków na rdzeń:'"));
-
114 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E '^CPU(:|\\(s\\)):?\\s+[0-9]+'"));
-
115
-
116 //KS: /proc/cpuinfo and lscpu holds much more info I have limited it but one can expand it if needed
-
117}
-
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:154
+

Definition at line 103 of file Monitor.cpp.

+
103 {
+
104// ************************
+
105
+
106 //KS: Use -m 1 to limit to only one grep because in one computing node there is a lot of CPU which are the same
+
107 MACH3LOG_INFO("Using following CPU:");
+
108
+
109 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 name"));
+
110 MACH3LOG_INFO("{}", TerminalToString("cat /proc/cpuinfo | grep -m 1 MHz"));
+
111 //KS: Below code is convoluted because I mostly work on English based Linux but sometimes on Polish based Linux, this ensures it works on both. We can add support for other languages if needed
+
112 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -i Archit"));
+
113 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1d |L1d:'"));
+
114 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L1i |L1i:'"));
+
115 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L2 |L2:'"));
+
116 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'L3 |L3:'"));
+
117 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E 'Thread.* per core:|Wątków na rdzeń:'"));
+
118 MACH3LOG_INFO("{}", TerminalToString("lscpu | grep -m 1 -E '^CPU(:|\\(s\\)):?\\s+[0-9]+'"));
+
119
+
120 //KS: /proc/cpuinfo and lscpu holds much more info I have limited it but one can expand it if needed
+
121}
+
MaCh3Utils::TerminalToString
std::string TerminalToString(const char *cmd)
KS: Convoluted code to grab output from terminal to string.
Definition Monitor.cpp:158

@@ -249,14 +249,14 @@

Definition at line 143 of file Monitor.cpp.

-
143 {
-
144// ************************
-
145 MACH3LOG_INFO("Disk Usage:");
-
146
-
147 // Get disk usage
-
148 MACH3LOG_INFO("{}", TerminalToString("df -h --total | grep total"));
-
149}
+

Definition at line 147 of file Monitor.cpp.

+
147 {
+
148// ************************
+
149 MACH3LOG_INFO("Disk Usage:");
+
150
+
151 // Get disk usage
+
152 MACH3LOG_INFO("{}", TerminalToString("df -h --total | grep total"));
+
153}
@@ -277,25 +277,25 @@

Definition at line 122 of file Monitor.cpp.

-
122 {
-
123// ************************
-
124
-
125#ifdef CUDA
-
126 MACH3LOG_INFO("Using following GPU:");
-
127 // Print GPU name
-
128 MACH3LOG_INFO("GPU Name: {}", TerminalToString("nvidia-smi --query-gpu=name --format=csv,noheader"));
-
129 // Print number of GPUs
-
130 MACH3LOG_INFO("Number of GPUs: {}", TerminalToString("nvidia-smi --query-gpu=count --format=csv,noheader"));
-
131 // Print total VRAM
-
132 MACH3LOG_INFO("Total VRAM: {} MB", TerminalToString("nvidia-smi --query-gpu=memory.total --format=csv,noheader,nounits"));
-
133 // Print Driver Version
-
134 MACH3LOG_INFO("Driver Version: {}", TerminalToString("nvidia-smi --query-gpu=driver_version --format=csv,noheader"));
-
135 // Print N GPU thread
-
136 MACH3LOG_INFO("Currently used GPU has: {} threads", GetNumGPUThreads());
-
137#endif
-
138 return;
-
139}
+

Definition at line 126 of file Monitor.cpp.

+
126 {
+
127// ************************
+
128
+
129#ifdef CUDA
+
130 MACH3LOG_INFO("Using following GPU:");
+
131 // Print GPU name
+
132 MACH3LOG_INFO("GPU Name: {}", TerminalToString("nvidia-smi --query-gpu=name --format=csv,noheader"));
+
133 // Print number of GPUs
+
134 MACH3LOG_INFO("Number of GPUs: {}", TerminalToString("nvidia-smi --query-gpu=count --format=csv,noheader"));
+
135 // Print total VRAM
+
136 MACH3LOG_INFO("Total VRAM: {} MB", TerminalToString("nvidia-smi --query-gpu=memory.total --format=csv,noheader,nounits"));
+
137 // Print Driver Version
+
138 MACH3LOG_INFO("Driver Version: {}", TerminalToString("nvidia-smi --query-gpu=driver_version --format=csv,noheader"));
+
139 // Print N GPU thread
+
140 MACH3LOG_INFO("Currently used GPU has: {} threads", GetNumGPUThreads());
+
141#endif
+
142 return;
+
143}
GetNumGPUThreads
int GetNumGPUThreads(const int Device)
KS: Get number of GPU threads for currently used GPU.
Definition gpuUtils.cu:110
@@ -324,37 +324,42 @@

49 //KS: Find MaCh3 version based on header file. There could be better way to just include version.h but as long as we don't have to hardcode version I am content
50 std::string MaCh3_VERSION = "";
51
-
52 std::string file = std::string(std::getenv("MaCh3_ROOT")) + "/version.h";
-
53 // Open the version.h file
-
54 std::ifstream versionFile(file);
+
52 if(std::getenv("MaCh3_ROOT") == nullptr){
+
53 throw MaCh3Exception(__FILE__, __LINE__, "Error: you haven't sourced setup.MaCh3.sh in core!");
+
54 }
55
-
56 // Check if the file is opened successfully
-
57 if (!versionFile.is_open()) {
-
58 MACH3LOG_ERROR("Error: Couldn't open version.h {}", file);
-
59 throw;
-
60 }
-
61
-
62 std::string line;
-
63 const std::string searchKey = "MaCh3_VERSION=";
-
64
-
65 // Read each line from the file
-
66 while (std::getline(versionFile, line)) {
-
67 // Search for the line containing MaCh3_VERSION
-
68 auto pos = line.find(searchKey);
-
69 if (pos != std::string::npos) {
-
70 // Extract the version string
-
71 MaCh3_VERSION = line.substr(pos + searchKey.length());
-
72 MaCh3_VERSION.erase(0, MaCh3_VERSION.find_first_not_of("\"")); // Remove leading quote
-
73 MaCh3_VERSION.erase(MaCh3_VERSION.find_last_not_of("\";") + 1); // Remove trailing quote and semicolon
-
74 break; // Stop searching once found
-
75 }
-
76 }
-
77 // Close the file
-
78 versionFile.close();
-
79
-
80 return MaCh3_VERSION;
-
81}
+
56 std::string file = std::string(std::getenv("MaCh3_ROOT")) + "/version.h";
+
57 // Open the version.h file
+
58 std::ifstream versionFile(file);
+
59
+
60 // Check if the file is opened successfully
+
61 if (!versionFile.is_open()) {
+
62 MACH3LOG_ERROR("Error: Couldn't open version.h {}", file);
+
63 throw;
+
64 }
+
65
+
66 std::string line;
+
67 const std::string searchKey = "MaCh3_VERSION=";
+
68
+
69 // Read each line from the file
+
70 while (std::getline(versionFile, line)) {
+
71 // Search for the line containing MaCh3_VERSION
+
72 auto pos = line.find(searchKey);
+
73 if (pos != std::string::npos) {
+
74 // Extract the version string
+
75 MaCh3_VERSION = line.substr(pos + searchKey.length());
+
76 MaCh3_VERSION.erase(0, MaCh3_VERSION.find_first_not_of("\"")); // Remove leading quote
+
77 MaCh3_VERSION.erase(MaCh3_VERSION.find_last_not_of("\";") + 1); // Remove trailing quote and semicolon
+
78 break; // Stop searching once found
+
79 }
+
80 }
+
81 // Close the file
+
82 versionFile.close();
+
83
+
84 return MaCh3_VERSION;
+
85}
MACH3LOG_ERROR
#define MACH3LOG_ERROR
Definition MaCh3Logger.h:18
+
MaCh3Exception
Custom exception class for MaCh3 errors.
Definition MaCh3Exception.h:12
@@ -498,16 +503,16 @@

Definition at line 86 of file Monitor.cpp.

-
86 {
-
87// ************************
-
88
-
89 MACH3LOG_INFO("Operating System Information:");
-
90
-
91 // Distribution and version
-
92 MACH3LOG_INFO("Distribution: {}", TerminalToString("lsb_release -d | awk -F':' '{print $2}'"));
-
93 MACH3LOG_INFO("Kernel Version: {}", TerminalToString("uname -r"));
-
94}
+

Definition at line 90 of file Monitor.cpp.

+
90 {
+
91// ************************
+
92
+
93 MACH3LOG_INFO("Operating System Information:");
+
94
+
95 // Distribution and version
+
96 MACH3LOG_INFO("Distribution: {}", TerminalToString("lsb_release -d | awk -F':' '{print $2}'"));
+
97 MACH3LOG_INFO("Kernel Version: {}", TerminalToString("uname -r"));
+
98}
@@ -529,56 +534,56 @@

Definition at line 217 of file Monitor.cpp.

-
217 { //Note: this value is in KB!
-
218// ***************************************************************************
-
219 std::ifstream file("/proc/self/status");
-
220 int result = -1;
-
221 std::string line;
-
222
-
223 if (Type == "VmSize")
-
224 {
-
225 while (std::getline(file, line))
-
226 {
-
227 if (line.compare(0, 7, "VmSize:") == 0)
-
228 {
-
229 result = parseLine(line.substr(7));
-
230 break;
-
231 }
-
232 }
-
233 }
-
234 else if (Type == "VmRSS")
-
235 {
-
236 while (std::getline(file, line))
-
237 {
-
238 if (line.compare(0, 6, "VmRSS:") == 0)
-
239 {
-
240 result = parseLine(line.substr(6));
-
241 break;
-
242 }
-
243 }
-
244 }
-
245 else if (Type == "MemTotal")
-
246 {
-
247 std::ifstream meminfo("/proc/meminfo");
-
248 while (std::getline(meminfo, line))
-
249 {
-
250 if (line.find("MemTotal:") != std::string::npos) {
-
251 result = parseLine(line.substr(9));
-
252 break;
-
253 }
-
254 }
-
255 }
-
256 else
-
257 {
-
258 std::cerr << "Not supported getValue: " << Type << std::endl;
-
259 std::cerr << __FILE__ << ":" << __LINE__ << std::endl;
-
260 throw;
-
261 }
-
262
-
263 return result;
-
264}
-
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:268
+

Definition at line 221 of file Monitor.cpp.

+
221 { //Note: this value is in KB!
+
222// ***************************************************************************
+
223 std::ifstream file("/proc/self/status");
+
224 int result = -1;
+
225 std::string line;
+
226
+
227 if (Type == "VmSize")
+
228 {
+
229 while (std::getline(file, line))
+
230 {
+
231 if (line.compare(0, 7, "VmSize:") == 0)
+
232 {
+
233 result = parseLine(line.substr(7));
+
234 break;
+
235 }
+
236 }
+
237 }
+
238 else if (Type == "VmRSS")
+
239 {
+
240 while (std::getline(file, line))
+
241 {
+
242 if (line.compare(0, 6, "VmRSS:") == 0)
+
243 {
+
244 result = parseLine(line.substr(6));
+
245 break;
+
246 }
+
247 }
+
248 }
+
249 else if (Type == "MemTotal")
+
250 {
+
251 std::ifstream meminfo("/proc/meminfo");
+
252 while (std::getline(meminfo, line))
+
253 {
+
254 if (line.find("MemTotal:") != std::string::npos) {
+
255 result = parseLine(line.substr(9));
+
256 break;
+
257 }
+
258 }
+
259 }
+
260 else
+
261 {
+
262 std::cerr << "Not supported getValue: " << Type << std::endl;
+
263 std::cerr << __FILE__ << ":" << __LINE__ << std::endl;
+
264 throw;
+
265 }
+
266
+
267 return result;
+
268}
+
MaCh3Utils::parseLine
int parseLine(const std::string &line)
CW: Get memory, which is probably silly.
Definition Monitor.cpp:272
@@ -650,11 +655,11 @@

40
41 MaCh3WelcomeInitialised = true;
42}
-
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:86
+
MaCh3Utils::GetOSInfo
void GetOSInfo()
KS: Find out more about operational system.
Definition Monitor.cpp:90
MaCh3Utils::GetMaCh3Version
std::string GetMaCh3Version()
KS: Get version of MaCh3.
Definition Monitor.cpp:46
-
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:143
-
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:99
-
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:122
+
MaCh3Utils::GetDiskUsage
void GetDiskUsage()
KS: Find out about Disk usage.
Definition Monitor.cpp:147
+
MaCh3Utils::GetCPUInfo
void GetCPUInfo()
KS: Check what CPU you are using.
Definition Monitor.cpp:103
+
MaCh3Utils::GetGPUInfo
void GetGPUInfo()
KS: Check what GPU you are using.
Definition Monitor.cpp:126
@@ -879,14 +884,14 @@

Definition at line 268 of file Monitor.cpp.

-
268 {
-
269// ***************************************************************************
-
270 std::istringstream iss(line);
-
271 int value;
-
272 iss >> value;
-
273 return value;
-
274}
+

Definition at line 272 of file Monitor.cpp.

+
272 {
+
273// ***************************************************************************
+
274 std::istringstream iss(line);
+
275 int value;
+
276 iss >> value;
+
277 return value;
+
278}
@@ -908,19 +913,19 @@

Definition at line 279 of file Monitor.cpp.

-
279 {
-
280// ***************************************************************************
-
281 std::stringstream ss;
-
282 ss << node;
-
283 std::string yamlString = ss.str();
-
284
-
285 std::istringstream iss(yamlString);
-
286 std::string line;
-
287 while (std::getline(iss, line)) {
-
288 MACH3LOG_INFO("{}", line);
-
289 }
-
290}
+

Definition at line 283 of file Monitor.cpp.

+
283 {
+
284// ***************************************************************************
+
285 std::stringstream ss;
+
286 ss << node;
+
287 std::string yamlString = ss.str();
+
288
+
289 std::istringstream iss(yamlString);
+
290 std::string line;
+
291 while (std::getline(iss, line)) {
+
292 MACH3LOG_INFO("{}", line);
+
293 }
+
294}
@@ -952,28 +957,28 @@

Definition at line 193 of file Monitor.cpp.

-
193 {
-
194// ************************
-
195
-
196 double progress = double((double(Done)/double(All)));
-
197 const int barWidth = 20;
-
198 std::ostringstream progressBar;
+

Definition at line 197 of file Monitor.cpp.

+
197 {
+
198// ************************
199
-
200 progressBar << "[";
-
201 int pos = barWidth * progress;
-
202 for (int i = 0; i < barWidth; ++i) {
-
203 if (i < pos)
-
204 progressBar << "=";
-
205 else if (i == pos)
-
206 progressBar << ">";
-
207 else
-
208 progressBar << " ";
-
209 }
-
210
-
211 progressBar << "] " << std::setw(3) << Done <<"/"<< All<<" ("<<static_cast<int>(progress * 100.0)<<"%)\r";
-
212 MACH3LOG_INFO("{}", progressBar.str());
-
213}
+
200 double progress = double((double(Done)/double(All)));
+
201 const int barWidth = 20;
+
202 std::ostringstream progressBar;
+
203
+
204 progressBar << "[";
+
205 int pos = barWidth * progress;
+
206 for (int i = 0; i < barWidth; ++i) {
+
207 if (i < pos)
+
208 progressBar << "=";
+
209 else if (i == pos)
+
210 progressBar << ">";
+
211 else
+
212 progressBar << " ";
+
213 }
+
214
+
215 progressBar << "] " << std::setw(3) << Done <<"/"<< All<<" ("<<static_cast<int>(progress * 100.0)<<"%)\r";
+
216 MACH3LOG_INFO("{}", progressBar.str());
+
217}
@@ -995,23 +1000,23 @@

Definition at line 154 of file Monitor.cpp.

-
154 {
-
155// ************************
-
156
-
157 std::array<char, 128> buffer;
-
158 std::string result;
-
159 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd, "r"), pclose);
-
160 if (!pipe) {
-
161 throw std::runtime_error("popen() failed!");
-
162 }
-
163 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) {
-
164 result += buffer.data();
-
165 }
-
166 // Remove trailing newline characters
-
167 result.erase(std::remove(result.begin(), result.end(), '\n'), result.end());
-
168 return result;
-
169}
+

Definition at line 158 of file Monitor.cpp.

+
158 {
+
159// ************************
+
160
+
161 std::array<char, 128> buffer;
+
162 std::string result;
+
163 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd, "r"), pclose);
+
164 if (!pipe) {
+
165 throw std::runtime_error("popen() failed!");
+
166 }
+
167 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) {
+
168 result += buffer.data();
+
169 }
+
170 // Remove trailing newline characters
+
171 result.erase(std::remove(result.begin(), result.end(), '\n'), result.end());
+
172 return result;
+
173}