saga::adaptors Namespace Reference

Namespaces
namespace	v1_0
namespace	utils
Classes
class	adaptor_data
struct	set_attribute_priv
struct	set_vector_attribute_priv
struct	remove_attribute_priv
class	attribute
class	attribute_cache_cpi
class	const_attribute_cpi_wrapper
class	attribute_cpi_wrapper
class	bulk_container< Cpi, FuncRetVal, phoenix::nil_t, phoenix::nil_t, phoenix::nil_t, phoenix::nil_t, phoenix::nil_t, phoenix::nil_t, phoenix::nil_t >
class	bulk_container_base
struct	task_blocker_for_bulk
class	bulk_strategy_base
class	bulk_strategy_simple_sort
class	bulk_strategy_try_exec
class	instance_data
class	dynamic_instance_data
class	instance_data_base
class	metric
struct	serialization
class	task
class	url
	Brief description starts here. More...
class	cpr_job
class	cpr_self
class	job
class	self
class	service_description
class	stream
Typedefs
typedef boost::posix_time::ptime	time_type
typedef boost::posix_time::time_duration	duration_type
typedef TR1::function< void(boost::system::error_code const &)>	workitem_function
typedef unsigned int	workitem_cookie_handle
Enumerations
enum	file_transfer_operator {   unknown_mode,   copy_local_remote,   append_local_remote,   copy_remote_local,   append_remote_local }
enum	error {   Success = 0,   FirstAdaptorSpecificException = 12,   AdaptorDeclined = FirstAdaptorSpecificException,   NoAdaptor = 13,   NoAdaptorInfo = 14,   Unexpected = 15 }
Functions
std::string	get_cpi_name (saga::object::type type)
template saga::task	attribute::set_attributepriv< saga::task_base::Sync > (std::string const &key, std::string const &val, saga::task_base::Sync)
template saga::task	attribute::set_attributepriv< saga::task_base::Async > (std::string const &key, std::string const &val, saga::task_base::Async)
template saga::task	attribute::set_attributepriv< saga::task_base::Task > (std::string const &key, std::string const &val, saga::task_base::Task)
template saga::task	attribute::set_vector_attributepriv< saga::task_base::Sync > (std::string const &key, strvec_type const &val, saga::task_base::Sync)
template saga::task	attribute::set_vector_attributepriv< saga::task_base::Async > (std::string const &key, strvec_type const &val, saga::task_base::Async)
template saga::task	attribute::set_vector_attributepriv< saga::task_base::Task > (std::string const &key, strvec_type const &val, saga::task_base::Task)
template saga::task	attribute::remove_attributepriv< saga::task_base::Sync > (std::string const &key, saga::task_base::Sync)
template saga::task	attribute::remove_attributepriv< saga::task_base::Async > (std::string const &key, saga::task_base::Async)
template saga::task	attribute::remove_attributepriv< saga::task_base::Task > (std::string const &key, saga::task_base::Task)
template<typename Cpi , typename FuncRetVal >
void	create_bulk_container_or_add_params (Cpi *cpi, bulk_container_base *&bc, std::vector< saga::uuid >(Cpi::*exec_bulk)(std::vector< FuncRetVal > &, std::vector< saga::uuid > &), FuncRetVal const &retval_, saga::uuid task_uuid_)
bool	parse_file_transfer_specification (std::string spec, std::string &left_url, file_transfer_operator&mode, std::string &right_url)
void	add_managed_thread (saga::session s, boost::thread *thrd)
void	remove_managed_thread (saga::session s, boost::thread *thrd)
bool	operator== (metric const &lhs, metric const &rhs)
template saga::task	metric::set_attributepriv< saga::task_base::Sync > (std::string const &key, std::string const &val, saga::task_base::Sync)
template saga::task	metric::set_attributepriv< saga::task_base::Async > (std::string const &key, std::string const &val, saga::task_base::Async)
template saga::task	metric::set_attributepriv< saga::task_base::Task > (std::string const &key, std::string const &val, saga::task_base::Task)
template saga::task	metric::set_vector_attributepriv< saga::task_base::Sync > (std::string const &key, strvec_type const &val, saga::task_base::Sync)
template saga::task	metric::set_vector_attributepriv< saga::task_base::Async > (std::string const &key, strvec_type const &val, saga::task_base::Async)
template saga::task	metric::set_vector_attributepriv< saga::task_base::Task > (std::string const &key, strvec_type const &val, saga::task_base::Task)
template saga::task	metric::remove_attributepriv< saga::task_base::Sync > (std::string const &key, saga::task_base::Sync)
template saga::task	metric::remove_attributepriv< saga::task_base::Async > (std::string const &key, saga::task_base::Async)
template saga::task	metric::remove_attributepriv< saga::task_base::Task > (std::string const &key, saga::task_base::Task)
workitem_cookie_handle	register_workitem (workitem_function f, time_type const &expire_at, saga::session const &s)
workitem_cookie_handle	register_workitem (workitem_function f, duration_type const &expire_from_now, saga::session const &s)
void	unregister_workitem (workitem_cookie_handle h, saga::session const &s)
std::string	get_package_name (saga::object obj, saga::object::type type)
std::string	serialize (saga::object obj)
saga::object	deserialize (std::string const &data)
saga::object	deserialize (saga::session s, std::string const &data)
std::ostream &	operator<< (std::ostream &os, url const &u)
std::istream &	operator>> (std::istream &is, url &u)
bool	operator== (saga::adaptors::url const &lhs, saga::adaptors::url const &rhs)
bool	operator< (saga::adaptors::url const &lhs, saga::adaptors::url const &rhs)
saga::job::state	job_state_value_to_enum (std::string const &val)
std::string	job_state_enum_to_value (int s)
std::string	get_state_name (saga::stream::state s)
saga::stream::state	stream_state_value_to_enum (std::string const &val)
std::string	stream_state_enum_to_value (int s)
Variables
char const *const	attribute_cpi = "attribute_cpi"
char const *const	permissions_cpi = "permissions_cpi"
char const *const	context_cpi = "context_cpi"
char const *const	url_cpi = "url_cpi"
char const *const	namespace_entry_cpi = "namespace_entry_cpi"
char const *const	namespace_dir_cpi = "namespace_dir_cpi"
char const *const	file_cpi = "file_cpi"
char const *const	directory_cpi = "directory_cpi"
char const *const	logical_file_cpi = "logical_file_cpi"
char const *const	logical_directory_cpi = "logical_directory_cpi"
char const *const	job_cpi = "job_cpi"
char const *const	job_service_cpi = "job_service_cpi"
char const *const	stream_cpi = "stream_cpi"
char const *const	stream_server_cpi = "stream_server_cpi"
char const *const	rpc_cpi = "rpc_cpi"
char const *const	advert_cpi = "advert_cpi"
char const *const	advert_directory_cpi = "advert_directory_cpi"
char const *const	discoverer_cpi = "discoverer_cpi"
char const *const	cpr_job_cpi = "cpr_job_cpi"
char const *const	cpr_job_service_cpi = "cpr_job_service_cpi"
char const *const	cpr_checkpoint_cpi = "cpr_checkpoint_cpi"
char const *const	cpr_directory_cpi = "cpr_directory_cpi"
char const *const	navigator_cpi = "navigator_cpi"
saga::impl::task_container *	tc

