From 70276678d4cadf6249c9b3e0cbcfa6b55086d358 Mon Sep 17 00:00:00 2001 From: "N.N." Date: Sat, 14 Aug 2010 17:28:17 +0000 Subject: version 0.12.26 : added pdp_vloopback svn path=/trunk/externals/pidip/; revision=13792 --- modules/pdp_vloopback.c | 338 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 338 insertions(+) create mode 100755 modules/pdp_vloopback.c (limited to 'modules/pdp_vloopback.c') diff --git a/modules/pdp_vloopback.c b/modules/pdp_vloopback.c new file mode 100755 index 0000000..12f9e31 --- /dev/null +++ b/modules/pdp_vloopback.c @@ -0,0 +1,338 @@ +/* + * PiDiP module + * Authors : Yves Degoyon ( ydegoyon@free.fr ) and Lluis Gomez i Bigorda + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + */ + +/* This object is a vloopback output module, + * inspired by the code of mjpegtools_yuv_to_v4l by Jan Panteltje + * it enables you to send pd output to another application + * that supports v4l input + */ + + +#include "pdp_config.h" +#include "pdp.h" +#include "pdp_imageproc.h" +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include + +typedef struct pdp_vloopback_struct +{ + t_object x_obj; + t_float x_f; + + t_symbol *x_device; + int x_vlfd; + + int x_packet0; + int x_packet1; + int x_dropped; + int x_queue_id; + + t_outlet *x_outlet0; + t_outlet *x_outlet1; + + int x_nbframes; + + struct video_window x_vidwin; + struct video_picture x_vidpic; + + bool x_initialized; + + unsigned int x_width; + unsigned int x_height; + +} t_pdp_vloopback; + +static void pdp_vloopback_close(t_pdp_vloopback *x) +{ + // close the vloopback device + if ( close( x->x_vlfd ) == -1 ) + { + post( "could not close device %s", x->x_device->s_name ); + perror( "closing device" ); + } + else + { + post( "closed device %s", x->x_device->s_name ); + } + + x->x_initialized=0; + x->x_nbframes=0; + +} + +static void pdp_vloopback_open(t_pdp_vloopback *x, t_symbol *name) +{ + // open a vloopback device and allocate buffers + + // check if the vloopback module is loaded + // it might be the one of webcamstudio called webcamstudio + int module_loaded=0; + int ret; + + x->x_device=name; + +#ifdef __LINUX__ + + if ( ( ret = system( "/sbin/lsmod | grep vloopback" ) ) == 256 ) + { + post( "pdp_vloopback : vloopback module is not loaded (ret=%d)", ret ); + } + else + { + post( "pdp_vloopback : vloopback module is loaded" ); + module_loaded=1; + } + + if ( ( ret = system( "/sbin/lsmod | grep webcamstudio" ) ) == 256 ) + { + post( "pdp_vloopback : webcamstudio module is not loaded (ret=%d)", ret ); + } + else + { + post( "pdp_vloopback : alternate module webcamstudio is loaded" ); + module_loaded=1; + } + + if ( module_loaded==0 ) + { + post( "pdp_vloopback : refusing to proceed" ); + return; + } + +#endif + + if ( x->x_initialized ) + { + pdp_vloopback_close(x); + } + + // open the device + if ( ( x->x_vlfd = open (name->s_name, O_RDWR) ) < 0 ) + { + post( "pdp_vloopback : unable to open : %s", name->s_name ); + perror( "open device" ); + return; + } + + // setting palette to RGB24 + if( ioctl(x->x_vlfd, VIDIOCGPICT, &x->x_vidpic) == -1) + { + post("pdp_vloopback : could get palette ( VIDIOCGPICT )"); + perror( "ioctl VIDIOCGPICT" ); + return; + } + + x->x_vidpic.palette = VIDEO_PALETTE_RGB24; + if( ioctl(x->x_vlfd, VIDIOCSPICT, &x->x_vidpic) == -1) + { + post("pdp_vloopback : could set palette ( VIDIOCSPICT )"); + perror( "ioctl VIDIOCSPICT" ); + return; + } + + // setting window size + if(ioctl (x->x_vlfd, VIDIOCGWIN, &x->x_vidwin) == -1) + { + post("pdp_vloopback : could get dimensions ( VIDIOCGWIN )"); + perror( "ioctl VIDIOCGWIN" ); + return; + } + + x->x_vidwin.width = x->x_width; + x->x_vidwin.height = x->x_height; + + if(ioctl (x->x_vlfd, VIDIOCSWIN, &x->x_vidwin) == -1) + { + post("pdp_vloopback : could set dimensions ( VIDIOCSWIN )"); + perror( "ioctl VIDIOCSWIN" ); + return; + } + + // all went well we are now initialized + x->x_initialized=1; + post( "pdp_vloopback : opened device : %s", x->x_device->s_name ); + +} + +static void pdp_vloopback_setlegaldim(t_pdp_vloopback *x, int xx, int yy) +{ + x->x_width = pdp_imageproc_legalwidth((int)xx); + x->x_height = pdp_imageproc_legalheight((int)yy); +} + +static void pdp_vloopback_dim(t_pdp_vloopback *x, t_floatarg xx, t_floatarg yy) +{ + pdp_vloopback_setlegaldim(x, (int)xx, (int)yy); + if (x->x_initialized){ + pdp_vloopback_close(x); + } + pdp_vloopback_open(x, x->x_device); +} + +static void pdp_vloopback_process_rgb(t_pdp_vloopback *x) +{ + t_pdp *header = pdp_packet_header(x->x_packet0); + char *data = (char *)pdp_packet_data(x->x_packet0); + int written, flength; + + if ( !x->x_initialized ) + { + post( "pdp_vloopback : no vloopback device opened" ); + return; + } + + if ( (header->info.image.width != x->x_width ) || + (header->info.image.height != x->x_height ) ) + { + pdp_vloopback_dim(x, header->info.image.width, header->info.image.height); + } + + // output the image + flength = x->x_width*x->x_height*3; + + if ( ( written = write(x->x_vlfd, data, flength) ) != flength ) + { + post( "pdp_vloopback : problem writing frame...closing" ); + post( "pdp_vloopback : wrote %d bytes out of %d", written, flength ); + } + else + { + outlet_float( x->x_outlet1, x->x_nbframes++); + } + +} + +static void pdp_vloopback_sendpacket(t_pdp_vloopback *x) +{ + /* release the packet */ + pdp_packet_mark_unused(x->x_packet0); + + /* unregister and propagate if valid dest packet */ + pdp_packet_pass_if_valid(x->x_outlet0, &x->x_packet0); +} + +static void pdp_vloopback_process(t_pdp_vloopback *x) +{ + int encoding; + t_pdp *header = 0; + + /* check if image data packets are compatible */ + if ( (header = pdp_packet_header(x->x_packet0)) + && (PDP_BITMAP == header->type)){ + + /* pdp_vloopback_process inputs and write into active inlet */ + switch(pdp_packet_header(x->x_packet0)->info.image.encoding){ + + case PDP_BITMAP_RGB: + pdp_queue_add(x, pdp_vloopback_process_rgb, pdp_vloopback_sendpacket, &x->x_queue_id); + break; + + default: + /* don't know the type, so dont pdp_vloopback_process */ + break; + + } + } +} + +static void pdp_vloopback_input_0(t_pdp_vloopback *x, t_symbol *s, t_floatarg f) +{ + /* if this is a register_ro message or register_rw message, register with packet factory */ + + if (s== gensym("register_rw")) + x->x_dropped = pdp_packet_convert_ro_or_drop(&x->x_packet0, (int)f, pdp_gensym("bitmap/rgb/*") ); + + if ((s == gensym("process")) && (-1 != x->x_packet0) && (!x->x_dropped)){ + + /* add the process method and callback to the process queue */ + pdp_vloopback_process(x); + + } +} + +static void pdp_vloopback_free(t_pdp_vloopback *x) +{ + pdp_vloopback_close(x); +} + +t_class *pdp_vloopback_class; + +void *pdp_vloopback_new(t_symbol *vdev) +{ + t_pdp_vloopback *x = (t_pdp_vloopback *)pd_new(pdp_vloopback_class); + + x->x_outlet0 = outlet_new(&x->x_obj, &s_anything); + x->x_outlet1 = outlet_new(&x->x_obj, &s_float); + + x->x_initialized = false; + x->x_nbframes = 0; + + x->x_packet0 = -1; + x->x_packet1 = -1; + x->x_queue_id = -1; + + x->x_width = 320; + x->x_height = 240; + + x->x_vlfd = -1; + if (vdev != gensym("")){ + x->x_device = vdev; + pdp_vloopback_open(x, x->x_device); + } + else + { + x->x_device = gensym("/dev/video1"); + } + + return (void *)x; +} + + +#ifdef __cplusplus +extern "C" +{ +#endif + + +void pdp_vloopback_setup(void) +{ + pdp_vloopback_class = class_new(gensym("pdp_vloopback"), (t_newmethod)pdp_vloopback_new, + (t_method)pdp_vloopback_free, sizeof(t_pdp_vloopback), CLASS_DEFAULT, A_DEFSYMBOL, A_DEFSYMBOL, A_NULL); + + class_addmethod(pdp_vloopback_class, (t_method)pdp_vloopback_close, gensym("close"), A_NULL); + class_addmethod(pdp_vloopback_class, (t_method)pdp_vloopback_open, gensym("open"), A_SYMBOL, A_NULL); + class_addmethod(pdp_vloopback_class, (t_method)pdp_vloopback_input_0, gensym("pdp"), A_SYMBOL, A_DEFFLOAT, A_NULL); + +} + +#ifdef __cplusplus +} +#endif -- cgit v1.2.1