chomp::multiwork::mwSubWorker< dim, coord > Class Template Reference

This class defines a worker for the multi-work subdivision framework. More...

#include <mwsubdiv.h>

Inheritance diagram for chomp::multiwork::mwSubWorker< dim, coord >:

Public Member Functions
	mwSubWorker (fcompute _compute)
	The constructor. More...
Public Member Functions inherited from chomp::multiwork::mwWorker
	mwWorker ()
	The default constructor. More...
virtual	~mwWorker ()
	The destructor. More...
int	Work ()
	Runs the worker on this computer. More...
void	KeepWorker (bool keep=true)
	Makes the worker keep running after the coordinator has disconnected. More...
Public Member Functions inherited from chomp::multiwork::mwTask
	mwTask ()
	The default constructor. More...
virtual	~mwTask ()
	The destructor. More...
void	Port (int number)
	Sets the port number for the communication or 0 to use none. More...
int	Port () const
	Returns the current port number. More...
void	ControlNumber (unsigned int number)
	Sets the control number for identification. More...
unsigned int	ControlNumber () const
	Returns the currently set identification control number. More...
void	TimeOut (int seconds)
	Sets the network connection time-out interval in seconds. More...
int	TimeOut () const
	Returns the currently set network connection time-out interval. More...
int	LogFile (const char *filename)
	Begins logging detailed communication debug information to the given file. More...
void	LogFile (const mwTask &other)
	Uses another task's log file to log this task's information. More...
void	LogClose ()
	Closes the log file and adds a line with the time information unless this log file was borrowed from another task. More...
int	Add (const char *name, int port=-1)
	Adds an address to the list of computers to connect to at the beginning of working or coordinating. More...
int	Load (const char *filename)
	Loads computer addresses from the given file. More...
int	QuitWorkers ()
	Quits all the workers whose addresses were added with the 'Add' and 'Load' functions. More...

Private Member Functions
int	Process (mwData &data)
	A function for processing the data by a worker. More...

Private Attributes
fcompute	compute
	The address of a function to use for the computations. More...

Additional Inherited Members
Static Protected Member Functions inherited from chomp::multiwork::mwTask
static int	SendMessage (int fd, unsigned int ctrl, unsigned int code, const mwData &x)
	Sends a message with data to the given socket. More...
static int	RecvMessage (int fd, unsigned int &ctrl, unsigned int &code, mwData &x)
	Receives a message with data from the given socket. More...
Protected Attributes inherited from chomp::multiwork::mwTask
std::ofstream *	logFile
	The debug log file stream. More...
std::vector< std::string >	computers
	A list of workers or coordinators to connect to at start-up. More...
std::vector< int >	ports
	A list of port numbers of workers to connect to at start-up. More...

Detailed Description

template<int dim, class coord>
class chomp::multiwork::mwSubWorker< dim, coord >

This class defines a worker for the multi-work subdivision framework.

Definition at line 107 of file mwsubdiv.h.

Constructor & Destructor Documentation

mwSubWorker()

template<int dim, class coord >

chomp::multiwork::mwSubWorker< dim, coord >::mwSubWorker ( fcompute  _compute )

inline

The constructor.

Definition at line 125 of file mwsubdiv.h.

                                                            :
        compute (_compute)
{
        return;
} /* mwSubWorker<dim,coord>::mwSubWorker */

Member Function Documentation

Process()

template<int dim, class coord >

int chomp::multiwork::mwSubWorker< dim, coord >::Process ( mwData &  data )

privatevirtual

A function for processing the data by a worker.

Reimplemented from chomp::multiwork::mwWorker.

Definition at line 134 of file mwsubdiv.h.

{
        // decode the number of the data pack to process
        int current = 0;
        data >> current;
 
        // say which data pack is being processed
        sout << "- " << current << ".\n";
 
        // decode the subdivision level
        int level = 0;
        data >> level;
 
        // decode the information on whether this is a full box or a probe
        bool full = false;
        data >> full;
 
        // the intervals
        double left [dim];
        double right [dim];
        for (int i = 0; i < dim; ++ i)
        {
                data >> left [i];
                if (full)
                        data >> right [i];
        }
 
        // the marker of the end of data
        int dataEndMarker = 0;
        data >> dataEndMarker;
        if (dataEndMarker != 13)
        {
                data. Reset ();
                sout << "! Incompatible data received. Rejecting it.\n";
                return mwReject;
        }
 
        // rune one set of computations
        int result = compute (left, full ? right : left, dim, level);
 
        // if the result is wrong then reject this piece of data
        if (result < 0)
        {
                sout << "! Data no. " << current <<
                        " produced a negative result. Rejecting it.\n";
                return mwReject;
        }
 
        // say what has been computed
        sout << "= " << current << " " << result << ".\n";
 
        // send back the data containing the result of the processing
        data. Reset ();
        data << current;
        data << result;
        return mwOk;
} /* mwSubWorker<dim,coord>::Process */

References chomp::multiwork::mwOk, chomp::multiwork::mwReject, and chomp::homology::sout.

Member Data Documentation

compute

template<int dim, class coord >

fcompute chomp::multiwork::mwSubWorker< dim, coord >::compute

private

The address of a function to use for the computations.

Definition at line 118 of file mwsubdiv.h.

---

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

• chomp/multiwork/mwsubdiv.h