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