Changeset 115
- Timestamp:
- 12/04/07 01:13:10 (1 year ago)
- Files:
-
- projects/AsynCluster/trunk/asyncluster/master/jobs.py (modified) (2 diffs)
- projects/AsynCluster/trunk/asyncluster/ndm/gui.py (modified) (3 diffs)
- projects/AsynCluster/trunk/asyncluster/ndm/main.py (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
projects/AsynCluster/trunk/asyncluster/master/jobs.py
r111 r115 26 26 27 27 from zope.interface import implements 28 from twisted.internet import reactor28 from twisted.internet import defer, reactor 29 29 from twisted.spread import pb 30 30 … … 103 103 104 104 jobID = getattr(self, 'jobID', None) 105 d = self.root.callRemote('cancelJob', jobID) 106 d.addCallback(doneCanceling) 105 if jobID is None: 106 d = defer.succeed(None) 107 else: 108 d = self.root.callRemote('cancelJob', jobID) 109 d.addCallback(doneCanceling) 107 110 return d 108 111 projects/AsynCluster/trunk/asyncluster/ndm/gui.py
r89 r115 161 161 layout.addWidget(w, 2, 0, 1, 3) 162 162 # Logout button 163 # DISABLED DUE TO NON-REAPPEARING LOGIN WINDOW163 # DISABLED - login box doesn't reappear 164 164 # w = self.quitButton = QtGui.QPushButton(self.tr("&Logout")) 165 165 # sp('Fixed', 'Fixed') 166 166 # QtCore.QObject.connect( 167 # w, QtCore.SIGNAL("clicked()"), self. main.sessionEnd)167 # w, QtCore.SIGNAL("clicked()"), self.close) 168 168 # layout.addWidget(w, 3, 1, 1, 1) 169 170 # That's all171 169 172 170 def update(self, hoursLeft): … … 216 214 env=env, path=homeDir, uid=uid) 217 215 os.system("renice +%d --user %s" % (niceness, self.user)) 218 p.d.addCallback(lambda _: self.main.sessionEnd()) 219 216 p.d.addCallback(lambda _: self.sessionEnd()) 217 218 def sessionEnd(self): 219 def ended(null): 220 os.system("killall --user %s" % self.user) 221 222 return self.main.sessionEnd().addCallback(ended) 223 220 224 def wmStop(self): 221 225 """ … … 232 236 Called when a session window has been closed. 233 237 """ 234 if hasattr(self, 'process'): 235 self.wmStop() 238 self.sessionEnd() 236 239 237 240 projects/AsynCluster/trunk/asyncluster/ndm/main.py
r89 r115 110 110 if callServer: 111 111 return self.sessionMgr.callRemote('end') 112 return defer.succeed(None) 112 113 113 114
