Class CBC_AngleSet

Defined in File cbc_angle_set.h

Inheritance Relationships

Base Type

public opensn::AngleSet (Class AngleSet)

Class Documentation

class CBC_AngleSet : public opensn::AngleSet 

Host CBC angle set.

Public Functions

CBC_AngleSet(std::size_t id, const LBSGroupset &groupset, const SPDS &spds, std::shared_ptr<FLUDS> &fluds, const std::vector<std::size_t> &angle_indices, std::map<std::uint64_t, std::shared_ptr<SweepBoundary>> &boundaries, const MPICommunicatorSet &comm_set)

virtual AsynchronousCommunicator *GetCommunicator() override

inline virtual void InitializeDelayedUpstreamData() override

Initializes delayed upstream data.

This method gets called when a sweep scheduler is constructed.

inline virtual int GetMaxBufferMessages() const override: Returns the maximum buffer size from the sweepbuffer.

inline virtual void SetMaxBufferMessages(int new_max) override: Sets the maximum buffer size for the sweepbuffer.

virtual AngleSetStatus AngleSetAdvance(SweepChunk &sweep_chunk, AngleSetStatus permission) override: This function advances the work stages of an angleset.

inline virtual AngleSetStatus FlushSendBuffers() override

virtual void ResetSweepBuffers() override: Resets the sweep buffer.

inline virtual bool ReceiveDelayedData() override: Instructs the sweep buffer to receive delayed data.

Protected Attributes

const CBC_SPDS &cbc_spds_

const std::vector<Task> *task_list_ = nullptr

std::vector<unsigned int> remaining_dependencies_: Unsatisfied dependency count by task.

std::vector<unsigned char> completed_tasks_: Task completion flags.

std::vector<std::uint32_t> ready_tasks_: Ready task stack.

std::vector<std::uint32_t> received_task_buffer_: Reusable buffer for newly unlocked received tasks.

std::size_t num_completed_tasks_ = 0

int max_buffer_messages_ = 0

CBC_AsynchronousCommunicator async_comm_