Manager.c File Reference

#include <stdio.h>
#include <stdlib.h>
#include <strings.h>
#include <signal.h>
#include <assert.h>
#include "Messages.h"
#include "Manager.h"
#include "Layout.h"
#include "parser.h"
#include "FilterSpec.h"
#include "FilterData/Policies.h"
#include "FilterData/Ports.h"
#include "FilterData/FilterData.h"
#include "FilterData/Termination.h"
#include "constants.h"
#include <TaskIdList/TaskIdList.h>

Include dependency graph for Manager.c:

Go to the source code of this file.

Functions
void	handleSigterm (int signal)
	Set recievedSigterm to 1, indicating that we recieved a TERM signal and must shutdown the application.
Layout *	initDs (char *confFile, int argc, char **argv)
	Initialize the manager internal structs and the filters.
int	compareTaskId (const void *a, const void *b)
int	replaceCrashedHost (Layout *layout, FilterSpec *pCrashedFilter, int crashedInstance)
int	appendWork (Layout *layout, void *work, unsigned int workSize)
	user function:add a new query to a pipeline of filters.
int	finalizeDs (Layout *layout)
	Finalize a Void pipeline. Only manager runs this.
Variables
int	recievedSignal = 0

---

Function Documentation

int appendWork (  Layout *  layout, void *  work, unsigned int  workSize )

user function:add a new query to a pipeline of filters. Called by manager. Parameters: layout  System Layout. work  Buffer with a Unit of Work (UoW) workSize  Unit of Work Size (UoW) Returns: Zero on success, -1 on error. used to notify manager some system error happened, and filter is aborting, similar to AEXIT used to notify manager some system error happened, and filter is aborting, similar to AEXIT if the message type is a work used to notify manager this filter ended its work used to notify manager the application called exit(dsExit) used to notify manager some system error happened, and filter is aborting, similar to AEXIT used to notify manager the application called exit(dsExit) used to notify a task exit, from pvm, dont change this used to notify host delete, crash, dont change this used to notify a task exit, from pvm, dont change this used to notify host delete, crash, dont change this used to notify a task exit, from pvm, dont change this used to notify host delete, crash, dont change this used to notify host delete, crash, dont change this used to notify a task exit, from pvm, dont change this used to notify host delete, crash, dont change this Definition at line 487 of file Manager.c. References layout, and MSGT_WORK.

int compareTaskId (  const void *  a, const void *  b )

Definition at line 434 of file Manager.c.

int finalizeDs (  Layout *  layout  )

Finalize a Void pipeline. Only manager runs this. if the message type is end of filter, which means, all done Definition at line 830 of file Manager.c. References layout, and MSGT_EOF.

void handleSigterm (  int  signal  )

Set recievedSigterm to 1, indicating that we recieved a TERM signal and must shutdown the application. Definition at line 46 of file Manager.c. References recievedSignal.

Layout * initDs (  char *  confFile, int  argc, char **  argv )

Initialize the manager internal structs and the filters. Parameters: confFile  XML file configuration, NULL if we want to make things by hand argc  argc received by main function that will be forwarded to filter processes argv  argv received by main function that will be forwarded to filter processes Returns: Layout of the pipeline Definition at line 400 of file Manager.c. References I_AM_THE_MANAGER, and runFilter(). Here is the call graph for this function:

int replaceCrashedHost (  Layout *  layout, FilterSpec *  pCrashedFilter, int  crashedInstance )

Todo: Choose host respecting filter demsnds change hostsGetIndex() Definition at line 442 of file Manager.c. References _filter_spec_::filterPlacement, FilterPlacement::hosts, hostsGetIndex(), hostsGetIndexByName(), hostsGetName(), hostsSetStatus(), layout, and NOTAVAIL. Here is the call graph for this function:

---

Variable Documentation

int recievedSignal = 0

Definition at line 41 of file Manager.c. Referenced by handleSigterm().

---