diff options
| author | Olivier Crête <olivier.crete@collabora.com> | 2012-01-27 16:50:08 +0100 |
|---|---|---|
| committer | Olivier Crête <olivier.crete@collabora.com> | 2012-07-31 16:08:54 +0200 |
| commit | ed911efc60de1538c4e24ca01f376e25c09a4124 (patch) | |
| tree | 45412690737447ab5ec60c2d713fd264274ced55 /example.py | |
| parent | fb74f736e23844bbf289011f9bff7ad91581af18 (diff) | |
| download | farstream-ed911efc60de1538c4e24ca01f376e25c09a4124.tar.gz | |
Port to GStreamer 0.11
Diffstat (limited to 'example.py')
| -rw-r--r-- | example.py | 55 |
1 files changed, 55 insertions, 0 deletions
diff --git a/example.py b/example.py new file mode 100644 index 00000000..e0076e5a --- /dev/null +++ b/example.py @@ -0,0 +1,55 @@ +import pygst +pygst.require('0.10') +import farstream, gst, gobject, sys + +loop = gobject.MainLoop() +pipeline = gst.Pipeline() + +conference = gst.element_factory_make ("fsrtpconference") +sdes = conference.get_property("sdes") +conference.set_property ("sdes",conference.get_property("sdes").copy().set_value("cname", sys.argv[1] + "@1.2.3.4")) +pipeline.add (conference) + +session = conference.new_session (farstream.MEDIA_TYPE_VIDEO) +participant = conference.new_participant () +stream = session.new_stream (participant, farstream.DIRECTION_BOTH) +stream.set_transmitter("multicast") + +stream.set_remote_codecs([farstream.Codec(96, "H263-1998", + farstream.MEDIA_TYPE_VIDEO, + 90000)]) +candidate = farstream.Candidate() +candidate.ip = "224.0.0.110" +candidate.port = 3442 +candidate.component_id = farstream.COMPONENT_RTP +candidate.proto = farstream.NETWORK_PROTOCOL_UDP +candidate.type = farstream.CANDIDATE_TYPE_MULTICAST +candidate.ttl = 1 + +candidate2 = candidate.copy() +candidate2.port = 3443 +candidate2.component_id = farstream.COMPONENT_RTCP +stream.force_remote_candidates ([candidate, candidate2]) + +videosource = gst.parse_bin_from_description (sys.argv[2] + " ! videoscale", True) +pipeline.add (videosource) +videosource.get_pad ("src").link(session.get_property ("sink-pad")) + +funnel = False +def _src_pad_added (stream, pad, codec, pipeline): + global funnel + print "src pad %s added for stream %s %s" % (pad.get_name(), stream.get_property("participant").get_property("cname"), codec.to_string()) + if not funnel: + funnel = gst.element_factory_make("funnel") + videosink = gst.element_factory_make ("xvimagesink") + pipeline.add(funnel) + pipeline.add(videosink) + funnel.set_state (gst.STATE_PLAYING) + videosink.set_state (gst.STATE_PLAYING) + funnel.link(videosink) + pad.link (funnel.get_pad ("sink%d")) + +stream.connect ("src-pad-added", _src_pad_added, pipeline) + +pipeline.set_state(gst.STATE_PLAYING) +loop.run() |