renatofilho@521
|
1 |
#vim:ts=4:sw=4:et
|
renatofilho@484
|
2 |
import pygst
|
renatofilho@484
|
3 |
pygst.require("0.10")
|
renatofilho@484
|
4 |
import gst
|
renatofilho@484
|
5 |
import gobject
|
renatofilho@484
|
6 |
import socket
|
renatofilho@549
|
7 |
import time
|
renatofilho@521
|
8 |
from threading import Thread
|
renatofilho@484
|
9 |
|
renatofilho@484
|
10 |
class Media:
|
morphbr@534
|
11 |
class StreamListener(Thread):
|
morphbr@534
|
12 |
def __init__ (self, stream_data):
|
morphbr@534
|
13 |
Thread.__init__(self)
|
morphbr@534
|
14 |
self.stream = stream_data
|
morphbr@534
|
15 |
print "Thread Created"
|
renatofilho@521
|
16 |
|
morphbr@534
|
17 |
def run (self):
|
morphbr@534
|
18 |
#Create socket
|
morphbr@534
|
19 |
print "Waiting connection"
|
morphbr@534
|
20 |
self.stream.Socket.listen(1)
|
morphbr@534
|
21 |
self.stream.Connection, self.stream.Addr = self.stream.Socket.accept ()
|
morphbr@534
|
22 |
print "Connection requested"
|
morphbr@534
|
23 |
self.stream.Sink.set_property ("fd", self.stream.Connection.fileno())
|
morphbr@534
|
24 |
self.stream.Pipe.set_state(gst.STATE_PLAYING)
|
morphbr@534
|
25 |
print "PLAYING"
|
renatofilho@521
|
26 |
|
renatofilho@521
|
27 |
|
renatofilho@484
|
28 |
class StreamData:
|
renatofilho@484
|
29 |
stream_count = 0
|
renatofilho@484
|
30 |
|
morphbr@534
|
31 |
def __init__ (self, pipe, abin, vbin, sink):
|
morphbr@534
|
32 |
self.stream_count += 1
|
morphbr@534
|
33 |
self.Id = self.stream_count
|
morphbr@534
|
34 |
self.Pipe = pipe
|
morphbr@534
|
35 |
self.Abin = abin
|
morphbr@534
|
36 |
self.Vbin = vbin
|
morphbr@534
|
37 |
self.Sink = sink
|
morphbr@534
|
38 |
self.Loop = gobject.MainLoop()
|
morphbr@534
|
39 |
self.ACaps = ""
|
morphbr@534
|
40 |
self.VCaps = ""
|
morphbr@534
|
41 |
self.Ready = False
|
morphbr@534
|
42 |
self.Socket = None
|
morphbr@534
|
43 |
self.Connection = None
|
morphbr@534
|
44 |
self.Addr = None
|
renatofilho@484
|
45 |
|
renatofilho@484
|
46 |
def __init__(self, config):
|
renatofilho@484
|
47 |
# set gstreamer basic options
|
renatofilho@484
|
48 |
self.config = config
|
renatofilho@484
|
49 |
self.streams = []
|
renatofilho@521
|
50 |
self.socket = None
|
renatofilho@521
|
51 |
self.connection = None
|
renatofilho@521
|
52 |
self.addr = None
|
morphbr@534
|
53 |
self.ready = False
|
renatofilho@549
|
54 |
self.current = None
|
renatofilho@484
|
55 |
|
renatofilho@484
|
56 |
|
renatofilho@521
|
57 |
def setup(self, uri, mux, vcodec, vbitrate,
|
renatofilho@484
|
58 |
fps, acodec, abitrate, width, height, port, options):
|
renatofilho@484
|
59 |
|
renatofilho@484
|
60 |
## Pipelines
|
renatofilho@521
|
61 |
pipe = gst.Pipeline ()
|
renatofilho@484
|
62 |
print "Opening Uri:" + uri
|
renatofilho@484
|
63 |
src = gst.element_make_from_uri (gst.URI_SRC, uri, "src")
|
renatofilho@549
|
64 |
#src = gst.element_factory_make ("gnomevfssrc", "src")
|
renatofilho@549
|
65 |
src.set_property ("location", uri)
|
renatofilho@484
|
66 |
if (src is None):
|
renatofilho@521
|
67 |
print "Fail to create src element"
|
renatofilho@484
|
68 |
return None
|
renatofilho@521
|
69 |
|
renatofilho@549
|
70 |
print ("Create source")
|
renatofilho@484
|
71 |
decode = gst.element_factory_make ("decodebin", "decode")
|
renatofilho@484
|
72 |
if (decode is None):
|
renatofilho@521
|
73 |
print "Fail to create decodebin"
|
renatofilho@484
|
74 |
return None
|
renatofilho@484
|
75 |
|
renatofilho@549
|
76 |
print ("Create source")
|
renatofilho@521
|
77 |
mux = gst.element_factory_make ("avimux", "mux")
|
renatofilho@484
|
78 |
if (mux is None):
|
renatofilho@521
|
79 |
print "Fail to create mux"
|
renatofilho@484
|
80 |
return None
|
renatofilho@484
|
81 |
|
renatofilho@484
|
82 |
sink = gst.element_factory_make ("fdsink", "sink")
|
renatofilho@484
|
83 |
if (sink is None):
|
renatofilho@521
|
84 |
print "Fail to create fdsink"
|
renatofilho@484
|
85 |
return None
|
renatofilho@484
|
86 |
|
renatofilho@549
|
87 |
print ("Create source")
|
renatofilho@521
|
88 |
|
renatofilho@521
|
89 |
#video encode
|
renatofilho@484
|
90 |
#queue ! videoscale ! video/x-raw-yuv,width=240,height=144 ! videorate ! ffenc_h263p bitrate=256000 me-method=2 ! rtph263ppay ! udpsink host=224.0.0.1 port=5000
|
renatofilho@484
|
91 |
vbin = gst.Bin ()
|
renatofilho@484
|
92 |
vqueue = gst.element_factory_make ("queue", "vqueue")
|
renatofilho@521
|
93 |
colorspace = gst.element_factory_make ("ffmpegcolorspace", "")
|
renatofilho@484
|
94 |
vrate = gst.element_factory_make ("videorate", "vrate")
|
renatofilho@549
|
95 |
vencode = gst.element_factory_make ("ffenc_mpeg4", "vencode")
|
renatofilho@549
|
96 |
#vencode = gst.element_factory_make ("ffenc_msmpeg4v1", "vencode")
|
renatofilho@549
|
97 |
vqueue_src = gst.element_factory_make ("queue", "vqueue_src")
|
renatofilho@484
|
98 |
|
renatofilho@549
|
99 |
#if (int(vbitrate) > 0):
|
renatofilho@549
|
100 |
vencode.set_property ("bitrate", 200)
|
renatofilho@549
|
101 |
#vencode.set_property ("quant-type", 1)
|
renatofilho@549
|
102 |
vencode.set_property ("pass", 2)
|
renatofilho@549
|
103 |
vencode.set_property ("quantizer", 5)
|
renatofilho@549
|
104 |
#vencode.set_property ("me-method", 1)
|
renatofilho@521
|
105 |
|
renatofilho@549
|
106 |
|
renatofilho@549
|
107 |
if (None in [vbin, vqueue, vrate, vencode, vqueue_src]):
|
renatofilho@484
|
108 |
print "Fail to create video encode elements."
|
renatofilho@484
|
109 |
return None
|
renatofilho@484
|
110 |
|
renatofilho@549
|
111 |
vbin.add (vqueue)
|
renatofilho@549
|
112 |
if ((int(width) > 0) and (int(height) > 0)):
|
renatofilho@549
|
113 |
print ("formating output to %d / %d" % (int(width), int(height)))
|
renatofilho@549
|
114 |
|
renatofilho@549
|
115 |
vscale = gst.element_factory_make ("ffvideoscale", "vscale")
|
renatofilho@549
|
116 |
|
renatofilho@549
|
117 |
vbin.add (vscale);
|
renatofilho@549
|
118 |
if (not vqueue.link (vscale)):
|
renatofilho@549
|
119 |
print "Fail to link video elements"
|
renatofilho@549
|
120 |
return None
|
renatofilho@549
|
121 |
|
renatofilho@549
|
122 |
vbin.add (colorspace)
|
renatofilho@549
|
123 |
|
renatofilho@549
|
124 |
if (not vscale.link (colorspace, \
|
renatofilho@549
|
125 |
gst.caps_from_string ("video/x-raw-yuv,width=(int)%d,height=(int)%d" % (int(width), int(height))))):
|
renatofilho@549
|
126 |
print "Fail to link video elements"
|
renatofilho@549
|
127 |
return None
|
renatofilho@549
|
128 |
else:
|
renatofilho@549
|
129 |
vbin.add (colorspace)
|
renatofilho@549
|
130 |
vqueue.link (colorspace)
|
renatofilho@549
|
131 |
|
renatofilho@549
|
132 |
vbin.add (vrate, vencode, vqueue_src)
|
renatofilho@549
|
133 |
if (not colorspace.link (vrate)):
|
renatofilho@549
|
134 |
print "Fail to colorspace with vrate"
|
renatofilho@484
|
135 |
return None
|
renatofilho@484
|
136 |
|
renatofilho@549
|
137 |
|
renatofilho@549
|
138 |
if (not vrate.link (vencode, \
|
renatofilho@549
|
139 |
gst.caps_from_string ("video/x-raw-yuv,framerate=(fraction)10/1"))):
|
renatofilho@549
|
140 |
print "Fail to link vrate element"
|
renatofilho@484
|
141 |
return None
|
renatofilho@484
|
142 |
|
renatofilho@549
|
143 |
if (not vencode.link (vqueue_src)):
|
renatofilho@549
|
144 |
print "Fail to link video encode with queue"
|
renatofilho@521
|
145 |
return None
|
renatofilho@521
|
146 |
|
renatofilho@484
|
147 |
vbin.add_pad (gst.GhostPad ("sink", vqueue.get_pad ("sink")))
|
renatofilho@549
|
148 |
vbin.add_pad (gst.GhostPad ("src", vqueue_src.get_pad ("src")))
|
renatofilho@484
|
149 |
|
renatofilho@484
|
150 |
#audio encode
|
renatofilho@484
|
151 |
#audio/x-raw-int ! queue ! audioconvert ! faac ! rtpmp4gpay ! udpsink name=upd_audio host=224.0.0.1 port=5002
|
renatofilho@484
|
152 |
abin = gst.Bin ()
|
renatofilho@549
|
153 |
aqueue = gst.element_factory_make ("queue", "aqueue")
|
renatofilho@484
|
154 |
aconvert = gst.element_factory_make ("audioconvert", "aconvert")
|
renatofilho@549
|
155 |
arate = gst.element_factory_make ("audioresample", "arate")
|
renatofilho@521
|
156 |
#aencode = gst.element_factory_make ("ffenc_ac3", "aencode")
|
renatofilho@549
|
157 |
aencode = gst.element_factory_make ("queue", "aencode")
|
renatofilho@549
|
158 |
#aencode = gst.element_factory_make ("lame", "aencode")
|
renatofilho@549
|
159 |
#aencode = gst.element_factory_make ("ffenc_mp2", "aencode")
|
renatofilho@549
|
160 |
aqueue_src = gst.element_factory_make ("queue", "aqueue_src")
|
renatofilho@484
|
161 |
|
renatofilho@549
|
162 |
if (None in [abin, aqueue, arate, aencode, aqueue_src]):
|
renatofilho@484
|
163 |
print "Fail to create video encode elements."
|
renatofilho@484
|
164 |
return None
|
renatofilho@484
|
165 |
|
renatofilho@549
|
166 |
abin.add (aqueue, aconvert, arate, aencode, aqueue_src)
|
renatofilho@549
|
167 |
if (not gst.element_link_many (aqueue, aconvert, arate, aencode, aqueue_src)):
|
renatofilho@484
|
168 |
print "Fail to link video elements"
|
renatofilho@484
|
169 |
return None
|
renatofilho@521
|
170 |
|
renatofilho@484
|
171 |
abin.add_pad (gst.GhostPad ("sink", aqueue.get_pad ("sink")))
|
renatofilho@549
|
172 |
abin.add_pad (gst.GhostPad ("src", aqueue_src.get_pad ("src")))
|
renatofilho@484
|
173 |
|
renatofilho@484
|
174 |
#Finish Pipeline
|
renatofilho@521
|
175 |
pipe.add (src, decode, abin, vbin, mux, sink)
|
renatofilho@521
|
176 |
gst.element_link_many (src, decode)
|
renatofilho@484
|
177 |
gst.element_link_many (mux, sink)
|
renatofilho@484
|
178 |
|
renatofilho@484
|
179 |
#Linking decode with mux
|
renatofilho@484
|
180 |
mux_audio = mux.get_pad ("audio_0")
|
renatofilho@484
|
181 |
mux_video = mux.get_pad ("video_0")
|
renatofilho@484
|
182 |
|
renatofilho@521
|
183 |
audio_pad = abin.get_pad ("src")
|
renatofilho@484
|
184 |
video_pad = vbin.get_pad ("src")
|
renatofilho@484
|
185 |
|
renatofilho@484
|
186 |
if (audio_pad.link (mux_audio) != gst.PAD_LINK_OK):
|
renatofilho@484
|
187 |
print "Fail to link audio with mux"
|
renatofilho@484
|
188 |
return None
|
renatofilho@521
|
189 |
|
renatofilho@484
|
190 |
if (video_pad.link (mux_video) != gst.PAD_LINK_OK):
|
renatofilho@484
|
191 |
print "Fail to link audio with mux"
|
renatofilho@484
|
192 |
return None
|
renatofilho@484
|
193 |
|
renatofilho@521
|
194 |
stream_data = self.StreamData (pipe, abin, vbin, sink)
|
renatofilho@521
|
195 |
bus = pipe.get_bus()
|
renatofilho@521
|
196 |
bus.add_signal_watch()
|
renatofilho@521
|
197 |
bus.connect ("message", self.__on_bus_message, stream_data)
|
renatofilho@484
|
198 |
|
renatofilho@521
|
199 |
decode.connect("new-decoded-pad", self.__on_decode_new_pad, stream_data)
|
renatofilho@521
|
200 |
decode.connect("unknown-type", self.__on_decode_unknown_type, stream_data)
|
renatofilho@484
|
201 |
|
renatofilho@549
|
202 |
print ("Create source")
|
renatofilho@521
|
203 |
pipe.set_state (gst.STATE_PAUSED)
|
renatofilho@484
|
204 |
print "Running Pipe"
|
renatofilho@521
|
205 |
stream_data.Loop.run ()
|
renatofilho@484
|
206 |
print "End run"
|
renatofilho@484
|
207 |
|
renatofilho@521
|
208 |
|
morphbr@534
|
209 |
#Create socket
|
morphbr@534
|
210 |
stream_data.Socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
morphbr@534
|
211 |
print "Bind on port %d" % port
|
morphbr@534
|
212 |
stream_data.Socket.bind(('', int (port)))
|
morphbr@534
|
213 |
self.streams.append (stream_data)
|
morphbr@534
|
214 |
return (True, "")
|
renatofilho@484
|
215 |
|
morphbr@534
|
216 |
def play(self):
|
renatofilho@549
|
217 |
print "Play"
|
morphbr@534
|
218 |
stream = self.streams[0]
|
renatofilho@549
|
219 |
self.current = self.StreamListener(stream)
|
renatofilho@549
|
220 |
self.current.start ()
|
renatofilho@549
|
221 |
time.sleep (1)
|
morphbr@534
|
222 |
return (True, "")
|
renatofilho@484
|
223 |
|
renatofilho@484
|
224 |
def stop(self):
|
renatofilho@549
|
225 |
self.current.join ()
|
renatofilho@549
|
226 |
self.current = None
|
morphbr@534
|
227 |
stream = self.streams[0]
|
morphbr@534
|
228 |
stream.Pipe.set_state(gst.STATE_NULL)
|
renatofilho@549
|
229 |
del (stream.Pipe)
|
renatofilho@549
|
230 |
stream.Pipe = None
|
renatofilho@549
|
231 |
stream.Abin = None
|
renatofilho@549
|
232 |
stream.Vbin = None
|
renatofilho@549
|
233 |
stream.Sink = None
|
renatofilho@549
|
234 |
if (stream.Connection != None):
|
renatofilho@549
|
235 |
stream.Connection.close ()
|
renatofilho@549
|
236 |
|
renatofilho@549
|
237 |
self.streams = []
|
renatofilho@549
|
238 |
time.sleep (5)
|
morphbr@534
|
239 |
return (True, "")
|
renatofilho@484
|
240 |
|
renatofilho@484
|
241 |
|
renatofilho@484
|
242 |
def __on_bus_message (self, bus, message, stream_data):
|
renatofilho@484
|
243 |
|
renatofilho@484
|
244 |
t = message.type
|
renatofilho@484
|
245 |
if (t == gst.MESSAGE_STATE_CHANGED):
|
renatofilho@484
|
246 |
oldstate = -1
|
renatofilho@484
|
247 |
newstate = -1
|
renatofilho@484
|
248 |
pending = -1
|
renatofilho@484
|
249 |
oldstate, newstate, pending = message.parse_state_changed ()
|
renatofilho@484
|
250 |
if ((oldstate == gst.STATE_READY) and \
|
renatofilho@484
|
251 |
(newstate == gst.STATE_PAUSED) and \
|
renatofilho@484
|
252 |
(pending == gst.STATE_VOID_PENDING) and \
|
renatofilho@484
|
253 |
(stream_data.Ready == False)):
|
renatofilho@521
|
254 |
state_changed_status, current_state, pending_state = stream_data.Pipe.get_state ()
|
renatofilho@521
|
255 |
if ((current_state == gst.STATE_PAUSED) and \
|
renatofilho@484
|
256 |
(pending_state == gst.STATE_VOID_PENDING)):
|
renatofilho@484
|
257 |
print "Pipe paused"
|
renatofilho@484
|
258 |
stream_data.Loop.quit ()
|
renatofilho@484
|
259 |
stream_data.Ready = True
|
renatofilho@484
|
260 |
elif (t == gst.MESSAGE_ERROR):
|
renatofilho@484
|
261 |
err, debug = message.parse_error()
|
renatofilho@521
|
262 |
print "Error: %s" % err, debug
|
renatofilho@484
|
263 |
stream_data.Loop.quit ()
|
renatofilho@484
|
264 |
stream_data.Ready = False
|
renatofilho@484
|
265 |
|
renatofilho@484
|
266 |
return True
|
renatofilho@521
|
267 |
|
renatofilho@484
|
268 |
def __on_decode_unknown_type (self, decode, pad, caps, stream_data):
|
renatofilho@484
|
269 |
|
renatofilho@484
|
270 |
print "Unknown Type"
|
renatofilho@484
|
271 |
return None
|
renatofilho@484
|
272 |
|
renatofilho@484
|
273 |
def __on_decode_new_pad (self, decode, pad, arg1, stream_data):
|
renatofilho@521
|
274 |
|
renatofilho@484
|
275 |
caps = pad.get_caps().to_string()
|
renatofilho@484
|
276 |
print "New pad " + caps
|
renatofilho@521
|
277 |
if (caps.rfind ("audio") != -1):
|
renatofilho@484
|
278 |
apad = stream_data.Abin.get_pad ("sink")
|
renatofilho@484
|
279 |
if (pad.link (apad) != gst.PAD_LINK_OK):
|
renatofilho@484
|
280 |
print "Error on link audio pad"
|
renatofilho@484
|
281 |
return None
|
renatofilho@484
|
282 |
elif (caps.rfind ("video") != -1):
|
renatofilho@484
|
283 |
vpad = stream_data.Vbin.get_pad ("sink")
|
renatofilho@484
|
284 |
if (pad.link (vpad) != gst.PAD_LINK_OK):
|
renatofilho@484
|
285 |
print "Error on link video pad"
|
renatofilho@484
|
286 |
return None
|
renatofilho@484
|
287 |
else:
|
renatofilho@484
|
288 |
print "Invalid caps"
|
renatofilho@549
|
289 |
print "Linked"
|
renatofilho@484
|
290 |
|