Changeset ecf679e for fedd


Ignore:
Timestamp:
Sep 23, 2009 2:13:21 PM (15 years ago)
Author:
Ted Faber <faber@…>
Branches:
axis_example, compt_changes, info-ops, master, version-2.00, version-3.01, version-3.02
Children:
46bc576
Parents:
8c9933c
Message:

fix terminate/multistatus

File:
1 edited

Legend:

Unmodified
Added
Removed
  • fedd/federation/experiment_control.py

    r8c9933c recf679e  
    14731473                        ],
    14741474                    attribute=[ topdl.Attribute(
    1475                         attribute='dragon_endpoint', value='true'),
     1475                        attribute='dragon_endpoint',
     1476                        value=tbparams[tb]['dragon']),
    14761477                        ]
    14771478                    )
     
    20282029            # save federant information
    20292030            for k in allocated.keys():
    2030                 tbparams[k]['federant'] = {\
    2031                         'name': [ { 'localname' : eid} ],\
    2032                         'allocID' : tbparams[k]['allocID'],\
    2033                         'master' : k == master,\
     2031                tbparams[k]['federant'] = {
     2032                        'name': [ { 'localname' : eid} ],
     2033                        'allocID' : tbparams[k]['allocID'],
     2034                        'master' : k == master,
     2035                        'uri': tbparams[k]['uri'],
    20342036                    }
    20352037                if tbparams[k].has_key('emulab'):
     
    24372439                    # Create and start a thread to stop the segment
    24382440                    thread_pool.wait_for_slot()
    2439                     uri = self.tbmap.get(tb, None)
     2441                    #uri = self.tbmap.get(tb, None)
     2442                    uri = tb
    24402443                    t  = self.pooled_thread(\
    24412444                            target=self.terminate_segment(log=dealloc_log,
     
    24562459            try:
    24572460                for tb in tbparams.keys():
    2458                     self.release_access(tb, tbparams[tb])
     2461                    # This releases access by uri
     2462                    self.release_access(None, tbparams[tb], uri=tb)
    24592463            except service_error, e:
    24602464                if status != 'failed' and not force:
Note: See TracChangeset for help on using the changeset viewer.