---

Typedef Documentation

typedef boost::posix_time::ptime saga::adaptors::time_type

Definition at line 26 of file register_workitem.hpp.

typedef boost::posix_time::time_duration saga::adaptors::duration_type

Definition at line 30 of file register_workitem.hpp.

typedef TR1::function<void(boost::system::error_code const&)> saga::adaptors::workitem_function

Definition at line 38 of file register_workitem.hpp.

typedef unsigned int saga::adaptors::workitem_cookie_handle

Definition at line 41 of file register_workitem.hpp.

---

Enumeration Type Documentation

enum saga::adaptors::file_transfer_operator

Enumerator:

unknown_mode
copy_local_remote
append_local_remote
copy_remote_local
append_remote_local

Definition at line 17 of file file_transfer_spec.hpp.

enum saga::adaptors::error

Enumerator:

Success
FirstAdaptorSpecificException
AdaptorDeclined
NoAdaptor
NoAdaptorInfo
Unexpected

Definition at line 39 of file error.hpp.

---

Function Documentation

std::string saga::adaptors::get_cpi_name

(

saga::object::type

type

)

[inline]

Definition at line 97 of file adaptor.hpp.

References saga::object::Advert, advert_cpi, advert_directory_cpi, saga::object::AdvertDirectory, saga::object::Context, context_cpi, cpr_checkpoint_cpi, cpr_directory_cpi, cpr_job_cpi, cpr_job_service_cpi, saga::object::CPRCheckpoint, saga::object::CPRDirectory, saga::object::CPRJob, saga::object::CPRJobService, saga::object::Directory, directory_cpi, discoverer_cpi, saga::object::EntityNavigator, saga::object::File, file_cpi, saga::object::Job, job_cpi, job_service_cpi, saga::object::JobService, logical_directory_cpi, logical_file_cpi, saga::object::LogicalDirectory, saga::object::LogicalFile, namespace_dir_cpi, namespace_entry_cpi, navigator_cpi, saga::object::NSDirectory, saga::object::NSEntry, saga::object::RPC, rpc_cpi, saga::object::ServiceDiscoverer, saga::object::Stream, stream_cpi, stream_server_cpi, saga::object::StreamServer, saga::object::URL, and url_cpi.

