CQMThread Class Reference

List of all members.

Public Member Functions
	~CQMThread ()
	CQMThread (CQuery &inQueryProcessor, const CXMLElement &inQuery, double inWeight, int inResultSize, double inDifferenceToBest)
	CQMThread (const CQMThread &in)
void	runThread (void)
void	runFastThread (void)
void	join (void)
double	getWeight () const
Public Attributes
CQuery &	mQueryProcessor
const CXMLElement *	mQuery
int	mResultSize
double	mDifferenceToBest
CXMLElement *	mResult
CIDRelevanceLevelPairList *	mFastResult
Private Attributes
bool	mIsThreaded
double	mWeight

---

Detailed Description

calls fastQuery for every child, merges the results and translates them back into URLs

NOTE THIS IS COMMENTED OUT. IT WAS TOO INEFFICIENT. IT WOULD BECOME A CHOICE IF WE WOULD OUTPUT THINGS RATHER SORTED BY THEIR URL THAN BY THEIR SCORE

CIDRelevanceLevelPairList* CQMultiple::fastQuery(const CXMLElement& inQuery, int inNumberOfInterestingImages, double inDifferenceToBest){

cout << "CMultiple Number of children:" << mChildren.size() << endl;

list<CWeightedResult> lTemporary; double lWeightSum(0);

for(lCChildren::const_iterator i=mChildren.begin(); i!=mChildren.end(); i++){ lWeightSum+=i->mWeight;

lTemporary.push_back(CWeightedResult());

cout << "this CMultiple:" << this << ", i->mQuery:" << i->mQuery << ", i->mWeight:" << i->mWeight << endl;

lTemporary.back().mList=i->mQuery->fastQuery(inQuery, mAccessor->size(), inDifferenceToBest);

if(lTemporary.back().mList){ lTemporary.back().mList->sort(CSortByID_IRLP()); lTemporary.back().mI=lTemporary.back().mList->begin();

lTemporary.back().mWeight=i->mWeight; }else{ lTemporary.pop_back(); } }

CIDRelevanceLevelPairList* lReturnValue=new CIDRelevanceLevelPairList();

while(lTemporary.size()){

list<CWeightedResult>::iterator lMinimumIterator=lTemporary.begin(); for(list<CWeightedResult>::iterator i=++lTemporary.begin(); i!=lTemporary.end(); i++){ the ID pointed to by i is smaller lMinimumIterator if((i->mI)->getID()<(lMinimumIterator->mI)->getID()){ lMinimumIterator=i; } } if((lReturnValue->size()) && ((lMinimumIterator->mI)->getID()==lReturnValue->back().getID())){ lReturnValue->back().setRelevanceLevel( lReturnValue->back().getRelevanceLevel() + ((lMinimumIterator->mI)->getRelevanceLevel()

lMinimumIterator->mWeight) ); }else{ lReturnValue->push_back(*lMinimumIterator->mI); lReturnValue->back().setRelevanceLevel( ((lMinimumIterator->mI)->getRelevanceLevel()

lMinimumIterator->mWeight) ); } (lMinimumIterator->mI)++; end of this list, so we delete it if(lMinimumIterator->mI==lMinimumIterator->mList->end()){ lTemporary.erase(lMinimumIterator); } } lReturnValue->sort(CSortByID_IRLP());// for testing, to see if there are any duplicates lReturnValue->sort(); lReturnValue->reverse(); cout << "Size of the result " << lReturnValue->size() << endl;

{ CIDRelevanceLevelPairList::iterator iSkip=lReturnValue->begin(); for(int i=0; i<inNumberOfInterestingImages && i<lReturnValue->size(); i++){ iSkip->setRelevanceLevel(iSkip->getRelevanceLevel()/lWeightSum); iSkip++; } lReturnValue->erase(iSkip,lReturnValue->end()); }

return lReturnValue; }; all information about a query thread for a CQMultiple

Definition at line 239 of file CQMultiple.cc.

---

Constructor & Destructor Documentation

CQMThread::~CQMThread

(

)

[inline]

destructor

Definition at line 263 of file CQMultiple.cc.

              {
    delete mQuery;
  }

