1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
"""Simple interpreter client for monserver provides a simple readline interface.
:copyright: 2000-2008 LOGILAB S.A. (Paris, FRANCE), all rights reserved.
:contact: http://www.logilab.fr/ -- mailto:contact@logilab.fr
:license: General Public License version 2 - http://www.gnu.org/licenses
"""
__docformat__ = "restructuredtext en"
from warnings import warn
warn('this module is deprecated and will disappear in a near release',
DeprecationWarning, stacklevel=1)
from socket import socket, SOCK_STREAM, AF_INET
from select import select
import sys
import readline
import threading
class SocketPrinter(threading.Thread):
"""A thread that reads from a socket and output
to stdout as data are received"""
def __init__(self, sock):
threading.Thread.__init__(self)
self.socket = sock
self.stop = False
def run(self):
"""prints socket input indefinitely"""
fd = self.socket.fileno()
self.socket.setblocking(0)
while not self.stop:
iwl, _, _ = select([fd], [], [], 2)
if fd in iwl:
data = self.socket.recv(100)
if data:
sys.stdout.write(data)
sys.stdout.flush()
def client( host, port ):
"""simple client that just sends input to the server"""
sock = socket( AF_INET, SOCK_STREAM )
sock.connect( (host, port) )
sp_thread = SocketPrinter(sock)
sp_thread.start()
while 1:
try:
line = raw_input() + "\n"
sock.send( line )
except EOFError:
print "Bye"
break
except:
sp_thread.stop = True
sp_thread.join()
raise
sp_thread.stop = True
sp_thread.join()
if __name__ == "__main__":
server_host = sys.argv[1]
server_port = int(sys.argv[2])
client(server_host, server_port)
|
