MASA-Core
Public Member Functions | Public Attributes | Private Member Functions | Private Attributes
Job Class Reference

Detailed Description

Definition at line 58 of file Job.hpp.

#include <Job.hpp>

List of all members.

Public Member Functions

 Job (int sequencesCount)
virtual ~Job ()
void setWorkPath (string workPath)
void setSpecialRowsPath (string specialRowsPath)
void setSharedPath (string sharedPath)
string getWorkPath ()
int initialize ()
FILE * fopenStatistics (int stage, int id)
int getSequenceCount () const
void addSequence (Sequence *sequence)
SequencegetSequence (int index)
AlignmentParamsgetAlignmentParams () const
AlignmentgetAlignment () const
void setAlignment (Alignment *alignment)
void loadSequenceData (Sequence *sequence)
string getCrosspointFile (int stage, int id, int deep=-1)
string getAlignmentBinaryFile (int id)
string getAlignmentTextFile (int id)
SpecialRowsAreagetSpecialRowsArea (int stage, int id, int deep=-1)
void clearSpecialRowsArea (SpecialRowsArea **area)
long long getSRALimit ()
long long getFlushInterval (int step)
AlignerPoolgetAlignerPool ()
int getPoolWaitId () const
void setPoolWaitId (int id)
int getBufferLimit () const
void setBufferLimit (int bufferLimit)

Public Attributes

int alignment_start
int alignment_end
int max_alignments
long long ram_limit
long long disk_limit
bool block_pruning
bool dump_blocks
string flush_column_url
string load_column_url
int predicted_traceback
int stage4_maximum_partition_size
bool stage4_orthogonal_execution
string dump_pruning_text_filename
int stage6_output_format
string outputBufferLogFile
string inputBufferLogFile
IAligneraligner
Configsconfigs
int peer_listen_port
string peer_connect

Private Member Functions

string getSpecialRowsPath (int stage, int id, int deep=-1)
void createPath (string path)
void initializeWorkPath ()
string resolve_env (string in)
void clearSpecialRowsAreas ()
void calculateFlushIntervals (int max_deep, long long limit, int seq0_len, int seq1_len)

Private Attributes

vector< Sequence * > sequences
AlignmentParamsalignment_params
Alignmentalignment
string statistics_filename
string status_filename
string info_filename
int last_crosspoint_id
string work_path
string crosspoints_path
string special_rows_path
int * flushIntervals
int maxFlushDeep
AlignerPoolalignerPool
string pool_shared_path
int pool_wait_id
int bufferLimit
map< string, SpecialRowsArea * > specialRowsAreas

Constructor & Destructor Documentation

Job::Job ( int  sequencesCount)

Definition at line 43 of file Job.cpp.

Job::~Job ( ) [virtual]

Definition at line 56 of file Job.cpp.


Member Function Documentation

void Job::addSequence ( Sequence sequence)

Definition at line 164 of file Job.cpp.

void Job::calculateFlushIntervals ( int  max_deep,
long long  limit,
int  seq0_len,
int  seq1_len 
) [private]

Definition at line 231 of file Job.cpp.

Definition at line 213 of file Job.cpp.

void Job::clearSpecialRowsAreas ( ) [private]

Definition at line 267 of file Job.cpp.

void Job::createPath ( string  path) [private]

Definition at line 318 of file Job.cpp.

FILE * Job::fopenStatistics ( int  stage,
int  id 
)

Definition at line 327 of file Job.cpp.

Definition at line 221 of file Job.cpp.

Definition at line 176 of file Job.cpp.

string Job::getAlignmentBinaryFile ( int  id)

Definition at line 300 of file Job.cpp.

Definition at line 172 of file Job.cpp.

string Job::getAlignmentTextFile ( int  id)

Definition at line 306 of file Job.cpp.

int Job::getBufferLimit ( ) const

Definition at line 402 of file Job.cpp.

string Job::getCrosspointFile ( int  stage,
int  id,
int  deep = -1 
)

Definition at line 192 of file Job.cpp.

long long Job::getFlushInterval ( int  step)

