MatchTaskServer Class Reference

Inheritance diagram for MatchTaskServer:

[legend]Collaboration diagram for MatchTaskServer:

[legend]List of all members.

Public Member Functions
	MatchTaskServer (void)
virtual void	operator() (MatchStore &store)
void	sendMatches (SocketInterface &socket)
void	sendSequence (bool yesOrNo=true)
Private Attributes
vector< MatchInfo >	matches_
map< SequenceNumber, std::string >	names_
bool	sendSequence_

---

Detailed Description

Definition at line 128 of file SSAHAServer.cpp.

---

Constructor & Destructor Documentation

MatchTaskServer::MatchTaskServer

(

void

)

[inline]

Definition at line 131 of file SSAHAServer.cpp.

: sendSequence_(false) {} // SocketInterface&

---

Member Function Documentation

void MatchTaskServer::operator()

(

MatchStore &

store

)

[virtual]

Implements MatchTask.

Definition at line 141 of file SSAHAServer.cpp.

References matches_, and names_.

{

 for (MatchStore::iterator i( store.begin() ) ; i!=store.end() ; ++i )
 {
    matches_.push_back( MatchInfo( **i ) );
    names_.insert
    ( pair<SequenceNumber, string>
      ( (*i)->getSubjectNum(), (*i)->getSubjectName() ) );
 }
}

void MatchTaskServer::sendMatches

(

SocketInterface &

socket

)

Definition at line 153 of file SSAHAServer.cpp.

References SourceReaderIndex::extractSource(), matches_, myPID, names_, MatchHeader::numMatches, MatchHeader::numSubjectNames, pSourceReader, SocketInterface::sendChars(), sendSequence_, SocketInterface::sendString(), SocketInterface::sendStruct(), MatchInfo::subjectEnd, MatchInfo::subjectNum, MatchInfo::subjectStart, and MatchHeader::wasSuccessful.

Referenced by processQuery().

{

  MatchHeader header;
  header.wasSuccessful=true; // TBD enum with more descriptive stuff
  header.numSubjectNames=names_.size();
  header.numMatches=matches_.size();
  cout << myPID << ": sending " << header.numMatches << " matches among "
       << header.numSubjectNames << " subject sequences." << endl; 
  
  socket.sendStruct(&header);

  char endString('\0');
  char* pSource;

  // Send the subject nums and names of all database sequences
  // which matched the query
  for ( map<SequenceNumber,std::string>::iterator i(names_.begin()); i != names_.end() ; i++  ) {
    cout << myPID << ": " << i->first << " " << i->second << endl;
    socket.sendStruct(&i->first);
    socket.sendString(i->second);
  } 

  // Send the match info itself
  for ( vector<MatchInfo>::iterator i( matches_.begin()); i != matches_.end() ; ++i ) {  
    
    socket.sendStruct((MatchInfo*)&(*i));
    
    if (sendSequence_==true) {
      //      cout << myPID << ": getting ready to send sequence " 
      //   << i->subjectNum << " " 
      //   << i->subjectStart << " " 
      //   << i->subjectEnd << endl;
      if(pSourceReader!=NULL) {
        pSourceReader->extractSource ( &pSource, i->subjectNum, i->subjectStart, i->subjectEnd );
        socket.sendChars( pSource, i->subjectEnd-i->subjectStart+1 );
        //cout << myPID << ": sent " 
        //   << i->subjectEnd-i->subjectStart+1 << " chars, "
        //   << pSource[0]
        //   << pSource[i->subjectEnd-i->subjectStart] << endl;
      } else {
        // send a null string if no index info is available
        socket.sendStruct(&endString);
        //      cout << myPID << ": sent null string" << endl; 
      }
    
    } 
  
  } 

}

Here is the call graph for this function:

Here is the caller graph for this function:

void MatchTaskServer::sendSequence

(

bool

yesOrNo = true

)

[inline]

Definition at line 134 of file SSAHAServer.cpp.

References sendSequence_.

Referenced by processQuery().

{ sendSequence_ = yesOrNo; }

Here is the caller graph for this function:

---

Member Data Documentation

vector<MatchInfo> MatchTaskServer::matches_ [private]

Definition at line 136 of file SSAHAServer.cpp.

Referenced by operator()(), and sendMatches().

map<SequenceNumber,std::string> MatchTaskServer::names_ [private]

Definition at line 137 of file SSAHAServer.cpp.

Referenced by operator()(), and sendMatches().

bool MatchTaskServer::sendSequence_ [private]

Definition at line 138 of file SSAHAServer.cpp.

Referenced by sendMatches(), and sendSequence().

---

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

• EnsemblServer/SSAHAServer.cpp

---