Rooba
/
mitogen
mirror of https://github.com/mitogen-hq/mitogen.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

whitespace.

This commit is contained in:
David Wilson 2014-01-10 11:49:17 +00:00
parent 09f3bda1bb
commit 9ed5d771f5
2 changed files with 680 additions and 679 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
econtext.py
View File

@ -66,7 +66,7 @@ class TimeoutError(StreamError):
def Log(fmt, *args): def Log(fmt, *args):
if DEBUG: if DEBUG:
sys.stderr.write('%d (%d): %s\n' % (os.getpid(), os.getppid(), sys.stderr.write('%d (%d): %s\n' % (os.getpid(), os.getppid(),
(fmt%args).replace('econtext.', ''))) (fmt % args).replace('econtext.', '')))
def CreateChild(*args): def CreateChild(*args):
@ -183,8 +183,8 @@ class Channel(object):
def __iter__(self): def __iter__(self):
''' '''
Return an iterator that yields objects arriving on this channel, until the Return an iterator that yields objects arriving on this channel, until
channel dies or is closed. the channel dies or is closed.
''' '''
while True: while True:
try: try:
@ -198,7 +198,8 @@ class Channel(object):
class SlaveModuleImporter(object): class SlaveModuleImporter(object):
''' '''
Import protocol implementation that fetches modules from the parent process. Import protocol implementation that fetches modules from the parent
process.
''' '''
def __init__(self, context): def __init__(self, context):
@ -358,8 +359,8 @@ class Stream(object):
def Receive(self): def Receive(self):
''' '''
Handle the next complete message on the stream. Raise CorruptMessageError Handle the next complete message on the stream. Raise
or IOError on failure. CorruptMessageError or IOError on failure.
''' '''
Log('%r.Receive()', self) Log('%r.Receive()', self)
@ -602,9 +603,9 @@ class Context(object):
def EnqueueAwaitReply(self, handle, deadline, data): def EnqueueAwaitReply(self, handle, deadline, data):
''' '''
Send a message to the given handle and wait for a response with an optional Send a message to the given handle and wait for a response with an
timeout. The message contains (reply_handle, data), where reply_handle is optional timeout. The message contains (reply_handle, data), where
the handle on which this function expects its reply. reply_handle is the handle on which this function expects its reply.
''' '''
Log('%r.EnqueueAwaitReply(%r, %r, %r)', self, handle, deadline, data) Log('%r.EnqueueAwaitReply(%r, %r, %r)', self, handle, deadline, data)
reply_handle = self._stream.AllocHandle() reply_handle = self._stream.AllocHandle()