mjpg-streamer摄像头远程传输UVC

input_init (input_uvc.c )

-->if (init_videoIn(videoIn, dev, width, height, fps, format, 1) < 0)

        init_videoIn(V4l2uvc.c (plugins\input_uvc) 

            init_v4l2

global.in.run = dlsym(global.in.handle, "input_run");

 input_run(input_uvc.c )

     -->pthread_create(&cam, 0, cam_thread, NULL);

        void *cam_thread( void *arg ) 

             uvcGrab(videoIn) 

            if (videoIn->formatIn == V4L2_PIX_FMT_YUYV)

                  pglobal->size = compress_yuyv_to_jpeg(videoIn, pglobal->buf, videoIn->framesizeIn, gquality);

else

  {

   pglobal->size = memcpy_picture(pglobal->buf, videoIn->tmpbuffer, videoIn->buf.bytesused);

  }

global.out[i].init = dlsym(global.out[i].handle, "output_init"); 

  output_init(   output_http.c)

 servers[param->id].id = param->id;

 servers[param->id].pglobal = param->global;

 servers[param->id].conf.port = port;

 servers[param->id].conf.credentials = credentials;

 servers[param->id].conf.www_folder = www_folder;

 servers[param->id].conf.nocommands = nocommands;

global.out[i].stop = dlsym(global.out[i].handle, "output_stop");

output_stop

pthread_cancel(servers[id].threadID);

global.out[i].run = dlsym(global.out[i].handle, "output_run"); 

    output_run(output_http.c)

         pthread_create(&(servers[id].threadID), NULL, server_thread, &(servers[id])); // 创建一个线程 server_thread

         pthread_detach(servers[id].threadID); // 等待线程结束,以便回收

            server_thread (Httpd.c\plugins\output_http)  

                  ->  client_thread

                        if ( strstr(buffer, "GET /?action=snapshot") != NULL )

 {

  req.type = A_SNAPSHOT; 

 }

 else if ( strstr(buffer, "GET /?action=stream") != NULL )

 {

  req.type = A_STREAM; 

 }

 else if ( strstr(buffer, "GET /?action=command") != NULL )

 {

                            req.type = A_COMMAND;

                    }

        switch ( req.type ){

case A_SNAPSHOT:

   DBG("Request for snapshot\n");

   send_snapshot(lcfd.fd);

   break;

  case A_STREAM:

   DBG("Request for stream\n");

   send_stream(lcfd.fd);

   break;

}