/home/msneddon/eclipse/galileoSR1_cpp/workspace/NFsim/src/NFscheduler/Scheduler.cpp File Reference

#include "Scheduler.h"
#include "../NFsim.hh"
#include <iostream>
#include <map>

Functions

vector< job * > getTestJobs ()
vector< job * > parseJobsFile (string buffer)
void convertModelScanToJobs (model *&currentModel, scan *currentScan, vector< job * > &joblist)
string getFileLine (ifstream &input)
vector< string > * getStringsFileline (ifstream &input, const char *delim, bool treatConsecutiveDelimAsOne)
vector< string > * stringToStrings (string fullString, const char *delim, bool treatConsecutiveDelimAsOne)
void findandreplace (string &source, string find, string replace)
const char * itoa (int inNum)
const char * dtoa (double inNum)
void send_to_slave (int slave, int tag, int datalen, char *data)
void send_to_master (int myid, int tag, int datalen, char *data)
void recv_from_slave ()
void recv_from_master ()
void job2str (job &j, char *p)
void str2job (char *str, job &jnow)
void push_stream (int rank, NFstream &strm)
void perr (const char *message)
void clear_slave_data ()
void slave_work (int rank, job &jnow)
void master_init (int size)
int schedulerInterpreter (int *argc, char ***argv)
void printParallelJobOutput (vector< job * > jobQueue)
void FinalizeMPI ()
void InitializeMPI (int *argc, char ***argv, int &Size, int &Rank)
string load_to_buffer (string filename)
void DynamicParallel (map< string, string > argMap, int rank, int size)
void EmbarrassingParallel (map< string, string > argMap, int rank, int size)
string BroadcastString (int Rank, int From, string InBuffer)
string ConvertBufferMapToString (map< string, map< int, string > > &FileMap)
string ConvergeAllData (int Rank, int Size, string Buffer)
void ConvertStringToBufferMap (map< string, map< int, string > > &FileMap, string ReportBuffer)
char * ConvertStringToCString (string Buffer)
void PrintFileBuffer (map< string, map< int, string > > FileMap, vector< job * > JobQueue)
string getPath (string InFilename)

Variables

msgtype msg
job job1
job job2
job jobs [10]
vector< string > slave_filenames
vector< string > slave_buffers
vector< char * > raw_buffers
vector< int > incoming_sizes
vector< job * > slave_assignment
map< job *, string > filenames
map< job *, string > buffers


Function Documentation

string BroadcastString ( int  Rank,
int  From,
string  InBuffer 
)

void clear_slave_data (  ) 

string ConvergeAllData ( int  Rank,
int  Size,
string  Buffer 
)

string ConvertBufferMapToString ( map< string, map< int, string > > &  FileMap  ) 

void convertModelScanToJobs ( model *&  currentModel,
scan currentScan,
vector< job * > &  joblist 
)

void ConvertStringToBufferMap ( map< string, map< int, string > > &  FileMap,
string  ReportBuffer 
)

char* ConvertStringToCString ( string  Buffer  ) 

const char* dtoa ( double  inNum  ) 

void DynamicParallel ( map< string, string >  argMap,
int  rank,
int  size 
)

void EmbarrassingParallel ( map< string, string >  argMap,
int  rank,
int  size 
)

void FinalizeMPI (  ) 

void findandreplace ( string &  source,
string  find,
string  replace 
)

string getFileLine ( ifstream &  input  ) 

string getPath ( string  InFilename  ) 

vector<string>* getStringsFileline ( ifstream &  input,
const char *  delim,
bool  treatConsecutiveDelimAsOne 
)

vector<job*> getTestJobs (  ) 

void InitializeMPI ( int *  argc,
char ***  argv,
int &  Size,
int &  Rank 
)

const char* itoa ( int  inNum  ) 

void job2str ( job j,
char *  p 
)

string load_to_buffer ( string  filename  ) 

void master_init ( int  size  ) 

vector<job*> parseJobsFile ( string  buffer  ) 

void perr ( const char *  message  ) 

void PrintFileBuffer ( map< string, map< int, string > >  FileMap,
vector< job * >  JobQueue 
)

void printParallelJobOutput ( vector< job * >  jobQueue  ) 

void push_stream ( int  rank,
NFstream strm 
)

void recv_from_master (  ) 

void recv_from_slave (  ) 

int schedulerInterpreter ( int *  argc,
char ***  argv 
)

void send_to_master ( int  myid,
int  tag,
int  datalen,
char *  data 
)

void send_to_slave ( int  slave,
int  tag,
int  datalen,
char *  data 
)

void slave_work ( int  rank,
job jnow 
)

void str2job ( char *  str,
job jnow 
)

vector<string>* stringToStrings ( string  fullString,
const char *  delim,
bool  treatConsecutiveDelimAsOne 
)


Variable Documentation

map<job*, string> buffers

map<job*, string> filenames

vector<int> incoming_sizes

job job1

job job2

job jobs[10]

msgtype msg

vector<char*> raw_buffers

vector<job*> slave_assignment

vector<string> slave_buffers

vector<string> slave_filenames


Generated on Thu Dec 9 11:02:48 2010 for NFsim by  doxygen 1.5.4