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
|
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()
|