template saga::task saga::adaptors::attribute::set_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::attribute::set_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Async
	)

template saga::task saga::adaptors::attribute::set_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Task
	)

template saga::task saga::adaptors::attribute::set_vector_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::attribute::set_vector_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Async
	)

template saga::task saga::adaptors::attribute::set_vector_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Task
	)

template saga::task saga::adaptors::attribute::remove_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::attribute::remove_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		saga::task_base::Async
	)

template saga::task saga::adaptors::attribute::remove_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		saga::task_base::Task
	)

template<typename Cpi , typename FuncRetVal >

void saga::adaptors::create_bulk_container_or_add_params	(	Cpi *	cpi,
		bulk_container_base *&	bc,
		std::vector< saga::uuid >(Cpi::*)(std::vector< FuncRetVal > &, std::vector< saga::uuid > &)	exec_bulk,
		FuncRetVal const &	retval_,
		saga::uuid	task_uuid_
	)		[inline]

Helper function, which is called from the adaptor's prepare function. creates a new bulk_container or adds a additional set of parameters to a existing one.

used to simplify life for adaptor developers. Hides templates.

Definition at line 59 of file bulk_container.hpp.

bool saga::adaptors::parse_file_transfer_specification	(	std::string	spec,
		std::string &	left_url,
		file_transfer_operator&	mode,
		std::string &	right_url
	)

Definition at line 40 of file file_transfer_spec.cpp.

References append_local_remote, append_remote_local, saga::BadParameter, copy_local_remote, copy_remote_local, saga::adaptors::utils::split(), and unknown_mode.

void saga::adaptors::add_managed_thread	(	saga::session	s,
		boost::thread *	thrd
	)

void saga::adaptors::remove_managed_thread	(	saga::session	s,
		boost::thread *	thrd
	)

bool saga::adaptors::operator==	(	metric const &	lhs,
		metric const &	rhs
	)

Definition at line 82 of file adaptors/metric.cpp.

References saga::adaptors::metric::get_impl().

template saga::task saga::adaptors::metric::set_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::metric::set_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Async
	)

template saga::task saga::adaptors::metric::set_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		std::string const &	val,
		saga::task_base::Task
	)

template saga::task saga::adaptors::metric::set_vector_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::metric::set_vector_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Async
	)

template saga::task saga::adaptors::metric::set_vector_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		strvec_type const &	val,
		saga::task_base::Task
	)

template saga::task saga::adaptors::metric::remove_attributepriv< saga::task_base::Sync >	(	std::string const &	key,
		saga::task_base::Sync
	)

template saga::task saga::adaptors::metric::remove_attributepriv< saga::task_base::Async >	(	std::string const &	key,
		saga::task_base::Async
	)

template saga::task saga::adaptors::metric::remove_attributepriv< saga::task_base::Task >	(	std::string const &	key,
		saga::task_base::Task
	)

workitem_cookie_handle saga::adaptors::register_workitem	(	workitem_function	f,
		time_type const &	expire_at,
		saga::session const &	s
	)

Definition at line 14 of file register_workitem.cpp.

workitem_cookie_handle saga::adaptors::register_workitem	(	workitem_function	f,
		duration_type const &	expire_from_now,
		saga::session const &	s
	)

Definition at line 26 of file register_workitem.cpp.

void saga::adaptors::unregister_workitem	(	workitem_cookie_handle	h,
		saga::session const &	s
	)

Definition at line 38 of file register_workitem.cpp.

std::string saga::adaptors::get_package_name	(	saga::object	obj,
		saga::object::type	type
	)		[inline]

Definition at line 28 of file serialization.cpp.

References saga::BadParameter, and saga::object::ServiceData.

Referenced by deserialize(), and serialize().

std::string saga::adaptors::serialize

(

saga::object

obj

)