CQMThread::CQMThread	(	CQuery &	inQueryProcessor,
		const CXMLElement &	inQuery,
		double	inWeight,
		int	inResultSize,
		double	inDifferenceToBest
	)			[inline]

constructor

Definition at line 267 of file CQMultiple.cc.

Referenced by CQMultiple::fastQuery().

                                :
    mQueryProcessor(inQueryProcessor),
    mQuery(new CXMLElement(inQuery)),
    mWeight(inWeight),
    mResultSize(inResultSize),
    mDifferenceToBest(inDifferenceToBest),
    mFastResult(0),
    mResult(0){
  };

CQMThread::CQMThread

(

const CQMThread &

in

)

[inline]

copy constructor

Definition at line 281 of file CQMultiple.cc.

                                :
    mQueryProcessor(in.mQueryProcessor),
    mQuery(new CXMLElement(*in.mQuery)),
    mWeight(in.mWeight),
    mResultSize(in.mResultSize),
    mDifferenceToBest(in.mDifferenceToBest),
    mResult(0),
    mFastResult(0),
    mIsThreaded(0){
  };

---

Member Function Documentation

void CQMThread::runThread

(

void

)

[inline]

running the thread

Definition at line 292 of file CQMultiple.cc.

References CQMultiple::doQueryThread().

                      {
    mResult=0;
#ifdef __GIFT_USES_THREADS__
#warning treading active
    mIsThreaded=true;
    pthread_create(&mThread,0,CQMultiple::doQueryThread,this);
#else
#warning treading blocked
    CQMultiple::doQueryThread(this);
#endif
  }

void CQMThread::runFastThread

(

void

)

[inline]

running the thread

Definition at line 304 of file CQMultiple.cc.

References CQMultiple::doFastQueryThread().

                          {
    mFastResult=0;
#ifdef __GIFT_USES_THREADS__
#warning treading active
    mIsThreaded=true;
    pthread_create(&mThread,0,CQMultiple::doFastQueryThread,this);
#else
#warning treading blocked
    CQMultiple::doFastQueryThread(this);
#endif
  }

void CQMThread::join

(

void

)

[inline]

joining this thread with the caller

Definition at line 316 of file CQMultiple.cc.

                 {
#ifdef __GIFT_USES_THREADS__
    void** lReturnValue(NULL);
    cout << "PREJOIN" << endl;
    if(mIsThreaded){
      int lJoinResult(pthread_join(mThread,lReturnValue));

      if(lJoinResult){
  cout << "CQMultiple: ERROR IN JOINING " 
       << lJoinResult
       << endl;
      }
    }else{
      cout << "This was an unthreaded join!" 
     << endl;
    }
    mIsThreaded=false;
    cout << "POSTJOIN" << endl;
#endif
  }

double CQMThread::getWeight

(

)

const [inline]

gives back the weight the results should receive when summing up

Definition at line 338 of file CQMultiple.cc.

                         {
    return mWeight;
  }

---

Member Data Documentation

bool CQMThread::mIsThreaded [private]

the thread administrator is this called as a thread or as a function

Definition at line 246 of file CQMultiple.cc.

double CQMThread::mWeight [private]

this is the weight the result should receive

Definition at line 248 of file CQMultiple.cc.

CQuery& CQMThread::mQueryProcessor

query processor used in this thread

Definition at line 251 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread(), and CQMultiple::doQueryThread().

const CXMLElement* CQMThread::mQuery

the query (an xml parse tree)

Definition at line 253 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread(), and CQMultiple::doQueryThread().

int CQMThread::mResultSize

the desired result size

Definition at line 255 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread().

double CQMThread::mDifferenceToBest

the cutoff

Definition at line 257 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread().

CXMLElement* CQMThread::mResult

the result of the query

Definition at line 259 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread(), and CQMultiple::doQueryThread().

CIDRelevanceLevelPairList* CQMThread::mFastResult

the result of the fastQuery

Definition at line 261 of file CQMultiple.cc.

Referenced by CQMultiple::doFastQueryThread().

---

The documentation for this class was generated from the following file:

• gift/libMRML/cc/CQMultiple.cc