From tashi-commits-return-76-apmail-incubator-tashi-commits-archive=incubator.apache.org@incubator.apache.org Tue May 19 21:58:48 2009 Return-Path: Delivered-To: apmail-incubator-tashi-commits-archive@minotaur.apache.org Received: (qmail 58029 invoked from network); 19 May 2009 21:58:41 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 19 May 2009 21:58:41 -0000 Received: (qmail 89009 invoked by uid 500); 19 May 2009 19:25:18 -0000 Delivered-To: apmail-incubator-tashi-commits-archive@incubator.apache.org Received: (qmail 81628 invoked by uid 500); 19 May 2009 19:24:02 -0000 Mailing-List: contact tashi-commits-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: tashi-dev@incubator.apache.org Delivered-To: mailing list tashi-commits@incubator.apache.org Received: (qmail 79503 invoked by uid 99); 19 May 2009 19:20:35 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 May 2009 19:20:35 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 19 May 2009 19:20:31 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id B2B222388982; Tue, 19 May 2009 19:20:10 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r776423 - in /incubator/tashi/trunk/src/tashi/nodemanager: nodemanagerservice.py vmcontrol/qemu.py Date: Tue, 19 May 2009 19:20:10 -0000 To: tashi-commits@incubator.apache.org From: mryan3@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090519192010.B2B222388982@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: mryan3 Date: Tue May 19 19:20:10 2009 New Revision: 776423 URL: http://svn.apache.org/viewvc?rev=776423&view=rev Log: Remove unnecessary lambdas Modified: incubator/tashi/trunk/src/tashi/nodemanager/nodemanagerservice.py incubator/tashi/trunk/src/tashi/nodemanager/vmcontrol/qemu.py Modified: incubator/tashi/trunk/src/tashi/nodemanager/nodemanagerservice.py URL: http://svn.apache.org/viewvc/incubator/tashi/trunk/src/tashi/nodemanager/nodemanagerservice.py?rev=776423&r1=776422&r2=776423&view=diff ============================================================================== --- incubator/tashi/trunk/src/tashi/nodemanager/nodemanagerservice.py (original) +++ incubator/tashi/trunk/src/tashi/nodemanager/nodemanagerservice.py Tue May 19 19:20:10 2009 @@ -163,7 +163,7 @@ def suspendVm(self, vmId, name, suspendCookie): instance = self.getInstance(vmId) instance.state = InstanceState.Suspending - threading.Thread(target=lambda: self.vmm.suspendVm(vmId, name, suspendCookie)).start() + threading.Thread(target=self.vmm.suspendVm, args=(vmId, name, suspendCookie)).start() @RPC def resumeVm(self, instance, name): @@ -188,7 +188,7 @@ def migrateVm(self, vmId, target, transportCookie): instance = self.getInstance(vmId) instance.state = InstanceState.MigrateTrans - threading.Thread(target=lambda: self.migrateVmHelper(instance, target, transportCookie)).start() + threading.Thread(target=self.migrateVmHelper, args=(instance, target, transportCookie)).start() return def receiveVmHelper(self, instance, transportCookie): @@ -211,7 +211,7 @@ @RPC def receiveVm(self, instance, transportCookie): instance.state = InstanceState.MigrateTrans - threading.Thread(target=lambda: self.receiveVmHelper(instance, transportCookie)).start() + threading.Thread(target=self.receiveVmHelper, args=(instance, transportCookie)).start() return @RPC Modified: incubator/tashi/trunk/src/tashi/nodemanager/vmcontrol/qemu.py URL: http://svn.apache.org/viewvc/incubator/tashi/trunk/src/tashi/nodemanager/vmcontrol/qemu.py?rev=776423&r1=776422&r2=776423&view=diff ============================================================================== --- incubator/tashi/trunk/src/tashi/nodemanager/vmcontrol/qemu.py (original) +++ incubator/tashi/trunk/src/tashi/nodemanager/vmcontrol/qemu.py Tue May 19 19:20:10 2009 @@ -205,7 +205,7 @@ def getControlConsole(self, vmId, port): """Spawn a thread that attaches the control console of a particular Qemu to a TCP port -- used for debugging only""" child = self.getChildFromPid(vmId) - threading.Thread(target=(lambda: controlConsole(child, port))).start() + threading.Thread(target=controlConsole, args=(child, port)).start() return port def consumeAvailable(self, child): @@ -568,7 +568,7 @@ consolePort = self.consolePort self.consolePort = self.consolePort+1 self.consolePortLock.release() - threading.Thread(target=lambda: controlConsole(child,consolePort)).start() + threading.Thread(target=controlConsole, args=(child,consolePort)).start() return "Control console listenting on %s:%d" % (hostname, consolePort) elif (arg == "list"): return "startVnc\nstopVnc\nchangeCdrom:\nstartConsole"