Changeset 350 in flair-src for trunk/lib/FlairSensorActuator/src
- Timestamp:
- Feb 19, 2020, 2:19:28 PM (5 years ago)
- Location:
- trunk/lib/FlairSensorActuator/src
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/lib/FlairSensorActuator/src/V4LCamera.cpp
r349 r350 40 40 V4LCamera::V4LCamera(string name,uint8_t camera_index, uint16_t width, uint16_t height, 41 41 Image::Type::Format format, uint8_t priority) 42 : Thread(getFrameworkManager(), name, priority ),42 : Thread(getFrameworkManager(), name, priority,1024*1024), 43 43 Camera(name, width, height, format) { 44 44 … … 52 52 53 53 if(format == Image::Type::Format::UYVY) { 54 if( init(width,height,V4L2_PIX_FMT_UYVY) == -1) {54 if(Init(width,height,V4L2_PIX_FMT_UYVY) == -1) { 55 55 Thread::Err("initialisation failed\n"); 56 56 } 57 57 } else if (format == Image::Type::Format::YUYV) { 58 if( init(width,height,V4L2_PIX_FMT_YUYV) == -1) {58 if(Init(width,height,V4L2_PIX_FMT_YUYV) == -1) { 59 59 Thread::Err("initialisation failed\n"); 60 60 } … … 63 63 } 64 64 65 66 allocBuffers(); 67 65 dQueuedBuffer.index=-1;//mark current buffer not valid for initialisation 66 useMemoryUsrPtr=false; 67 if(useMemoryUsrPtr) { 68 AllocUserBuffers(); 69 } else { 70 AllocV4LBuffers(); 71 } 72 68 73 for (int i=0;i < nbBuffers;i++) { 69 struct v4l2_buffer buf; 70 memset(&buf, 0, sizeof (v4l2_buffer)); 71 72 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; 73 buf.memory = V4L2_MEMORY_MMAP; 74 buf.index = (unsigned long)i; 75 76 if (-1 == xioctl (device, VIDIOC_QBUF, &buf)) { 77 Thread::Err("VIDIOC_QBUF error\n"); 78 } 74 QueueBuffer(i); 79 75 } 80 76 … … 103 99 104 100 V4LCamera::~V4LCamera() { 105 for (int i = 0; i < nbBuffers; i++) { 106 //FreeFunction((char*)buffers[i].start); 101 if(useMemoryUsrPtr) { 102 for (int i = 0; i < nbBuffers; i++) { 103 FreeFunction((char*)buffers[i]); 104 } 105 } else { 106 FreeFunction(imageData); 107 107 } 108 108 SafeStop(); … … 111 111 } 112 112 113 int V4LCamera:: init(int width, int height,unsigned long colorspace) {113 int V4LCamera::Init(int width, int height,unsigned long colorspace) { 114 114 struct v4l2_capability cap; 115 115 memset(&cap, 0, sizeof (v4l2_capability)); … … 245 245 } 246 246 */ 247 int V4LCamera:: allocBuffers() {247 int V4LCamera::AllocV4LBuffers() { 248 248 struct v4l2_requestbuffers req; 249 249 memset(&req, 0, sizeof (v4l2_requestbuffers)); … … 309 309 }; 310 310 311 int V4LCamera::Alloc Buffers(void) {311 int V4LCamera::AllocUserBuffers(void) { 312 312 struct v4l2_requestbuffers req; 313 313 memset(&req, 0, sizeof (v4l2_requestbuffers)); … … 333 333 return 1; 334 334 }; 335 336 int V4LCamera::cvGrabFrame(void) { 337 unsigned int count; 338 339 count = 1; 340 341 while (count-- > 0) { 342 for (;;) { 343 fd_set fds; 344 struct timeval tv; 345 int r; 346 347 FD_ZERO (&fds); 348 FD_SET (device, &fds); 349 350 /* Timeout. */ 351 tv.tv_sec = 2; 352 tv.tv_usec = 0; 353 354 r = select (device+1, &fds, NULL, NULL, &tv); 355 356 if (-1 == r) { 357 if (EINTR == errno) 358 continue; 359 360 perror ("select"); 361 } 362 363 if (0 == r) { 364 fprintf (stderr, "select timeout\n"); 365 366 /* end the infinite loop */ 367 break; 368 } 369 370 if (read_frame_v4l2 ()) 371 break; 372 } 373 } 374 return(1); 375 } 376 377 int V4LCamera::read_frame_v4l2(void) { 335 /* 336 int V4LCamera::GrabFrame(void) { 337 //queue previous buffer 338 if(QueueBuffer(bufferIndex)<0) return -1; 339 340 fd_set fds; 341 struct timeval tv; 342 FD_ZERO (&fds); 343 FD_SET (device, &fds); 344 345 tv.tv_sec = 0; 346 tv.tv_usec = 100000; 347 348 int r = select (device+1, &fds, NULL, NULL, &tv); 349 350 if (-1 == r) { 351 char errorMsg[256]; 352 Thread::Err("select (%s)\n", strerror_r(-r, errorMsg, sizeof(errorMsg))); 353 return -1; 354 } 355 356 if (0 == r) { 357 Thread::Err("select timeout\n"); 358 return -1; 359 } 360 378 361 struct v4l2_buffer buf; 379 362 memset(&buf, 0, sizeof (v4l2_buffer)); 380 381 363 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; 382 buf.memory = V4L2_MEMORY_MMAP; 383 384 if (-1 == xioctl (device, VIDIOC_DQBUF, &buf)) { 385 switch (errno) { 386 case EAGAIN: 387 return 0; 388 389 case EIO: 390 /* Could ignore EIO, see spec. */ 391 392 /* fall through */ 393 394 default: 395 /* display the error and stop processing */ 396 perror ("VIDIOC_DQBUF"); 397 return 1; 398 } 399 } 400 401 if(buf.index >= nbBuffers) { 402 Thread::Err("buf.index >= capture->req.count\n"); 403 } 404 405 bufferIndex = buf.index; 406 407 if (-1 == xioctl (device, VIDIOC_QBUF, &buf)) 408 perror ("VIDIOC_QBUF"); 409 364 buf.memory = V4L2_MEMORY_USERPTR;//V4L2_MEMORY_MMAP; 365 366 //get last captured image 367 int prevDQbuf=-1; 368 for(int i=0;i<nbBuffers;i++) { 369 if (xioctl (device, VIDIOC_DQBUF, &buf)==-1) { 370 if (errno==EAGAIN) { 371 break; 372 } else { 373 Thread::Err("VIDIOC_DQBUF xioctl\n"); 374 return -1; 375 } 376 } else { 377 if(prevDQbuf!=-1) { 378 QueueBuffer(prevDQbuf); 379 } 380 for (int i=0; i<nbBuffers; i++) { 381 if((void*)(buf.m.userptr)==buffers[i]) { 382 prevDQbuf=i; 383 bufferIndex=i; 384 break; 385 } 386 } 387 } 388 } 389 410 390 return 1; 391 } 392 */ 393 int V4LCamera::cvGrabFrame(void) { 394 if(QueueBuffer(&dQueuedBuffer)<0) return -1; 395 396 fd_set fds; 397 struct timeval tv; 398 FD_ZERO (&fds); 399 FD_SET (device, &fds); 400 401 tv.tv_sec = 0; 402 tv.tv_usec = 100000; 403 404 int r=select(device+1, &fds, NULL, NULL, &tv); 405 406 if (r==-1) { 407 char errorMsg[256]; 408 Thread::Err("select (%s)\n", strerror_r(-r, errorMsg, sizeof(errorMsg))); 409 return -1; 410 } 411 412 if (r==0) { 413 Thread::Err("select timeout\n"); 414 return -1; 415 } 416 417 struct v4l2_buffer buf; 418 memset(&buf, 0, sizeof (v4l2_buffer)); 419 buf.type=V4L2_BUF_TYPE_VIDEO_CAPTURE; 420 if(useMemoryUsrPtr) { 421 buf.memory=V4L2_MEMORY_USERPTR; 422 } else { 423 buf.memory=V4L2_MEMORY_MMAP; 424 } 425 426 //get last captured image 427 dQueuedBuffer.index=-1; 428 for(int i=0;i<nbBuffers;i++) { 429 if (xioctl (device, VIDIOC_DQBUF, &buf)==-1) { 430 if (errno==EAGAIN) {//when no new buffer is available for reading (non blocking) 431 //Printf("%s eagain\n",Thread::ObjectName().c_str()); 432 break; 433 } else { 434 Thread::Err("VIDIOC_DQBUF xioctl\n"); 435 return -1; 436 } 437 } else { 438 //Printf("%s %i dqueued\n",Thread::ObjectName().c_str(),buf.index); 439 //Printf("%i %x %i %i\n",buf.bytesused,buf.flags,buf.field,buf.sequence); 440 if(dQueuedBuffer.index!=-1) { 441 //Printf("%s %i queued\n",Thread::ObjectName().c_str(),dQueuedBuffer.index); 442 QueueBuffer(&dQueuedBuffer); 443 } 444 dQueuedBuffer=buf; 445 } 446 } 447 //Printf("%s %i\n",Thread::ObjectName().c_str(),dQueuedBuffer.index); 448 449 return 1; 411 450 } 412 451 413 452 void V4LCamera::Run(void) { 414 453 Time cam_time, new_time, fpsNow, fpsPrev; 415 //IplImage *img; // raw image416 454 int fpsCounter = 0; 417 455 418 // init image old419 if (!cvGrabFrame()) {420 Printf("Could not grab a frame\n");421 }422 456 cam_time = GetTime(); 423 457 fpsPrev = cam_time; … … 471 505 472 506 // cam pictures 473 cvRetrieveRawFrame();474 507 if (!cvGrabFrame()) { 475 508 Printf("Could not grab a frame\n"); 476 509 } 477 new_time = GetTime(); 510 511 //copy to CMEM allocated buffer if necessary 512 if(!useMemoryUsrPtr) { 513 memcpy(imageData,(char *)buffers[dQueuedBuffer.index],output->GetDataType().GetSize()); 514 } 478 515 479 516 //check for ps3eye deconnection in hds uav 517 new_time = GetTime(); 480 518 if(new_time-cam_time>100*1000*1000) { 481 Thread::Warn("delta t rop grand\n");519 Thread::Warn("delta t trop grand\n"); 482 520 hasProblems=true; 483 } 521 }/* 522 if(hasProblems==false) { 523 struct v4l2_format form; 524 form.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; 525 xioctl(device, VIDIOC_G_FMT,&form); 526 if(xioctl (device, VIDIOC_G_FMT,&form)<0) { 527 Thread::Warn("camera disconnected\n"); 528 hasProblems=true; 529 } 530 }*/ 484 531 485 532 output->GetMutex(); 486 487 533 output->buffer=imageData; 488 534 output->ReleaseMutex(); … … 494 540 } 495 541 496 void V4LCamera::cvRetrieveRawFrame(void) { 497 memcpy(imageData,(char *)buffers[bufferIndex],output->GetDataType().GetSize()); 542 int V4LCamera::QueueBuffer(struct v4l2_buffer *buf) { 543 if(buf->index>=0 && buf->index<nbBuffers) { 544 int ret=xioctl (device, VIDIOC_QBUF,buf); 545 if (ret==-1) { 546 Thread::Err("VIDIOC_QBUF xioctl %s\n",strerror(-ret)); 547 return -1; 548 } 549 } 550 return 0; 498 551 } 499 552 500 553 int V4LCamera::QueueBuffer(int index) { 501 struct v4l2_buffer buf; 502 if(index>=0 && index<nbBuffers) { 503 memset(&buf, 0, sizeof (v4l2_buffer)); 504 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; 505 buf.memory = V4L2_MEMORY_USERPTR; 506 buf.index = (unsigned long)index; 507 buf.m.userptr=(unsigned long)(buffers[index]); 508 buf.length=output->GetDataType().GetSize(); 509 510 int ret=xioctl (device, VIDIOC_QBUF, &buf); 511 if (ret==-1) { 512 Thread::Err("VIDIOC_QBUF xioctl %s\n",strerror(-ret)); 513 return -1; 514 } 515 } 516 return 0; 517 } 518 519 int V4LCamera::GrabFrame(void) { 520 //queue previous buffer 521 if(QueueBuffer(bufferIndex)<0) return -1; 522 523 fd_set fds; 524 struct timeval tv; 525 FD_ZERO (&fds); 526 FD_SET (device, &fds); 527 528 tv.tv_sec = 0; 529 tv.tv_usec = 100000; 530 531 int r = select (device+1, &fds, NULL, NULL, &tv); 532 533 if (-1 == r) { 534 char errorMsg[256]; 535 Thread::Err("select (%s)\n", strerror_r(-r, errorMsg, sizeof(errorMsg))); 536 return -1; 537 } 538 539 if (0 == r) { 540 Thread::Err("select timeout\n"); 541 return -1; 542 } 543 544 struct v4l2_buffer buf; 545 memset(&buf, 0, sizeof (v4l2_buffer)); 546 buf.type = V4L2_BUF_TYPE_VIDEO_CAPTURE; 547 buf.memory = V4L2_MEMORY_USERPTR;//V4L2_MEMORY_MMAP; 548 549 //get last captured image 550 int prevDQbuf=-1; 551 for(int i=0;i<4;i++) { 552 if (xioctl (device, VIDIOC_DQBUF, &buf)==-1) { 553 if (errno==EAGAIN) { 554 break; 555 } else { 556 Thread::Err("VIDIOC_DQBUF xioctl\n"); 557 return -1; 558 } 559 } else { 560 if(prevDQbuf!=-1) { 561 QueueBuffer(prevDQbuf); 562 } 563 for (int i=0; i<nbBuffers; i++) { 564 if((void*)(buf.m.userptr)==buffers[i]) { 565 prevDQbuf=i; 566 bufferIndex=i; 567 break; 568 } 569 } 570 } 571 } 572 573 return 1; 554 struct v4l2_buffer buf; 555 memset(&buf, 0, sizeof (v4l2_buffer)); 556 557 buf.type=V4L2_BUF_TYPE_VIDEO_CAPTURE; 558 buf.index=(unsigned long)index; 559 if(useMemoryUsrPtr) { 560 buf.memory=V4L2_MEMORY_USERPTR; 561 buf.m.userptr=(unsigned long)(buffers[index]); 562 buf.length=output->GetDataType().GetSize(); 563 } else { 564 buf.memory=V4L2_MEMORY_MMAP; 565 } 566 return QueueBuffer(&buf); 574 567 } 575 568 -
trunk/lib/FlairSensorActuator/src/V4LCamera.h
r349 r350 16 16 #include <Thread.h> 17 17 #include "Camera.h" 18 //todo use pimpl and remove this 18 19 19 #include <linux/videodev2.h> 20 #include <libv4l1-videodev.h>21 22 20 #define DEFAULT_V4L_BUFFERS 4 23 21 … … 152 150 void* buffers[DEFAULT_V4L_BUFFERS]; 153 151 int nbBuffers; 154 int bufferIndex;155 152 char *imageData; 153 bool useMemoryUsrPtr; 156 154 157 int init(int width, int height,unsigned long colorspace);158 staticint xioctl( int fd, int request, void *arg);155 int Init(int width, int height,unsigned long colorspace); 156 int xioctl( int fd, int request, void *arg); 159 157 void SetProperty(int property,float value); 160 158 float GetProperty(int property); 161 int GrabFrame(void);162 int Alloc Buffers(void);163 int allocBuffers(void);159 //int GrabFrame(void); 160 int AllocV4LBuffers(void); 161 int AllocUserBuffers(void); 164 162 int QueueBuffer(int index); 163 int QueueBuffer(struct v4l2_buffer *buf); 164 struct v4l2_buffer dQueuedBuffer; 165 165 166 166 167 167 int cvGrabFrame(void); 168 int read_frame_v4l2(void); 169 void cvRetrieveRawFrame(void); 168 170 169 171 170
Note:
See TracChangeset
for help on using the changeset viewer.