...
I create a temporary data strcuture ,each time the scoreboarding function is called in JKFlow.pm for a particular flowflile and then for a particular direction , and store the values of $ref->{aggdata}{tuplevalues} as well as certain other important variables representing the state of scoreboard including the $ref-> {count}, $ref->{startperiod}and $ref->{counter} in that data strcuture. It is then marshalled and written to disk using the technique i explained on this page.
The checkpoints are written such that there is a single checkpoint for each type of report and it is updated for each flow-file. e.g. I have shown the score directory for a particular monitored direction below:
| Code Block |
|---|
akbar@iepm-resp $ pwd
/u1/flows/score/USATLAS Computing Farm - CERN
akbar@iepm-resp $
akbar@iepm-resp $ ls -ahl
total 32K
drwxr-xr-x 4 akbar sg 4.0K May 8 00:01 ./
drwxr-xr-x 94 akbar sg 4.0K May 8 00:01 ../
-rw-r--r-- 1 akbar sg 561 May 8 00:01 1440checkpoint.dat
-rw-r--r-- 1 akbar sg 561 May 8 00:01 15checkpoint.dat
drwxr-xr-x 2 akbar sg 4.0K May 8 00:01 2007-03-21/
-rw-r--r-- 1 akbar sg 561 May 8 00:01 360checkpoint.dat
-rw-r--r-- 1 akbar sg 561 May 8 00:01 60checkpoint.dat
drwxr-xr-x 3 akbar sg 4.0K May 8 00:01 other/
akbar@iepm-resp $
|