You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
360 lines
8.9 KiB
360 lines
8.9 KiB
/***************************************************************************
|
|
* Copyright (C) 2002 by Roberto Raggi *
|
|
* roberto@kdevelop.org *
|
|
* *
|
|
* This program is free software; you can redistribute it and/or modify *
|
|
* it under the terms of the GNU General Public License as published by *
|
|
* the Free Software Foundation; either version 2 of the License, or *
|
|
* (at your option) any later version. *
|
|
* *
|
|
***************************************************************************/
|
|
|
|
#include "backgroundparser.h"
|
|
#include "javasupportpart.h"
|
|
#include "javasupport_events.h"
|
|
#include "driver.h"
|
|
#include "kdevdeepcopy.h"
|
|
#include "kdevdriver.h"
|
|
|
|
#include <tqmutex.h>
|
|
|
|
#include <tdeparts/part.h>
|
|
#include <tdetexteditor/editinterface.h>
|
|
#include <tdetexteditor/document.h>
|
|
#include <tdetexteditor/view.h>
|
|
|
|
#include <kdevpartcontroller.h>
|
|
#include <kdevproject.h>
|
|
|
|
#include <kurl.h>
|
|
#include <kdebug.h>
|
|
#include <tdeapplication.h>
|
|
|
|
#include <tqfile.h>
|
|
#include <tqfileinfo.h>
|
|
#include <tqtextstream.h>
|
|
|
|
class KDevSourceProvider: public SourceProvider
|
|
{
|
|
public:
|
|
KDevSourceProvider( JavaSupportPart* javaSupport )
|
|
: m_javaSupport( javaSupport ),
|
|
m_readFromDisk( false ) {}
|
|
|
|
void setReadFromDisk( bool b ) { m_readFromDisk = b; }
|
|
bool readFromDisk() const { return m_readFromDisk; }
|
|
|
|
virtual TQString contents( const TQString& fileName )
|
|
{
|
|
if( !m_readFromDisk ){
|
|
//kdDebug(9013) << "-------> kapp is locked = " << kapp->locked() << endl;
|
|
bool needToLock = kapp->locked() == false;
|
|
|
|
if( needToLock )
|
|
kapp->lock();
|
|
|
|
//kdDebug(9013) << "-------> kapp locked" << endl;
|
|
|
|
TQPtrList<KParts::Part> parts( *m_javaSupport->partController()->parts() );
|
|
TQPtrListIterator<KParts::Part> it( parts );
|
|
while( it.current() ){
|
|
KTextEditor::Document* doc = dynamic_cast<KTextEditor::Document*>( it.current() );
|
|
++it;
|
|
|
|
KTextEditor::EditInterface* editIface = dynamic_cast<KTextEditor::EditInterface*>( doc );
|
|
if( !doc || !editIface || doc->url().path() != fileName )
|
|
continue;
|
|
|
|
TQString contents = TQString( editIface->text().ascii() ); // deep copy
|
|
|
|
if( needToLock )
|
|
kapp->unlock();
|
|
|
|
//kdDebug(9013) << "-------> kapp unlocked" << endl;
|
|
|
|
return contents;
|
|
}
|
|
|
|
if( needToLock )
|
|
kapp->unlock();
|
|
//kdDebug(9013) << "-------> kapp unlocked" << endl;
|
|
}
|
|
|
|
TQFile f( fileName );
|
|
TQTextStream stream( &f );
|
|
if( f.open(IO_ReadOnly) ){
|
|
TQString contents = stream.read();
|
|
f.close();
|
|
return contents;
|
|
}
|
|
|
|
return TQString();
|
|
}
|
|
|
|
virtual bool isModified( const TQString& fileName )
|
|
{
|
|
Q_UNUSED( fileName );
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
JavaSupportPart* m_javaSupport;
|
|
bool m_readFromDisk;
|
|
private:
|
|
KDevSourceProvider( const KDevSourceProvider& source );
|
|
void operator = ( const KDevSourceProvider& source );
|
|
};
|
|
|
|
class SynchronizedFileList
|
|
{
|
|
public:
|
|
SynchronizedFileList() {}
|
|
|
|
bool isEmpty() const
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
return m_fileList.isEmpty();
|
|
}
|
|
|
|
uint count() const
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
return m_fileList.count();
|
|
}
|
|
|
|
TQPair<TQString, bool> front() const
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
return m_fileList.front();
|
|
}
|
|
|
|
void clear()
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
m_fileList.clear();
|
|
}
|
|
|
|
void push_back( const TQString& fileName, bool readFromDisk=false )
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
m_fileList.append( qMakePair(fileName, readFromDisk) ); /// \FIXME ROBE deepcopy?!
|
|
}
|
|
|
|
void pop_front()
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
m_fileList.pop_front();
|
|
}
|
|
|
|
bool contains( const TQString& fileName ) const
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
TQValueList< TQPair<TQString, bool> >::ConstIterator it = m_fileList.begin();
|
|
while( it != m_fileList.end() ){
|
|
if( (*it).first == fileName )
|
|
return true;
|
|
++it;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void remove( const TQString& fileName )
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
TQValueList< TQPair<TQString, bool> >::Iterator it = m_fileList.begin();
|
|
while( it != m_fileList.end() ){
|
|
if( (*it).first == fileName )
|
|
m_fileList.remove( it );
|
|
++it;
|
|
}
|
|
}
|
|
|
|
private:
|
|
mutable TQMutex m_mutex;
|
|
TQValueList< TQPair<TQString, bool> > m_fileList;
|
|
};
|
|
|
|
BackgroundParser::BackgroundParser( JavaSupportPart* part, TQWaitCondition* consumed )
|
|
: m_consumed( consumed ), m_javaSupport( part ), m_close( false )
|
|
{
|
|
m_fileList = new SynchronizedFileList();
|
|
m_driver = new KDevDriver( m_javaSupport );
|
|
m_driver->setSourceProvider( new KDevSourceProvider(m_javaSupport) );
|
|
//disabled for now m_driver->setResolveDependencesEnabled( true );
|
|
}
|
|
|
|
BackgroundParser::~BackgroundParser()
|
|
{
|
|
removeAllFiles();
|
|
|
|
delete( m_driver );
|
|
m_driver = 0;
|
|
|
|
delete m_fileList;
|
|
m_fileList = 0;
|
|
}
|
|
|
|
void BackgroundParser::addFile( const TQString& fileName, bool readFromDisk )
|
|
{
|
|
TQString fn = deepCopy( fileName );
|
|
|
|
bool added = false;
|
|
if( !m_fileList->contains(fn) ){
|
|
m_fileList->push_back( fn, readFromDisk );
|
|
added = true;
|
|
}
|
|
|
|
if( added )
|
|
m_canParse.wakeAll();
|
|
}
|
|
|
|
void BackgroundParser::removeAllFiles()
|
|
{
|
|
kdDebug(9013) << "BackgroundParser::removeAllFiles()" << endl;
|
|
TQMutexLocker locker( &m_mutex );
|
|
|
|
TQMap<TQString, Unit*>::Iterator it = m_unitDict.begin();
|
|
while( it != m_unitDict.end() ){
|
|
Unit* unit = it.data();
|
|
++it;
|
|
delete( unit );
|
|
unit = 0;
|
|
}
|
|
m_unitDict.clear();
|
|
m_driver->reset();
|
|
m_fileList->clear();
|
|
|
|
m_isEmpty.wakeAll();
|
|
}
|
|
|
|
void BackgroundParser::removeFile( const TQString& fileName )
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
|
|
if( Unit* unit = findUnit(fileName) ){
|
|
m_driver->remove( fileName );
|
|
m_unitDict.remove( fileName );
|
|
delete( unit );
|
|
unit = 0;
|
|
}
|
|
|
|
if( m_fileList->isEmpty() )
|
|
m_isEmpty.wakeAll();
|
|
}
|
|
|
|
Unit* BackgroundParser::parseFile( const TQString& fileName, bool readFromDisk )
|
|
{
|
|
static_cast<KDevSourceProvider*>( m_driver->sourceProvider() )->setReadFromDisk( readFromDisk );
|
|
|
|
m_driver->remove( fileName );
|
|
m_driver->parseFile( fileName );
|
|
RefJavaAST translationUnit = m_driver->takeTranslationUnit( fileName );
|
|
|
|
Unit* unit = new Unit;
|
|
unit->fileName = fileName;
|
|
unit->translationUnit = translationUnit;
|
|
unit->problems = m_driver->problems( fileName );
|
|
|
|
static_cast<KDevSourceProvider*>( m_driver->sourceProvider() )->setReadFromDisk( false );
|
|
|
|
if( m_unitDict.find(fileName) != m_unitDict.end() ){
|
|
Unit* u = m_unitDict[ fileName ];
|
|
m_unitDict.remove( fileName );
|
|
delete( u );
|
|
u = 0;
|
|
}
|
|
|
|
m_unitDict.insert( fileName, unit );
|
|
|
|
if( m_fileList->contains(fileName) ){
|
|
kdDebug(9013) << "========================> FILE: " << fileName << " IN QUEUE <=============" << endl;
|
|
} else {
|
|
TDEApplication::postEvent( m_javaSupport, new FileParsedEvent(fileName, unit->problems) );
|
|
}
|
|
|
|
m_currentFile = TQString();
|
|
|
|
if( m_fileList->isEmpty() )
|
|
m_isEmpty.wakeAll();
|
|
|
|
return unit;
|
|
}
|
|
|
|
Unit* BackgroundParser::findUnit( const TQString& fileName )
|
|
{
|
|
TQMap<TQString, Unit*>::Iterator it = m_unitDict.find( fileName );
|
|
return it != m_unitDict.end() ? *it : 0;
|
|
}
|
|
|
|
RefJavaAST BackgroundParser::translationUnit( const TQString& fileName )
|
|
{
|
|
Unit* u = 0;
|
|
if( (u = findUnit(fileName)) == 0 ){
|
|
m_fileList->remove( fileName );
|
|
u = parseFile( fileName, false );
|
|
}
|
|
|
|
return u->translationUnit;
|
|
}
|
|
|
|
TQValueList<Problem> BackgroundParser::problems( const TQString& fileName )
|
|
{
|
|
Unit* u = 0;
|
|
if( (u = findUnit(fileName)) == 0 ){
|
|
m_fileList->remove( fileName );
|
|
u = parseFile( fileName, false );
|
|
}
|
|
|
|
return u ? u->problems : TQValueList<Problem>();
|
|
}
|
|
|
|
void BackgroundParser::close()
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
m_close = true;
|
|
m_canParse.wakeAll();
|
|
}
|
|
|
|
bool BackgroundParser::filesInQueue()
|
|
{
|
|
TQMutexLocker locker( &m_mutex );
|
|
|
|
return m_fileList->count() || !m_currentFile.isEmpty();
|
|
}
|
|
|
|
void BackgroundParser::run()
|
|
{
|
|
// (void) m_javaSupport->codeCompletion()->repository()->getEntriesInScope( TQStringList(), false );
|
|
|
|
while( !m_close ){
|
|
|
|
m_mutex.lock();
|
|
while( m_fileList->isEmpty() ){
|
|
m_canParse.wait( &m_mutex );
|
|
|
|
if( m_close ){
|
|
break;
|
|
}
|
|
}
|
|
|
|
if( m_close ){
|
|
m_mutex.unlock();
|
|
break;
|
|
}
|
|
|
|
TQPair<TQString, bool> entry = m_fileList->front();
|
|
TQString fileName = entry.first;
|
|
bool readFromDisk = entry.second;
|
|
m_currentFile = fileName;
|
|
m_fileList->pop_front();
|
|
|
|
(void) parseFile( fileName, readFromDisk );
|
|
m_mutex.unlock();
|
|
}
|
|
|
|
kdDebug(9013) << "!!!!!!!!!!!!!!!!!! BG PARSER DESTROYED !!!!!!!!!!!!" << endl;
|
|
|
|
//commented to fix #83352
|
|
//TQThread::exit();
|
|
}
|