2002-09-09 00:41:53 +02:00
/*
* vo_bl . c - playback using the Blinkenlights UPD protocol ( and to files )
*
* UDP socket handling copied from bsender . c part of blib - 0.6 :
* http : //sven.gimp.org/blinkenlights/
* Copyright ( c ) 2001 - 2001 The Blinkenlights Crew :
* Sven Neumann < sven @ gimp . org >
* Michael Natterer < mitch @ gimp . org >
* Daniel Mack < daniel @ yoobay . net >
* ( these portions are licensed under GNU GPL v2 or " (at your option)
* any later version " )
*
* Other stuff : Copyright ( C ) Rik Snel 2002 , License GNU GPL v2
2004-08-11 15:39:32 +02:00
*
* patch from Stefan Schuermans < 1 stein @ schuermans . info > :
* - correction of " maxval " in Blinkenlights UDP protcol
* - new scheme for new HDL
* - new scheme for grayscale in arbitrary size
2002-09-09 00:41:53 +02:00
*/
# include <stdio.h>
# include <stdlib.h>
# include <string.h>
# include <unistd.h>
# include <fcntl.h>
# include <errno.h>
# include <sys/stat.h>
# include <sys/types.h>
# include <sys/time.h>
# include <sys/mman.h>
# include <sys/ioctl.h>
# include "config.h"
2003-06-11 18:48:09 +02:00
# ifndef HAVE_WINSOCK2
# define closesocket close
# include <netdb.h>
# include <sys/socket.h>
# include <netinet/in.h>
# else
# include <winsock2.h>
# endif
2002-09-09 00:41:53 +02:00
# include "video_out.h"
# include "video_out_internal.h"
2004-10-28 03:15:53 +02:00
# include "mp_msg.h"
# include "m_option.h"
2002-09-09 00:41:53 +02:00
# include "fastmemcpy.h"
2007-12-02 15:06:03 +01:00
static const vo_info_t info =
2002-09-09 00:41:53 +02:00
{
" Blinkenlights driver: http://www.blinkenlights.de " ,
" bl " ,
" Rik Snel <snel@phys.uu.nl> " ,
" "
} ;
2007-12-02 15:39:15 +01:00
const LIBVO_EXTERN ( bl )
2002-11-11 16:22:10 +01:00
2002-09-09 00:41:53 +02:00
/* General variables */
static unsigned char * image = NULL ;
static unsigned char * tmp = NULL ;
static int framenum , yoff , stride ;
static char * bl_subdevice = NULL ;
static int prevpts = - 1 ;
typedef struct {
char * name ; /* filename */
FILE * fp ;
2005-04-14 14:44:28 +02:00
int header_written ; /* if header was written already */
2002-09-09 00:41:53 +02:00
} bl_file_t ;
typedef struct {
char * name ; /* hostname */
int port ;
int fd ; /* file descriptor */
} bl_host_t ;
typedef struct {
char * name ;
int img_format ;
int channels ;
int width ;
int height ;
int bpc ; /* bits per component: bpc = 3, channels = 3 => bpp = 24*/
/* file output functions */
int ( * init_file ) ( bl_file_t * file ) ;
void ( * write_frame ) ( bl_file_t * file , unsigned char * i , int duration ) ;
void ( * close_file ) ( bl_file_t * file ) ;
/* network output functions */
int ( * init_connection ) ( bl_host_t * host ) ;
void ( * send_frame ) ( bl_host_t * host ) ;
void ( * close_connection ) ( bl_host_t * host ) ;
} bl_properties_t ;
static bl_properties_t * bl = NULL ;
/* arbitrary limit because I am too lazy to do proper memory management */
# define BL_MAX_FILES 16
# define BL_MAX_HOSTS 16
static bl_file_t bl_files [ BL_MAX_FILES ] ;
static bl_host_t bl_hosts [ BL_MAX_HOSTS ] ;
static int no_bl_files = 0 ;
static int no_bl_hosts = 0 ;
typedef struct {
uint32_t magic ;
uint16_t height ;
uint16_t width ;
uint16_t channels ;
uint16_t maxval ;
unsigned char data [ 0 ] ;
} bl_packet_t ;
static bl_packet_t * bl_packet = NULL ;
static int bl_size ;
/* bml output functions */
static int bml_init ( bl_file_t * f ) {
f - > fp = fopen ( f - > name , " w " ) ;
if ( ! f - > fp ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: error opening %s \n " , f - > name ) ;
return 1 ;
}
2005-04-14 14:44:28 +02:00
f - > header_written = 0 ;
return 0 ;
}
static void bml_write_frame ( bl_file_t * f , unsigned char * i , int duration ) {
int j , k ;
if ( ! f - > header_written )
{
fprintf ( f - > fp ,
2002-09-09 00:41:53 +02:00
" <?xml version= \" 1.0 \" encoding= \" utf-8 \" ?> \n "
" <blm width= \" %d \" height= \" %d \" bits= \" %d \" channels= \" %d \" > \n "
" <header> \n "
" <title>Movie autogenerated by MPlayer</title> \n "
" <url>http://www.mplayerhq.hu</url> \n "
" </header> \n " , bl - > width , bl - > height , bl - > bpc , bl - > channels ) ;
2005-04-14 14:44:28 +02:00
f - > header_written = 1 ;
}
2002-09-09 00:41:53 +02:00
fprintf ( f - > fp , " <frame duration= \" %d \" > \n " , duration ) ;
for ( j = 0 ; j < bl - > height ; j + + ) {
fprintf ( f - > fp , " <row> " ) ;
for ( k = 0 ; k < bl - > width ; k + + )
fprintf ( f - > fp , " %02x " , * ( i + j * bl - > width + k ) ) ;
fprintf ( f - > fp , " </row> \n " ) ;
}
fprintf ( f - > fp , " </frame> \n " ) ;
}
static void bml_close ( bl_file_t * f ) {
fprintf ( f - > fp , " </blm> \n " ) ;
fclose ( f - > fp ) ;
}
/* Blinkenlights UDP protocol */
static int udp_init ( bl_host_t * h ) {
struct sockaddr_in addr ;
struct hostent * dest ;
dest = gethostbyname ( h - > name ) ;
if ( ! dest ) {
mp_msg ( MSGT_VO , MSGL_ERR ,
" unable to resolve host %s \n " , h - > name ) ;
return 1 ;
}
h - > fd = - 1 ;
addr . sin_family = AF_INET ;
addr . sin_port = htons ( h - > port ) ;
2007-06-05 17:09:49 +02:00
memcpy ( & addr . sin_addr . s_addr , dest - > h_addr_list [ 0 ] , dest - > h_length ) ;
2002-09-09 00:41:53 +02:00
h - > fd = socket ( PF_INET , SOCK_DGRAM , IPPROTO_UDP ) ;
if ( h - > fd < 0 ) {
mp_msg ( MSGT_VO , MSGL_ERR ,
" couldn't create socket for %s \n " , h - > name ) ;
return 1 ;
}
if ( connect ( h - > fd , ( struct sockaddr * ) & addr , sizeof ( addr ) ) < 0 ) {
mp_msg ( MSGT_VO , MSGL_ERR , " couldn't connect socket for %s \n " ,
h - > name ) ;
2003-06-11 18:48:09 +02:00
closesocket ( h - > fd ) ;
2002-09-09 00:41:53 +02:00
return 1 ;
}
return 0 ;
}
static void udp_send ( bl_host_t * h ) {
2003-05-29 21:36:58 +02:00
if ( send ( h - > fd , bl_packet , bl_size , 0 ) ! = bl_size )
2002-09-09 00:41:53 +02:00
mp_msg ( MSGT_VO , MSGL_ERR , " unable to send to %s \n " , h - > name ) ;
}
static void udp_close ( bl_host_t * h ) {
2003-06-11 18:48:09 +02:00
closesocket ( h - > fd ) ;
2002-09-09 00:41:53 +02:00
}
2004-08-11 15:39:32 +02:00
# define NO_BLS 3
2002-09-09 00:41:53 +02:00
static bl_properties_t bls [ NO_BLS ] = {
2004-08-11 15:39:32 +02:00
{ " hdl " , IMGFMT_YV12 , 1 , 18 , 8 , 8 ,
& bml_init , & bml_write_frame , & bml_close ,
& udp_init , & udp_send , & udp_close } ,
2002-09-09 00:41:53 +02:00
{ " arcade " , IMGFMT_YV12 , 1 , 26 , 20 , 8 ,
& bml_init , & bml_write_frame , & bml_close ,
2004-08-11 15:39:32 +02:00
& udp_init , & udp_send , & udp_close } ,
{ " grayscale " , IMGFMT_YV12 , 1 , - 1 , - 1 , 8 , /* use width and height of movie */
& bml_init , & bml_write_frame , & bml_close ,
2002-09-09 00:41:53 +02:00
& udp_init , & udp_send , & udp_close } } ;
2005-08-05 03:24:37 +02:00
static int config ( uint32_t width , uint32_t height , uint32_t d_width ,
2005-04-18 17:52:38 +02:00
uint32_t d_height , uint32_t flags , char * title , uint32_t format )
2002-09-09 00:41:53 +02:00
{
2004-08-11 15:39:32 +02:00
void * ptr ;
/* adapt size of Blinkenlights UDP stream to size of movie */
if ( bl - > width < 0 | | bl - > height < 0 ) {
2005-07-10 14:35:43 +02:00
if ( bl - > width < 0 ) { /* use width of movie */
2004-08-11 15:39:32 +02:00
bl - > width = width ;
2005-07-10 14:35:43 +02:00
bl_packet - > width = htons ( bl - > width ) ;
}
if ( bl - > height < 0 ) { /* use height of movie */
2004-08-11 15:39:32 +02:00
bl - > height = height ;
2005-07-10 14:35:43 +02:00
bl_packet - > height = htons ( bl - > height ) ;
}
2004-08-11 15:39:32 +02:00
/* check for maximum size of UDP packet */
if ( 12 + bl - > width * bl - > height * bl - > channels > 65507 ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: %dx%d-%d does not fit into an UDP packet \n " ,
bl - > width , bl - > height , bl - > channels ) ;
return 1 ;
}
/* resize frame and tmp buffers */
bl_size = 12 + bl - > width * bl - > height * bl - > channels ;
ptr = realloc ( bl_packet , 12 + bl - > width * bl - > height * 3 ) ; /* space for header and image data */
if ( ptr )
bl_packet = ( bl_packet_t * ) ptr ;
else {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: out of memory error \n " ) ;
return 1 ;
}
image = ( ( unsigned char * ) bl_packet + 12 ) ; /* pointer to image data */
ptr = realloc ( tmp , bl - > width * bl - > height * 3 ) ; /* space for image data only */
if ( ptr )
tmp = ( unsigned char * ) ptr ;
else {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: out of memory error \n " ) ;
return 1 ;
}
}
2002-09-09 00:41:53 +02:00
framenum = 0 ;
if ( format ! = IMGFMT_YV12 ) {
mp_msg ( MSGT_VO , MSGL_ERR , " vo_bl called with wrong format " ) ;
return 1 ;
}
if ( width > bl - > width ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: width of movie too large %d > %d \n " , width , bl - > width ) ;
return 1 ;
}
if ( height > bl - > height ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: height of movie too large %d > %d \n " , height , bl - > height ) ;
return 1 ;
}
if ( ! image ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: image should be initialized, internal error \n " ) ;
return 1 ;
}
memset ( image , 0 , bl - > width * bl - > height * 3 ) ; /* blank the image */
mp_msg ( MSGT_VO , MSGL_V , " vo_config bl called \n " ) ;
return 0 ;
}
static void draw_osd ( void ) {
}
static void flip_page ( void ) {
int i ;
if ( prevpts > = 0 ) for ( i = 0 ; i < no_bl_files ; i + + )
bl - > write_frame ( & bl_files [ i ] , tmp , ( vo_pts - prevpts ) / 90 ) ;
2007-06-05 16:27:54 +02:00
fast_memcpy ( tmp , image , bl - > width * bl - > height * bl - > channels ) ;
2002-09-09 00:41:53 +02:00
prevpts = vo_pts ;
for ( i = 0 ; i < no_bl_hosts ; i + + ) bl - > send_frame ( & bl_hosts [ i ] ) ;
framenum + + ;
return ;
}
2005-08-05 03:24:37 +02:00
static int draw_frame ( uint8_t * src [ ] ) {
2002-09-09 00:41:53 +02:00
return 0 ;
}
2005-08-05 03:24:37 +02:00
static int query_format ( uint32_t format ) {
2002-09-09 00:41:53 +02:00
if ( format = = bl - > img_format )
return VFCAP_CSP_SUPPORTED | VFCAP_CSP_SUPPORTED_BY_HW ;
return 0 ;
}
static void uninit ( void ) {
int i ;
mp_msg ( MSGT_VO , MSGL_V , " bl: uninit called \n " ) ;
free ( bl_packet ) ;
bl_packet = NULL ;
free ( bl_subdevice ) ;
bl_subdevice = NULL ;
for ( i = 0 ; i < no_bl_files ; i + + ) bl - > close_file ( & bl_files [ i ] ) ;
for ( i = 0 ; i < no_bl_hosts ; i + + ) bl - > close_connection ( & bl_hosts [ i ] ) ;
no_bl_files = 0 ;
no_bl_hosts = 0 ;
bl = NULL ;
}
static void check_events ( void ) {
}
2005-08-05 03:24:37 +02:00
static int draw_slice ( uint8_t * srcimg [ ] , int stride [ ] ,
2002-09-09 00:41:53 +02:00
int wf , int hf , int xf , int yf ) {
int i , j , w , h , x , y ;
uint8_t * dst ;
uint8_t * src = srcimg [ 0 ] ;
uint8_t * src1 = srcimg [ 1 ] ;
uint8_t * src2 = srcimg [ 2 ] ;
w = wf ; h = hf ; x = xf ; y = yf ;
dst = image ; /* + zr->off_y + zr->image_width*(y/zr->vdec)+x;*/
// copy Y:
for ( i = 0 ; i < h ; i + + ) {
2007-06-05 16:27:54 +02:00
fast_memcpy ( dst , src , w ) ;
2002-09-09 00:41:53 +02:00
dst + = bl - > width ;
src + = stride [ 0 ] ;
}
return 0 ;
}
2005-08-05 03:24:37 +02:00
static int preinit ( const char * arg ) {
2002-09-09 00:41:53 +02:00
char * p , * q ;
int end = 0 , i ;
2004-08-11 15:39:32 +02:00
char txt [ 256 ] ;
2002-09-09 00:41:53 +02:00
if ( ! arg | | strlen ( arg ) = = 0 ) {
2004-08-11 15:39:32 +02:00
mp_msg ( MSGT_VO , MSGL_ERR , " bl: subdevice must be given, example: -vo bl:arcade:host=localhost:2323 \n " ) ;
2002-09-09 00:41:53 +02:00
return 1 ;
}
bl_subdevice = malloc ( strlen ( arg ) + 1 ) ;
if ( ! bl_subdevice ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: out of memory error \n " ) ;
return 1 ;
}
p = bl_subdevice ;
strcpy ( p , arg ) ;
mp_msg ( MSGT_VO , MSGL_V , " bl: preinit called with %s \n " , arg ) ;
2004-08-11 15:39:32 +02:00
for ( i = 0 ; i < NO_BLS ; i + + ) {
if ( ! strncmp ( p , bls [ i ] . name , strlen ( bls [ i ] . name ) ) )
break ;
}
if ( i > = NO_BLS ) {
txt [ 0 ] = 0 ;
for ( i = 0 ; i < NO_BLS ; i + + )
if ( strlen ( txt ) + 4 + strlen ( bls [ i ] . name ) + 1 < sizeof ( txt ) )
sprintf ( txt + strlen ( txt ) , " %s%s " ,
txt [ 0 ] = = 0 ? " " : i = = NO_BLS - 1 ? " or " : " , " , bls [ i ] . name ) ;
mp_msg ( MSGT_VO , MSGL_ERR , " bl: subdevice must start with %s \n bl: i.e. -vo bl:arcade:host=localhost:2323 \n " , txt ) ;
2002-09-09 00:41:53 +02:00
return 1 ;
}
2004-08-11 15:39:32 +02:00
bl = & bls [ i ] ;
p + = strlen ( bls [ i ] . name ) ;
2002-09-09 00:41:53 +02:00
if ( * p = = ' \0 ' ) {
no_bl_hosts = 1 ;
bl_hosts [ 0 ] . name = " localhost " ;
bl_hosts [ 0 ] . port = 2323 ;
mp_msg ( MSGT_VO , MSGL_V , " bl: no hosts/files specified, using localhost:2323 \n " ) ;
end = 1 ;
} else if ( * p ! = ' : ' ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: syntax error in subdevice \n " ) ;
return 1 ;
}
p + + ;
while ( ! end ) {
q = p + 5 ;
if ( ! strncmp ( p , " file= " , 5 ) ) {
if ( no_bl_files = = BL_MAX_FILES ) {
2004-08-11 15:39:32 +02:00
mp_msg ( MSGT_VO , MSGL_ERR , " bl: maximum number of files reached (%d) \n " , BL_MAX_FILES ) ;
2002-09-09 00:41:53 +02:00
return 1 ;
}
p + = 5 ;
while ( * q ! = ' , ' & & * q ! = ' \0 ' ) q + + ;
if ( * q = = ' \0 ' ) end = 1 ;
* q = ' \0 ' ;
bl_files [ no_bl_files ] . name = p ;
mp_msg ( MSGT_VO , MSGL_V , " blfile[%d]: %s \n " ,
no_bl_files , p ) ;
no_bl_files + + ;
} else if ( ! strncmp ( p , " host= " , 5 ) ) {
if ( no_bl_hosts = = BL_MAX_HOSTS ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: maximum number of hosts reached (%d) \n " , BL_MAX_HOSTS ) ;
return 1 ;
}
p + = 5 ;
while ( * q ! = ' , ' & & * q ! = ' \0 ' & & * q ! = ' : ' ) q + + ;
if ( * q = = ' : ' ) {
* q + + = ' \0 ' ;
bl_hosts [ no_bl_hosts ] . name = p ;
bl_hosts [ no_bl_hosts ] . port = atoi ( q ) ;
while ( * q ! = ' , ' & & * q ! = ' \0 ' ) q + + ;
if ( * q = = ' \0 ' ) end = 1 ;
} else {
/* use default port */
if ( * q = = ' \0 ' ) end = 1 ;
* q = ' \0 ' ;
bl_hosts [ no_bl_hosts ] . name = p ;
bl_hosts [ no_bl_hosts ] . port = 2323 ;
}
mp_msg ( MSGT_VO , MSGL_V ,
" blhost[%d]: %s:%d \n " ,
no_bl_hosts , p ,
bl_hosts [ no_bl_hosts ] . port ) ;
no_bl_hosts + + ;
} else {
2007-02-21 11:05:46 +01:00
mp_msg ( MSGT_VO , MSGL_ERR , " bl: syntax error in entry %d in subdevice %s, should be a comma separated \n list of host=name:port and file=foo.bml \n " , no_bl_hosts , no_bl_files , arg ) ;
2002-09-09 00:41:53 +02:00
return 1 ;
}
p = + + q ;
}
2004-08-11 15:39:32 +02:00
if ( bl - > width > = 0 & & bl - > height > = 0 ) { /* size already known */
bl_size = 12 + bl - > width * bl - > height * bl - > channels ;
bl_packet = malloc ( 12 + bl - > width * bl - > height * 3 ) ; /* space for header and image data */
image = ( ( unsigned char * ) bl_packet + 12 ) ; /* pointer to image data */
tmp = malloc ( bl - > width * bl - > height * 3 ) ; /* space for image data only */
}
else { /* size unknown yet */
bl_size = 12 ;
bl_packet = malloc ( 12 + 3 ) ; /* space for header and a pixel */
image = ( ( unsigned char * ) bl_packet + 12 ) ; /* pointer to image data */
tmp = malloc ( 3 ) ; /* space for a pixel only */
}
2002-09-09 00:41:53 +02:00
if ( ! bl_packet | | ! tmp ) {
mp_msg ( MSGT_VO , MSGL_ERR , " bl: out of memory error \n " ) ;
return 1 ;
}
bl_packet - > magic = htonl ( 0x23542666 ) ;
bl_packet - > width = htons ( bl - > width ) ;
bl_packet - > height = htons ( bl - > height ) ;
bl_packet - > channels = htons ( bl - > channels ) ;
2004-08-11 15:39:32 +02:00
bl_packet - > maxval = htons ( ( 1 < < bl - > bpc ) - 1 ) ;
2002-09-09 00:41:53 +02:00
/* open all files */
for ( i = 0 ; i < no_bl_files ; i + + )
if ( bl - > init_file ( & bl_files [ i ] ) ) return 1 ;
/* open all sockets */
for ( i = 0 ; i < no_bl_hosts ; i + + )
if ( bl - > init_connection ( & bl_hosts [ i ] ) ) return 1 ;
return 0 ;
}
2005-08-05 03:24:37 +02:00
static int control ( uint32_t request , void * data , . . . ) {
2002-09-09 00:41:53 +02:00
switch ( request ) {
case VOCTRL_QUERY_FORMAT :
return query_format ( * ( ( uint32_t * ) data ) ) ;
}
return VO_NOTIMPL ;
}