Modified echoserver example to not use separate readers/writers.
This commit is contained in:
@@ -13,14 +13,14 @@ and then 'quit')
|
|||||||
import eventlet
|
import eventlet
|
||||||
from eventlet.green import socket
|
from eventlet.green import socket
|
||||||
|
|
||||||
def handle(reader, writer):
|
def handle(fd):
|
||||||
print "client connected"
|
print "client connected"
|
||||||
while True:
|
while True:
|
||||||
# pass through every non-eof line
|
# pass through every non-eof line
|
||||||
x = reader.readline()
|
x = fd.readline()
|
||||||
if not x: break
|
if not x: break
|
||||||
writer.write(x)
|
fd.write(x)
|
||||||
writer.flush()
|
fd.flush()
|
||||||
print "echoed", x,
|
print "echoed", x,
|
||||||
print "client disconnected"
|
print "client disconnected"
|
||||||
|
|
||||||
@@ -34,6 +34,6 @@ while True:
|
|||||||
try:
|
try:
|
||||||
new_sock, address = server.accept()
|
new_sock, address = server.accept()
|
||||||
print "accepted", address
|
print "accepted", address
|
||||||
pool.spawn_n(handle, new_sock.makefile('r'), new_sock.makefile('w'))
|
pool.spawn_n(handle, new_sock.makefile('rw'))
|
||||||
except (SystemExit, KeyboardInterrupt):
|
except (SystemExit, KeyboardInterrupt):
|
||||||
break
|
break
|
||||||
|
|||||||
Reference in New Issue
Block a user