12 #ifndef SST_CORE_SYNC_SYNCQUEUE_H 13 #define SST_CORE_SYNC_SYNCQUEUE_H 15 #include "sst/core/activityQueue.h" 16 #include "sst/core/threadsafe.h" 42 bool empty()
override;
54 uint64_t getDataSize() {
return buf_size + (activities.capacity() *
sizeof(
Activity*)); }
59 std::vector<Activity*> activities;
66 #endif // SST_CORE_SYNC_SYNCQUEUE_H Activity * front() override
Returns the next activity.
Definition: syncQueue.cc:73
Activity * pop() override
Remove and return the next activity.
Definition: syncQueue.cc:61
Base class for all Activities in the SST Event Queue.
Definition: activity.h:45
char * getData()
Accessor method to the internal queue.
Definition: syncQueue.cc:87
int size() override
Returns the number of activities in the queue.
Definition: syncQueue.cc:47
bool empty() override
Returns true if the queue is empty.
Definition: syncQueue.cc:40
void clear()
Clear elements from the queue.
Definition: syncQueue.cc:80
Definition: threadsafe.h:121
Internal API.
Definition: syncQueue.h:29
void insert(Activity *activity) override
Insert a new activity into the queue.
Definition: syncQueue.cc:54
Base Class for a queue of Activities.
Definition: activityQueue.h:21