HWRF
trunk@4391
|
Runs regribbing operations on the output of exhwrf_products, and runs the GFDL vortex tracker on the regribbed output. More...
Runs regribbing operations on the output of exhwrf_products, and runs the GFDL vortex tracker on the regribbed output.
Note that this script is restartable: if it fails, and you call it again, it will pick up where it left off. To force a reprocessing of the entire post-processing system, call exhwrf_unpost first.
Functions | |
def | gribber () |
Runs the hwrf.gribtask.GRIBTask on one thread. More... | |
def | tracker (n) |
Runs the hwrf.tracker.TrackerTask on one thread. More... | |
def | copier () |
Runs the hwrf.copywrf.WRFCopyTask to copy native WRF input and output files to COM, and then runs the gribber(). More... | |
def | products () |
Runs the hwrf.nhc_products.NHCProducts on multiple threads. More... | |
def | wavepost () |
def | starter (dryrun) |
Main program for subprocesses. More... | |
def | slave_main () |
This is run multiple times in parallel, once in each subprocess. More... | |
def | launchself () |
Launches an MPI program that will call this script in multiple threads using the mpiserial program. More... | |
def | doit () |
Main entry point. More... | |
def scripts.exhwrf_products.copier | ( | ) |
Runs the hwrf.copywrf.WRFCopyTask to copy native WRF input and output files to COM, and then runs the gribber().
Does this on one thread.
Definition at line 49 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.starter().
def scripts.exhwrf_products.doit | ( | ) |
Main entry point.
Slave processes (launched by mpiserial) just call slave_main to pass control on to tracker(), gribber() or copier(). The main process (which calls mpiserial) will wait for mpiserial to exit, and then run the products() function.
Definition at line 198 of file exhwrf_products.py.
def scripts.exhwrf_products.gribber | ( | ) |
Runs the hwrf.gribtask.GRIBTask on one thread.
Definition at line 21 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.copier(), and scripts.exhwrf_products.starter().
def scripts.exhwrf_products.launchself | ( | ) |
Launches an MPI program that will call this script in multiple threads using the mpiserial program.
Definition at line 186 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.doit().
def scripts.exhwrf_products.products | ( | ) |
Runs the hwrf.nhc_products.NHCProducts on multiple threads.
Definition at line 65 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.doit().
def scripts.exhwrf_products.slave_main | ( | ) |
This is run multiple times in parallel, once in each subprocess.
It sets up the environment and logging settings and then runs the starter() function.
Definition at line 140 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.doit().
def scripts.exhwrf_products.starter | ( | dryrun | ) |
Main program for subprocesses.
Calls tracker() for the last one or three threads (depending on whether extra_trackers=yes in the [config] section). Calls copier() for the last non-tracker rank. Calls the gribber() on all other ranks.
Definition at line 87 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.slave_main().
def scripts.exhwrf_products.tracker | ( | n | ) |
Runs the hwrf.tracker.TrackerTask on one thread.
n | the domain of interest: 1 2 or 3 |
Definition at line 32 of file exhwrf_products.py.
Referenced by scripts.exhwrf_products.starter().