research.m1stereo.tv/gitweb/ - melted/blob - src/melted++/MltMelted.cpp

   1 /**
   2  * MltMiracle.cpp - MLT Wrapper
   3  * Copyright (C) 2004-2005 Charles Yates
   4  * Author: Charles Yates <charles.yates@pandora.be>
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU Lesser General Public License as published
   8  * by the Free Software Foundation; either version 2 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software Foundation,
  18  * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  19  */
  20
  21 #include "MltMiracle.h"
  22 #include "MltService.h"
  23 #include "MltResponse.h"
  24 using namespace Mlt;
  25
  26 #include <time.h>
  27
  28 static valerie_response mlt_miracle_execute( void *arg, char *command )
  29 {
  30         Miracle *miracle = ( Miracle * )arg;
  31         if ( miracle != NULL )
  32         {
  33                 Response *response = miracle->execute( command );
  34                 valerie_response real = valerie_response_clone( response->get_response( ) );
  35                 delete response;
  36                 return real;
  37         }
  38         else
  39         {
  40                 valerie_response response = valerie_response_init( );
  41                 valerie_response_set_error( response, 500, "Invalid server" );
  42                 return response;
  43         }
  44 }
  45
  46 static valerie_response mlt_miracle_received( void *arg, char *command, char *doc )
  47 {
  48         Miracle *miracle = ( Miracle * )arg;
  49         if ( miracle != NULL )
  50         {
  51                 Response *response = miracle->received( command, doc );
  52                 if ( response != NULL )
  53                 {
  54                         valerie_response real = valerie_response_clone( response->get_response( ) );
  55                         delete response;
  56                         return real;
  57                 }
  58                 return NULL;
  59         }
  60         else
  61         {
  62                 valerie_response response = valerie_response_init( );
  63                 valerie_response_set_error( response, 500, "Invalid server" );
  64                 return response;
  65         }
  66 }
  67
  68 static valerie_response mlt_miracle_push( void *arg, char *command, mlt_service service )
  69 {
  70         Miracle *miracle = ( Miracle * )arg;
  71         if ( miracle != NULL )
  72         {
  73                 Service input( service );
  74                 Response *response = miracle->push( command, &input );
  75                 valerie_response real = valerie_response_clone( response->get_response( ) );
  76                 delete response;
  77                 return real;
  78         }
  79         else
  80         {
  81                 valerie_response response = valerie_response_init( );
  82                 valerie_response_set_error( response, 500, "Invalid server" );
  83                 return response;
  84         }
  85 }
  86
  87 Miracle::Miracle( char *name, int port, char *config ) :
  88         Properties( false )
  89 {
  90         server = miracle_server_init( name );
  91         miracle_server_set_port( server, port );
  92         miracle_server_set_config( server, config );
  93 }
  94
  95 Miracle::~Miracle( )
  96 {
  97         miracle_server_close( server );
  98 }
  99
 100 mlt_properties Miracle::get_properties( )
 101 {
 102         return &server->parent;
 103 }
 104
 105 bool Miracle::start( )
 106 {
 107         if ( miracle_server_execute( server ) == 0 )
 108         {
 109                 _real = server->parser->real;
 110                 _execute = server->parser->execute;
 111                 _received = server->parser->received;
 112                 _push = server->parser->push;
 113                 server->parser->real = this;
 114                 server->parser->execute = mlt_miracle_execute;
 115                 server->parser->received = mlt_miracle_received;
 116                 server->parser->push = mlt_miracle_push;
 117         }
 118         return server->shutdown == 0;
 119 }
 120
 121 bool Miracle::is_running( )
 122 {
 123         return server->shutdown == 0;
 124 }
 125
 126 Response *Miracle::execute( char *command )
 127 {
 128         return new Response( _execute( _real, command ) );
 129 }
 130
 131 Response *Miracle::received( char *command, char *doc )
 132 {
 133         return new Response( _received( _real, command, doc ) );
 134 }
 135
 136 Response *Miracle::push( char *command, Service *service )
 137 {
 138         return new Response( _push( _real, command, service->get_service( ) ) );
 139 }
 140
 141 void Miracle::wait_for_shutdown( )
 142 {
 143         struct timespec tm = { 1, 0 };
 144         while ( !server->shutdown )
 145                 nanosleep( &tm, NULL );
 146 }
 147
 148 void Miracle::log_level( int threshold )
 149 {
 150         miracle_log_init( log_stderr, threshold );
 151 }
 152
 153 Properties *Miracle::unit( int index )
 154 {
 155         mlt_properties properties = miracle_server_fetch_unit( server, index );
 156         return properties != NULL ? new Properties( properties ) : NULL;
 157 }