Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import os
- import sys
- import socket
- import threading
- def puts(string):
- sys.stdout.write(string + "\n")
- recv_limit = 128
- thread_limit = 100
- thread_start = 0
- def client(conn, addr):
- global thread_start
- try:
- TypeData = conn.recv(recv_limit)
- if (len(TypeData) > recv_limit):
- puts("Client sent more data than recv_limit.")
- else:
- puts("OK")
- except Exception:
- thread_start -= 1
- puts("client disconnected")
- if (conn):
- conn.close()
- sock = socket.socket()
- try:
- sock.bind("127.0.0.1", 8000)
- except socket.error:
- puts("Addr already in use")
- sock.listen(0)
- while (recv_limit):
- conn, addr = sock.accept()
- puts("conn recv [%s:%s]" % (addr[0], addr[1]))
- if (thread_start == thread_limit):
- conn.close()
- puts("Client exceeded maximum thread limit.")
- else:
- thread = threading.Thread(target=client, args=(conn,addr,)).start()
- thread_start +=1
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement