Derecho  0.9
Distributed systems toolkit for RDMA
Public Member Functions | Private Member Functions | Private Attributes | List of all members
sst::util::PollingData Class Reference

#include <poll_utils.hpp>

Collaboration diagram for sst::util::PollingData:
Collaboration graph
[legend]

Public Member Functions

void insert_completion_entry (uint32_t index, std::pair< int32_t, int32_t > ce)
 
std::optional< std::pair< int32_t, int32_t > > get_completion_entry (const std::thread::id id)
 
uint32_t get_index (const std::thread::id id)
 
void set_waiting (const std::thread::id id)
 
void reset_waiting (const std::thread::id id)
 
void wait_for_requests ()
 

Private Member Functions

bool check_waiting ()
 

Private Attributes

std::vector< std::list< std::pair< int32_t, int32_t > > > completion_entries
 
std::map< std::thread::id, uint32_t > tid_to_index
 
std::vector< bool > if_waiting
 
std::condition_variable poll_cv
 
std::mutex poll_mutex
 

Detailed Description

Definition at line 13 of file poll_utils.hpp.

Member Function Documentation

◆ check_waiting()

bool sst::util::PollingData::check_waiting ( )
private

Definition at line 19 of file poll_utils.cpp.

◆ get_completion_entry()

std::optional< std::pair< int32_t, int32_t > > sst::util::PollingData::get_completion_entry ( const std::thread::id  id)

Definition at line 28 of file poll_utils.cpp.

◆ get_index()

uint32_t sst::util::PollingData::get_index ( const std::thread::id  id)

Definition at line 39 of file poll_utils.cpp.

◆ insert_completion_entry()

void sst::util::PollingData::insert_completion_entry ( uint32_t  index,
std::pair< int32_t, int32_t >  ce 
)

Definition at line 23 of file poll_utils.cpp.

◆ reset_waiting()

void sst::util::PollingData::reset_waiting ( const std::thread::id  id)

Definition at line 56 of file poll_utils.cpp.

◆ set_waiting()

void sst::util::PollingData::set_waiting ( const std::thread::id  id)

Definition at line 49 of file poll_utils.cpp.

◆ wait_for_requests()

void sst::util::PollingData::wait_for_requests ( )

Definition at line 62 of file poll_utils.cpp.

Member Data Documentation

◆ completion_entries

std::vector<std::list<std::pair<int32_t, int32_t> > > sst::util::PollingData::completion_entries
private

Definition at line 21 of file poll_utils.hpp.

◆ if_waiting

std::vector<bool> sst::util::PollingData::if_waiting
private

Definition at line 23 of file poll_utils.hpp.

◆ poll_cv

std::condition_variable sst::util::PollingData::poll_cv
private

Definition at line 24 of file poll_utils.hpp.

◆ poll_mutex

std::mutex sst::util::PollingData::poll_mutex
private

Definition at line 25 of file poll_utils.hpp.

◆ tid_to_index

std::map<std::thread::id, uint32_t> sst::util::PollingData::tid_to_index
private

Definition at line 22 of file poll_utils.hpp.


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