Thrill  0.1
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
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

#define THRILL_API_CONTEXT_HEADER

Definition at line 15 of file context.hpp.