Changeset 446

Show
Ignore:
Timestamp:
05/08/08 10:51:11 (8 months ago)
Author:
jmowery
Message:

small fixes after refactor

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • branches/trunk-pmd-intproto/mgmt/manager.py

    r443 r446  
    166166def handleupdate(mgr, argv): 
    167167        useage = 'useage:\n   update (group GROUPNAME | all | client [clientlist])' 
    168         if argv[0] == 'client': 
     168        if len(argv) == 0 or argv[0] == 'all': 
     169                msg = m.update() 
     170        elif argv[0] == 'client': 
    169171                msg = mgr.update() 
    170172                msg.body = sys.argv[3:] 
     
    174176                        sys.exit(1) 
    175177                msg = m.update_group(argv[1]) 
    176         elif argv[0] == 'all' or argv[0] == '': 
    177                 msg = m.update() 
    178178        else: 
    179179                print 'unknown update request' 
  • branches/trunk-pmd-intproto/server/master.py

    r445 r446  
    9696                else: 
    9797                        msg.body = [] 
    98                 return res 
     98                return msg 
    9999 
    100100        def storeadd(self, (mgr, info), msg): 
     
    141141                ''' 
    142142                Handle servicing of a manager connection.  In general, we read 
    143                 a request from the manager.   
    144                  
     143                a request from the manager. 
     144 
    145145                If the request is one of a couple 
    146146                of types handled internally by the server, process the request 
     
    172172                                        res = self.storeremove((mgr, info), val) 
    173173                                else: 
    174                                         res = comm(ret2, val, (mgr, info)) 
     174                                        res = self.comm(ret2, val, (mgr, info)) 
    175175                                pickle.dump(res, mgr.makefile()) 
    176176                                return res 
     
    226226                n.update() 
    227227                return True 
    228          
     228 
    229229        def comm(self, func, msg, (mgr, info)): 
    230230                target = val.targets