gmyth-stream/server/tests/client_ffmpeg.py
author morphbr
Wed Apr 04 00:10:15 2007 +0100 (2007-04-04)
branchtrunk
changeset 492 63d9475228ac
parent 484 27e83a8f68d7
child 494 f1411bd6f17e
permissions -rw-r--r--
[svn r497] - Updated gmyth-streamer mencoder, xmlrpc and client_ffmpeg
renatofilho@484
     1
import os
renatofilho@484
     2
import sys
renatofilho@484
     3
import time
renatofilho@484
     4
import socket
renatofilho@484
     5
renatofilho@484
     6
renatofilho@484
     7
if len(sys.argv) < 2:
renatofilho@484
     8
    HOST = 'localhost'
renatofilho@484
     9
    PORT = 5000
renatofilho@484
    10
elif len(sys.argv) == 2:
renatofilho@484
    11
    HOST = sys.argv[1]
renatofilho@484
    12
    PORT = 5000
renatofilho@484
    13
else:
renatofilho@484
    14
    HOST = sys.argv[1]
renatofilho@484
    15
    PORT = int(sys.argv[2])
renatofilho@484
    16
renatofilho@484
    17
socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
renatofilho@484
    18
socket.settimeout(10)
renatofilho@484
    19
renatofilho@484
    20
try:
renatofilho@484
    21
    socket.connect( (HOST,PORT) )
renatofilho@484
    22
except:
renatofilho@484
    23
    print "\n--> Could not connect to ('%s':'%d')\n" % (HOST,PORT)
renatofilho@484
    24
    sys.exit(-1)
renatofilho@484
    25
renatofilho@484
    26
morphbr@492
    27
#mplayer = os.popen("which mplayer").read().strip()
morphbr@492
    28
#mplayer += " - 1> /dev/null"
morphbr@492
    29
#pin, pout = os.popen2(mplayer)
morphbr@492
    30
morphbr@492
    31
teste = open("/tmp/teste2", "w")
renatofilho@484
    32
renatofilho@484
    33
data = socket.recv(1024)
renatofilho@484
    34
i = 0
renatofilho@484
    35
renatofilho@484
    36
while (data != ""):
morphbr@492
    37
    #pin.write(data)
morphbr@492
    38
    teste.write(data)
renatofilho@484
    39
    data = socket.recv(1024)
renatofilho@484
    40
    if (i == 500):
renatofilho@484
    41
        socket.send("OK")
renatofilho@484
    42
    i += 1
renatofilho@484
    43
morphbr@492
    44
#pin.close()
renatofilho@484
    45
socket.close()
renatofilho@484
    46
renatofilho@484
    47
renatofilho@484
    48
# from select import select
renatofilho@484
    49
# r, w, x = select([pout], []. [], 0)
renatofilho@484
    50
# if pout in r:
renatofilho@484
    51
#     pout.read(32)