Realm
A distributed, event-based tasking library
Loading...
Searching...
No Matches
Realm::GASNetEXPoller Class Reference

#include <gasnetex_internal.h>

Inheritance diagram for Realm::GASNetEXPoller:
Collaboration diagram for Realm::GASNetEXPoller:

Public Member Functions

 GASNetEXPoller (GASNetEXInternal *_internal)
 
void begin_polling ()
 
void end_polling ()
 
void add_critical_xpair (XmitSrcDestPair *xpair)
 
void add_pending_event (GASNetEXEvent *event)
 
bool has_work_remaining ()
 
virtual bool do_work (TimeLimit work_until)
 
void wait_for_full_poll_cycle ()
 
- Public Member Functions inherited from Realm::BackgroundWorkItem
 BackgroundWorkItem (const std::string &_name)
 
virtual ~BackgroundWorkItem (void)
 
void add_to_manager (BackgroundWorkManager *_manager, int _numa_domain=-1, long long _min_timeslice_needed=-1)
 

Protected Attributes

bool started = false
 
GASNetEXInternalinternal
 
Mutex mutex
 
atomic< bool > shutdown_flag
 
Mutex::CondVar shutdown_cond
 
atomic< bool > pollwait_flag
 
Mutex::CondVar pollwait_cond
 
XmitSrcDestPair::XmitPairList critical_xpairs
 
GASNetEXEvent::EventList pending_events
 
- Protected Attributes inherited from Realm::BackgroundWorkItem
std::string name
 
BackgroundWorkManagermanager
 
int numa_domain
 
long long min_timeslice_needed
 
unsigned index
 

Additional Inherited Members

- Protected Member Functions inherited from Realm::BackgroundWorkItem
void make_active (void)
 

Constructor & Destructor Documentation

◆ GASNetEXPoller()

Realm::GASNetEXPoller::GASNetEXPoller ( GASNetEXInternal _internal)

Member Function Documentation

◆ add_critical_xpair()

void Realm::GASNetEXPoller::add_critical_xpair ( XmitSrcDestPair xpair)

◆ add_pending_event()

void Realm::GASNetEXPoller::add_pending_event ( GASNetEXEvent event)

◆ begin_polling()

void Realm::GASNetEXPoller::begin_polling ( )

◆ do_work()

virtual bool Realm::GASNetEXPoller::do_work ( TimeLimit  work_until)
virtual

◆ end_polling()

void Realm::GASNetEXPoller::end_polling ( )

◆ has_work_remaining()

bool Realm::GASNetEXPoller::has_work_remaining ( )

◆ wait_for_full_poll_cycle()

void Realm::GASNetEXPoller::wait_for_full_poll_cycle ( )

Member Data Documentation

◆ critical_xpairs

XmitSrcDestPair::XmitPairList Realm::GASNetEXPoller::critical_xpairs
protected

◆ internal

GASNetEXInternal* Realm::GASNetEXPoller::internal
protected

◆ mutex

Mutex Realm::GASNetEXPoller::mutex
protected

◆ pending_events

GASNetEXEvent::EventList Realm::GASNetEXPoller::pending_events
protected

◆ pollwait_cond

Mutex::CondVar Realm::GASNetEXPoller::pollwait_cond
protected

◆ pollwait_flag

atomic<bool> Realm::GASNetEXPoller::pollwait_flag
protected

◆ shutdown_cond

Mutex::CondVar Realm::GASNetEXPoller::shutdown_cond
protected

◆ shutdown_flag

atomic<bool> Realm::GASNetEXPoller::shutdown_flag
protected

◆ started

bool Realm::GASNetEXPoller::started = false
protected

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