Ignore:
Timestamp:
Apr 28, 2010 4:09:53 AM (14 years ago)
Author:
Ted Faber <faber@…>
Branches:
axis_example, compt_changes, info-ops, master, version-3.01, version-3.02
Children:
12658df
Parents:
05fceef
Message:

New syntax for testbeds that includes a /instance rider. This allows users to
request multiple segments from a single testbed.

File:
1 edited

Legend:

Unmodified
Added
Removed
  • fedd/federation/dragon_access.py

    r05fceef rab847bc  
    99import time
    1010
    11 from threading import *
     11from threading import Thread, Lock
    1212from subprocess import Popen, call, PIPE, STDOUT
    1313
     
    804804            # redoing the allocation.
    805805            self.state_lock.acquire()
    806             retval = self.allocation[aid].get('started', None)
     806            retval = self.state[aid].get('started', None)
    807807            self.state_lock.release()
    808808            if retval:
     
    858858        self.export_store_info(certfile, vlan_no, connInfo)
    859859
     860
    860861        if gri:
     862            rtopo = topo.clone()
     863            for s in rtopo.substrates:
     864                s.set_attribute('vlan', vlan_no)
     865                s.set_attribute('gri', gri)
     866
    861867            # Grab the log (this is some anal locking, but better safe than
    862868            # sorry)
     
    867873            # if the 'started' key is in the allocation, we'll return it rather
    868874            # than redo the setup.
    869             self.allocation[aid]['started'] = {
     875            self.state[aid]['started'] = {
    870876                    'allocID': req['allocID'],
    871877                    'allocationLog': logv,
     878                    'segmentdescription': {
     879                        'topdldescription': rtopo.to_dict()
     880                        },
    872881                    }
    873             retval = self.allocation[aid]['started']
     882            retval = self.state[aid]['started']
    874883            self.write_state()
    875884            self.state_lock.release()
Note: See TracChangeset for help on using the changeset viewer.