|
|
@ -1778,16 +1778,16 @@ class Latch(object):
|
|
|
|
self._cls_all_sockets.extend((rsock, wsock))
|
|
|
|
self._cls_all_sockets.extend((rsock, wsock))
|
|
|
|
return rsock, wsock
|
|
|
|
return rsock, wsock
|
|
|
|
|
|
|
|
|
|
|
|
COOKIE_SIZE = 33
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def _make_cookie(self):
|
|
|
|
def _make_cookie(self):
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
Return a 33-byte string encoding the ID of the instance and the current
|
|
|
|
Return a string encoding the ID of the instance and the current thread.
|
|
|
|
thread. This disambiguates legitimate wake-ups, accidental writes to
|
|
|
|
This disambiguates legitimate wake-ups, accidental writes to the FD,
|
|
|
|
the FD, and buggy internal FD sharing.
|
|
|
|
and buggy internal FD sharing.
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
ident = threading.currentThread().ident
|
|
|
|
ident = threading.currentThread().ident
|
|
|
|
return b(u'%016x-%016x' % (int(id(self)), ident))
|
|
|
|
return b(u'%010d-%016x-%016x' % (os.getpid(), int(id(self)), ident))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
COOKIE_SIZE = len(_make_cookie(None))
|
|
|
|
|
|
|
|
|
|
|
|
def get(self, timeout=None, block=True):
|
|
|
|
def get(self, timeout=None, block=True):
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|