/*************************************************************************** * v4l2grab Version 0.2 * * Copyright (C) 2009 by Tobias Müller * * Tobias_Mueller@twam.info * * * * based on V4L2 Specification, Appendix B: Video Capture Example * * (http://v4l2spec.bytesex.org/spec/capture-example.html) * * * * 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., * * 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ***************************************************************************/ // use ITU-R float conversion for YUV422toRGB888 by default #if !defined(ITU_R_FLOAT) && !defined(ITU_R_INT) && !defined(NTSC) #define ITU_R_FLOAT #endif #if ((defined(ITU_R_FLOAT)) && (defined(ITU_R_INT)) && (defined(NTSC))) || ((defined(ITU_R_FLOAT)) && (defined(ITU_R_INT))) || ((defined(ITU_R_FLOAT)) && (defined(NTSC))) || ((defined(ITU_R_INT)) && (defined(NTSC))) #error Only one conversion for YUV422toRGB888 is allowed! #endif // compile with all three access methods #if !defined(IO_READ) && !defined(IO_MMAP) && !defined(IO_USERPTR) #define IO_READ #define IO_MMAP #define IO_USERPTR #endif #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define CLEAR(x) memset (&(x), 0, sizeof (x)) typedef enum { #ifdef IO_READ IO_METHOD_READ, #endif #ifdef IO_MMAP IO_METHOD_MMAP, #endif #ifdef IO_USERPTR IO_METHOD_USERPTR, #endif } io_method; struct buffer { void * start; size_t length; }; static io_method io = IO_METHOD_MMAP; static int fd = -1; struct buffer * buffers = NULL; static unsigned int n_buffers = 0; // global settings static unsigned int width = 640; static unsigned int height = 480; static unsigned char jpegQuality = 70; static char* jpegFilename = NULL; static char* deviceName = "/dev/video0"; /** Convert from YUV422 format to RGB888. Formulae are described on http://en.wikipedia.org/wiki/YUV \param width width of image \param height height of image \param src source \param dst destination */ static void YUV422toRGB888(int width, int height, unsigned char *src, unsigned char *dst) { int line, column; unsigned char *py, *pu, *pv; unsigned char *tmp = dst; /* In this format each four bytes is two pixels. Each four bytes is two Y's, a Cb and a Cr. Each Y goes to one of the pixels, and the Cb and Cr belong to both pixels. */ py = src; pu = src + 1; pv = src + 3; #define CLIP(x) ( (x)>=0xFF ? 0xFF : ( (x) <= 0x00 ? 0x00 : (x) ) ) for (line = 0; line < height; ++line) { for (column = 0; column < width; ++column) { #ifdef ITU_R_FLOAT // ITU-R float *tmp++ = CLIP((double)*py + 1.402*((double)*pv-128.0)); *tmp++ = CLIP((double)*py - 0.344*((double)*pu-128.0) - 0.714*((double)*pv-128.0)); *tmp++ = CLIP((double)*py + 1.772*((double)*pu-128.0)); #endif #ifdef ITU_R_INT // ITU-R integer *tmp++ = CLIP( *py + (*pv-128) + ((*pv-128) >> 2) + ((*pv-128) >> 3) + ((*pv-128) >> 5) ); *tmp++ = CLIP( *py - (((*pu-128) >> 2) + ((*pu-128) >> 4) + ((*pu-128) >> 5)) - (((*pv-128) >> 1) + ((*pv-128) >> 3) + ((*pv-128) >> 4) + ((*pv-128) >> 5)) ); // 52 58 *tmp++ = CLIP( *py + (*pu-128) + ((*pu-128) >> 1) + ((*pu-128) >> 2) + ((*pu-128) >> 6) ); #endif #ifdef NTSC // NTSC integer *tmp++ = CLIP( (298*(*py-16) + 409*(*pv-128) + 128) >> 8 ); *tmp++ = CLIP( (298*(*py-16) - 100*(*pu-128) - 208*(*pv-128) + 128) >> 8 ); *tmp++ = CLIP( (298*(*py-16) + 516*(*pu-128) + 128) >> 8 ); #endif // increase py every time py += 2; // increase pu,pv every second time if ((column & 1)==1) { pu += 4; pv += 4; } } } } /** Print error message and terminate programm with EXIT_FAILURE return code. \param s error message to print */ static void errno_exit(const char* s) { fprintf(stderr, "%s error %d, %s\n", s, errno, strerror (errno)); exit(EXIT_FAILURE); } /** Do ioctl and retry if error was EINTR ("A signal was caught during the ioctl() operation."). Parameters are the same as on ioctl. \param fd file descriptor \param request request \param argp argument \returns result from ioctl */ static int xioctl(int fd, int request, void* argp) { int r; do r = ioctl(fd, request, argp); while (-1 == r && EINTR == errno); return r; } /** Write image to jpeg file. \param img image to write */ static void jpegWrite(unsigned char* img) { struct jpeg_compress_struct cinfo; struct jpeg_error_mgr jerr; JSAMPROW row_pointer[1]; FILE *outfile = fopen( jpegFilename, "wb" ); // try to open file for saving if (!outfile) { errno_exit("jpeg"); } // create jpeg data cinfo.err = jpeg_std_error( &jerr ); jpeg_create_compress(&cinfo); jpeg_stdio_dest(&cinfo, outfile); // set image parameters cinfo.image_width = width; cinfo.image_height = height; cinfo.input_components = 3; cinfo.in_color_space = JCS_RGB; // set jpeg compression parameters to default jpeg_set_defaults(&cinfo); // and then adjust quality setting jpeg_set_quality(&cinfo, jpegQuality, TRUE); // start compress jpeg_start_compress(&cinfo, TRUE); // feed data while (cinfo.next_scanline < cinfo.image_height) { row_pointer[0] = &img[cinfo.next_scanline * cinfo.image_width * cinfo.input_components]; jpeg_write_scanlines(&cinfo, row_pointer, 1); } // finish compression jpeg_finish_compress(&cinfo); // destroy jpeg data jpeg_destroy_compress(&cinfo); // close output file fclose(outfile); } /** process image read */ static void imageProcess(const void* p) { unsigned char* src = (unsigned char*)p; unsigned char* dst = malloc(width*height*3*sizeof(char)); // convert from YUV422 to RGB888 YUV422toRGB888(width,height,src,dst); // write jpeg jpegWrite(dst); } /** read single frame */ static int frameRead(void) { struct v4l2_buffer buf; #ifdef IO_USERPTR unsigned int i; #endif switch (io) { #ifdef IO_READ case IO_METHOD_READ: if (-1 == read (fd, buffers[0].start, buffers[0].length)) { switch (errno) { case EAGAIN: return 0; case EIO: // Could ignore EIO, see spec. // fall through default: errno_exit("read"); } } imageProcess(buffers[0].start); break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: CLEAR(buf); buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; buf.memory = V4L2_MEMORY_MMAP; if (-1 == xioctl(fd, VIDIOC_DQBUF, &buf)) { switch (errno) { case EAGAIN: return 0; case EIO: // Could ignore EIO, see spec // fall through default: errno_exit("VIDIOC_DQBUF"); } } assert(buf.index < n_buffers); imageProcess(buffers[buf.index].start); if (-1 == xioctl(fd, VIDIOC_QBUF, &buf)) errno_exit("VIDIOC_QBUF"); break; #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: CLEAR (buf); buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; buf.memory = V4L2_MEMORY_USERPTR; if (-1 == xioctl(fd, VIDIOC_DQBUF, &buf)) { switch (errno) { case EAGAIN: return 0; case EIO: // Could ignore EIO, see spec. // fall through default: errno_exit("VIDIOC_DQBUF"); } } for (i = 0; i < n_buffers; ++i) if (buf.m.userptr == (unsigned long) buffers[i].start && buf.length == buffers[i].length) break; assert (i < n_buffers); imageProcess((void *)buf.m.userptr); if (-1 == xioctl(fd, VIDIOC_QBUF, &buf)) errno_exit("VIDIOC_QBUF"); break; #endif } return 1; } /** mainloop: read frames and process them */ static void mainLoop(void) { unsigned int count; unsigned int numberOfTimeouts; numberOfTimeouts = 0; count = 1; while (count-- > 0) { for (;;) { fd_set fds; struct timeval tv; int r; FD_ZERO(&fds); FD_SET(fd, &fds); /* Timeout. */ tv.tv_sec = 1; tv.tv_usec = 0; r = select(fd + 1, &fds, NULL, NULL, &tv); if (-1 == r) { if (EINTR == errno) continue; errno_exit("select"); } if (0 == r) { if (numberOfTimeouts <= 0) { count++; } else { fprintf(stderr, "select timeout\n"); exit(EXIT_FAILURE); } } if (frameRead()) break; /* EAGAIN - continue select loop. */ } } } /** stop capturing */ static void captureStop(void) { enum v4l2_buf_type type; switch (io) { #ifdef IO_READ case IO_METHOD_READ: /* Nothing to do. */ break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: #endif #if defined(IO_MMAP) || defined(IO_USERPTR) type = V4L2_BUF_TYPE_VIDEO_CAPTURE; if (-1 == xioctl(fd, VIDIOC_STREAMOFF, &type)) errno_exit("VIDIOC_STREAMOFF"); break; #endif } } /** start capturing */ static void captureStart(void) { unsigned int i; enum v4l2_buf_type type; switch (io) { #ifdef IO_READ case IO_METHOD_READ: /* Nothing to do. */ break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: for (i = 0; i < n_buffers; ++i) { struct v4l2_buffer buf; CLEAR(buf); buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; buf.memory = V4L2_MEMORY_MMAP; buf.index = i; if (-1 == xioctl(fd, VIDIOC_QBUF, &buf)) errno_exit("VIDIOC_QBUF"); } type = V4L2_BUF_TYPE_VIDEO_CAPTURE; if (-1 == xioctl(fd, VIDIOC_STREAMON, &type)) errno_exit("VIDIOC_STREAMON"); break; #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: for (i = 0; i < n_buffers; ++i) { struct v4l2_buffer buf; CLEAR (buf); buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; buf.memory = V4L2_MEMORY_USERPTR; buf.index = i; buf.m.userptr = (unsigned long) buffers[i].start; buf.length = buffers[i].length; if (-1 == xioctl(fd, VIDIOC_QBUF, &buf)) errno_exit("VIDIOC_QBUF"); } type = V4L2_BUF_TYPE_VIDEO_CAPTURE; if (-1 == xioctl(fd, VIDIOC_STREAMON, &type)) errno_exit("VIDIOC_STREAMON"); break; #endif } } static void deviceUninit(void) { unsigned int i; switch (io) { #ifdef IO_READ case IO_METHOD_READ: free(buffers[0].start); break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: for (i = 0; i < n_buffers; ++i) if (-1 == munmap (buffers[i].start, buffers[i].length)) errno_exit("munmap"); break; #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: for (i = 0; i < n_buffers; ++i) free (buffers[i].start); break; #endif } free(buffers); } #ifdef IO_READ static void readInit(unsigned int buffer_size) { buffers = calloc(1, sizeof(*buffers)); if (!buffers) { fprintf(stderr, "Out of memory\n"); exit(EXIT_FAILURE); } buffers[0].length = buffer_size; buffers[0].start = malloc(buffer_size); if (!buffers[0].start) { fprintf (stderr, "Out of memory\n"); exit(EXIT_FAILURE); } } #endif #ifdef IO_MMAP static void mmapInit(void) { struct v4l2_requestbuffers req; CLEAR(req); req.count = 4; req.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; req.memory = V4L2_MEMORY_MMAP; if (-1 == xioctl(fd, VIDIOC_REQBUFS, &req)) { if (EINVAL == errno) { fprintf(stderr, "%s does not support memory mapping\n", deviceName); exit(EXIT_FAILURE); } else { errno_exit("VIDIOC_REQBUFS"); } } if (req.count < 2) { fprintf(stderr, "Insufficient buffer memory on %s\n", deviceName); exit(EXIT_FAILURE); } buffers = calloc(req.count, sizeof(*buffers)); if (!buffers) { fprintf(stderr, "Out of memory\n"); exit(EXIT_FAILURE); } for (n_buffers = 0; n_buffers < req.count; ++n_buffers) { struct v4l2_buffer buf; CLEAR(buf); buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; buf.memory = V4L2_MEMORY_MMAP; buf.index = n_buffers; if (-1 == xioctl(fd, VIDIOC_QUERYBUF, &buf)) errno_exit("VIDIOC_QUERYBUF"); buffers[n_buffers].length = buf.length; buffers[n_buffers].start = mmap (NULL /* start anywhere */, buf.length, PROT_READ | PROT_WRITE /* required */, MAP_SHARED /* recommended */, fd, buf.m.offset); if (MAP_FAILED == buffers[n_buffers].start) errno_exit("mmap"); } } #endif #ifdef IO_USERPTR static void userptrInit(unsigned int buffer_size) { struct v4l2_requestbuffers req; unsigned int page_size; page_size = getpagesize(); buffer_size = (buffer_size + page_size - 1) & ~(page_size - 1); CLEAR(req); req.count = 4; req.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; req.memory = V4L2_MEMORY_USERPTR; if (-1 == xioctl(fd, VIDIOC_REQBUFS, &req)) { if (EINVAL == errno) { fprintf(stderr, "%s does not support user pointer i/o\n", deviceName); exit(EXIT_FAILURE); } else { errno_exit("VIDIOC_REQBUFS"); } } buffers = calloc(4, sizeof (*buffers)); if (!buffers) { fprintf(stderr, "Out of memory\n"); exit(EXIT_FAILURE); } for (n_buffers = 0; n_buffers < 4; ++n_buffers) { buffers[n_buffers].length = buffer_size; buffers[n_buffers].start = memalign (/* boundary */ page_size, buffer_size); if (!buffers[n_buffers].start) { fprintf(stderr, "Out of memory\n"); exit(EXIT_FAILURE); } } } #endif /** initialize device */ static void deviceInit(void) { struct v4l2_capability cap; struct v4l2_cropcap cropcap; struct v4l2_crop crop; struct v4l2_format fmt; unsigned int min; if (-1 == xioctl(fd, VIDIOC_QUERYCAP, &cap)) { if (EINVAL == errno) { fprintf(stderr, "%s is no V4L2 device\n",deviceName); exit(EXIT_FAILURE); } else { errno_exit("VIDIOC_QUERYCAP"); } } if (!(cap.capabilities & V4L2_CAP_VIDEO_CAPTURE)) { fprintf(stderr, "%s is no video capture device\n",deviceName); exit(EXIT_FAILURE); } switch (io) { #ifdef IO_READ case IO_METHOD_READ: if (!(cap.capabilities & V4L2_CAP_READWRITE)) { fprintf(stderr, "%s does not support read i/o\n",deviceName); exit(EXIT_FAILURE); } break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: #endif #if defined(IO_MMAP) || defined(IO_USERPTR) if (!(cap.capabilities & V4L2_CAP_STREAMING)) { fprintf(stderr, "%s does not support streaming i/o\n",deviceName); exit(EXIT_FAILURE); } break; #endif } /* Select video input, video standard and tune here. */ CLEAR(cropcap); cropcap.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; if (0 == xioctl(fd, VIDIOC_CROPCAP, &cropcap)) { crop.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; crop.c = cropcap.defrect; /* reset to default */ if (-1 == xioctl(fd, VIDIOC_S_CROP, &crop)) { switch (errno) { case EINVAL: /* Cropping not supported. */ break; default: /* Errors ignored. */ break; } } } else { /* Errors ignored. */ } CLEAR(fmt); // v4l2_format fmt.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; fmt.fmt.pix.width = width; fmt.fmt.pix.height = height; fmt.fmt.pix.pixelformat = V4L2_PIX_FMT_YUYV; fmt.fmt.pix.field = V4L2_FIELD_INTERLACED; if (-1 == xioctl(fd, VIDIOC_S_FMT, &fmt)) errno_exit("VIDIOC_S_FMT"); /* Note VIDIOC_S_FMT may change width and height. */ if (width != fmt.fmt.pix.width) { width = fmt.fmt.pix.width; fprintf(stderr,"Image width set to %i by device %s.\n",width,deviceName); } if (height != fmt.fmt.pix.height) { height = fmt.fmt.pix.height; fprintf(stderr,"Image height set to %i by device %s.\n",height,deviceName); } /* Buggy driver paranoia. */ min = fmt.fmt.pix.width * 2; if (fmt.fmt.pix.bytesperline < min) fmt.fmt.pix.bytesperline = min; min = fmt.fmt.pix.bytesperline * fmt.fmt.pix.height; if (fmt.fmt.pix.sizeimage < min) fmt.fmt.pix.sizeimage = min; switch (io) { #ifdef IO_READ case IO_METHOD_READ: readInit(fmt.fmt.pix.sizeimage); break; #endif #ifdef IO_MMAP case IO_METHOD_MMAP: mmapInit(); break; #endif #ifdef IO_USERPTR case IO_METHOD_USERPTR: userptrInit(fmt.fmt.pix.sizeimage); break; #endif } } /** close device */ static void deviceClose(void) { if (-1 == close (fd)) errno_exit("close"); fd = -1; } /** open device */ static void deviceOpen(void) { struct stat st; // stat file if (-1 == stat(deviceName, &st)) { fprintf(stderr, "Cannot identify '%s': %d, %s\n", deviceName, errno, strerror (errno)); exit(EXIT_FAILURE); } // check if its device if (!S_ISCHR (st.st_mode)) { fprintf(stderr, "%s is no device\n", deviceName); exit(EXIT_FAILURE); } // open device fd = open(deviceName, O_RDWR /* required */ | O_NONBLOCK, 0); // check if opening was successfull if (-1 == fd) { fprintf(stderr, "Cannot open '%s': %d, %s\n", deviceName, errno, strerror (errno)); exit(EXIT_FAILURE); } } /** print usage information */ static void usage(FILE* fp, int argc, char** argv) { fprintf (fp, "Usage: %s [options]\n\n" "Options:\n" "-d | --device name Video device name [/dev/video0]\n" "-h | --help Print this message\n" "-o | --output JPEG output filename\n" "-q | --quality JPEG quality (0-100)\n" "-m | --mmap Use memory mapped buffers\n" "-r | --read Use read() calls\n" "-u | --userptr Use application allocated buffers\n" "-W | --width width\n" "-H | --height height\n" "", argv[0]); } static const char short_options [] = "d:ho:q:mruW:H:"; static const struct option long_options [] = { { "device", required_argument, NULL, 'd' }, { "help", no_argument, NULL, 'h' }, { "output", required_argument, NULL, 'o' }, { "quality", required_argument, NULL, 'q' }, { "mmap", no_argument, NULL, 'm' }, { "read", no_argument, NULL, 'r' }, { "userptr", no_argument, NULL, 'u' }, { "width", required_argument, NULL, 'W' }, { "height", required_argument, NULL, 'H' }, { 0, 0, 0, 0 } }; int main(int argc, char **argv) { for (;;) { int index, c = 0; c = getopt_long(argc, argv, short_options, long_options, &index); if (-1 == c) break; switch (c) { case 0: /* getopt_long() flag */ break; case 'd': deviceName = optarg; break; case 'h': // print help usage(stdout, argc, argv); exit(EXIT_SUCCESS); case 'o': // set jpeg filename jpegFilename = optarg; break; case 'q': // set jpeg quality jpegQuality = atoi(optarg); break; case 'm': #ifdef IO_MMAP io = IO_METHOD_MMAP; #else fprintf(stderr, "You didn't compile for mmap support.\n"); exit(EXIT_FAILURE); #endif break; case 'r': #ifdef IO_READ io = IO_METHOD_READ; #else fprintf(stderr, "You didn't compile for read support.\n"); exit(EXIT_FAILURE); #endif break; case 'u': #ifdef IO_USERPTR io = IO_METHOD_USERPTR; #else fprintf(stderr, "You didn't compile for userptr support.\n"); exit(EXIT_FAILURE); #endif break; case 'W': // set width width = atoi(optarg); break; case 'H': // set height height = atoi(optarg); break; default: usage(stderr, argc, argv); exit(EXIT_FAILURE); } } // check for need parameters if (!jpegFilename) { fprintf(stderr, "You have to specify JPEG output filename!\n\n"); usage(stdout, argc, argv); exit(EXIT_FAILURE); } // open and initialize device deviceOpen(); deviceInit(); // start capturing captureStart(); // process frames mainLoop(); // stop capturing captureStop(); // close device deviceUninit(); deviceClose(); exit(EXIT_SUCCESS); return 0; }