Skip to content

2014 09 18

Jump to bottom
andre-merzky edited this page Sep 17, 2014 · 18 revisions
  • Agenda:
    • open TODOs
      • TODO SJ: doc is missing 10.000 feet overview (SJ?)
      • TODO SJ: contact Helmut about SuperMuc allocation
      • DONE AM: reduce testing frequency further after release
      • WIP AM: follow up with Anjani on EC2
      • WIP AM: RP slide decks
      • TODO AM: test supermuc, check out gsi contexts
      • DONE AM: suspend testing on FG
      • TODO MS: verify state model wrt. data staging
      • TODO AM: better name for STATE_X
    • open agenda items
      • WIP AM: AGENDA: cleanup
      • WIP AM: AGENDA: configuration files
      • TODO AM: AGENDA: test suite granularity
      • TODO AM: AGENDA: performance PTY / SHELL / SAGA
      • TODO AM: AGENDA: discuss how to ensure test coverage
      • TODO AM: AGENDA: discuss #307, async call semantics
      • TODO AM: AGENDA: student project: plotting
    • MS.8
      • What are goals for the next couple of weeks?
      • (check on open tickets)
    • eval tutorial with Indiana: online, Scott and Abhinav
      • TODO IU: provide application code
    • configuration files
    • cleanup modes
      • cleanup database entries: session.close (cleanup=TRUE)
      • terminate pilots: session.close (terminate=TRUE)
      • clean pilot sandbox: pilot_description.cleanup = TRUE
      • clean unit sandbox: unit_description.cleanup = TRUE
      • last two are enacted by agent on clean shutdown
      • first two can be performed after application finishes, via radicalpilot-cleanup
    • STATE_X:
      • AM: should be SCHEDULING: the CU has reached the scheduler but has not yet been assigned to a pilot (e.g., if none is free to run the CU).
      • but: SCHEDULING already used within the agent:
# scheduler
for task in wait_q :
    task.state = SCHEDULING

    while True :
        pilot = find_free_pilot (task)
        if  pilot :
            task.pilot = pilot
            break
        
task.state = PENDING_EXECUTION
submit_task_to_pilot (task)

# agent
for task in mongodb.find (pid  : my_pid, 
                          state: PENDING_EXECUTION)
    task.state = SCHEDULING

    while True :
        cores = find_free_cores (task)
        if  cores :
            task.cores = cores
            break
        
task.state = EXECUTING
submit_task_to_cores (task)
  • Notes:
Clone this wiki locally