Commit bac862ba authored by Alessandro Mirone's avatar Alessandro Mirone

speedup

parent b6f761b9
......@@ -918,12 +918,13 @@ class Processing_Transposing(ProcessingBaseClass):
ntoktreated = self.resources["TreatedDataResources"] .tokenperpacketid[pid]
ntoktransposed = self.resources["TransposedDataResources"].tokenperpacketid[pid]
C.transpose_chunk(psn, ntoktreated, ntoktransposed, NPBUNCHES, self.STEAM_DIRECTION )
print(" TRANSP OK")
self.event.set()
else:
self.event.clear()
self.event.wait()
print(" finito")
class Processing_Dispenser(ProcessingBaseClass):
num_of_algorithms=1
......@@ -1004,6 +1005,7 @@ class Processing_Reconstructing(ProcessingBaseClass):
pid_i = psn % NPBUNCHES
ncpus , mygpus = self.resources["SiliciumResources"].resourcesForPacket[psn]
print("RECONS")
C.reconstruct(psn, NPBUNCHES , ncpus, self.STEAM_DIRECTION )
......
This diff is collapsed.
......@@ -2550,9 +2550,9 @@ def Postprocess(Cspace):
sat1,sat2 , Sat1, Sat2= Cspace.getSaturations(aMin,aMax)
# print( sat1,sat2 , Sat1, Sat2)
print( sat1,sat2 , Sat1, Sat2)
# print( " strings", myrank )
print( " strings", myrank )
Parameters.saturations = (sat1,sat2 , Sat1, Sat2)
......
......@@ -30,5 +30,5 @@
# is a problem for you.
#############################################################################*/
version = "2020b"
version = "2020a"
......@@ -42,16 +42,12 @@ mailserver = None
# LAUNCHING_INSTRUCTION = "echo 'localhost\n' > machinefile ; time PyHST2_2017c input.par gpu2-1304,0"
# LAUNCHING_INSTRUCTION = "time PyHST2_2018b input.par scisoft13,0 | tee output"
LAUNCHING_INSTRUCTION = "PyHST2_2019b input.par | tee output"
outputprefix="/data/scisofttmp/mirone/TEST_PYHST/RESULTS/slurm_2019b/"
# outputprefix="/data/scisofttmp/mirone/TEST_PYHST/RESULTS/2017c/2gpu_bis/tests"
# outputprefix="/data/scisofttmp/paleo/TEST_PYHST/DATASETS_RED/OUTPUTS"
inputprefix ="INPUTS"
PREFIX="/scisoft/users/mirone/WORKS/TEST_PYHST/DATASETS"
CASI_DISTRIBUTED = ["NNFBP", "CRAYON", "ID11_SNOW", "LENA_MULTIRINGS", "MULTIPAGANIN", "PATCHES_VECTORIAL", "SIRT_LENA"]
......@@ -66,12 +62,11 @@ CASI_partial = [ "ID11_SNOW", "LENA", "LENA_MULTIRINGS", "MOUSSE", "MULTIP
casi = [ "ID11_SNOW" ]
##################################################
PREFIX="/home/mirone/WORKS/TEST_PYHST/DATASETS"
PREFIX="/scisoft/users/mirone/WORKS/TEST_PYHST/DATASETS"
PREFIX="/home/esrf/mirone/WORKS/TEST_PYHST/DATASETS"
casi=["CRAYON"]
LAUNCHING_INSTRUCTION = "PyHST2_2019b input.par "
outputprefix="/home/mirone/TEST_PYHST/RESULTS/slurm_2019b/"
outputprefix="/data/scisofttmp/mirone/TEST_PYHST/RESULTS/slurm_2019b/"
LAUNCHING_INSTRUCTION = "PyHST2_2020a input.par p9-04,0"
outputprefix="/home/esrf/mirone/nobackup/TEST_PYHST/RESULTS/p9-04/"
# outputprefix="/tmp/TEST_PYHST/RESULTS/p9-04/"
###############################################################
......@@ -120,7 +115,6 @@ for root, dirnames, filenames in os.walk(inputprefix):
for filename in fnmatch.filter(filenames, 'input.par'):
matches.append(os.path.join(root, filename))
print matches
repertori = []
......@@ -135,18 +129,17 @@ for caso in casi:
inpcut = inpcut[:pL]
if inpcut == caso:
matches.append(inp)
print matches
for inp in matches:
print inp
print( inp)
pL = inp.find("/")
pR = inp.rfind("/")
direttorio = os.path.join(outputprefix,inp[pL+1:pR])
filename = inp[pR+1:]
print direttorio
print filename
print( direttorio)
print( filename)
if not os.path.exists(direttorio):
os.makedirs(direttorio)
......@@ -173,7 +166,7 @@ for d in repertori:
l=adapt(l, prefix)
S=S+l+"\n"
open("input_adapted.par","w").write(S)
print S
print( S)
if(1):
s=open("input.par","r").read()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment