|
| uniface (const char URI[]) |
|
| uniface (std::string const &URI) |
|
| uniface (communicator *comm_) |
|
| uniface (const uniface &)=delete |
|
uniface & | operator= (const uniface &)=delete |
|
template<typename TYPE > |
void | push (const std::string &attr, const TYPE &value) |
| Announce the value value with the parameter attr Useful if, for example, you wish to pass a parameter rather than a field without an associated timestamp. More...
|
|
template<typename TYPE > |
void | push (const std::string &attr, const point_type &loc, const TYPE &value) |
| Push data with tag "attr" to buffer Push data with tag "attr" to bcuffer. If using CONFIG::FIXEDPOINTS=true, data must be pushed in the same order that the points were previously pushed. More...
|
|
template<typename TYPE > |
TYPE | fetch (const std::string &attr) |
| Fetch a single parameter from the interface Overloaded fetch to fetch a single parameter of name attr . There is no barrier on this fetch as there is no time associated with the value. More...
|
|
template<class SAMPLER , class TIME_SAMPLER , typename ... ADDITIONAL> |
SAMPLER::OTYPE | fetch (const std::string &attr, const point_type &focus, const time_type t, SAMPLER &sampler, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch from the interface, blocking with barrier at time=t. More...
|
|
template<class SAMPLER , class TIME_SAMPLER , typename ... ADDITIONAL> |
SAMPLER::OTYPE | fetch (const std::string &attr, const point_type &focus, const time_type t, const iterator_type it, SAMPLER &sampler, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch from the interface, blocking with barrier at time=t,it. More...
|
|
template<class SAMPLER , class TIME_SAMPLER , class COUPLING_ALGO , typename ... ADDITIONAL> |
SAMPLER::OTYPE | fetch (const std::string &attr, const point_type &focus, const time_type t, SAMPLER &sampler, const TIME_SAMPLER &t_sampler, const COUPLING_ALGO &cpl_algo, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch from the interface with coupling algorithms, blocking with barrier at time=t. More...
|
|
template<class SAMPLER , class TIME_SAMPLER , class COUPLING_ALGO , typename ... ADDITIONAL> |
SAMPLER::OTYPE | fetch (const std::string &attr, const point_type &focus, const time_type t, const iterator_type it, SAMPLER &sampler, const TIME_SAMPLER &t_sampler, const COUPLING_ALGO &cpl_algo, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch from the interface with coupling algorithms, blocking with barrier at time=t,it. More...
|
|
template<typename TYPE , class TIME_SAMPLER , typename ... ADDITIONAL> |
std::vector< point_type > | fetch_points (const std::string &attr, const time_type t, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch points currently stored in the interface, blocking with barrier at time=t. More...
|
|
template<typename TYPE , class TIME_SAMPLER , typename ... ADDITIONAL> |
std::vector< point_type > | fetch_points (const std::string &attr, const time_type t, const iterator_type it, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch points currently stored in the interface, blocking with barrier at time=t,it. More...
|
|
template<typename TYPE , class TIME_SAMPLER , typename ... ADDITIONAL> |
std::vector< TYPE > | fetch_values (const std::string &attr, const time_type t, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch values currently stored in the interface, blocking with barrier at time=t. More...
|
|
template<typename TYPE , class TIME_SAMPLER , typename ... ADDITIONAL> |
std::vector< TYPE > | fetch_values (const std::string &attr, const time_type t, const iterator_type it, const TIME_SAMPLER &t_sampler, bool barrier_enabled=true, ADDITIONAL &&... additional) |
| Fetch values currently stored in the interface, blocking with barrier at time=t,it. More...
|
|
int | commit (time_type t, iterator_type it=std::numeric_limits< iterator_type >::lowest()) |
| Serializes pushed data and sends it to remote nodes Serializes pushed data and sends it to remote nodes. Returns the actual number of peers contacted. More...
|
|
void | update_smart_send (time_type t) |
| Updates Smart Send locality data Creates a new comm rank mapping for Smart Send functionality. More...
|
|
void | forecast (time_type t, iterator_type it=std::numeric_limits< iterator_type >::lowest()) |
| Sends a forecast of an upcoming time to remote nodes. More...
|
|
bool | is_ready (const std::string &attr, time_type t) const |
| Tests whether data is available at time=t. More...
|
|
bool | is_ready (const std::string &attr, time_type t, iterator_type it) const |
| Tests whether data is available at time=t,it. More...
|
|
void | barrier (time_type t) |
| Blocking barrier at time=t. Initiates receive from remote nodes. More...
|
|
void | barrier (time_type t, iterator_type it) |
| Blocking barrier at time=t,it. Initiates receive from remote nodes. More...
|
|
void | barrier_ss_send () |
| Blocking barrier for Smart Send send values. Initiates receive from remote nodes. More...
|
|
void | barrier_ss_recv () |
| Blocking barrier for Smart Send receive values. Initiates receive from remote nodes. More...
|
|
void | announce_send_span (time_type start, time_type timeout, span_t s, bool synchronised=false) |
| Announces to all remote nodes using non-blocking peer-to-peer approach "I'll send this span". More...
|
|
void | announce_send_disable (bool synchronised=false) |
| Announces to all remote nodes "I'm disabled for send". More...
|
|
void | announce_recv_span (time_type start, time_type timeout, span_t s, bool synchronised=false) |
| Announces to all remote nodes using non-blocking peer-to-peer approach "I'm receiving this span". More...
|
|
void | announce_recv_disable (bool synchronised=false) |
| Announces to all remote nodes "I'm disabled for receive". More...
|
|
void | forget (time_type last, bool reset_log=false) |
| Removes log between (-inf, @last]. More...
|
|
void | forget (std::pair< time_type, iterator_type > last, bool reset_log=false) |
| Removes log between ([-inf,-inf], [@last.first,@last.second]]. More...
|
|
void | forget (time_type first, time_type last, bool reset_log=false) |
| Removes log between [@first, @last]. More...
|
|
void | forget (std::pair< time_type, iterator_type > first, std::pair< time_type, iterator_type > last, bool reset_log=false) |
| Removes log between [[@first.first,@first.second], [@last.first,@last.second]]. More...
|
|
void | set_memory (time_type length) |
| Removes log between (-inf, current-@length] automatically. More...
|
|
std::string | uri_host () |
| Returns the URI host (domain) for the created uniface. More...
|
|
std::string | uri_path () |
| Returns the URI path (name) for the created uniface. More...
|
|
std::string | uri_protocol () |
| Returns the URI protocol for the created uniface. More...
|
|