send_client.py

#!/usr/bin/env python

import gst

host="141.12.88.134"
port=5000

pipeline = gst.Pipeline('server')
p = "videotestsrc ! capsfilter ! x264enc ! rtph264pay ! udpsink host=%s port=%s" %(host, port)

pipeline = gst.parse_launch(p)
udpsink = pipeline.get_by_name("udpsink0")


udpsink = pipeline.get_by_name("udpsink0")


def print_stats():
    data = udpsink.emit("get_stats", host, port)
    stats = "%s:%s bytes_sent: %s, packets_sent: %s, connect_time: %s" %(host, port, data[0], data[1], data[2])
    print stats
    return True

import gobject
gobject.timeout_add_seconds(2, print_stats)

pipeline.set_state(gst.STATE_PLAYING)

import gtk
gtk.main()