rework set default transtion, nested proxy edl fixes, doubleclick proxy media fix...
[goodguy/history.git] / cinelerra-5.1 / cinelerra / indexthread.C
1
2 /*
3  * CINELERRA
4  * Copyright (C) 2009 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 "asset.h"
23 #include "bcsignals.h"
24 #include "clip.h"
25 #include "condition.h"
26 #include "edl.h"
27 #include "edlsession.h"
28 #include "filexml.h"
29 #include "indexfile.h"
30 #include "indexstate.h"
31 #include "indexthread.h"
32 #include "language.h"
33 #include "maxchannels.h"
34 #include "mwindow.h"
35 #include "mwindowgui.h"
36 #include "preferences.h"
37 #include "mainsession.h"
38 #include "samples.h"
39 #include <unistd.h>
40 #include "trackcanvas.h"
41 #include "tracks.h"
42
43 // Read data from buffers and calculate peaks
44
45 IndexThread::IndexThread(MWindow *mwindow,
46         IndexFile *index_file,
47         char *index_filename,
48         int64_t buffer_size,
49         int64_t length_source)
50  : Thread(1, 0, 0)
51 {
52         this->buffer_size = buffer_size;
53         this->length_source = length_source;
54         this->mwindow = mwindow;
55         this->index_filename = index_filename;
56         this->index_file = index_file;
57
58 // initialization is completed in run
59         for(int i = 0; i < TOTAL_INDEX_BUFFERS; i++)
60         {
61 // Must allocate MAX_CHANNELS for a nested EDL
62                 int min_channels = MAX(MAX_CHANNELS, index_file->source_channels);
63                 buffer_in[i] = new Samples*[min_channels];
64                 bzero(buffer_in[i], sizeof(Samples*) * min_channels);
65
66                 output_lock[i] = new Condition(0, "IndexThread::output_lock");
67                 input_lock[i] = new Condition(1, "IndexThread::input_lock");
68
69                 for(int j = 0; j < index_file->source_channels; j++)
70                 {
71                         buffer_in[i][j] = new Samples(buffer_size);
72                 }
73         }
74
75 //printf("IndexThread::IndexThread %d\n", __LINE__);
76 //index_state->dump();
77
78         interrupt_flag = 0;
79 }
80
81 IndexThread::~IndexThread()
82 {
83         for(int i = 0; i < TOTAL_INDEX_BUFFERS; i++)
84         {
85                 for(int j = 0; j < index_file->source_channels; j++)
86                 {
87                         delete buffer_in[i][j];
88                 }
89                 delete [] buffer_in[i];
90                 delete output_lock[i];
91                 delete input_lock[i];
92         }
93 }
94
95 void IndexThread::start_build()
96 {
97         interrupt_flag = 0;
98         current_buffer = 0;
99         for(int i = 0; i <  TOTAL_INDEX_BUFFERS; i++) last_buffer[i] = 0;
100         start();
101 }
102
103 void IndexThread::stop_build()
104 {
105         join();
106 }
107
108 void IndexThread::run()
109 {
110         int done = 0;
111         IndexState *index_state = index_file->get_state();
112         int index_channels = index_file->source_channels;
113         index_state->add_audio_stream(index_channels, index_file->source_length);
114         index_state->init_scan(mwindow->preferences->index_size);
115         index_state->index_status = INDEX_BUILDING;
116
117         while(!interrupt_flag && !done) {
118                 output_lock[current_buffer]->lock("IndexThread::run");
119
120                 if(last_buffer[current_buffer]) done = 1;
121                 if(!interrupt_flag && !done) {
122 // process buffer
123                         int64_t len = input_len[current_buffer];
124                         for( int ch=0; ch<index_channels; ++ch ) {
125                                 double *samples = buffer_in[current_buffer][ch]->get_data();
126                                 index_state->put_data(ch,samples,len);
127                         }
128
129 // draw simultaneously with build
130                         index_file->redraw_edits(0);
131                 }
132
133                 input_lock[current_buffer]->unlock();
134                 current_buffer++;
135                 if(current_buffer >= TOTAL_INDEX_BUFFERS) current_buffer = 0;
136         }
137
138         index_file->redraw_edits(1);
139
140 // write the index file to disk
141         Asset *asset = index_file->indexable->is_asset ? (Asset*)index_file->indexable : 0;
142         index_state->create_index(index_filename, asset);
143 }
144
145
146