hvirtual/cinelerra/videodevice.C

   1 #include "assets.h"
   2 #include "bccapture.h"
   3 #include "channel.h"
   4 #include "chantables.h"
   5 #include "playbackconfig.h"
   6 #include "playbackengine.h"
   7 #include "preferences.h"
   8 #include "recordconfig.h"
   9 #include "recordmonitor.h"
  10 #include "vdevice1394.h"
  11 #include "vdevicebuz.h"
  12 #include "vdevicev4l.h"
  13 #include "vdevicex11.h"
  14 #include "videoconfig.h"
  15 #include "videodevice.h"
  16 #include "videowindow.h"
  17 #include "videowindowgui.h"
  18 #include "vframe.h"
  19
  20
  21 KeepaliveThread::KeepaliveThread(VideoDevice *device) : Thread()
  22 {
  23         still_alive = 1;
  24         failed = 0;
  25         interrupted = 0;
  26         set_synchronous(1);
  27         this->device = device;
  28         capturing = 0;
  29 }
  30
  31 KeepaliveThread::~KeepaliveThread()
  32 {
  33 }
  34
  35 int KeepaliveThread::start_keepalive()
  36 {
  37         startup_lock.lock();
  38         start();
  39         startup_lock.lock();
  40         startup_lock.unlock();
  41 }
  42
  43 void KeepaliveThread::run()
  44 {
  45         startup_lock.unlock();
  46         while(!interrupted)
  47         {
  48                 still_alive = 0;
  49 // Give the capture a moment
  50 // Should fix the delay in case users want slower frame rates.
  51                 timer.delay((long)(KEEPALIVE_DELAY * 1000));
  52
  53 // See if a capture happened
  54                 if(still_alive == 0 && capturing)
  55                 {
  56 //                      printf("KeepaliveThread::run: device crashed\n");
  57                         failed++;
  58                 }
  59                 else
  60                         failed = 0;
  61         }
  62 }
  63
  64 int KeepaliveThread::reset_keepalive()
  65 {
  66         still_alive = 1;
  67 }
  68
  69 int KeepaliveThread::get_failed()
  70 {
  71         if(failed) return 1; else return 0;
  72 }
  73
  74 int KeepaliveThread::stop()
  75 {
  76         interrupted = 1;
  77
  78 // Force an immediate exit even if capture_frame worked.
  79         Thread::end();
  80         Thread::join();
  81 }
  82
  83
  84
  85
  86
  87
  88
  89 VideoDevice::VideoDevice()
  90 {
  91         in_config = new VideoInConfig;
  92         out_config = new VideoOutConfig(0, 0);
  93         initialize();
  94 }
  95
  96 VideoDevice::~VideoDevice()
  97 {
  98         input_sources.remove_all_objects();
  99         delete in_config;
 100         delete out_config;
 101 }
 102
 103 int VideoDevice::initialize()
 104 {
 105         sharing = 0;
 106         done_sharing = 0;
 107         sharing_lock.reset();
 108         orate = irate = 0;
 109         out_w = out_h = 0;
 110         r = w = 0;
 111         is_playing_back = is_recording = 0;
 112         input_x = 0;
 113         input_y = 0;
 114         input_z = 1;
 115         frame_resized = 0;
 116         capturing = 0;
 117         keepalive = 0;
 118         swap_bytes = 0;
 119         input_base = 0;
 120         output_base = 0;
 121         output_format = 0;
 122         interrupt = 0;
 123         adevice = 0;
 124         quality = 80;
 125         cpus = 1;
 126         single_frame = 0;
 127 }
 128
 129 int VideoDevice::open_input(VideoInConfig *config,
 130         int input_x,
 131         int input_y,
 132         float input_z,
 133         float frame_rate)
 134 {
 135         int result = 0;
 136
 137         *this->in_config = *config;
 138
 139         r = 1;
 140         this->input_z = -1;   // Force initialization.
 141         this->frame_rate = frame_rate;
 142
 143         switch(in_config->driver)
 144         {
 145                 case VIDEO4LINUX:
 146                         keepalive = new KeepaliveThread(this);
 147                         keepalive->start_keepalive();
 148                         input_base = new VDeviceV4L(this);
 149                         result = input_base->open_input();
 150                         break;
 151                 case SCREENCAPTURE:
 152                         this->input_x = input_x;
 153                         this->input_y = input_y;
 154                         input_base = new VDeviceX11(this, 0);
 155                         result = input_base->open_input();
 156                         break;
 157                 case CAPTURE_BUZ:
 158 //printf("VideoDevice 1\n");
 159                         keepalive = new KeepaliveThread(this);
 160                         keepalive->start_keepalive();
 161                         input_base = new VDeviceBUZ(this);
 162                         result = input_base->open_input();
 163                         break;
 164 #ifdef HAVE_FIREWIRE
 165                 case CAPTURE_FIREWIRE:
 166                         input_base = new VDevice1394(this);
 167                         result = input_base->open_input();
 168                         break;
 169 #endif
 170         }
 171
 172         if(!result) capturing = 1;
 173         return 0;
 174 }
 175
 176 int VideoDevice::is_compressed(int driver)
 177 {
 178         return (driver == CAPTURE_BUZ ||
 179                 driver == CAPTURE_LML ||
 180                 driver == CAPTURE_FIREWIRE);
 181 }
 182
 183 char* VideoDevice::get_vcodec(int driver)
 184 {
 185         switch(driver)
 186         {
 187                 case CAPTURE_BUZ:
 188                 case CAPTURE_LML:
 189                         return QUICKTIME_MJPA;
 190                         break;
 191
 192                 case CAPTURE_FIREWIRE:
 193                         return QUICKTIME_DV;
 194                         break;
 195         }
 196 }
 197
 198
 199 char* VideoDevice::drivertostr(int driver)
 200 {
 201         switch(driver)
 202         {
 203                 case PLAYBACK_X11:
 204                         return PLAYBACK_X11_TITLE;
 205                         break;
 206                 case PLAYBACK_X11_XV:
 207                         return PLAYBACK_X11_XV_TITLE;
 208                         break;
 209                 case PLAYBACK_BUZ:
 210                         return PLAYBACK_BUZ_TITLE;
 211                         break;
 212                 case VIDEO4LINUX:
 213                         return VIDEO4LINUX_TITLE;
 214                         break;
 215                 case SCREENCAPTURE:
 216                         return SCREENCAPTURE_TITLE;
 217                         break;
 218                 case CAPTURE_BUZ:
 219                         return CAPTURE_BUZ_TITLE;
 220                         break;
 221                 case CAPTURE_FIREWIRE:
 222                         return CAPTURE_FIREWIRE_TITLE;
 223                         break;
 224         }
 225         return "";
 226 }
 227
 228 int VideoDevice::is_compressed()
 229 {
 230         return is_compressed(in_config->driver);
 231 }
 232
 233 int VideoDevice::get_best_colormodel(Asset *asset)
 234 {
 235         if(input_base)
 236                 return input_base->get_best_colormodel(asset);
 237         else
 238                 return BC_RGB888;
 239 }
 240
 241 int VideoDevice::close_all()
 242 {
 243         int i;
 244
 245 //printf("VideoDevice::close_all 1\n");
 246         if(w)
 247         {
 248                 if(output_base)
 249                 {
 250                         output_base->close_all();
 251                         delete output_base;
 252                 }
 253         }
 254
 255 //printf("VideoDevice::close_all 2\n");
 256         if(r && capturing)
 257         {
 258                 capturing = 0;
 259                 if(input_base)
 260                 {
 261                         input_base->close_all();
 262                         delete input_base;
 263                         input_base = 0;
 264                 }
 265
 266                 if(keepalive)
 267                 {
 268                         keepalive->stop();
 269                         delete keepalive;
 270                 }
 271         }
 272
 273 //printf("VideoDevice::close_all 3\n");
 274         input_sources.remove_all_objects();
 275
 276 //printf("VideoDevice::close_all 4\n");
 277         initialize();
 278
 279 //printf("VideoDevice::close_all 5\n");
 280         return 0;
 281 }
 282
 283
 284 int VideoDevice::set_adevice(AudioDevice *adevice)
 285 {
 286         this->adevice = adevice;
 287         return 0;
 288 }
 289
 290
 291 // int VideoDevice::stop_sharing()
 292 // {
 293 //      if(sharing)
 294 //      {
 295 //              sharing_lock.lock();
 296 //              done_sharing = 1;
 297 //              if(input_base) input_base->stop_sharing();
 298 //      }
 299 //      return 0;
 300 // }
 301 //
 302
 303 // int VideoDevice::get_shared_data(unsigned char *data, long size)
 304 // {
 305 //      if(input_base)
 306 //      {
 307 //              input_base->get_shared_data(data, size);
 308 //      }
 309 //      return 0;
 310 // }
 311
 312 void VideoDevice::create_channeldb(ArrayList<Channel*> *channeldb)
 313 {
 314         if(input_base)
 315                 input_base->create_channeldb(channeldb);
 316 }
 317
 318 ArrayList<char *>* VideoDevice::get_inputs()
 319 {
 320         return &input_sources;
 321 }
 322
 323 int VideoDevice::get_failed()
 324 {
 325         if(keepalive)
 326                 return keepalive->get_failed();
 327         else
 328                 return 0;
 329 }
 330
 331 int VideoDevice::interrupt_crash()
 332 {
 333         if(input_base) return input_base->interrupt_crash();
 334         return 0;
 335 }
 336
 337 int VideoDevice::set_translation(int input_x, int input_y)
 338 {
 339         this->input_x = input_x;
 340         this->input_y = input_y;
 341         return 0;
 342 }
 343
 344 int VideoDevice::set_field_order(int odd_field_first)
 345 {
 346         this->odd_field_first = odd_field_first;
 347         return 0;
 348 }
 349
 350 int VideoDevice::set_channel(Channel *channel)
 351 {
 352         if(input_base) return input_base->set_channel(channel);
 353         if(output_base) return output_base->set_channel(channel);
 354 }
 355
 356 void VideoDevice::set_quality(int quality)
 357 {
 358         this->quality = quality;
 359 }
 360
 361 void VideoDevice::set_cpus(int cpus)
 362 {
 363         this->cpus = cpus;
 364 }
 365
 366 int VideoDevice::set_picture(int brightness,
 367         int hue,
 368         int color,
 369         int contrast,
 370         int whiteness)
 371 {
 372         if(input_base) return input_base->set_picture(brightness,
 373                         hue,
 374                         color,
 375                         contrast,
 376                         whiteness);
 377 }
 378
 379 int VideoDevice::update_translation()
 380 {
 381         float frame_in_capture_x1f, frame_in_capture_x2f, frame_in_capture_y1f, frame_in_capture_y2f;
 382         float capture_in_frame_x1f, capture_in_frame_x2f, capture_in_frame_y1f, capture_in_frame_y2f;
 383         int z_changed = 0;
 384
 385         if(frame_resized)
 386         {
 387                 input_x = new_input_x;
 388                 input_y = new_input_y;
 389
 390                 if(in_config->driver == VIDEO4LINUX || in_config->driver == VIDEO4LINUX2)
 391                 {
 392                         if(input_z != new_input_z)
 393                         {
 394                                 input_z = new_input_z;
 395                                 z_changed = 1;
 396
 397                                 capture_w = (int)((float)in_config->w * input_z + 0.5);
 398                                 capture_h = (int)((float)in_config->h * input_z + 0.5);
 399
 400 // Need to align to multiple of 4
 401                                 capture_w &= ~3;
 402                                 capture_h &= ~3;
 403                         }
 404
 405                         frame_in_capture_x1f = (float)input_x * input_z + capture_w / 2 - in_config->w / 2;
 406                         frame_in_capture_x2f = (float)input_x * input_z  + capture_w / 2 + in_config->w / 2;
 407                         frame_in_capture_y1f = (float)input_y * input_z  + capture_h / 2 - in_config->h / 2;
 408                         frame_in_capture_y2f = (float)input_y * input_z  + capture_h / 2 + in_config->h / 2;
 409
 410                         capture_in_frame_x1f = 0;
 411                         capture_in_frame_y1f = 0;
 412                         capture_in_frame_x2f = in_config->w;
 413                         capture_in_frame_y2f = in_config->h;
 414
 415                         if(frame_in_capture_x1f < 0) { capture_in_frame_x1f -= frame_in_capture_x1f; frame_in_capture_x1f = 0; }
 416                         if(frame_in_capture_y1f < 0) { capture_in_frame_y1f -= frame_in_capture_y1f; frame_in_capture_y1f = 0; }
 417                         if(frame_in_capture_x2f > capture_w) { capture_in_frame_x2f -= frame_in_capture_x2f - capture_w; frame_in_capture_x2f = capture_w; }
 418                         if(frame_in_capture_y2f > capture_h) { capture_in_frame_y2f -= frame_in_capture_y2f - capture_h; frame_in_capture_y2f = capture_h; }
 419
 420                         frame_in_capture_x1 = (int)frame_in_capture_x1f;
 421                         frame_in_capture_y1 = (int)frame_in_capture_y1f;
 422                         frame_in_capture_x2 = (int)frame_in_capture_x2f;
 423                         frame_in_capture_y2 = (int)frame_in_capture_y2f;
 424
 425                         capture_in_frame_x1 = (int)capture_in_frame_x1f;
 426                         capture_in_frame_y1 = (int)capture_in_frame_y1f;
 427                         capture_in_frame_x2 = (int)capture_in_frame_x2f;
 428                         capture_in_frame_y2 = (int)capture_in_frame_y2f;
 429
 430                         frame_resized = 0;
 431                 }
 432         }
 433         return 0;
 434 }
 435
 436 int VideoDevice::set_latency_counter(int value)
 437 {
 438         latency_counter = value;
 439         return 0;
 440 }
 441
 442 int VideoDevice::read_buffer(VFrame *frame)
 443 {
 444         int result = 0;
 445         if(!capturing) return 0;
 446
 447 //printf("VideoDevice::read_buffer %p %p\n", frame, input_base);
 448         if(input_base)
 449         {
 450 // Reset the keepalive thread
 451                 if(keepalive) keepalive->capturing = 1;
 452                 result = input_base->read_buffer(frame);
 453                 if(keepalive)
 454                 {
 455                         keepalive->capturing = 0;
 456                         keepalive->reset_keepalive();
 457                 }
 458                 return result;
 459         }
 460
 461         return 0;
 462 }
 463
 464
 465 // ================================= OUTPUT ==========================================
 466
 467
 468 int VideoDevice::open_output(VideoOutConfig *config,
 469                                         float rate,
 470                                         int out_w,
 471                                         int out_h,
 472                                         Canvas *output,
 473                                         int single_frame)
 474 {
 475         w = 1;
 476 //printf("VideoDevice::open_output 1 %d\n", out_config->driver);
 477         *this->out_config = *config;
 478 //printf("VideoDevice::open_output 1 %d\n", out_config->driver);
 479         this->out_w = out_w;
 480         this->out_h = out_h;
 481         this->orate = rate;
 482         this->single_frame = single_frame;
 483
 484 //printf("VideoDevice::open_output 1 %d\n", out_config->driver);
 485         switch(out_config->driver)
 486         {
 487                 case PLAYBACK_BUZ:
 488                         output_base = new VDeviceBUZ(this);
 489                         break;
 490                 case PLAYBACK_X11:
 491                 case PLAYBACK_X11_XV:
 492                         output_base = new VDeviceX11(this, output);
 493                         break;
 494
 495                 case PLAYBACK_DV1394:
 496                 case PLAYBACK_FIREWIRE:
 497                         output_base = new VDevice1394(this);
 498                         break;
 499         }
 500 //printf("VideoDevice::open_output 2 %d\n", out_config->driver);
 501
 502         if(output_base->open_output())
 503         {
 504                 delete output_base;
 505                 output_base = 0;
 506         }
 507 //printf("VideoDevice::open_output 3 %d\n", out_config->driver);
 508
 509         if(output_base)
 510                 return 0;
 511         else
 512                 return 1;
 513 }
 514
 515
 516
 517 int VideoDevice::start_playback()
 518 {
 519 // arm buffer before doing this
 520         is_playing_back = 1;
 521         interrupt = 0;
 522
 523         if(output_base) return output_base->start_playback();
 524         return 1;
 525 }
 526
 527 int VideoDevice::stop_playback()
 528 {
 529         if(output_base) output_base->stop_playback();
 530         is_playing_back = 0;
 531         interrupt = 0;
 532         return 0;
 533 }
 534
 535 void VideoDevice::goose_input()
 536 {
 537         if(input_base) input_base->goose_input();
 538 }
 539
 540 void VideoDevice::new_output_buffers(VFrame **outputs, int colormodel)
 541 {
 542         for(int i = 0; i < MAX_CHANNELS; i++)
 543                 outputs[i] = 0;
 544
 545         if(!output_base) return;
 546         output_base->new_output_buffer(outputs, colormodel);
 547 }
 548
 549
 550 int VideoDevice::interrupt_playback()
 551 {
 552         interrupt = 1;
 553         return 0;
 554 }
 555
 556 int VideoDevice::write_buffer(VFrame **outputs, EDL *edl)
 557 {
 558 //printf("VideoDevice::write_buffer 1 %p\n", output_base);
 559         if(output_base) return output_base->write_buffer(outputs, edl);
 560         return 1;
 561 }
 562
 563 int VideoDevice::output_visible()
 564 {
 565         if(output_base) return output_base->output_visible();
 566 }
 567
 568 BC_Bitmap* VideoDevice::get_bitmap()
 569 {
 570         if(output_base) return output_base->get_bitmap();
 571 }