marcel/pylot
3
0
Fork 0
Code Issues 7 Pull Requests 1 Releases Wiki Activity

restructuring for parallization

Browse Source
This commit is contained in:
Marcel Paffrath 2016-05-23 11:23:23 +02:00
parent 1f47f3dd85
commit 73d71a61d5
1 changed files with 26 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
pylot/core/active/activeSeismoPick.py
View File

@ -216,45 +216,42 @@ class Survey(object):
for shot in self.data.values(): for shot in self.data.values():
tstartpick = datetime.now(); tstartpick = datetime.now();
shot.setVmin(vmin)
shot.setVmax(vmax)
count += 1 count += 1
for traceID in shot.getTraceIDlist(): shot.pickParallel(folm)
distance = shot.getDistance(traceID) # receive distance
pickwin_used = shot.getCut() # tpicksum += (datetime.now() - tstartpick);
cutwindow = shot.getCut() # tpick = tpicksum / count
# tremain = (tpick * (len(self.getShotDict()) - count))
# tend = datetime.now() + tremain
# progress = float(count) / float(len(self.getShotDict())) * 100
# self._update_progress(shot.getShotname(), tend, progress)
# for higher distances use a linear vmin/vmax to cut out late/early regions with high noise self.setSNR()
if distance > 5.: self.setEarllate()
pwleft = distance / vmax ################## TEST
pwright = distance / vmin
if pwright > cutwindow[1]:
pwright = cutwindow[1]
pickwin_used = (pwleft, pwright)
shot.setPickwindow(traceID, pickwin_used)
shot.pickTraces(traceID, folm, HosAic, aicwindow) # picker
shot.setSNR(traceID)
# if shot.getSNR(traceID)[0] < snrthreshold:
if shot.getSNR(traceID)[0] < shot.getSNRthreshold(traceID):
shot.removePick(traceID)
# set epp and lpp if SNR > 1 (else earllatepicker cant set values)
if shot.getSNR(traceID)[0] > 1:
shot.setEarllatepick(traceID)
tpicksum += (datetime.now() - tstartpick);
tpick = tpicksum / count
tremain = (tpick * (len(self.getShotDict()) - count))
tend = datetime.now() + tremain
progress = float(count) / float(len(self.getShotDict())) * 100
self._update_progress(shot.getShotname(), tend, progress)
print('\npickAllShots: Finished\n') print('\npickAllShots: Finished\n')
ntraces = self.countAllTraces() ntraces = self.countAllTraces()
pickedtraces = self.countAllPickedTraces() pickedtraces = self.countAllPickedTraces()
print('Picked %s / %s traces (%d %%)\n' print('Picked %s / %s traces (%d %%)\n'
% (pickedtraces, ntraces, float(pickedtraces) / float(ntraces) * 100.)) % (pickedtraces, ntraces, float(pickedtraces) / float(ntraces) * 100.))
def setSNR(self):
for shot in self.data.values():
for traceID in shot.getTraceIDlist():
shot.setSNR(traceID)
# if shot.getSNR(traceID)[0] < snrthreshold:
if shot.getSNR(traceID)[0] < shot.getSNRthreshold(traceID):
shot.removePick(traceID)
def setEarllate(self):
for shot in self.data.values():
for traceID in shot.getTraceIDlist():
# set epp and lpp if SNR > 1 (else earllatepicker cant set values)
if shot.getSNR(traceID)[0] > 1:
shot.setEarllatepick(traceID)
def cleanBySPE(self, maxSPE): def cleanBySPE(self, maxSPE):
''' '''
Sets all picks as invalid if they exceed a certain value of the symmetric pick error. Sets all picks as invalid if they exceed a certain value of the symmetric pick error.