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

#include "NFstream.h"
#include "../NFsim.hh"
#include <vector>
#include <string>
#include <map>
#include <iostream>
#include <fstream>
#include <sstream>

Go to the source code of this file.

Classes
struct	job
struct	scan
struct	model
struct	msgtype
Defines
#define	MASTER   0
#define	TAG_MSG   99
#define	TAG_DATA   98
#define	MSG_DATA_SIZE   (1<<20)
#define	MAX_MPI_SIZE   4096
Enumerations
enum	{   cmd_free = 0, cmd_job, cmd_pre_data_ack, cmd_data_ack,   rpt_ready, rpt_pre_data, rpt_data, rpt_done }
Functions
vector< job * >	parseJobsFile (string filename)
int	schedulerInterpreter (int *argc, char ***argv)
void	convertModelScanToJobs (model *&currentModel, scan *currentScan, vector< job * > &joblist)
const char *	itoa (int inNum)
const char *	dtoa (double inNum)
string	getFileLine (ifstream &input)
vector< string > *	stringToStrings (string fullString, const char *delim, bool treatConsecutiveDelimAsOne=true)
vector< string > *	getStringsFileline (ifstream &input, const char *delim, bool treatConsecutiveDelimAsOne)
void	findandreplace (string &source, string find, string replace)
void	printFileLineOutput ()
void	push_stream (int rank, NFstream &strm)
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	perr (const char *)
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	ConvergeAllData (int Rank, int Size, string Buffer)
void	ConvertStringToBufferMap (map< string, map< int, string > > &FileMap, string ReportBuffer)
string	ConvertBufferMapToString (map< string, map< int, string > > &FileBuffers)
char *	ConvertStringToCString (string Buffer)
void	PrintFileBuffer (map< string, map< int, string > > FileMap, vector< job * > JobQueue)
string	getPath (string Filename)

---

Define Documentation

#define MASTER   0

#define MAX_MPI_SIZE   4096

#define MSG_DATA_SIZE   (1<<20)

#define TAG_DATA   98

#define TAG_MSG   99

---

Enumeration Type Documentation

anonymous enum

Enumerator:

cmd_free
cmd_job
cmd_pre_data_ack
cmd_data_ack
rpt_ready
rpt_pre_data
rpt_data
rpt_done

---

Function Documentation

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

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

string ConvertBufferMapToString

(

map< string, map< int, string > > &

FileBuffers

)

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

Filename

)

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

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

const char* itoa

(

int

inNum

)

string load_to_buffer

(

string

filename

)

vector<job*> parseJobsFile

(

string

filename

)

void perr

(

const char *

)

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

void printFileLineOutput

(

)

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
	)

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

---