| blob | d7e86262ffcfa22bf22975726204e01641e7a4bc |
1 --- /dev/null 2006-09-07 16:53:33.000000000 +0200
2 +++ avmedia/source/gstreamer/gstplayer.cxx 2006-09-22 14:56:04.000000000 +0200
3 @@ -0,0 +1,628 @@
4 +/*************************************************************************
5 + *
6 + * OpenOffice.org - a multi-platform office productivity suite
7 + *
8 + * $RCSfile$
9 + *
10 + * $Revision$
11 + *
12 + * last change: $Author$ $Date$
13 + *
14 + * The Contents of this file are made available subject to
15 + * the terms of GNU Lesser General Public License Version 2.1.
16 + *
17 + *
18 + * GNU Lesser General Public License Version 2.1
19 + * =============================================
20 + * Copyright 2005 by Sun Microsystems, Inc.
21 + * 901 San Antonio Road, Palo Alto, CA 94303, USA
22 + *
23 + * This library is free software; you can redistribute it and/or
24 + * modify it under the terms of the GNU Lesser General Public
25 + * License version 2.1, as published by the Free Software Foundation.
26 + *
27 + * This library is distributed in the hope that it will be useful,
28 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
29 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
30 + * Lesser General Public License for more details.
31 + *
32 + * You should have received a copy of the GNU Lesser General Public
33 + * License along with this library; if not, write to the Free Software
34 + * Foundation, Inc., 59 Temple Place, Suite 330, Boston,
35 + * MA 02111-1307 USA
36 + *
37 + ************************************************************************/
38 +
39 +#include <math.h>
40 +
41 +#ifndef __RTL_USTRING_
42 +#include <rtl/string.hxx>
43 +#endif
44 +
45 +#include "gstplayer.hxx"
46 +#include "gstframegrabber.hxx"
47 +#include "gstwindow.hxx"
48 +
49 +#include <gst/interfaces/xoverlay.h>
50 +
51 +#define AVMEDIA_GST_PLAYER_IMPLEMENTATIONNAME "com.sun.star.comp.avmedia.Player_GStreamer"
52 +#define AVMEDIA_GST_PLAYER_SERVICENAME "com.sun.star.media.Player_GStreamer"
53 +
54 +#if DEBUG
55 +#define DBG OSL_TRACE
56 +#else
57 +#define DBG(...)
58 +#endif
59 +
60 +using namespace ::com::sun::star;
61 +
62 +namespace avmedia { namespace gstreamer {
63 +
64 +// ----------------
65 +// - Player -
66 +// ----------------
67 +
68 +Player::Player( const uno::Reference< lang::XMultiServiceFactory >& rxMgr ) :
69 + mxMgr( rxMgr ),
70 + mpPlaybin( NULL ),
71 + mbFakeVideo (sal_False ),
72 + mnUnmutedVolume( 0 ),
73 + mbMuted( false ),
74 + mbLooping( false ),
75 + mbInitialized( false ),
76 + mnWindowID( 0 ),
77 + mpXOverlay( NULL ),
78 + mnDuration( 0 ),
79 + mnWidth( 0 ),
80 + mnHeight( 0 ),
81 + maSizeCondition( osl_createCondition() )
82 +{
83 + // Initialize GStreamer library
84 + int argc = 1;
85 + char *arguments[] = { "openoffice.org" };
86 + char** argv = arguments;
87 + GError* pError = NULL;
88 +
89 + mbInitialized = gst_init_check( &argc, &argv, &pError );
90 +
91 + if (pError != NULL)
92 + // TODO: thow an exception?
93 + g_error_free (pError);
94 +}
95 +
96 +// ------------------------------------------------------------------------------
97 +
98 +Player::~Player()
99 +{
100 + // Release the elements and pipeline
101 + if( mbInitialized )
102 + {
103 + if( mpPlaybin )
104 + {
105 + gst_element_set_state( mpPlaybin, GST_STATE_NULL );
106 + gst_object_unref( GST_OBJECT( mpPlaybin ) );
107 +
108 + mpPlaybin = NULL;
109 + }
110 +
111 + if( mpXOverlay ) {
112 + g_object_unref( G_OBJECT ( mpXOverlay ) );
113 + mpXOverlay = NULL;
114 + }
115 + }
116 +}
117 +
118 +// ------------------------------------------------------------------------------
119 +
120 +static gboolean gst_pipeline_bus_callback( GstBus *, GstMessage *message, gpointer data )
121 +{
122 + Player* pPlayer = (Player *) data;
123 +
124 + pPlayer->processMessage( message );
125 +
126 + return TRUE;
127 +}
128 +
129 +static GstBusSyncReply gst_pipeline_bus_sync_handler( GstBus *, GstMessage * message, gpointer data )
130 +{
131 + Player* pPlayer = (Player *) data;
132 +
133 + return pPlayer->processSyncMessage( message );
134 +}
135 +
136 +void Player::processMessage( GstMessage *message )
137 +{
138 + //DBG ( "gst message received: src name: %s structure type: %s",
139 + // gst_object_get_name (message->src),
140 + // message->structure ? gst_structure_get_name (message->structure) : "<none>");
141 +
142 + switch( GST_MESSAGE_TYPE( message ) ) {
143 + case GST_MESSAGE_EOS:
144 + //DBG( "EOS, reset state to NULL" );
145 + gst_element_set_state( mpPlaybin, GST_STATE_READY );
146 + break;
147 + case GST_MESSAGE_STATE_CHANGED:
148 + if( message->src == GST_OBJECT( mpPlaybin ) ) {
149 + GstState newstate, pendingstate;
150 +
151 + gst_message_parse_state_changed (message, NULL, &newstate, &pendingstate);
152 +
153 + if( newstate == GST_STATE_PAUSED &&
154 + pendingstate == GST_STATE_VOID_PENDING &&
155 + mpXOverlay )
156 + gst_x_overlay_expose( mpXOverlay );
157 + }
158 + default:
159 + break;
160 + }
161 +}
162 +
163 +GstBusSyncReply Player::processSyncMessage( GstMessage *message )
164 +{
165 + DBG( "%p processSyncMessage", this );
166 + //DBG ( "gst message received: src name: %s structure type: %s",
167 + // gst_object_get_name (message->src),
168 + // message->structure ? gst_structure_get_name (message->structure) : "<none>");
169 +
170 + if (message->structure) {
171 + if( !strcmp( gst_structure_get_name( message->structure ), "prepare-xwindow-id" ) && mnWindowID != 0 ) {
172 + if( mpXOverlay )
173 + g_object_unref( G_OBJECT ( mpXOverlay ) );
174 + mpXOverlay = GST_X_OVERLAY( GST_MESSAGE_SRC( message ) );
175 + g_object_ref( G_OBJECT ( mpXOverlay ) );
176 + gst_x_overlay_set_xwindow_id( mpXOverlay, mnWindowID );
177 + return GST_BUS_DROP;
178 + }
179 + }
180 +
181 + if( GST_MESSAGE_TYPE( message ) == GST_MESSAGE_STATE_CHANGED ) {
182 + if( message->src == GST_OBJECT( mpPlaybin ) ) {
183 + GstState newstate, pendingstate;
184 +
185 + gst_message_parse_state_changed (message, NULL, &newstate, &pendingstate);
186 +
187 + DBG( "%p state change received, new state %d", this, newstate );
188 + if( newstate == GST_STATE_PAUSED &&
189 + pendingstate == GST_STATE_VOID_PENDING ) {
190 +
191 + DBG( "%p change to paused received", this );
192 +
193 + if( mnDuration == 0) {
194 + GstFormat format = GST_FORMAT_TIME;
195 + gint64 gst_duration = 0L;
196 +
197 + if( gst_element_query_duration( mpPlaybin, &format, &gst_duration) && format == GST_FORMAT_TIME && gst_duration > 0L )
198 + mnDuration = gst_duration;
199 + }
200 +
201 + if( mnWidth == 0 ) {
202 + GList *pStreamInfo = NULL;
203 +
204 + g_object_get( G_OBJECT( mpPlaybin ), "stream-info", &pStreamInfo, NULL );
205 +
206 + for ( ; pStreamInfo != NULL; pStreamInfo = pStreamInfo->next) {
207 + GObject *pInfo = G_OBJECT( pStreamInfo->data );
208 +
209 + if( !pInfo )
210 + continue;
211 +
212 + int nType;
213 + g_object_get( pInfo, "type", &nType, NULL );
214 + GEnumValue *pValue = g_enum_get_value( G_PARAM_SPEC_ENUM( g_object_class_find_property( G_OBJECT_GET_CLASS( pInfo ), "type" ) )->enum_class,
215 + nType );
216 +
217 + if( !g_strcasecmp( pValue->value_nick, "video" ) ) {
218 + GstStructure *pStructure;
219 + GstPad *pPad;
220 +
221 + g_object_get( pInfo, "object", &pPad, NULL );
222 + pStructure = gst_caps_get_structure( GST_PAD_CAPS( pPad ), 0 );
223 + if( pStructure ) {
224 + gst_structure_get_int( pStructure, "width", &mnWidth );
225 + gst_structure_get_int( pStructure, "height", &mnHeight );
226 + DBG( "queried size: %d x %d", mnWidth, mnHeight );
227 + }
228 + }
229 + }
230 +
231 + sal_Bool aSuccess = osl_setCondition( maSizeCondition );
232 + DBG( "%p set condition result: %d", this, aSuccess );
233 + }
234 + }
235 + }
236 + } else if( GST_MESSAGE_TYPE( message ) == GST_MESSAGE_ERROR ) {
237 + if( mnWidth == 0 ) {
238 + // an error occured, set condition so that OOo thread doesn't wait for us
239 + sal_Bool aSuccess = osl_setCondition( maSizeCondition );
240 + DBG( "%p set condition result: %d", this, aSuccess );
241 + }
242 + }
243 +
244 + return GST_BUS_PASS;
245 +}
246 +
247 +void Player::preparePlaybin( const ::rtl::OUString& rURL, bool bFakeVideo )
248 +{
249 + GstBus *pBus;
250 +
251 + //sal_Bool aSuccess = osl_setCondition( maSizeCondition );
252 + //DBG( "%p set condition result: %d", this, aSuccess );
253 +
254 + if( mpPlaybin != NULL ) {
255 + gst_element_set_state( mpPlaybin, GST_STATE_NULL );
256 + g_object_unref( mpPlaybin );
257 + }
258 +
259 + mpPlaybin = gst_element_factory_make( "playbin", NULL );
260 +
261 + if( bFakeVideo )
262 + g_object_set( G_OBJECT( mpPlaybin ), "video-sink", gst_element_factory_make( "fakesink", NULL ), NULL );
263 +
264 + mbFakeVideo = bFakeVideo;
265 +
266 + rtl::OString ascURL = OUStringToOString( rURL, RTL_TEXTENCODING_ASCII_US );
267 + g_object_set( G_OBJECT( mpPlaybin ), "uri", ascURL.getStr() , NULL );
268 +
269 + pBus = gst_element_get_bus( mpPlaybin );
270 + gst_bus_add_watch( pBus, gst_pipeline_bus_callback, this );
271 + DBG( "%p set sync handler", this );
272 + gst_bus_set_sync_handler( pBus, gst_pipeline_bus_sync_handler, this );
273 + g_object_unref( pBus );
274 +}
275 +
276 +bool Player::create( const ::rtl::OUString& rURL )
277 +{
278 + bool bRet = false;
279 +
280 + // create all the elements and link them
281 +
282 + if( mbInitialized )
283 + {
284 + preparePlaybin( rURL, true );
285 +
286 + gst_element_set_state( mpPlaybin, GST_STATE_PAUSED );
287 +
288 + bRet = true;
289 + }
290 +
291 +
292 + if( bRet )
293 + maURL = rURL;
294 + else
295 + maURL = ::rtl::OUString();
296 +
297 + return bRet;
298 +}
299 +
300 +// ------------------------------------------------------------------------------
301 +
302 +void SAL_CALL Player::start( )
303 + throw (uno::RuntimeException)
304 +{
305 + //DBG ("Player::start");
306 +
307 + // set the pipeline state to READY and run the loop
308 + if( mbInitialized && NULL != mpPlaybin )
309 + {
310 + gst_element_set_state( mpPlaybin, GST_STATE_PLAYING );
311 + }
312 +}
313 +
314 +// ------------------------------------------------------------------------------
315 +
316 +void SAL_CALL Player::stop( )
317 + throw (uno::RuntimeException)
318 +{
319 + // set the pipeline in PAUSED STATE
320 + if( mpPlaybin )
321 + gst_element_set_state( mpPlaybin, GST_STATE_PAUSED );
322 +
323 + DBG( "stop %p", mpPlaybin );
324 +}
325 +
326 +// ------------------------------------------------------------------------------
327 +
328 +sal_Bool SAL_CALL Player::isPlaying()
329 + throw (uno::RuntimeException)
330 +{
331 + bool bRet = false;
332 +
333 + // return whether the pipeline is in PLAYING STATE or not
334 + if( mbInitialized && mpPlaybin )
335 + {
336 + bRet = GST_STATE_PLAYING == GST_STATE( mpPlaybin );
337 + }
338 +
339 + DBG( "isPlaying %d", bRet );
340 +
341 + return bRet;
342 +}
343 +
344 +// ------------------------------------------------------------------------------
345 +
346 +double SAL_CALL Player::getDuration( )
347 + throw (uno::RuntimeException)
348 +{
349 + // slideshow checks for non-zero duration, so cheat here
350 + double duration = 0.01;
351 +
352 + if( mpPlaybin && mnDuration > 0 ) {
353 + duration = mnDuration / 1E9;
354 +
355 + //DBG( "gst duration: %lld ns duration: %lf s", gst_duration, duration );
356 + }
357 +
358 + return duration;
359 +}
360 +
361 +// ------------------------------------------------------------------------------
362 +
363 +void SAL_CALL Player::setMediaTime( double fTime )
364 + throw (uno::RuntimeException)
365 +{
366 + if( mpPlaybin ) {
367 + gint64 gst_position = llround (fTime * 1E9);
368 +
369 + gst_element_seek( mpPlaybin, 1.0,
370 + GST_FORMAT_TIME,
371 + GST_SEEK_FLAG_FLUSH,
372 + GST_SEEK_TYPE_SET, gst_position,
373 + GST_SEEK_TYPE_NONE, 0 );
374 + if( !isPlaying() )
375 + gst_element_set_state( mpPlaybin, GST_STATE_PAUSED );
376 +
377 + DBG( "seek to: %lld ns original: %lf s", gst_position, fTime );
378 + }
379 +}
380 +
381 +// ------------------------------------------------------------------------------
382 +
383 +double SAL_CALL Player::getMediaTime( )
384 + throw (uno::RuntimeException)
385 +{
386 + double position = 0.0;
387 +
388 + if( mpPlaybin ) {
389 + // get current position in the stream
390 + GstFormat format = GST_FORMAT_TIME;
391 + gint64 gst_position;
392 + if( gst_element_query_position( mpPlaybin, &format, &gst_position ) && format == GST_FORMAT_TIME && gst_position > 0L )
393 + position = gst_position / 1E9;
394 + }
395 +
396 + return position;
397 +}
398 +
399 +// ------------------------------------------------------------------------------
400 +
401 +void SAL_CALL Player::setStopTime( double fTime )
402 + throw (uno::RuntimeException)
403 +{
404 + // TODO implement
405 +}
406 +
407 +// ------------------------------------------------------------------------------
408 +
409 +double SAL_CALL Player::getStopTime( )
410 + throw (uno::RuntimeException)
411 +{
412 + // Get the time at which to stop
413 +
414 + return 0;
415 +}
416 +
417 +// ------------------------------------------------------------------------------
418 +
419 +void SAL_CALL Player::setRate( double fRate )
420 + throw (uno::RuntimeException)
421 +{
422 + // TODO set the window rate
423 +}
424 +
425 +// ------------------------------------------------------------------------------
426 +
427 +double SAL_CALL Player::getRate( )
428 + throw (uno::RuntimeException)
429 +{
430 + double rate = 0.0;
431 +
432 + // TODO get the window rate
433 + if( mbInitialized )
434 + {
435 +
436 + }
437 +
438 + return rate;
439 +}
440 +
441 +// ------------------------------------------------------------------------------
442 +
443 +void SAL_CALL Player::setPlaybackLoop( sal_Bool bSet )
444 + throw (uno::RuntimeException)
445 +{
446 + // TODO check how to do with GST
447 + mbLooping = bSet;
448 +}
449 +
450 +// ------------------------------------------------------------------------------
451 +
452 +sal_Bool SAL_CALL Player::isPlaybackLoop( )
453 + throw (uno::RuntimeException)
454 +{
455 + // TODO check how to do with GST
456 + return mbLooping;
457 +}
458 +
459 +// ------------------------------------------------------------------------------
460 +
461 +void SAL_CALL Player::setMute( sal_Bool bSet )
462 + throw (uno::RuntimeException)
463 +{
464 + DBG( "set mute: %d muted: %d unmuted volume: %lf", bSet, mbMuted, mnUnmutedVolume );
465 +
466 + // change the volume to 0 or the unmuted volume
467 + if( mpPlaybin && mbMuted != bSet )
468 + {
469 + double nVolume = mnUnmutedVolume;
470 + if( bSet )
471 + {
472 + nVolume = 0.0;
473 + }
474 +
475 + g_object_set( G_OBJECT( mpPlaybin ), "volume", nVolume, NULL );
476 +
477 + mbMuted = bSet;
478 + }
479 +}
480 +
481 +// ------------------------------------------------------------------------------
482 +
483 +sal_Bool SAL_CALL Player::isMute( )
484 + throw (uno::RuntimeException)
485 +{
486 + return mbMuted;
487 +}
488 +
489 +// ------------------------------------------------------------------------------
490 +
491 +void SAL_CALL Player::setVolumeDB( sal_Int16 nVolumeDB )
492 + throw (uno::RuntimeException)
493 +{
494 + mnUnmutedVolume = pow( 10.0, nVolumeDB / 20.0 );
495 +
496 + DBG( "set volume: %d gst volume: %lf", nVolumeDB, mnUnmutedVolume );
497 +
498 + // change volume
499 + if( !mbMuted && mpPlaybin )
500 + {
501 + g_object_set( G_OBJECT( mpPlaybin ), "volume", (gdouble) mnUnmutedVolume, NULL );
502 + }
503 +}
504 +
505 +// ------------------------------------------------------------------------------
506 +
507 +sal_Int16 SAL_CALL Player::getVolumeDB( )
508 + throw (uno::RuntimeException)
509 +{
510 + sal_Int16 nVolumeDB;
511 +
512 + if( mpPlaybin ) {
513 + double nGstVolume = 0.0;
514 +
515 + g_object_get( G_OBJECT( mpPlaybin ), "volume", &nGstVolume, NULL );
516 +
517 + nVolumeDB = (sal_Int16) ( 20.0*log10 ( nGstVolume ) );
518 +
519 + //DBG( "get volume: %d gst volume: %lf", nVolumeDB, nGstVolume );
520 + }
521 +
522 + return nVolumeDB;
523 +}
524 +
525 +// ------------------------------------------------------------------------------
526 +
527 +awt::Size SAL_CALL Player::getPreferredPlayerWindowSize( )
528 + throw (uno::RuntimeException)
529 +{
530 + awt::Size aSize( 0, 0 );
531 +
532 + DBG( "%p Player::getPreferredPlayerWindowSize, member %d x %d", this, mnWidth, mnHeight );
533 +
534 + TimeValue aTimeout = { 10, 0 };
535 + oslConditionResult aResult = osl_waitCondition( maSizeCondition, &aTimeout );
536 +
537 + if( mbFakeVideo ) {
538 + mbFakeVideo = sal_False;
539 +
540 + g_object_set( G_OBJECT( mpPlaybin ), "video-sink", NULL, NULL );
541 + gst_element_set_state( mpPlaybin, GST_STATE_READY );
542 + gst_element_set_state( mpPlaybin, GST_STATE_PAUSED );
543 + }
544 +
545 + DBG( "%p Player::getPreferredPlayerWindowSize after waitCondition %d, member %d x %d", this, aResult, mnWidth, mnHeight );
546 +
547 + if( mnWidth != 0 && mnHeight != 0 ) {
548 + aSize.Width = mnWidth;
549 + aSize.Height = mnHeight;
550 + }
551 +
552 + return aSize;
553 +}
554 +
555 +// ------------------------------------------------------------------------------
556 +
557 +uno::Reference< ::media::XPlayerWindow > SAL_CALL Player::createPlayerWindow( const uno::Sequence< uno::Any >& rArguments )
558 + throw (uno::RuntimeException)
559 +{
560 + uno::Reference< ::media::XPlayerWindow > xRet;
561 + awt::Size aSize( getPreferredPlayerWindowSize() );
562 +
563 + DBG( "Player::createPlayerWindow %d %d length: %d", aSize.Width, aSize.Height, rArguments.getLength() );
564 +
565 + if( aSize.Width > 0 && aSize.Height > 0 )
566 + {
567 + ::avmedia::gstreamer::Window* pWindow = new ::avmedia::gstreamer::Window( mxMgr, *this );
568 +
569 + xRet = pWindow;
570 +
571 + if( rArguments.getLength() > 2 ) {
572 + rArguments[ 2 ] >>= mnWindowID;
573 + DBG( "window ID: %ld", mnWindowID );
574 + }
575 +
576 + //if( !pWindow->create( aArguments ) )
577 + //xRet = uno::Reference< ::media::XPlayerWindow >();
578 + }
579 +
580 + return xRet;
581 +}
582 +
583 +// ------------------------------------------------------------------------------
584 +
585 +uno::Reference< media::XFrameGrabber > SAL_CALL Player::createFrameGrabber( )
586 + throw (uno::RuntimeException)
587 +{
588 + uno::Reference< media::XFrameGrabber > xRet;
589 +
590 + /*if( maURL.getLength() > 0 )
591 + {
592 + FrameGrabber* pGrabber = new FrameGrabber( mxMgr );
593 +
594 + xRet = pGrabber;
595 +
596 + if( !pGrabber->create( maURL ) )
597 + xRet.clear();
598 + }*/
599 +
600 + return xRet;
601 +}
602 +
603 +// ------------------------------------------------------------------------------
604 +
605 +::rtl::OUString SAL_CALL Player::getImplementationName( )
606 + throw (uno::RuntimeException)
607 +{
608 + return ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM( AVMEDIA_GST_PLAYER_IMPLEMENTATIONNAME ) );
609 +}
610 +
611 +// ------------------------------------------------------------------------------
612 +
613 +sal_Bool SAL_CALL Player::supportsService( const ::rtl::OUString& ServiceName )
614 + throw (uno::RuntimeException)
615 +{
616 + return ServiceName.equalsAsciiL( RTL_CONSTASCII_STRINGPARAM ( AVMEDIA_GST_PLAYER_SERVICENAME ) );
617 +}
618 +
619 +// ------------------------------------------------------------------------------
620 +
621 +uno::Sequence< ::rtl::OUString > SAL_CALL Player::getSupportedServiceNames( )
622 + throw (uno::RuntimeException)
623 +{
624 + uno::Sequence< ::rtl::OUString > aRet(1);
625 + aRet[0] = ::rtl::OUString( RTL_CONSTASCII_USTRINGPARAM ( AVMEDIA_GST_PLAYER_SERVICENAME ) );
626 +
627 + return aRet;
628 +}
629 +
630 +} // namespace gstreamer
631 +} // namespace avmedia