mirror of https://github.com/python/cpython.git
Add test for asynchat. This also tests asyncore.
This commit is contained in:
parent
e4a1b6d7c4
commit
66172520ee
|
@ -0,0 +1,3 @@
|
|||
test_asynchat
|
||||
Connected
|
||||
Received: 'hello world'
|
|
@ -0,0 +1,55 @@
|
|||
# test asynchat -- requires threading
|
||||
|
||||
import asyncore, asynchat, socket, threading
|
||||
|
||||
HOST = "127.0.0.1"
|
||||
PORT = 54321
|
||||
|
||||
class echo_server(threading.Thread):
|
||||
|
||||
def run(self):
|
||||
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
sock.bind((HOST, PORT))
|
||||
sock.listen(1)
|
||||
conn, client = sock.accept()
|
||||
buffer = ""
|
||||
while "\n" not in buffer:
|
||||
data = conn.recv(10)
|
||||
if not data:
|
||||
break
|
||||
buffer = buffer + data
|
||||
while buffer:
|
||||
n = conn.send(buffer)
|
||||
buffer = buffer[n:]
|
||||
conn.close()
|
||||
sock.close()
|
||||
|
||||
class echo_client(asynchat.async_chat):
|
||||
|
||||
def __init__(self):
|
||||
asynchat.async_chat.__init__(self)
|
||||
self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
|
||||
self.connect((HOST, PORT))
|
||||
self.set_terminator("\n")
|
||||
self.buffer = ""
|
||||
self.send("hello ")
|
||||
self.send("world\n")
|
||||
|
||||
def handle_connect(self):
|
||||
print "Connected"
|
||||
|
||||
def collect_incoming_data(self, data):
|
||||
self.buffer = self.buffer + data
|
||||
|
||||
def found_terminator(self):
|
||||
print "Received:", `self.buffer`
|
||||
self.buffer = ""
|
||||
self.close()
|
||||
|
||||
def main():
|
||||
s = echo_server()
|
||||
s.start()
|
||||
c = echo_client()
|
||||
asyncore.loop()
|
||||
|
||||
main()
|
Loading…
Reference in New Issue