Change in vdsm[master]: remoteFileHandler pep8 fixes

smizrahi at redhat.com smizrahi at redhat.com
Wed Nov 21 16:15:33 UTC 2012


Saggi Mizrahi has uploaded a new change for review.

Change subject: remoteFileHandler pep8 fixes
......................................................................

remoteFileHandler pep8 fixes

Change-Id: I849c858597e55a8366e5e1a3f964048da43e80dd
Signed-off-by: Saggi Mizrahi <smizrahi at redhat.com>
---
M vdsm/storage/remoteFileHandler.py
1 file changed, 8 insertions(+), 7 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/vdsm refs/changes/98/9398/1

diff --git a/vdsm/storage/remoteFileHandler.py b/vdsm/storage/remoteFileHandler.py
index d54bdcc..a47764b 100644
--- a/vdsm/storage/remoteFileHandler.py
+++ b/vdsm/storage/remoteFileHandler.py
@@ -146,7 +146,7 @@
                 raise Timeout()
 
             if not self._poll(self._myRead, select.POLLIN | select.POLLPRI,
-                    timeLeft):
+                              timeLeft):
                 raise Timeout()
 
             try:
@@ -166,7 +166,7 @@
                 raise Timeout()
 
             if not self._poll(self._myWrite, select.POLLOUT,
-                    timeLeft):
+                              timeLeft):
                 raise Timeout()
 
             l += os.write(self._myWrite, data[l:])
@@ -187,7 +187,7 @@
             # If for some reason the connection drops\gets out of sync we treat
             # it as a timeout so we only have one error path
             self.log.error("Problem with handler, treating as timeout",
-                    exc_info=True)
+                           exc_info=True)
             raise Timeout()
 
         res, err = pickle.loads(rawResponse)
@@ -223,7 +223,8 @@
             env['PYTHONPATH'] = "%s:%s" % (
                 constants.P_VDSM, env.get("PYTHONPATH", ""))
             self.process = BetterPopen([constants.EXT_PYTHON, __file__,
-                str(hisRead), str(hisWrite)], close_fds=False, env=env)
+                                       str(hisRead), str(hisWrite)],
+                                       close_fds=False, env=env)
 
             self.proxy = CrabRPCProxy(myRead, myWrite)
 
@@ -273,14 +274,14 @@
                     handler = self.handlers[i] = PoolHandler()
 
                 return handler.proxy.callCrabRPCFunction(timeout, name,
-                        *args, **kwargs)
+                                                         *args, **kwargs)
             except Timeout:
                 try:
                     self.handlers[i] = None
                     handler.stop()
                 except:
                     self.log.error("Could not signal stuck handler (PID:%d)",
-                            handler.process.pid, exc_info=True)
+                                   handler.process.pid, exc_info=True)
 
                 self.handlers[i] = None
                 raise
@@ -386,7 +387,7 @@
         try:
             server = CrabRPCServer(myRead, myWrite)
             for func in (writeLines, readLines, createSparseFile, echo, sleep,
-                    directWriteLines, directReadLines, simpleWalk):
+                         directWriteLines, directReadLines, simpleWalk):
 
                 server.registerFunction(func)
 


--
To view, visit http://gerrit.ovirt.org/9398
To unsubscribe, visit http://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: I849c858597e55a8366e5e1a3f964048da43e80dd
Gerrit-PatchSet: 1
Gerrit-Project: vdsm
Gerrit-Branch: master
Gerrit-Owner: Saggi Mizrahi <smizrahi at redhat.com>


More information about the vdsm-patches mailing list