|
| | 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...
|
| |