Definition at line 259 of file Job.cpp.

int Job::getPoolWaitId ( ) const

Definition at line 394 of file Job.cpp.

Sequence * Job::getSequence ( int  index)

Definition at line 168 of file Job.cpp.

int Job::getSequenceCount ( ) const

Definition at line 160 of file Job.cpp.

SpecialRowsArea * Job::getSpecialRowsArea ( int  stage,
int  id,
int  deep = -1 
)

Definition at line 275 of file Job.cpp.

string Job::getSpecialRowsPath ( int  stage,
int  id,
int  deep = -1 
) [private]

Definition at line 202 of file Job.cpp.

long long Job::getSRALimit ( )

Definition at line 354 of file Job.cpp.

string Job::getWorkPath ( )

Definition at line 313 of file Job.cpp.

int Job::initialize ( )

Definition at line 62 of file Job.cpp.

void Job::initializeWorkPath ( ) [private]

Definition at line 118 of file Job.cpp.

void Job::loadSequenceData ( Sequence sequence)

Definition at line 184 of file Job.cpp.

string Job::resolve_env ( string  in) [private]

Definition at line 366 of file Job.cpp.

void Job::setAlignment ( Alignment alignment)

Definition at line 180 of file Job.cpp.

void Job::setBufferLimit ( int  bufferLimit)

Definition at line 406 of file Job.cpp.

void Job::setPoolWaitId ( int  id)

Definition at line 398 of file Job.cpp.

void Job::setSharedPath ( string  sharedPath)

Definition at line 156 of file Job.cpp.

void Job::setSpecialRowsPath ( string  specialRowsPath)

Definition at line 152 of file Job.cpp.

void Job::setWorkPath ( string  workPath)

Definition at line 148 of file Job.cpp.


Member Data Documentation

Definition at line 81 of file Job.hpp.

Definition at line 141 of file Job.hpp.

Definition at line 131 of file Job.hpp.

Definition at line 65 of file Job.hpp.

Definition at line 130 of file Job.hpp.

Definition at line 64 of file Job.hpp.

Definition at line 69 of file Job.hpp.

int Job::bufferLimit [private]

Definition at line 144 of file Job.hpp.

Definition at line 82 of file Job.hpp.

string Job::crosspoints_path [private]

Definition at line 137 of file Job.hpp.

long long Job::disk_limit

Definition at line 68 of file Job.hpp.

Definition at line 70 of file Job.hpp.

Definition at line 76 of file Job.hpp.

Definition at line 71 of file Job.hpp.

int* Job::flushIntervals [private]

Definition at line 139 of file Job.hpp.

string Job::info_filename [private]

Definition at line 134 of file Job.hpp.

Definition at line 79 of file Job.hpp.

int Job::last_crosspoint_id [private]

Definition at line 135 of file Job.hpp.

Definition at line 72 of file Job.hpp.

Definition at line 66 of file Job.hpp.

int Job::maxFlushDeep [private]

Definition at line 140 of file Job.hpp.

Definition at line 78 of file Job.hpp.

Definition at line 85 of file Job.hpp.

Definition at line 84 of file Job.hpp.

string Job::pool_shared_path [private]

Definition at line 142 of file Job.hpp.

int Job::pool_wait_id [private]

Definition at line 143 of file Job.hpp.

Definition at line 73 of file Job.hpp.

long long Job::ram_limit

Definition at line 67 of file Job.hpp.

vector<Sequence*> Job::sequences [private]

Definition at line 129 of file Job.hpp.

string Job::special_rows_path [private]

Definition at line 138 of file Job.hpp.

map<string, SpecialRowsArea*> Job::specialRowsAreas [private]

Definition at line 146 of file Job.hpp.

Definition at line 74 of file Job.hpp.

Definition at line 75 of file Job.hpp.

Definition at line 77 of file Job.hpp.

string Job::statistics_filename [private]

Definition at line 132 of file Job.hpp.

string Job::status_filename [private]

Definition at line 133 of file Job.hpp.

string Job::work_path [private]

Definition at line 136 of file Job.hpp.


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