context.hpp File Reference

#include <thrill/common/config.hpp>
#include <thrill/common/defines.hpp>
#include <thrill/common/json_logger.hpp>
#include <thrill/common/profile_task.hpp>
#include <thrill/data/block_pool.hpp>
#include <thrill/data/cat_stream.hpp>
#include <thrill/data/file.hpp>
#include <thrill/data/mix_stream.hpp>
#include <thrill/data/multiplexer.hpp>
#include <thrill/net/flow_control_channel.hpp>
#include <thrill/net/flow_control_manager.hpp>
#include <thrill/net/manager.hpp>
#include <algorithm>
#include <cassert>
#include <functional>
#include <numeric>
#include <random>
#include <string>
#include <tuple>
#include <vector>

Include dependency graph for context.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	Context
	The Context of a job is a unique instance per worker which holds references to all underlying parts of Thrill. More...
class	HostContext
	The HostContext contains all data structures shared among workers on the same host. More...
class	MemoryConfig

Namespaces
	thrill
	thrill::api

Macros
#define	THRILL_API_CONTEXT_HEADER

Functions
int	Run (const std::function< void(Context &)> &job_startpoint)
	Runs the given job startpoint with a Context instance. More...
Run Methods with Internal Networks for Testing
void	RunLocalMock (const MemoryConfig &mem_config, size_t num_hosts, size_t workers_per_host, const std::function< void(Context &)> &job_startpoint)
	Function to run a number of mock hosts as locally independent threads, which communicate via internal stream sockets. More...
void	RunLocalTests (const std::function< void(Context &)> &job_startpoint)
	Helper Function to execute RunLocalMock() tests using mock networks in test suite for many different numbers of workers and hosts as independent threads in one program. More...
void	RunLocalTests (size_t ram, const std::function< void(Context &)> &job_startpoint)
	Helper Function to execute RunLocalMock() tests using mock networks in test suite for many different numbers of workers and hosts as independent threads in one program. More...
void	RunLocalSameThread (const std::function< void(Context &)> &job_startpoint)
	Runs the given job_startpoint within the same thread with a test network –> run test with one host and one thread. More...
int	RunCheckDieWithParent ()
	Check environment variable THRILL_DIE_WITH_PARENT and enable process flag: this is useful for ssh/invoke.sh: it kills spawned processes when the ssh connection breaks. More...
int	RunCheckUnlinkBinary ()
	Check environment variable THRILL_UNLINK_BINARY and unlink given program path: this is useful for ssh/invoke.sh: it removes the copied program files while it is running, hence it is gone even if the program crashes. More...

Macro Definition Documentation

THRILL_API_CONTEXT_HEADER

#define THRILL_API_CONTEXT_HEADER

Definition at line 15 of file context.hpp.