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::delete_current_sources()
96 for(int i = 0; i < current_indexables.size(); i++)
97 current_indexables.get(i)->Garbage::remove_user();
98 current_indexables.remove_all();
101 void MainIndexes::start_loop()
107 void MainIndexes::stop_loop()
111 input_lock->unlock();
112 interrupt_lock->unlock();
117 void MainIndexes::start_build()
119 //printf("MainIndexes::start_build 1\n");
121 // Locked up when indexes were already being built and an indexable was
123 // interrupt_lock.lock();
124 input_lock->unlock();
127 void MainIndexes::interrupt_build()
129 //printf("MainIndexes::interrupt_build 1\n");
131 index_lock->lock("MainIndexes::interrupt_build");
132 if(indexfile) indexfile->interrupt_index();
133 index_lock->unlock();
134 //printf("MainIndexes::interrupt_build 2\n");
135 interrupt_lock->lock("MainIndexes::interrupt_build");
136 //printf("MainIndexes::interrupt_build 3\n");
137 interrupt_lock->unlock();
138 //printf("MainIndexes::interrupt_build 4\n");
141 void MainIndexes::load_next_sources()
143 delete_current_sources();
145 // Transfer from new list
146 next_lock->lock("MainIndexes::load_next_sources");
147 for(int i = 0; i < next_indexables.size(); i++)
148 current_indexables.append(next_indexables.get(i));
150 // Clear pointers from new list only
151 next_indexables.remove_all();
156 void MainIndexes::run()
159 // Wait for new indexables to be released
160 input_lock->lock("MainIndexes::run 1");
163 interrupt_lock->lock("MainIndexes::run 2");
167 // test index of each indexable
168 MainProgressBar *progress = 0;
169 int total_sources = current_indexables.size();
171 for( int i = 0; i < total_sources && !interrupt_flag; ++i ) {
172 Indexable *indexable = current_indexables[i];
173 IndexState *index_state = indexable->index_state;
174 // if status is known, no probe
175 if( index_state->index_status != INDEX_NOTTESTED ) continue;
177 IndexFile indexfile(mwindow, indexable);
178 int ret = indexfile.open_index();
180 indexfile.close_index();
181 // use existing index
182 index_state->index_status = INDEX_READY;
183 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 2");
184 mwindow->edl->set_index_file(indexable);
185 if(mwindow->gui) mwindow->gui->unlock_window();
190 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 1");
191 progress = mwindow->mainprogress->start_progress(_("Building Indexes..."), 1);
192 if(mwindow->gui) mwindow->gui->unlock_window();
194 // only if audio tracks
195 indexfile.create_index(progress);
196 if( progress->is_cancelled() )
200 if(progress) { // progress box is only created when an index is built
201 if(mwindow->gui) mwindow->gui->lock_window("MainIndexes::run 3");
202 progress->stop_progress();
204 if(mwindow->gui) mwindow->gui->unlock_window();
208 interrupt_lock->unlock();