cinelerra-5.1/cinelerra/virtualanode.C

   1
   2 /*
   3  * CINELERRA
   4  * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License as published by
   8  * the Free Software Foundation; either version 2 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * along with this program; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  *
  20  */
  21
  22 #include "aattachmentpoint.h"
  23 #include "aedit.h"
  24 #include "amodule.h"
  25 #include "arender.h"
  26 #include "atrack.h"
  27 #include "automation.h"
  28 #include "clip.h"
  29 #include "edits.h"
  30 #include "edl.h"
  31 #include "edlsession.h"
  32 #include "floatautos.h"
  33 #include "mwindow.h"
  34 #include "module.h"
  35 #include "panauto.h"
  36 #include "plugin.h"
  37 #include "renderengine.h"
  38 #include "samples.h"
  39 #include "track.h"
  40 #include "transition.h"
  41 #include "transportque.h"
  42 #include "virtualaconsole.h"
  43 #include "virtualanode.h"
  44
  45
  46 #include <string.h>
  47
  48 VirtualANode::VirtualANode(RenderEngine *renderengine,
  49                 VirtualConsole *vconsole,
  50                 Module *real_module,
  51                 Plugin *real_plugin,
  52                 Track *track,
  53                 VirtualNode *parent_module)
  54  : VirtualNode(renderengine,
  55                 vconsole,
  56                 real_module,
  57                 real_plugin,
  58                 track,
  59                 parent_module)
  60 {
  61         for(int i = 0; i < MAXCHANNELS; i++)
  62         {
  63                 pan_before[i] = pan_after[i] = 0;
  64         }
  65 }
  66
  67 VirtualANode::~VirtualANode()
  68 {
  69 }
  70
  71
  72
  73
  74
  75 VirtualNode* VirtualANode::create_module(Plugin *real_plugin,
  76                                                         Module *real_module,
  77                                                         Track *track)
  78 {
  79         return new VirtualANode(renderengine,
  80                 vconsole,
  81                 real_module,
  82                 0,
  83                 track,
  84                 this);
  85 }
  86
  87
  88 VirtualNode* VirtualANode::create_plugin(Plugin *real_plugin)
  89 {
  90         return new VirtualANode(renderengine,
  91                 vconsole,
  92                 0,
  93                 real_plugin,
  94                 track,
  95                 this);
  96 }
  97
  98
  99
 100 int VirtualANode::read_data(Samples *output_temp,
 101         int64_t size,
 102         int64_t start_position,
 103         int64_t sample_rate)
 104 {
 105         VirtualNode *previous_plugin = 0;
 106
 107 // Current edit in parent track
 108         AEdit *parent_edit = 0;
 109         if(parent_node && parent_node->track && renderengine)
 110         {
 111                 int64_t edl_rate = renderengine->get_edl()->session->sample_rate;
 112                 int64_t start_position_project = (int64_t)(start_position *
 113                         edl_rate /
 114                         sample_rate +
 115                         0.5);
 116                 parent_edit = (AEdit*)parent_node->track->edits->editof(start_position_project,
 117                         renderengine->command->get_direction(),
 118                         0);
 119         }
 120
 121
 122         if(vconsole->debug_tree)
 123                 printf("  VirtualANode::read_data position=%jd rate=%jd"
 124                         " title=%s parent_node=%p parent_edit=%p\n",
 125                         start_position, sample_rate, track->title,
 126                         parent_node, parent_edit);
 127
 128
 129 // This is a plugin on parent module with a preceeding effect.
 130 // Get data from preceeding effect on parent module.
 131         if(parent_node &&
 132                 (previous_plugin = parent_node->get_previous_plugin(this)))
 133         {
 134                 ((VirtualANode*)previous_plugin)->render(output_temp,
 135                         size,
 136                         start_position,
 137                         sample_rate);
 138         }
 139         else
 140 // The current node is the first plugin on parent module.
 141 // The parent module has an edit to read from or the current node
 142 // has no source to read from.
 143 // Read data from parent module
 144         if(parent_node && (parent_edit || !real_module))
 145         {
 146                 ((VirtualANode*)parent_node)->read_data(output_temp,
 147                         size,
 148                         start_position,
 149                         sample_rate);
 150         }
 151         else
 152         if(real_module)
 153 // This is the first node in the tree
 154         {
 155                 ((AModule*)real_module)->render(output_temp,
 156                         size,
 157                         start_position,
 158                         renderengine->command->get_direction(),
 159                         sample_rate,
 160                         0);
 161         }
 162         return 0;
 163 }
 164
 165 int VirtualANode::render(Samples *output_temp,
 166         int64_t size,
 167         int64_t start_position,
 168         int64_t sample_rate)
 169 {
 170         const int debug = 0;
 171 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 172         ARender *arender = ((VirtualAConsole*)vconsole)->arender;
 173         if(real_module)
 174         {
 175 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 176                 render_as_module(arender->audio_out,
 177                         output_temp,
 178                         size,
 179                         start_position,
 180                         sample_rate);
 181 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 182         }
 183         else
 184         if(real_plugin)
 185         {
 186 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 187                 render_as_plugin(output_temp,
 188                         size,
 189                         start_position,
 190                         sample_rate);
 191 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 192         }
 193 if(debug) printf("VirtualANode::render %d this=%p\n", __LINE__, this);
 194         return 0;
 195 }
 196
 197 void VirtualANode::render_as_plugin(Samples *output_temp,
 198         int64_t size,
 199         int64_t start_position,
 200         int64_t sample_rate)
 201 {
 202         if(!attachment ||
 203                 !real_plugin ||
 204                 !real_plugin->on) return;
 205
 206 // If we're the first plugin in the parent module, data needs to be read from
 207 // what comes before the parent module.  Otherwise, data needs to come from the
 208 // previous plugin.
 209         ((AAttachmentPoint*)attachment)->render(
 210                 output_temp,
 211                 plugin_buffer_number,
 212                 start_position,
 213                 size,
 214                 sample_rate);
 215 }
 216
 217 int VirtualANode::render_as_module(Samples **audio_out,
 218                                 Samples *output_temp,
 219                                 int64_t len,
 220                                 int64_t start_position,
 221                                 int64_t sample_rate)
 222 {
 223         int direction = renderengine->command->get_direction();
 224         EDL *edl = vconsole->renderengine->get_edl();
 225         const int debug = 0;
 226
 227 // Process last subnode.  This calls read_data, propogates up the chain
 228 // of subnodes, and finishes the chain.
 229         if(subnodes.total)
 230         {
 231                 VirtualANode *node = (VirtualANode*)subnodes.values[subnodes.total - 1];
 232                 node->render(output_temp,
 233                         len,
 234                         start_position,
 235                         sample_rate);
 236         }
 237         else
 238 // Read data from previous entity
 239         {
 240                 read_data(output_temp,
 241                         len,
 242                         start_position,
 243                         sample_rate);
 244         }
 245
 246 // for(int k = 0; k < len; k++)
 247 // {
 248 //      output_temp->get_data()[k] = (k / 10) % 2;
 249 // }
 250
 251 if(debug) printf("VirtualANode::render_as_module %d\n", __LINE__);
 252         render_fade(output_temp->get_data(),
 253                                 len,
 254                                 start_position,
 255                                 sample_rate,
 256                                 track->automation->autos[AUTOMATION_FADE],
 257                                 direction,
 258                                 0);
 259 if(debug) printf("VirtualANode::render_as_module %d\n", __LINE__);
 260
 261 // Get the peak but don't limit
 262 // Calculate position relative to project for meters
 263         int64_t project_sample_rate = edl->session->sample_rate;
 264         int64_t start_position_project = start_position *
 265                 project_sample_rate /
 266                 sample_rate;
 267 if(debug) printf("VirtualANode::render_as_module %d\n", __LINE__);
 268         if(real_module && renderengine->command->realtime)
 269         {
 270                 ARender *arender = ((VirtualAConsole*)vconsole)->arender;
 271 // Starting sample of meter block
 272                 int64_t meter_render_start;
 273 // Ending sample of meter block
 274                 int64_t meter_render_end;
 275 // Number of samples in each meter fragment normalized to requested rate
 276                 int meter_render_fragment = arender->meter_render_fragment *
 277                         sample_rate /
 278                         project_sample_rate;
 279
 280
 281 // Scan fragment in meter sized fragments
 282                 for(int i = 0; i < len; )
 283                 {
 284                         meter_render_start = i;
 285                         meter_render_end = i + meter_render_fragment;
 286                         if(meter_render_end > len)
 287                                 meter_render_end = len;
 288 // Number of samples into the fragment this meter sized fragment is,
 289 // normalized to project sample rate.
 290                         int64_t meter_render_start_project = meter_render_start *
 291                                 project_sample_rate / sample_rate;
 292
 293 // Scan meter sized fragment
 294                         double peak = 0, *output_samples = output_temp->get_data();
 295                         while( i < meter_render_end ) {
 296                                 double sample = fabs(output_samples[i++]);
 297                                 if( sample > peak ) peak = sample;
 298                         }
 299
 300                         MeterHistory *meter_history = ((AModule*)real_module)->meter_history;
 301                         int64_t pos = (direction == PLAY_FORWARD) ?
 302                                 (start_position_project + meter_render_start_project) :
 303                                 (start_position_project - meter_render_start_project) ;
 304                         meter_history->set_peak(0, peak, pos);
 305                 }
 306         }
 307 if(debug) printf("VirtualANode::render_as_module %d\n", __LINE__);
 308
 309 // process pans and copy the output to the output channels
 310 // Keep rendering unmuted fragments until finished.
 311         int mute_position = 0;
 312
 313         for(int i = 0; i < len; )
 314         {
 315                 int mute_constant;
 316                 int mute_fragment = len - i;
 317                 int mute_fragment_project = mute_fragment *
 318                         project_sample_rate /
 319                         sample_rate;
 320                 start_position_project = start_position +
 321                         ((direction == PLAY_FORWARD) ? i : -i);
 322                 start_position_project = start_position_project *
 323                         project_sample_rate /
 324                         sample_rate;
 325
 326 // How many samples until the next mute?
 327                 get_mute_fragment(start_position_project,
 328                                 mute_constant,
 329                                 mute_fragment_project,
 330                                 (Autos*)track->automation->autos[AUTOMATION_MUTE],
 331                                 direction,
 332                                 0);
 333 // Fragment is playable
 334                 if(!mute_constant)
 335                 {
 336                         for(int j = 0;
 337                                 j < MAX_CHANNELS;
 338                                 j++)
 339                         {
 340                                 if(audio_out[j])
 341                                 {
 342                                         double *buffer = audio_out[j]->get_data();
 343
 344                                         render_pan(output_temp->get_data() + mute_position,
 345                                                                 buffer + mute_position,
 346                                                                 mute_fragment,
 347                                                                 start_position,
 348                                                                 sample_rate,
 349                                                                 (Autos*)track->automation->autos[AUTOMATION_PAN],
 350                                                                 j,
 351                                                                 direction,
 352                                                                 0);
 353 //printf("VirtualANode::render_as_module %d %lld\n", __LINE__, start_position);
 354                                 }
 355                         }
 356                 }
 357
 358                 len -= mute_fragment;
 359                 i += mute_fragment;
 360                 mute_position += mute_fragment;
 361         }
 362 if(debug) printf("VirtualANode::render_as_module %d\n", __LINE__);
 363
 364         return 0;
 365 }
 366
 367 int VirtualANode::render_fade(double *buffer, int64_t len,
 368         int64_t input_position, int64_t sample_rate,
 369         Autos *autos, int direction, int use_nudge)
 370 {
 371         double fade_value;
 372         FloatAuto *previous = 0;
 373         FloatAuto *next = 0;
 374         EDL *edl = vconsole->renderengine->get_edl();
 375         const int debug = 0;
 376         int64_t project_sample_rate = edl->session->sample_rate;
 377         double to_project_rate = (double)project_sample_rate / sample_rate;
 378         double to_sample_rate = (double)sample_rate / project_sample_rate;
 379
 380         if(use_nudge)
 381                 input_position += track->nudge * to_sample_rate;
 382
 383 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 384 // Normalize input position to project sample rate here.
 385 // Automation functions are general to video and audio so it
 386 // can't normalize itself.
 387         int64_t input_pos = input_position * to_project_rate;
 388         int64_t len_project = len * to_project_rate;
 389
 390 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 391         if(((FloatAutos*)autos)->automation_is_constant(
 392                 input_pos, len_project, direction, fade_value))
 393         {
 394 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 395                 double value = fade_value<=INFINITYGAIN ?
 396                          0. : DB::fromdb(fade_value);
 397                 if( EQUIV(value, 0.) ) {
 398                         for(int64_t i = 0; i < len; i++)
 399                                 buffer[i] = 0;
 400                 }
 401                 else if( !EQUIV(value, 1.) ) {
 402                         for(int64_t i = 0; i < len; i++)
 403                                 buffer[i] *= value;
 404                 }
 405 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 406         }
 407         else
 408         {
 409 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 410                 for(int64_t i = 0; i < len; i++)
 411                 {
 412                         input_pos = input_position * to_project_rate;
 413
 414                         fade_value = ((FloatAutos*)autos)->get_value(
 415                                 input_pos, direction, previous, next);
 416
 417                         double value = fade_value<=INFINITYGAIN ?
 418                                  0. : DB::fromdb(fade_value);
 419                         if( EQUIV(value,0.) )
 420                                 buffer[i] = 0;
 421                         else if( !EQUIV(value,1.) ) {
 422                                 buffer[i] *= value;
 423                         }
 424
 425                         if(direction == PLAY_FORWARD)
 426                                 input_position++;
 427                         else
 428                                 input_position--;
 429                 }
 430 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 431         }
 432 if(debug) printf("VirtualANode::render_fade %d\n", __LINE__);
 433
 434         return 0;
 435 }
 436
 437 int VirtualANode::render_pan(double *input, // start of input fragment
 438         double *output,            // start of output fragment
 439         int64_t fragment_len,      // fragment length in input scale
 440         int64_t input_position,    // starting sample of input buffer in project
 441         int64_t sample_rate,       // sample rate of input_position
 442         Autos *autos,
 443         int channel,
 444         int direction,
 445         int use_nudge)
 446 {
 447         double slope = 0.0;
 448         double intercept = 1.0;
 449         EDL *edl = vconsole->renderengine->get_edl();
 450         int64_t project_sample_rate = edl->session->sample_rate;
 451         double to_project_rate = (double)project_sample_rate / sample_rate;
 452         double to_sample_rate = (double)sample_rate / project_sample_rate;
 453         if(use_nudge)
 454                 input_position += track->nudge * to_sample_rate;
 455
 456         for(int i = 0; i < fragment_len; )
 457         {
 458                 int64_t len = fragment_len - i;
 459                 int64_t slope_len = len * to_project_rate;
 460                 int64_t input_pos = input_position * to_project_rate;
 461
 462 // Get slope intercept formula for next fragment
 463                 get_pan_automation(slope, intercept, input_pos,
 464                         slope_len, autos, channel, direction);
 465
 466                 slope_len *= to_sample_rate;
 467                 slope = slope * to_sample_rate;
 468                 slope_len = MIN(slope_len, len);
 469
 470 //printf("VirtualANode::render_pan 3 %d %jd %f %p %p\n", i, slope_len, slope, output, input);
 471                 if(!EQUIV(slope, 0)) {
 472                         for(double j = 0; j < slope_len; j++, i++) {
 473                                 value = slope * j + intercept;
 474                                 output[i] += input[i] * value;
 475                         }
 476                 }
 477                 else if( EQUIV(intercept, 1) ) {
 478                         for(int64_t j = 0; j < slope_len; j++, i++)
 479                                 output[i] += input[i];
 480                 }
 481                 else if( !EQUIV(intercept, 0) ) {
 482                         for(int64_t j = 0; j < slope_len; j++, i++)
 483                                 output[i] += input[i] * intercept;
 484                 }
 485                 else
 486                         i += slope_len;
 487
 488                 if(direction == PLAY_FORWARD)
 489                         input_position += slope_len;
 490                 else
 491                         input_position -= slope_len;
 492
 493 //printf("VirtualANode::render_pan 4\n");
 494         }
 495
 496         return 0;
 497 }
 498
 499
 500 void VirtualANode::get_pan_automation(double &slope,
 501         double &intercept,
 502         int64_t input_position,
 503         int64_t &slope_len,
 504         Autos *autos,
 505         int channel,
 506         int direction)
 507 {
 508         intercept = 0;
 509         slope = 0;
 510
 511         Auto *prev_keyframe = 0, *next_keyframe = 0;
 512         prev_keyframe = autos->get_prev_auto(input_position, direction, prev_keyframe);
 513         next_keyframe = autos->get_next_auto(input_position, direction, next_keyframe);
 514         PanAuto *prev_pan_auto = (PanAuto *)prev_keyframe;
 515         PanAuto *next_pan_auto = (PanAuto *)next_keyframe;
 516
 517         if(direction == PLAY_FORWARD)
 518         {
 519 // Two distinct automation points within range
 520                 if(next_pan_auto->position > prev_pan_auto->position)
 521                 {
 522                         slope = ((double)next_pan_auto->values[channel] - prev_pan_auto->values[channel]) /
 523                                 ((double)next_pan_auto->position - prev_pan_auto->position);
 524                         intercept = ((double)input_position - prev_pan_auto->position) * slope +
 525                                 prev_pan_auto->values[channel];
 526
 527                         if(next_pan_auto->position < input_position + slope_len)
 528                                 slope_len = next_pan_auto->position - input_position;
 529                 }
 530                 else
 531 // One automation point within range
 532                 {
 533                         slope = 0;
 534                         intercept = prev_pan_auto->values[channel];
 535                 }
 536         }
 537         else
 538         {
 539 // Two distinct automation points within range
 540                 if(next_pan_auto->position < prev_pan_auto->position)
 541                 {
 542                         slope = ((double)next_pan_auto->values[channel] - prev_pan_auto->values[channel]) /
 543                                 ((double)next_pan_auto->position - prev_pan_auto->position);
 544                         intercept = ((double)input_position - prev_pan_auto->position) * slope +
 545                                 prev_pan_auto->values[channel];
 546
 547                         if(next_pan_auto->position > input_position - slope_len)
 548                                 slope_len = input_position - next_pan_auto->position;
 549                 }
 550                 else
 551 // One automation point within range
 552                 {
 553                         slope = 0;
 554                         intercept = next_pan_auto->values[channel];
 555                 }
 556         }
 557 }