4 * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
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.
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.
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
23 #include "bcsignals.h"
27 #include "filesystem.h"
28 #include "indexfile.h"
29 #include "indexstate.h"
30 #include "condition.h"
34 #include "mainerror.h"
35 #include "mainindexes.h"
36 #include "mainprogress.h"
39 #include "mwindowgui.h"
40 #include "preferences.h"
45 MainIndexes::MainIndexes(MWindow *mwindow)
49 this->mwindow = mwindow;
50 input_lock = new Condition(0, "MainIndexes::input_lock");
51 next_lock = new Mutex("MainIndexes::next_lock");
52 index_lock = new Mutex("MainIndexes::index_lock");
53 interrupt_lock = new Condition(1, "MainIndexes::interrupt_lock");
59 MainIndexes::~MainIndexes()
61 mwindow->mainprogress->cancelled = 1;
65 delete interrupt_lock;
70 void MainIndexes::add_next_asset(File *file, Indexable *indexable)
72 next_lock->lock("MainIndexes::add_next_asset");
76 IndexFile indexfile(mwindow, indexable);
77 IndexState *index_state = indexable->index_state;
80 int ret = indexfile.open_index();
82 index_state->index_status = INDEX_READY;
83 indexfile.close_index();
86 // Put source in stack
87 index_state->index_status = INDEX_NOTTESTED;
88 next_indexables.append(indexable);
89 indexable->add_user();
94 void MainIndexes::start_loop()
100 void MainIndexes::stop_loop()
104 input_lock->unlock();
105 interrupt_lock->unlock();
110 void MainIndexes::start_build()
112 if( !current_indexables.size() ) return;
113 //printf("MainIndexes::start_build 1\n");
115 // Locked up when indexes were already being built and an indexable was
117 // interrupt_lock.lock();
118 input_lock->unlock();
121 void MainIndexes::interrupt_build()
123 //printf("MainIndexes::interrupt_build 1\n");
125 index_lock->lock("MainIndexes::interrupt_build");
126 if(indexfile) indexfile->interrupt_index();
127 index_lock->unlock();
128 //printf("MainIndexes::interrupt_build 2\n");
129 interrupt_lock->lock("MainIndexes::interrupt_build");
130 //printf("MainIndexes::interrupt_build 3\n");
131 interrupt_lock->unlock();
132 //printf("MainIndexes::interrupt_build 4\n");
135 void MainIndexes::load_next_sources()
137 // Transfer from new list
138 next_lock->lock("MainIndexes::load_next_sources");
139 for(int i = 0; i < next_indexables.size(); i++)
140 current_indexables.append(next_indexables.get(i));
142 // Clear pointers from new list only
143 next_indexables.remove_all();
148 void MainIndexes::run()
151 // Wait for new indexables to be released
152 input_lock->lock("MainIndexes::run 1");
155 interrupt_lock->lock("MainIndexes::run 2");
159 // test index of each indexable
160 MainProgressBar *progress = 0;
162 next_lock->lock("MainIndexes::run");
163 for( int i=0; i<current_indexables.size() && !interrupt_flag; ++i ) {
164 Indexable *indexable = current_indexables[i];
165 IndexState *index_state = indexable->index_state;
166 // if status is known, no probe
167 if( index_state->index_status != INDEX_NOTTESTED ) continue;
170 IndexFile indexfile(mwindow, indexable);
171 int ret = indexfile.open_index();
173 indexfile.close_index();
174 // use existing index
175 index_state->index_status = INDEX_READY;
176 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 2");
177 mwindow->edl->set_index_file(indexable);
178 if(mwindow->gui) mwindow->gui->unlock_window();
183 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 1");
184 progress = mwindow->mainprogress->start_progress(_("Building Indexes..."), 1);
185 if(mwindow->gui) mwindow->gui->unlock_window();
187 // only if audio tracks
188 indexfile.create_index(progress);
189 if( progress->is_cancelled() )
191 next_lock->lock("MainIndexes::run");
194 for( int i=0; i<current_indexables.size(); ++i )
195 current_indexables[i]->remove_user();
196 current_indexables.remove_all();
199 if(progress) { // progress box is only created when an index is built
200 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 3");
201 progress->stop_progress();
203 if(mwindow->gui) mwindow->gui->unlock_window();
207 interrupt_lock->unlock();