Definition at line 105 of file serialization.cpp.

References saga::object::get_id(), get_package_name(), saga::object::get_type(), saga::NoSuccess, SAGA_OSSTREAM, and SAGA_OSSTREAM_GETSTRING.

saga::object saga::adaptors::deserialize

(

std::string const &

data

)

Definition at line 157 of file serialization.cpp.

saga::object saga::adaptors::deserialize	(	saga::session	s,
		std::string const &	data
	)

Definition at line 162 of file serialization.cpp.

References get_package_name(), saga::NoSuccess, SAGA_ISSTREAM, and SAGA_VERSION_ISCOMPATIBLE_EX.

std::ostream & saga::adaptors::operator<<	(	std::ostream &	os,
		url const &	u
	)

Definition at line 14 of file adaptors/url.cpp.

std::istream & saga::adaptors::operator>>	(	std::istream &	is,
		url &	u
	)

Definition at line 20 of file adaptors/url.cpp.

bool saga::adaptors::operator==	(	saga::adaptors::url const &	lhs,
		saga::adaptors::url const &	rhs
	)

Definition at line 28 of file adaptors/url.cpp.

bool saga::adaptors::operator<	(	saga::adaptors::url const &	lhs,
		saga::adaptors::url const &	rhs
	)

Definition at line 36 of file adaptors/url.cpp.

saga::job::state saga::adaptors::job_state_value_to_enum

(

std::string const &

val

)

Definition at line 295 of file job.cpp.

std::string saga::adaptors::job_state_enum_to_value

(

int

s

)

Definition at line 318 of file job.cpp.

std::string saga::adaptors::get_state_name

(

saga::stream::state

s

)

Definition at line 31 of file adaptors/stream.cpp.

saga::stream::state saga::adaptors::stream_state_value_to_enum

(

std::string const &

val

)

Definition at line 254 of file stream.cpp.

std::string saga::adaptors::stream_state_enum_to_value

(

int

s

)

Definition at line 274 of file stream.cpp.

---

Variable Documentation

char const* const saga::adaptors::attribute_cpi = "attribute_cpi"

Definition at line 52 of file adaptor.hpp.

Referenced by saga::adaptors::v1_0::register_attribute_functions(), and saga::adaptors::v1_0::attribute_cpi< Derived, Mutex >::register_cpi().

char const* const saga::adaptors::permissions_cpi = "permissions_cpi"

Definition at line 53 of file adaptor.hpp.

Referenced by saga::adaptors::v1_0::permissions_cpi< Derived >::register_cpi(), and saga::adaptors::v1_0::register_permissions_functions().

char const* const saga::adaptors::context_cpi = "context_cpi"

Definition at line 55 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::url_cpi = "url_cpi"

Definition at line 56 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::namespace_entry_cpi = "namespace_entry_cpi"

Definition at line 59 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::namespace_dir_cpi = "namespace_dir_cpi"

Definition at line 60 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::file_cpi = "file_cpi"

Definition at line 61 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::directory_cpi = "directory_cpi"

Definition at line 62 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::logical_file_cpi = "logical_file_cpi"

Definition at line 65 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::logical_directory_cpi = "logical_directory_cpi"

Definition at line 66 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::job_cpi = "job_cpi"

Definition at line 69 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::job_service_cpi = "job_service_cpi"

Definition at line 70 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::stream_cpi = "stream_cpi"

Definition at line 73 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::stream_server_cpi = "stream_server_cpi"

Definition at line 74 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::rpc_cpi = "rpc_cpi"

Definition at line 77 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::advert_cpi = "advert_cpi"

Definition at line 80 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::advert_directory_cpi = "advert_directory_cpi"

Definition at line 81 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::discoverer_cpi = "discoverer_cpi"

Definition at line 84 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::cpr_job_cpi = "cpr_job_cpi"

Definition at line 87 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::cpr_job_service_cpi = "cpr_job_service_cpi"

Definition at line 88 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::cpr_checkpoint_cpi = "cpr_checkpoint_cpi"

Definition at line 89 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::cpr_directory_cpi = "cpr_directory_cpi"

Definition at line 90 of file adaptor.hpp.

Referenced by get_cpi_name().

char const* const saga::adaptors::navigator_cpi = "navigator_cpi"

Definition at line 93 of file adaptor.hpp.

Referenced by get_cpi_name().

saga::impl::task_container* saga::adaptors::tc

Definition at line 22 of file bulk_strategy_base.cpp.