Changeset 30586 for branches/czw_branch/20101203/ippTasks
- Timestamp:
- Feb 11, 2011, 4:29:48 PM (15 years ago)
- Location:
- branches/czw_branch/20101203
- Files:
-
- 14 edited
- 1 copied
-
. (modified) (1 prop)
-
ippTasks (modified) (1 prop)
-
ippTasks/Makefile.am (modified) (1 diff)
-
ippTasks/addstar.pro (modified) (1 diff)
-
ippTasks/diff.pro (modified) (3 diffs)
-
ippTasks/diskbalance.pro (modified) (1 diff)
-
ippTasks/dist.pro (modified) (7 diffs)
-
ippTasks/ipphosts.mhpcc.config (modified) (9 diffs)
-
ippTasks/magic.cleanup.pro (copied) (copied from trunk/ippTasks/magic.cleanup.pro )
-
ippTasks/nightly_science.pro (modified) (32 diffs)
-
ippTasks/pstamp.pro (modified) (4 diffs)
-
ippTasks/publish.pro (modified) (3 diffs)
-
ippTasks/rcserver.pro (modified) (1 diff)
-
ippTasks/register.pro (modified) (11 diffs)
-
ippTasks/survey.pro (modified) (9 diffs)
Legend:
- Unmodified
- Added
- Removed
-
branches/czw_branch/20101203
- Property svn:mergeinfo changed
-
branches/czw_branch/20101203/ippTasks
-
Property svn:mergeinfo
set to
/branches/eam_branches/ipp-20101103/ippTasks merged eligible /trunk/ippTasks merged eligible
-
Property svn:mergeinfo
set to
-
branches/czw_branch/20101203/ippTasks/Makefile.am
r30018 r30586 17 17 warp.pro \ 18 18 magic.pro \ 19 magic.cleanup.pro \ 19 20 destreak.pro \ 20 21 destreak.cleanup.pro \ -
branches/czw_branch/20101203/ippTasks/addstar.pro
r28211 r30586 173 173 $run = $run --minidvodb_group $MINIDVODB_GROUP 174 174 if (("$MINIDVODB_NAME" != "NULL") && ("$MINIDVODB_NAME" != "(null)")) 175 $run = $run --minidvodb_name $MINIDVODB_NAME #have addstar_run.pl grab the 'active' name if it is NULL 175 $run = $run --minidvodb_name $MINIDVODB_NAME 176 #have addstar_run.pl grab the 'active' name if it is NULL 176 177 end 177 178 end -
branches/czw_branch/20101203/ippTasks/diff.pro
r28375 r30586 45 45 end 46 46 task diff.revert 47 active false47 active true 48 48 end 49 49 task diff.summary.load … … 448 448 periods -timeout 120.0 449 449 npending 1 450 active false451 450 452 451 stdout NULL … … 457 456 # Only revert failures with fault=2 (SYS_ERROR), which tend to be 458 457 # temporary filesystem problems. Every other fault type is 459 # interesting and should be kept for debugging (and so it does n't458 # interesting and should be kept for debugging (and so it does not 460 459 # continue to occur). 461 $run = difftool -revertdiffskyfile -fault 2 460 # XXX: actually we are getting enough jobs with fault 4 that work after reverting 461 # that we are going to remove that cut for now 462 # 463 #$run = difftool -revertdiffskyfile -fault 2 464 $run = difftool -revertdiffskyfile 462 465 if ($DB:n == 0) 463 466 option DEFAULT -
branches/czw_branch/20101203/ippTasks/diskbalance.pro
r29631 r30586 194 194 book getword balancePending $pageName source_name -var SOURCE 195 195 book getword balancePending $pageName destination_name -var DESTINATION 196 196 book getword balancePending $pageName destination_host -var DEST_HOST 197 197 # Fix this with multihost restriction when possible. 198 set.host.for.balance $DEST INATION198 set.host.for.balance $DEST_HOST 199 199 200 200 stdout NULL -
branches/czw_branch/20101203/ippTasks/dist.pro
r29386 r30586 61 61 end 62 62 task dist.revert 63 active false63 active true 64 64 end 65 65 end … … 95 95 end 96 96 97 # This is now only used if we are not using a nebulous outroot 97 98 macro get.host.for.component 98 99 if ($0 != 3) … … 122 123 end 123 124 125 # This is now only used if we are not using a nebulous outroot 124 126 macro set.dist.workdir.by.component 125 127 if ($0 != 5) … … 139 141 book getword ipphosts distribution count -var count 140 142 if ("$count" == "NULL") 141 echo "ERROR: distributi n hosts list is empty"143 echo "ERROR: distribution hosts list is empty" 142 144 break 143 145 end … … 289 291 end 290 292 291 292 set.dist.workdir.by.component $DIST_STAGE_ID $COMPONENT $OUTDIR_TEMPLATE OUTDIR293 if ("$OUTDIR" == "NULL")294 echo ERROR failed to set workdir for $COMPONENT295 break296 end297 298 293 substr $COMPONENT 0 3 COMP_HEAD 299 294 if ("$COMP_HEAD" == "sky") 300 295 set.host.for.skycell $COMPONENT 296 set.workdir.by.skycell $COMPONENT $OUTDIR_TEMPLATE $default_host OUTDIR 301 297 else 302 # assume component is a class_id, if not we will default to anyhost 298 # assume component is a class_id, if it is not we will default to 299 # host "anyhost" 300 # and volume "any" 303 301 set.host.for.camera $CAMERA $COMPONENT 302 set.workdir.by.camera $CAMERA $COMPONENT $OUTDIR_TEMPLATE $default_host OUTDIR 303 end 304 305 if ("$OUTDIR" == "NULL") 306 echo ERROR failed to set workdir for $COMPONENT 307 break 304 308 end 305 309 306 310 sprintf logfile "%s/dist.%s.%s.log" $OUTDIR $DIST_ID $COMPONENT 307 # stdout $logfile308 # stderr $logfile309 311 310 312 $run = dist_component.pl --dist_id $DIST_ID --camera $CAMERA --stage $DIST_STAGE --stage_id $DIST_STAGE_ID --component $COMPONENT --path_base $PATH_BASE --chip_path_base $CHIP_PATH_BASE --state $STATE --data_state $DATA_STATE $EXTRA_ARGS --outdir $OUTDIR --logfile $logfile … … 401 403 book getpage distToAdvance 0 -var pageName -key pantaskState INIT 402 404 if ("$pageName" == "NULL") break 405 406 # XXX the sql for disttool -toadvance does not include the camera: 407 # hack around this for now 408 $CAMERA = GPC1 403 409 404 410 book setword distToAdvance $pageName pantaskState RUN … … 414 420 end 415 421 416 host anyhost 417 418 # using $DIST_ID as the "component" works fine here since we only look 419 # at the last two digits. But make sure that there 2 digits 420 $fake_component = $STAGE_ID + 10 421 set.dist.workdir.by.component $fake_component "exposure" $OUTDIR_TEMPLATE OUTDIR 422 substr $OUTDIR_TEMPLATE 0 3 SCHEME 423 if ("$SCHEME" == "neb") 424 # XXX This does not work if workdir is not in nebulous 425 # and $default_host == "any" because /data/any does not exist 426 # use "dummy" as component. Result will be 'any' 427 # set.workdir.by.camera $CAMERA dummy $OUTDIR_TEMPLATE $default_host OUTDIR 428 set.workdir.by.camera GPC1 dummy $OUTDIR_TEMPLATE $default_host OUTDIR 429 else 430 # using $DIST_ID as the "component" works fine here since we only look 431 # at the last two digits. But make sure that there 2 digits 432 $fake_component = $STAGE_ID + 10 433 set.dist.workdir.by.component $fake_component "exposure" $OUTDIR_TEMPLATE OUTDIR 434 end 435 422 436 if ("$OUTDIR" == "NULL") 423 437 echo ERROR failed to set workdir for $DIST_ID 424 438 break 425 439 end 440 host anyhost 426 441 427 442 sprintf logfile "%s/dist.advance.%s.log" $OUTDIR $DIST_ID 428 # stdout $logfile 429 # stderr $logfile 430 431 $run = dist_advancerun.pl --dist_id $DIST_ID --stage $STAGE --stage_id $STAGE_ID --outdir $OUTDIR $EXTRA_ARGS --logfile $logfile 443 444 $run = dist_advancerun.pl --dist_id $DIST_ID --stage $STAGE --stage_id $STAGE_ID --camera $CAMERA --outdir $OUTDIR $EXTRA_ARGS --logfile $logfile 432 445 add_standard_args run 433 446 -
branches/czw_branch/20101203/ippTasks/ipphosts.mhpcc.config
r28500 r30586 22 22 sky09 STR ipp014 23 23 sky10 STR ipp015 24 sky11 STR ipp0 1624 sky11 STR ipp006 25 25 sky12 STR ipp017 26 26 sky13 STR ipp018 … … 125 125 XY26 STR ipp027 126 126 XY27 STR ipp028 127 XY30 STR ipp0 16127 XY30 STR ipp006 128 128 XY31 STR ipp044 129 129 … … 204 204 ota26 STR ipp027 205 205 ota27 STR ipp028 206 ota30 STR ipp0 16206 ota30 STR ipp006 207 207 ota31 STR ipp044 208 208 … … 298 298 XY11 STR ipp039 299 299 300 XY12 STR ipp00 9300 XY12 STR ipp005 301 301 XY13 STR ipp024 302 302 XY14 STR ipp010 … … 305 305 XY16 STR ipp011 306 306 XY17 STR ipp026 307 XY20 STR ipp0 12307 XY20 STR ipp006 308 308 XY21 STR ipp041 309 309 310 310 XY22 STR ipp013 311 311 XY23 STR ipp042 312 XY24 STR ipp0 14312 XY24 STR ipp007 313 313 XY25 STR ipp043 314 314 315 315 XY26 STR ipp027 316 316 XY27 STR ipp028 317 XY30 STR ipp0 16317 XY30 STR ipp006 318 318 XY31 STR ipp044 319 319 … … 358 358 XY72 STR ipp052 359 359 360 XY73 STR ipp0 53360 XY73 STR ipp007 361 361 XY74 STR ipp015 362 362 XY75 STR ipp025 … … 371 371 sky02 STR ipp007 372 372 sky03 STR ipp008 373 sky04 STR ipp00 9373 sky04 STR ipp005 374 374 sky05 STR ipp010 375 375 sky06 STR ipp011 376 sky07 STR ipp0 12376 sky07 STR ipp006 377 377 sky08 STR ipp013 378 sky09 STR ipp0 14378 sky09 STR ipp007 379 379 sky10 STR ipp015 380 sky11 STR ipp0 16380 sky11 STR ipp006 381 381 sky12 STR ipp017 382 382 sky13 STR ipp018 … … 414 414 sky45 STR ipp051 415 415 sky46 STR ipp052 416 sky47 STR ipp0 53416 sky47 STR ipp007 417 417 sky48 STR ipp023 418 418 sky49 STR ipp024 … … 445 445 sky76 STR ipp051 446 446 sky77 STR ipp052 447 sky78 STR ipp0 53448 END 447 sky78 STR ipp006 448 END -
branches/czw_branch/20101203/ippTasks/nightly_science.pro
r30018 r30586 7 7 ns.detrends.off 8 8 ns.dqstats.on 9 # ns.sweetspot.on10 # ns.registration.on11 # ns.burntool.on12 # ns.chips.on13 9 ns.stacks.on 14 10 ns.diffs.on … … 19 15 ns.detrends.off 20 16 ns.dqstats.off 21 # ns.sweetspot.off22 # ns.registration.off23 # ns.burntool.off24 # ns.chips.off25 17 ns.stacks.off 26 18 ns.diffs.off … … 53 45 end 54 46 55 # macro ns.sweetspot.on56 # task ns.sweetspot.load57 # active true58 # end59 # end60 61 # macro ns.registration.on62 # task ns.registration.load63 # active true64 # end65 # end66 67 # macro ns.burntool.on68 # task ns.burntool.load69 # active true70 # end71 # task ns.burntool.run72 # active true73 # end74 # end75 76 # macro ns.chips.on77 # task ns.chips.load78 # active true79 # end80 # task ns.chips.run81 # active true82 # end83 # end84 85 47 macro ns.stacks.on 86 48 task ns.stacks.load … … 91 53 end 92 54 task ns.stacks.confirm 93 active true55 active false 94 56 end 95 57 end … … 122 84 end 123 85 124 # macro ns.sweetspot.off125 # task ns.sweetspot.load126 # active false127 # end128 # end129 130 # macro ns.registration.off131 # task ns.registration.load132 # active false133 # end134 # end135 136 # macro ns.burntool.off137 # task ns.burntool.load138 # active false139 # end140 # task ns.burntool.run141 # active false142 # end143 # end144 145 # macro ns.chips.off146 # task ns.chips.load147 # active false148 # end149 # task ns.chips.run150 # active false151 # end152 # end153 154 86 macro ns.stacks.off 155 87 task ns.stacks.load … … 159 91 active false 160 92 end 93 task ns.stacks.confirm 94 active false 95 end 96 161 97 end 162 98 … … 170 106 end 171 107 172 # $ns_regPAGE = 0 173 # $ns_burnPAGE = 0 174 # $ns_RburnPAGE = 0 175 # $ns_RburnCELL = 0 176 # $ns_chipPAGE = 0 177 # $ns_RchipPAGE = 0 108 macro ns.stacks.confirm.on 109 task ns.stacks.confirm 110 active true 111 end 112 end 113 114 macro ns.stacks.confirm.off 115 task ns.stacks.confirm 116 active false 117 end 118 end 119 120 178 121 $ns_stackPAGE = 0 179 122 $ns_RstackPAGE = 0 … … 183 126 184 127 book init nsData 128 book init nsDiffs 129 book init nsStacks 185 130 # 186 131 # Macros to control the book. 187 132 # 188 133 macro ns.add.date 134 if ($0 != 2) 135 echo "USAGE: ns.add.date (YYYY-MM-DD)" 136 break 137 end 138 189 139 book newpage nsData $1 190 140 book setword nsData $1 nsState NEW 191 book setword nsData $1 nsStackState TOWARP 192 book setword nsData $1 nsDiffState TOWARP 141 book setword nsData $1 dbname $DB:0 142 143 book newpage nsDiffs $1 144 book setword nsDiffs $1 nsDiffState TOWARP 145 book setword nsDiffs $1 nsObservingState UNKNOWN 146 147 book newpage nsStacks $1 148 book setword nsStacks $1 nsStackState TOWARP 149 193 150 end 194 151 … … 198 155 book getpage nsData $i -var date 199 156 book getword nsData $date nsState -var state 200 book getword ns Data$date nsStackState -var Sstate201 book getword nsD ata$date nsDiffState -var Dstate202 book getword nsD ata$date nsObservingState -var Ostate157 book getword nsStacks $date nsStackState -var Sstate 158 book getword nsDiffs $date nsDiffState -var Dstate 159 book getword nsDiffs $date nsObservingState -var Ostate 203 160 echo $date $state $Sstate $Dstate $Ostate 204 161 end … … 212 169 book setword nsData $1 nsState $2 213 170 end 214 215 171 216 172 … … 232 188 book newpage nsData $today 233 189 book setword nsData $today nsState NEW 234 book setword nsData $today nsStackState TOWARP 235 book setword nsData $today nsDiffState TOWARP 190 book newpage nsStacks $today 191 book setword nsStacks $today nsStackState TOWARP 192 book newpage nsDiffs $today 193 book setword nsDiffs $today nsDiffState TOWARP 236 194 book setword nsData $today dbname $DB:0 237 195 238 196 # command echo $today 239 command nightly_science.pl --clean_old --date $today --dbname $DB:0 197 $run = nightly_science.pl --clean_old --date $today --dbname $DB:0 198 # add_standard_args run 199 command $run 240 200 end 241 201 … … 272 232 $today = `date -u +%Y-%m-%d` 273 233 274 command nightly_science.pl --queue_detrends --date $today --dbname $DB:0 275 add_standard_args 234 $run = nightly_science.pl --queue_detrends --date $today --dbname $DB:0 235 # add_standard_args $run 236 command $run 276 237 end 277 238 … … 309 270 $today = `date -u +%Y-%m-%d` 310 271 311 command nightly_science.pl --queue_dqstats --date $today --dbname $DB:0 312 add_standard_args 272 $run = nightly_science.pl --queue_dqstats --date $today --dbname $DB:0 273 # add_standard_args $run 274 command $run 275 313 276 end 314 277 … … 333 296 # 334 297 task ns.stacks.load 298 active false 335 299 host local 336 300 periods -poll $LOADPOLL … … 344 308 345 309 book getpage nsData $ns_stackPAGE -var date 346 book getword nsData $date nsStackState -var ns_STATE 347 book getword nsData $date dbname -var $DBNAME 310 book getword nsStacks $date nsStackState -var ns_STATE 311 book getword nsDiffs $date nsDiffState -var ns_diff_STATE 312 book getword nsData $date dbname -var DBNAME 348 313 book npages nsData -var Npages 349 314 … … 358 323 if ("$ns_STATE" != "TOWARP") break 359 324 360 $run = nightly_science.pl --check_stacks --date $date 361 add_standard_args 325 $run = nightly_science.pl --check_stacks --date $date --dbname $DBNAME 326 # add_standard_args $run 362 327 command $run 363 328 … … 367 332 task.exit 0 368 333 # convert 'stdout' to book format 369 book delpage ns Data$options:0370 ipptool2book stdout ns Data-uniq -key date371 372 book getword ns Data$options:0 nsNmacros -var ns_Nmacros334 book delpage nsStacks $options:0 335 ipptool2book stdout nsStacks -uniq -key date 336 337 book getword nsStacks $options:0 nsNmacros -var ns_Nmacros 373 338 if ("$ns_Nmacros" != "NULL") 374 339 for i 0 $ns_Nmacros 375 340 sprintf macroName "ns%dMacro" $i 376 book getword ns Data$options:0 $macroName -var macroCmd341 book getword nsStacks $options:0 $macroName -var macroCmd 377 342 $macroCmd 378 343 end … … 413 378 414 379 book getpage nsData $ns_RstackPAGE -var date 415 book getword nsData $date nsStackState -var ns_STATE 416 book getword nsData $date dbname -var $DBNAME 380 book getword nsStacks $date nsStackState -var ns_STATE 381 book getword nsDiffs $date nsDiffState -var ns_diff_STATE 382 book getword nsData $date dbname -var DBNAME 417 383 book npages nsData -var Npages 418 384 … … 425 391 option $date 426 392 427 if (("$ns_STATE" != " QUEUESTACKS")&&("$ns_STATE" != "TOWARP")&&("$ns_STATE" != "FORCETOWARP")) break428 $run = nightly_science.pl --queue_stacks --date $date 429 add_standard_args 393 if (("$ns_STATE" != "STACKING")&&("$ns_STATE" != "TOWARP")&&("$ns_STATE" != "FORCETOWARP")) break 394 $run = nightly_science.pl --queue_stacks --date $date --dbname $DBNAME 395 # add_standard_args $run 430 396 command $run 431 397 end … … 433 399 task.exit 0 434 400 # convert 'stdout' to book format 435 book delpage ns Data$options:0401 book delpage nsStacks $options:0 436 402 # We've queued up stacking. We're done with this date, so don't reload the page. 437 ipptool2book stdout ns Data-uniq -key date438 439 book getword ns Data$options:0 nsNmacros -var ns_Nmacros403 ipptool2book stdout nsStacks -uniq -key date 404 405 book getword nsStacks $options:0 nsNmacros -var ns_Nmacros 440 406 if ("$ns_Nmacros" != "NULL") 441 407 for i 0 $ns_Nmacros 442 408 sprintf macroName "ns%dMacro" $i 443 book getword ns Data$options:0 $macroName -var macroCmd409 book getword nsStacks $options:0 $macroName -var macroCmd 444 410 $macroCmd 445 411 end … … 468 434 # 469 435 task ns.stacks.confirm 436 active false 470 437 host local 471 438 periods -poll $LOADPOLL … … 479 446 480 447 book getpage nsData $ns_CstackPAGE -var date 481 book getword ns Data$date nsStackState -var ns_STATE482 book getword nsData $date dbname -var $DBNAME448 book getword nsStacks $date nsStackState -var ns_STATE 449 book getword nsData $date dbname -var DBNAME 483 450 book npages nsData -var Npages 484 451 … … 492 459 493 460 if ("$ns_STATE" != "STACKING") break 494 $run = nightly_science.pl --confirm_stacks --date $date 495 add_standard_args 461 $run = nightly_science.pl --confirm_stacks --date $date --dbname $DBNAME 462 # add_standard_args $run 496 463 command $run 497 464 end … … 499 466 task.exit 0 500 467 # convert 'stdout' to book format 501 book delpage ns Data$options:0502 ipptool2book stdout ns Data-uniq -key date503 504 book getword ns Data$options:0 nsNmacros -var ns_Nmacros468 book delpage nsStacks $options:0 469 ipptool2book stdout nsStacks -uniq -key date 470 471 book getword nsStacks $options:0 nsNmacros -var ns_Nmacros 505 472 if ("$ns_Nmacros" != "NULL") 506 473 for i 0 $ns_Nmacros 507 474 sprintf macroName "ns%dMacro" $i 508 book getword ns Data$options:0 $macroName -var macroCmd475 book getword nsStacks $options:0 $macroName -var macroCmd 509 476 $macroCmd 510 477 end … … 534 501 # 535 502 task ns.diffs.load 503 active false 536 504 host local 537 505 periods -poll $LOADPOLL … … 545 513 546 514 book getpage nsData $ns_diffPAGE -var date 547 book getword nsData $date nsDiffState -var ns_STATE 548 book getword nsData $date dbname -var $DBNAME 515 book getword nsDiffs $date nsDiffState -var ns_STATE 516 book getword nsStacks $date nsStackState -var ns_stack_STATE 517 book getword nsData $date dbname -var DBNAME 549 518 book npages nsData -var Npages 550 519 … … 558 527 559 528 if ("$ns_STATE" != "TOWARP") break 560 $run = nightly_science.pl --check_diffs --date $date 561 add_standard_args 529 $run = nightly_science.pl --check_diffs --date $date --dbname $DBNAME 530 # add_standard_args $run 562 531 command $run 563 532 end … … 566 535 task.exit 0 567 536 # convert 'stdout' to book format 568 book delpage nsD ata$options:0569 ipptool2book stdout nsD ata-uniq -key date570 571 book getword nsD ata$options:0 nsNmacros -var ns_Nmacros537 book delpage nsDiffs $options:0 538 ipptool2book stdout nsDiffs -uniq -key date 539 540 book getword nsDiffs $options:0 nsNmacros -var ns_Nmacros 572 541 if ("$ns_Nmacros" != "NULL") 573 542 for i 0 $ns_Nmacros 574 543 sprintf macroName "ns%dMacro" $i 575 book getword nsD ata$options:0 $macroName -var macroCmd544 book getword nsDiffs $options:0 $macroName -var macroCmd 576 545 $macroCmd 577 546 end … … 604 573 periods -poll $LOADPOLL 605 574 periods -exec $LOADEXEC 606 periods -timeout 120575 periods -timeout 900 607 576 npending 1 608 577 … … 612 581 613 582 book getpage nsData $ns_RdiffPAGE -var date 614 book getword nsData $date nsDiffState -var ns_STATE 615 book getword nsData $date dbname -var $DBNAME 583 book getword nsDiffs $date nsDiffState -var ns_STATE 584 book getword nsStacks $date nsStackState -var ns_stack_STATE 585 book getword nsData $date dbname -var DBNAME 616 586 book npages nsData -var Npages 617 587 … … 624 594 option $date 625 595 626 if (("$ns_STATE" != " QUEUEDIFFS")&&("$ns_STATE" != "TOWARP")&&("$ns_STATE" != "FORCETOWARP")) break627 $run = nightly_science.pl --queue_diffs --date $date 628 add_standard_args 596 if (("$ns_STATE" != "DIFFING")&&("$ns_STATE" != "QUEUEDIFFS")&&("$ns_STATE" != "TOWARP")&&("$ns_STATE" != "FORCETOWARP")) break 597 $run = nightly_science.pl --queue_diffs --date $date --dbname $DBNAME 598 # add_standard_args $run 629 599 command $run 630 600 end … … 632 602 task.exit 0 633 603 # convert 'stdout' to book format 634 book delpage nsD ata$options:0604 book delpage nsDiffs $options:0 635 605 # We've queued up diffing. We're done with this date, so don't reload the page. 636 ipptool2book stdout nsD ata-uniq -key date637 638 book getword nsD ata$options:0 nsNmacros -var ns_Nmacros606 ipptool2book stdout nsDiffs -uniq -key date 607 608 book getword nsDiffs $options:0 nsNmacros -var ns_Nmacros 639 609 if ("$ns_Nmacros" != "NULL") 640 610 for i 0 $ns_Nmacros 641 611 sprintf macroName "ns%dMacro" $i 642 book getword nsD ata$options:0 $macroName -var macroCmd612 book getword nsDiffs $options:0 $macroName -var macroCmd 643 613 $macroCmd 644 614 end -
branches/czw_branch/20101203/ippTasks/pstamp.pro
r29719 r30586 148 148 end 149 149 150 macro pstamp.status.on 151 task pstamp.save.status 152 active true 153 end 154 end 155 macro pstamp.status.off 156 task pstamp.save.status 157 active false 158 end 159 end 160 macro pstamp.status.set.exec 161 task pstamp.save.status 162 periods -exec $1 163 end 164 end 165 150 166 task pstamp.request.find 151 167 host local … … 258 274 book getword pstampRequest $pageName ds_outProduct -var PRODUCT 259 275 book getword pstampRequest $pageName outdir -var OUTDIR 276 book getword pstampRequest $pageName need_magic -var NEED_MAGIC 260 277 book getword pstampRequest $pageName label -var LABEL 261 278 … … 263 280 264 281 $run = pstamp_parser_run.pl --req_id $REQ_ID --uri $URI --product $PRODUCT --outdir $OUTDIR --label $LABEL --redirect-output 282 283 if ($NEED_MAGIC != 0) 284 $run = $run --need_magic 285 end 265 286 266 287 add_standard_args run … … 900 921 end 901 922 end 923 924 task pstamp.save.status 925 host local 926 927 periods -poll $LOADPOLL 928 periods -exec 90 929 periods -timeout 20 930 npending 1 931 932 task.exec 933 stdout NULL 934 stderr $LOGSUBDIR/pstamp.save.status.log 935 936 $run = pstamp_save_server_status.pl --update-link 937 command $run 938 end 939 940 task.exit $EXIT_SUCCESS 941 # echo nothing to do 942 end 943 944 task.exit default 945 showcommand failure 946 end 947 948 task.exit crash 949 showcommand crash 950 end 951 952 task.exit timeout 953 showcommand timeout 954 end 955 end -
branches/czw_branch/20101203/ippTasks/publish.pro
r30118 r30586 79 79 end 80 80 add_poll_args run 81 add_poll_labels run 81 82 command $run 82 83 end … … 131 132 book getword publishRun $pageName dbname -var DBNAME 132 133 book getword publishRun $pageName output_format -var OUTPUT_FORMAT 134 book getword publishRun $pageName need_magic -var NEED_MAGIC 133 135 134 136 stdout $LOGDIR/publish.run.log … … 139 141 140 142 $run = publish_file.pl --pub_id $PUB_ID --camera $CAMERA --workdir $WORKDIR --product $PRODUCT --stage $STAGE --stage_id $STAGE_ID --output_format $OUTPUT_FORMAT --redirect-output 143 144 if ("$NEED_MAGIC" == "T") 145 $run = $run --need-magic 146 end 147 141 148 add_standard_args run 142 149 -
branches/czw_branch/20101203/ippTasks/rcserver.pro
r28792 r30586 136 136 137 137 sprintf logfile "%s/makefs.%s.%s.log" $DIST_DIR $DIST_ID $DEST_ID 138 stdout $logfile139 stderr $logfile140 138 141 139 book setword rcPendingFS $pageName pantaskState RUN 142 140 143 $run = dist_make_fileset.pl --dist_id $DIST_ID --target_id $TARGET_ID --stage $STAGE --stage_id $STAGE_ID --data_group $DATA_GROUP --filter $FILTER --dest_id $DEST_ID --product_name $PRODUCT_NAME --ds_dbhost $DS_DBHOST --ds_dbname $DS_DBNAME --dist_dir $DIST_DIR 141 $run = dist_make_fileset.pl --dist_id $DIST_ID --target_id $TARGET_ID --stage $STAGE --stage_id $STAGE_ID --data_group $DATA_GROUP --filter $FILTER --dest_id $DEST_ID --product_name $PRODUCT_NAME --ds_dbhost $DS_DBHOST --ds_dbname $DS_DBNAME --dist_dir $DIST_DIR --logfile $logfile 144 142 145 143 add_standard_args run -
branches/czw_branch/20101203/ippTasks/register.pro
r30118 r30586 9 9 book init regPendingExp 10 10 book init regPendingBurntoolImfile 11 book init regDates 11 12 12 13 macro register.reset … … 14 15 book init regPendingExp 15 16 book init regPendingBurntoolImfile 17 book init regDates 16 18 end 17 19 … … 21 23 book listbook regPendingExp 22 24 book listbook regPendingBurntoolImfile 25 book listbook regDates 23 26 end 24 27 … … 30 33 active true 31 34 end 35 task register.imfile.revert 36 active false 37 end 32 38 task register.exp.load 33 39 active true … … 51 57 active false 52 58 end 59 task register.imfile.revert 60 active false 61 end 53 62 task register.exp.load 54 63 active false … … 65 74 end 66 75 67 $valid_burntool_value = 14 76 macro register.revert.on 77 task register.imfile.revert 78 active true 79 end 80 end 81 82 macro register.revert.off 83 task register.imfile.revert 84 active false 85 end 86 end 87 88 macro burntool.on 89 task register.burntool.load 90 active true 91 end 92 task register.burntool.run 93 active true 94 end 95 end 96 97 macro burntool.off 98 task register.burntool.load 99 active false 100 end 101 task register.burntool.run 102 active false 103 end 104 end 105 106 macro register.add.date 107 if ($0 != 4) 108 echo "USAGE: register.add.date (YYYY-MM-DD) (DBNAME) (VALID_BURNTOOL)" 109 break 110 end 111 112 book newpage regDates $1 113 book setword regDates $1 nsState NEW 114 book setword regDates $1 dbname $2 115 book setword regDates $1 valid_burntool $3 116 end 117 118 119 # $valid_burntool_value = 14 120 $sunrise = 17:30:00 121 $sunset = 03:30:00 68 122 69 123 macro replace.survey.values … … 147 201 $regPendingImfile_DB = 0 148 202 $regPendingBurntoolImfile_DB = 0 203 $regRevertImfile_DB = 0 149 204 $regPendingExp_DB = 0 150 205 … … 265 320 # XXX register_imfile.pl differs from the standard script : it does not have an 'outroot' argument, and it does not take '--redirect' 266 321 $run = register_imfile.pl --exp_id $EXP_ID --tmp_class_id $TMP_CLASS_ID --tmp_exp_name $TMP_EXP_NAME --uri $URI --logfile $logfile --bytes $BYTES --md5sum $MD5SUM 322 $run = $run --sunset $sunset --sunrise $sunrise 267 323 add_standard_args run 268 324 … … 295 351 end 296 352 end 353 354 task register.imfile.revert 355 host local 356 periods -poll 60.0 357 periods -exec 1800.0 358 periods -timeout 120.0 359 npending 1 360 361 stdout NULL 362 stderr $LOGDIR/register.imfile.revert.log 363 364 task.exec 365 $run = regtool -revertprocessedimfile 366 if ($DB:n == 0) 367 option DEFAULT 368 else 369 option $DB:$regRevertImfile_DB 370 $run = $run -dbname $DB:$regRevertImfile_DB 371 $regRevertImfile_DB ++ 372 if ($regRevertImfile_DB >= $DB:n) set regRevertImfile_DB = 0 373 end 374 add_poll_args run 375 command $run 376 end 377 378 # success 379 task.exit 0 380 end 381 382 # locked list 383 task.exit default 384 showcommand failure 385 end 386 387 task.exit crash 388 showcommand crash 389 end 390 391 # operation times out 392 task.exit timeout 393 showcommand timeout 394 end 395 end 396 297 397 298 398 # select exposures ready for register_exp.pl … … 463 563 # select entried from the current DB; cycle to the next DB, if it exists 464 564 task.exec 565 book npages regDates -var Npages 566 if ($Npages == 0) 567 $today = `date -u +%Y-%m-%d` 568 $dbname = $DB:0 569 $valid_burntool = 14 570 else 571 book getpage regDates $reg_datePAGE -var today 572 book getword regDates $today dbname -var dbname 573 book getword regDates $today valid_burntool -var valid_burntool 574 $reg_datePAGE ++ 575 if ($reg_datePAGE >= $Npages) set reg_datePAGE = 0 576 end 577 465 578 $run = regtool -pendingburntoolimfile 466 $today = `date -u +%Y-%m-%d` 579 467 580 # debugging purposes 468 # $today = "2010-12-06" 469 $run = $run -date $today -valid_burntool $valid_burntool_value 470 if ($DB:n == 0) 471 option DEFAULT 472 else 473 # save the DB name for the exit tasks 474 option $DB:$regPendingBurntoolImfile_DB 475 $run = $run -dbname $DB:$regPendingBurntoolImfile_DB 476 $regPendingBurntoolImfile_DB ++ 477 if ($regPendingBurntoolImfile_DB >= $DB:n) set regPendingBurntoolImfile_DB = 0 478 end 581 # $today = "2010-12-25" 582 $dateobs_begin = $today\T$sunset 583 $dateobs_end = $today\T$sunrise 584 $run = $run -dateobs_begin $dateobs_begin -dateobs_end $dateobs_end -valid_burntool $valid_burntool 585 $run = $run -dbname $dbname 586 option $dbname 587 # if ($DB:n == 0) 588 # option DEFAULT 589 # else 590 # # save the DB name for the exit tasks 591 # option $DB:$regPendingBurntoolImfile_DB 592 # $run = $run -dbname $DB:$regPendingBurntoolImfile_DB 593 # if ("$dbname" != "$DB:$regPendingBurntoolImfile_DB") 594 # break 595 # end 596 # $regPendingBurntoolImfile_DB ++ 597 # if ($regPendingBurntoolImfile_DB >= $DB:n) set regPendingBurntoolImfile_DB = 0 598 # end 479 599 480 600 # echo $run … … 574 694 end 575 695 576 696 task register.initday.load 697 host local 698 periods -poll $LOADPOLL 699 periods -exec $LOADEXEC 700 periods -timeout 30 701 trange 0:00:00 1:00:00 -nmax 1 702 npending 1 703 704 task.exec 705 $today = `date -u +%Y-%m-%d` 706 book newpage regDates $today 707 book setword regDates $today nsState NEW 708 book setword regDates $today dbname $DB:0 709 book setword regDates $today valid_burntool 14 710 711 command true 712 end 713 714 task.exit 0 715 # nothing to do here? 716 end 717 # locked list 718 task.exit default 719 showcommand failure 720 end 721 task.exit crash 722 showcommand crash 723 end 724 #operation times out? 725 task.exit timeout 726 showcommand timeout 727 end 728 end 729 577 730 578 731 -
branches/czw_branch/20101203/ippTasks/survey.pro
r29768 r30586 259 259 # user functions to manipulate destreak labels 260 260 macro survey.add.destreak 261 if ($0 != 3)262 echo "USAGE: survey.add.destreak (label) (workdir base) "261 if ($0 != 4) 262 echo "USAGE: survey.add.destreak (label) (workdir base) (recovery root)" 263 263 break 264 264 end 265 265 book newpage SURVEY_DESTREAK $1 266 266 book setword SURVEY_DESTREAK $1 WORKDIR $2 267 book setword SURVEY_DESTREAK $1 RECOVERYROOT $3 267 268 book setword SURVEY_DESTREAK $1 STATE PENDING 268 269 end … … 286 287 # user functions to manipulate dist labels 287 288 macro survey.add.dist 288 if ($0 != 2)289 echo "USAGE: survey.add.dist (label) "289 if ($0 != 3) 290 echo "USAGE: survey.add.dist (label) (workdir)" 290 291 break 291 292 end 292 293 book newpage SURVEY_DIST $1 294 book setword SURVEY_DIST $1 WORKDIR $2 293 295 book setword SURVEY_DIST $1 STATE PENDING 294 296 end … … 366 368 # user functions to manipulate publish labels 367 369 macro survey.add.publish 368 if ($0 != 3)369 echo "USAGE: survey.add.publish ( label) (client_id)"370 if ($0 != 5) 371 echo "USAGE: survey.add.publish (tag) (label) (client_id) (comment)" 370 372 break 371 373 end 372 374 book newpage SURVEY_PUBLISH $1 373 book setword SURVEY_PUBLISH $1 CLIENT_ID $2 375 book setword SURVEY_PUBLISH $1 LABEL $2 376 book setword SURVEY_PUBLISH $1 CLIENT_ID $3 377 book setword SURVEY_PUBLISH $1 COMMENT $4 374 378 book setword SURVEY_PUBLISH $1 STATE PENDING 375 379 end … … 821 825 book setword SURVEY_DESTREAK $label STATE DONE 822 826 book getword SURVEY_DESTREAK $label WORKDIR -var workdir 827 book getword SURVEY_DESTREAK $label RECOVERYROOT -var recoveryroot 823 828 824 829 $run = magic_destreak_defineruns.pl --label $label --workdir $workdir/$label 830 if ("$recoveryroot" != "NULL") 831 $run = $run --recoveryroot $recoveryroot/$label 832 end 825 833 826 834 if ($DB:n == 0) … … 889 897 end 890 898 899 book getword SURVEY_DIST $label WORKDIR -var workdir_base 900 $year = `date +%Y` 901 $month = `date +%m` 902 $day = `date +%d` 903 $workdir = $workdir_base/$label/$year/$month/$day 904 891 905 book setword SURVEY_DIST $label STATE DONE 892 906 893 907 # note workdir is set by the script based on site.config 894 $run = dist_defineruns.pl --label $label 908 $run = dist_defineruns.pl --label $label --workdir $workdir 895 909 896 910 if ($DB:n == 0) … … 901 915 end 902 916 903 # echo $run 917 if ($VERBOSE > 1 ) 918 echo $run 919 end 904 920 command $run 905 921 end … … 1084 1100 endif 1085 1101 1086 book getpage SURVEY_PUBLISH 0 -var label -key STATE NEW 1087 if ("$label" == "NULL") 1088 # All labels have been done --- reset 1089 # echo "Resetting labels" 1102 # survey.publish allows multiple entries per label. 1103 # The key is called tag and must be unique 1104 book getpage SURVEY_PUBLISH 0 -var tag -key STATE NEW 1105 if ("$tag" == "NULL") 1106 # All tags have been done --- reset 1107 # echo "Resetting tags" 1090 1108 for i 0 $N 1091 book getpage SURVEY_PUBLISH $i -var label1092 book setword SURVEY_PUBLISH $ labelSTATE NEW1109 book getpage SURVEY_PUBLISH $i -var tag 1110 book setword SURVEY_PUBLISH $tag STATE NEW 1093 1111 end 1094 book getpage SURVEY_PUBLISH 0 -var label-key STATE NEW1112 book getpage SURVEY_PUBLISH 0 -var tag -key STATE NEW 1095 1113 1096 1114 # Select different database … … 1099 1117 end 1100 1118 1101 book setword SURVEY_PUBLISH $label STATE DONE 1102 book getword SURVEY_PUBLISH $label CLIENT_ID -var client_id 1119 book setword SURVEY_PUBLISH $tag STATE DONE 1120 book getword SURVEY_PUBLISH $tag LABEL -var label 1121 book getword SURVEY_PUBLISH $tag CLIENT_ID -var client_id 1122 book getword SURVEY_PUBLISH $tag COMMENT -var comment 1103 1123 1104 1124 $run = pubtool -definerun -label $label -client_id $client_id 1125 1126 if ("$comment" != "NULL") 1127 $run = $run -comment $comment 1128 end 1105 1129 1106 1130 if ($DB:n == 0) … … 1111 1135 end 1112 1136 1113 #echo $run 1137 echo $run 1138 1114 1139 command $run 1140 1115 1141 end 1116 1142
Note:
See TracChangeset
for help on using the changeset viewer.
