v4l_mosaic.c

mediastreamer2是开源的网络传输媒体流的库

/** Copyright 2007 Simon Morlat, all rights reserved **/

#include <mediastreamer2/msfilter.h>
#include <mediastreamer2/msvideo.h>
#include <mediastreamer2/msticker.h>
#include <mediastreamer2/msv4l.h>
#include <mediastreamer2/mstee.h>


int main(int argc, char *argv[]){
#if defined(WIN32)
	int count;
#endif
	MSFilter *source,*pixconv,*tee,*stitcher,*output;
	MSVideoSize vsize;
	MSTicker *ticker;
	int format;
	int i;

	ms_init();
	source=ms_filter_new(MS_V4L_ID);
	tee=ms_filter_new(MS_TEE_ID);
	stitcher=ms_filter_new_from_name("MSVideoStitcher");
	if (stitcher==NULL){
		ms_error("Fail to create stitcher: plugin not loaded ?");
		return -1;
	}
	output=ms_filter_new(MS_VIDEO_OUT_ID);
	
	vsize.width=MS_VIDEO_SIZE_CIF_W;
	vsize.height=MS_VIDEO_SIZE_CIF_H;
	ms_filter_call_method(source,MS_FILTER_SET_VIDEO_SIZE,&vsize);
	ms_filter_call_method_noarg(source,MS_V4L_START);
	/* get the output format for webcam reader */
	ms_filter_call_method(source,MS_FILTER_GET_PIX_FMT,&format);
	if (format==MS_MJPEG){
		pixconv=ms_filter_new(MS_MJPEG_DEC_ID);
	}else{
		pixconv = ms_filter_new(MS_PIX_CONV_ID);
		/*set it to the pixconv */
		ms_filter_call_method(pixconv,MS_FILTER_SET_PIX_FMT,&format);
		ms_filter_call_method(pixconv,MS_FILTER_SET_VIDEO_SIZE,&vsize);
	}
	ms_filter_link(source,0,pixconv,0);
	ms_filter_link(pixconv,0,tee,0);
	ms_filter_link(tee,0,stitcher,0);
	ms_filter_link(tee,1,stitcher,1);
	ms_filter_link(tee,2,stitcher,2);
	ms_filter_link(tee,3,stitcher,3);
	ms_filter_link(stitcher,0,output,0);

	//mute everything but 0:
	for(i=1;i<4;++i)
		ms_filter_call_method(tee,MS_TEE_MUTE,&i);

	ticker=ms_ticker_new();
	ms_ticker_attach(ticker,source);

	/*add new region every five seconds*/
	
#if defined(WIN32)
  count=0;
  while (count<250)
  {
	  MSG msg;
	  BOOL fGotMessage;
	  if((fGotMessage = PeekMessage(&msg, (HWND) NULL, 0, 0, PM_REMOVE)) != 0)
		{
		  TranslateMessage(&msg); 
		  DispatchMessage(&msg);
		}
	  count++;
	  Sleep(20);
  }
#else
	ms_sleep(5);
#endif

	i=1;
	ms_filter_call_method(tee,MS_TEE_UNMUTE,&i);

#if defined(WIN32)
  count=0;
  while (count<250)
  {
	  MSG msg;
	  BOOL fGotMessage;
	  if((fGotMessage = PeekMessage(&msg, (HWND) NULL, 0, 0, PM_REMOVE)) != 0)
		{
		  TranslateMessage(&msg); 
		  DispatchMessage(&msg);
		}
	  count++;
	  Sleep(20);
  }
#else
	ms_sleep(5);
#endif

	i=2;
	ms_filter_call_method(tee,MS_TEE_UNMUTE,&i);

#if defined(WIN32)
  count=0;
  while (count<250)
  {
	  MSG msg;
	  BOOL fGotMessage;
	  if((fGotMessage = PeekMessage(&msg, (HWND) NULL, 0, 0, PM_REMOVE)) != 0)
		{
		  TranslateMessage(&msg); 
		  DispatchMessage(&msg);
		}
	  count++;
	  Sleep(20);
  }
#else
	ms_sleep(5);
#endif

	i=3;
	ms_filter_call_method(tee,MS_TEE_UNMUTE,&i);

#if defined(WIN32)
  count=0;
  while (count<250)
  {
	  MSG msg;
	  BOOL fGotMessage;
	  if((fGotMessage = PeekMessage(&msg, (HWND) NULL, 0, 0, PM_REMOVE)) != 0)
		{
		  TranslateMessage(&msg); 
		  DispatchMessage(&msg);
		}
	  count++;
	  Sleep(20);
  }
#else
	ms_sleep(5);
#endif

	ms_ticker_detach(ticker,source);
	ms_ticker_destroy(ticker);
	ms_filter_unlink(source,0,pixconv,0);
	ms_filter_unlink(pixconv,0,tee,0);
	ms_filter_unlink(tee,0,stitcher,0);
	ms_filter_unlink(tee,1,stitcher,1);
	ms_filter_unlink(tee,2,stitcher,2);
	ms_filter_unlink(tee,3,stitcher,3);
	ms_filter_unlink(stitcher,0,output,0);
	
	ms_filter_destroy(source);
	ms_filter_destroy(pixconv);
	ms_filter_destroy(tee);
	ms_filter_destroy(stitcher);
	ms_filter_destroy(output);
	return 0;
}