Initial commit

log_summary.sh

@@ -0,0 +1,13 @@
+# name=summary.`date --rfc-3339=seconds` 
+
+# echo Subject: Dell Cluster log summary
+# echo
+
+for lfile in `python /home/ignis/log_notification_mailer/query_slurm.py`
+do
+echo $lfile
+echo --------------------------------------------------------------------------------
+tail -n 10000 $lfile | grep "Time\|(T)\|(p)\|(Phi)" | tail -n 10
+echo ================================================================================
+echo 
+done

log_summary_from_listfile.sh

@@ -0,0 +1,20 @@
+# name=summary.`date --rfc-3339=seconds` 
+
+# echo Subject: Dell Cluster log summary
+# echo
+
+for lfile in `cat /home/ignis/log_notification_mailer/sample.list`
+do
+echo $lfile
+tail -n 10000 $lfile/job.*.out | grep "Time\|(T)\|(p)\|(Phi)" | tail -n 10
+echo ================================================================================
+tail -n 5 $lfile/job.*.out
+echo 
+done
+
+for lfile in `cat /home/ignis/log_notification_mailer/sample.list`
+do
+uuencode $lfile/OHsurface.png $(basename $lfile)-OHsurface.png
+uuencode $lfile/Tsurface.png $(basename $lfile)-Tsurface.png
+uuencode $lfile/Tplot.png $(basename $lfile)-Tplot.png
+done

pv_cases.sh

@@ -0,0 +1,11 @@
+#!/bin/bash
+
+name=summary.`date --rfc-3339=seconds` 
+
+source $HOME/.bashrc
+source ~/OpenFOAM/OpenFOAM-2.4.x/etc/bashrc WM_NCOMPPROCS=32; source ~/OpenFOAM/cantera/bin/setup_cantera
+
+for lfile in `cat /home/ignis/log_notification_mailer/sample.list`
+do
+/home/ignis/ospv/bin/pvpython /home/ignis/log_notification_mailer/pv-notify.py $lfile
+done

query_slurm.py

@@ -0,0 +1,15 @@
+import subprocess as sp
+
+USER = 'ignis'
+
+idlist = sp.check_output('squeue -h -u {} -t running -o "%i"'.format(USER), shell=True).split()
+
+foamBanner='F ield         | OpenFOAM: The Open Source CFD Toolbox'
+
+for sid in idlist:
+    a = sp.check_output('scontrol show job {}'.format(sid), shell=True).split()
+    d = {aa.split("=")[0]: aa.split("=")[-1] for aa in a}
+
+    with open(d["StdOut"]) as logfile:
+        if logfile.read().find(foamBanner) >= 0:
+            print d["StdOut"]

query_slurm_check.py

@@ -0,0 +1,15 @@
+import subprocess as sp
+
+USER = 'ignis'
+
+idlist = sp.check_output('squeue -h -u {} -o "%i"'.format(USER), shell=True).split()
+
+foamBanner='F ield         | OpenFOAM: The Open Source CFD Toolbox'
+
+for sid in idlist:
+    a = sp.check_output('scontrol show job {}'.format(sid), shell=True).split()
+    d = {aa.split("=")[0]: aa.split("=")[-1] for aa in a}
+
+    with open(d["StdOut"]) as logfile:
+        if logfile.read().find(foamBanner) >= 0:
+            print d["StdOut"]

reconstruct_cases.sh

@@ -0,0 +1,12 @@
+#!/bin/bash
+
+name=summary.`date --rfc-3339=seconds` 
+
+source $HOME/.bashrc
+source ~/OpenFOAM/OpenFOAM-2.4.x/etc/bashrc WM_NCOMPPROCS=32; source ~/OpenFOAM/cantera/bin/setup_cantera
+
+for lfile in `cat /home/ignis/log_notification_mailer/sample.list`
+do
+find $lfile/processor* -name h | xargs rm
+reconstructPar -latestTime -case $lfile
+done