Derecho  0.9
Distributed systems toolkit for RDMA
Public Member Functions | Private Attributes | List of all members
derecho::rpc::PendingResults< void > Class Template Reference

Specialization of PendingResults for void functions, which do not generate replies. More...

#include <rpc_utils.hpp>

Inheritance diagram for derecho::rpc::PendingResults< void >:
Inheritance graph
[legend]
Collaboration diagram for derecho::rpc::PendingResults< void >:
Collaboration graph
[legend]

Public Member Functions

QueryResults< void > get_future ()
 
void fulfill_map (const node_list_t &sent_nodes)
 
void set_exception_for_removed_node (const node_id_t &)
 
void set_exception_for_caller_removed ()
 
bool all_responded () const
 
void reset ()
 
- Public Member Functions inherited from derecho::rpc::PendingBase
virtual ~PendingBase ()
 

Private Attributes

std::promise< std::unique_ptr< std::set< node_id_t > > > promise_for_pending_map
 
bool map_fulfilled = false
 

Detailed Description

template<>
class derecho::rpc::PendingResults< void >

Specialization of PendingResults for void functions, which do not generate replies.

Its only functionality is to fulfill the "reply map" in its corresponding QueryResults<void>, which is just a set of nodes to which the RPC message was delivered.

Definition at line 498 of file rpc_utils.hpp.

Member Function Documentation

◆ all_responded()

bool derecho::rpc::PendingResults< void >::all_responded ( ) const
inlinevirtual

Implements derecho::rpc::PendingBase.

Definition at line 526 of file rpc_utils.hpp.

◆ fulfill_map()

void derecho::rpc::PendingResults< void >::fulfill_map ( const node_list_t sent_nodes)
inlinevirtual

Implements derecho::rpc::PendingBase.

Definition at line 508 of file rpc_utils.hpp.

◆ get_future()

QueryResults<void> derecho::rpc::PendingResults< void >::get_future ( )
inline

Definition at line 504 of file rpc_utils.hpp.

◆ reset()

void derecho::rpc::PendingResults< void >::reset ( )
inlinevirtual

Implements derecho::rpc::PendingBase.

Definition at line 530 of file rpc_utils.hpp.

◆ set_exception_for_caller_removed()

void derecho::rpc::PendingResults< void >::set_exception_for_caller_removed ( )
inlinevirtual

Implements derecho::rpc::PendingBase.

Definition at line 519 of file rpc_utils.hpp.

◆ set_exception_for_removed_node()

void derecho::rpc::PendingResults< void >::set_exception_for_removed_node ( const node_id_t )
inlinevirtual

Implements derecho::rpc::PendingBase.

Definition at line 517 of file rpc_utils.hpp.

Member Data Documentation

◆ map_fulfilled

bool derecho::rpc::PendingResults< void >::map_fulfilled = false
private

Definition at line 501 of file rpc_utils.hpp.

◆ promise_for_pending_map

std::promise<std::unique_ptr<std::set<node_id_t> > > derecho::rpc::PendingResults< void >::promise_for_pending_map
private

Definition at line 500 of file rpc_utils.hpp.


The documentation for this class was generated from the following file: