renatofilho@484: import os
renatofilho@484: import sys
renatofilho@484: import time
renatofilho@484: import socket
renatofilho@484: 
renatofilho@484: 
renatofilho@484: if len(sys.argv) < 2:
renatofilho@484:     HOST = 'localhost'
renatofilho@484:     PORT = 5000
renatofilho@484: elif len(sys.argv) == 2:
renatofilho@484:     HOST = sys.argv[1]
renatofilho@484:     PORT = 5000
renatofilho@484: else:
renatofilho@484:     HOST = sys.argv[1]
renatofilho@484:     PORT = int(sys.argv[2])
renatofilho@484: 
renatofilho@484: socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
renatofilho@484: socket.settimeout(10)
renatofilho@484: 
renatofilho@484: try:
renatofilho@484:     socket.connect( (HOST,PORT) )
renatofilho@484: except:
renatofilho@484:     print "\n--> Could not connect to ('%s':'%d')\n" % (HOST,PORT)
renatofilho@484:     sys.exit(-1)
renatofilho@484: 
renatofilho@484: 
morphbr@494: mplayer = os.popen("which mplayer").read().strip()
morphbr@494: mplayer += " - 1> /dev/null"
morphbr@494: pin, pout = os.popen2(mplayer)
morphbr@492: 
morphbr@494: #teste = open("/tmp/teste2", "w")
renatofilho@484: 
renatofilho@484: data = socket.recv(1024)
renatofilho@484: i = 0
renatofilho@484: 
renatofilho@484: while (data != ""):
morphbr@494:     pin.write(data)
morphbr@494:     #teste.write(data)
renatofilho@484:     data = socket.recv(1024)
renatofilho@484:     if (i == 500):
renatofilho@484:         socket.send("OK")
renatofilho@484:     i += 1
renatofilho@484: 
morphbr@494: pin.close()
renatofilho@484: socket.close()
renatofilho@484: 
renatofilho@484: 
renatofilho@484: # from select import select
renatofilho@484: # r, w, x = select([pout], []. [], 0)
renatofilho@484: # if pout in r:
renatofilho@484: #     pout.read(32)