/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

---