traverseda
/
cpython
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

[Part of patch #909005] Use True/False

This commit is contained in:
Andrew M. Kuchling 2004-03-21 19:46:16 +00:00
parent c3a87b8dbb
commit 68522b1895
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
Lib/asyncore.py
View File

@ -157,7 +157,7 @@ def poll2(timeout=0.0, map=None):
poll3 = poll2 # Alias for backward compatibility poll3 = poll2 # Alias for backward compatibility
def loop(timeout=30.0, use_poll=0, map=None): def loop(timeout=30.0, use_poll=False, map=None):
if map is None: if map is None:
map = socket_map map = socket_map
@ -171,10 +171,10 @@ def loop(timeout=30.0, use_poll=0, map=None):
class dispatcher: class dispatcher:
debug = 0 debug = False
connected = 0 connected = False
accepting = 0 accepting = False
closing = 0 closing = False
addr = None addr = None
def __init__(self, sock=None, map=None): def __init__(self, sock=None, map=None):
@ -187,7 +187,7 @@ class dispatcher:
self.set_socket(sock, map) self.set_socket(sock, map)
# I think it should inherit this anyway # I think it should inherit this anyway
self.socket.setblocking(0) self.socket.setblocking(0)
self.connected = 1 self.connected = True
# XXX Does the constructor require that the socket passed # XXX Does the constructor require that the socket passed
# be connected? # be connected?
try: try:
@ -273,7 +273,7 @@ class dispatcher:
# ================================================== # ==================================================
def listen(self, num): def listen(self, num):
self.accepting = 1 self.accepting = True
if os.name == 'nt' and num > 5: if os.name == 'nt' and num > 5:
num = 1 num = 1
return self.socket.listen(num) return self.socket.listen(num)
@ -283,14 +283,14 @@ class dispatcher:
return self.socket.bind(addr) return self.socket.bind(addr)
def connect(self, address): def connect(self, address):
self.connected = 0 self.connected = False
err = self.socket.connect_ex(address) err = self.socket.connect_ex(address)
# XXX Should interpret Winsock return values # XXX Should interpret Winsock return values
if err in (EINPROGRESS, EALREADY, EWOULDBLOCK): if err in (EINPROGRESS, EALREADY, EWOULDBLOCK):
return return
if err in (0, EISCONN): if err in (0, EISCONN):
self.addr = address self.addr = address
self.connected = 1 self.connected = True
self.handle_connect() self.handle_connect()
else: else:
raise socket.error, err raise socket.error, err
@ -360,11 +360,11 @@ class dispatcher:
# for an accepting socket, getting a read implies # for an accepting socket, getting a read implies
# that we are connected # that we are connected
if not self.connected: if not self.connected:
self.connected = 1 self.connected = True
self.handle_accept() self.handle_accept()
elif not self.connected: elif not self.connected:
self.handle_connect() self.handle_connect()
self.connected = 1 self.connected = True
self.handle_read() self.handle_read()
else: else:
self.handle_read() self.handle_read()
@ -373,7 +373,7 @@ class dispatcher:
# getting a write implies that we are connected # getting a write implies that we are connected
if not self.connected: if not self.connected:
self.handle_connect() self.handle_connect()
self.connected = 1 self.connected = True
self.handle_write() self.handle_write()
def handle_expt_event(self): def handle_expt_event(self):
@ -518,7 +518,7 @@ if os.name == 'posix':
def __init__(self, fd): def __init__(self, fd):
dispatcher.__init__(self) dispatcher.__init__(self)
self.connected = 1 self.connected = True
# set it to non-blocking mode # set it to non-blocking mode
flags = fcntl.fcntl(fd, fcntl.F_GETFL, 0) flags = fcntl.fcntl(fd, fcntl.F_GETFL, 0)
flags = flags | os.O_NONBLOCK flags = flags | os.O_NONBLOCK