MySQL 8.0.39
Source Code Documentation
|
Data structure for objects that are processed in any chain. More...
#include <item_processing_data.h>
Public Member Functions | |
Item_processing_data (Chain_data *chain_data, I_dump_task *process_task_object, I_chain_element *chain_element, const std::function< void(Item_processing_data *)> *completion_callback, Item_processing_data *parent_item_data) | |
~Item_processing_data () | |
Chain_data * | get_chain () const |
Returns chain data in which this item is being processed. More... | |
Item_processing_data * | get_parent_item_data () const |
void | start_processing () |
bool | end_processing () |
I_dump_task * | get_process_task_object () const |
I_chain_element * | get_processing_chain_element () const |
bool | have_completion_callback () |
bool | had_chain_created () const |
void | set_had_chain_created () |
void | set_chain (Chain_data *) |
bool | call_completion_callback_at_end () |
Private Attributes | |
Chain_data * | m_chain_data |
Chain in which current processing item is processed. More... | |
I_dump_task * | m_process_task_object |
Instance of task object that is being processing. More... | |
I_chain_element * | m_chain_element |
Instance of chain element that is processing specified element. More... | |
const std::function< void(Item_processing_data *)> * | m_completion_callback |
Callback to call after element is fully processed to the output. More... | |
Item_processing_data * | m_parent_item_data |
Link to item process information of parent module execution, if exists. More... | |
std::atomic< uint32_t > | m_active_executions |
Number of modules that have pending or are executing this task. More... | |
bool | m_had_chain_created |
Indicates if this item led to creation of at least one new chain. More... | |
Data structure for objects that are processed in any chain.
Item_processing_data::Item_processing_data | ( | Chain_data * | chain_data, |
I_dump_task * | process_task_object, | ||
I_chain_element * | chain_element, | ||
const std::function< void(Item_processing_data *)> * | completion_callback, | ||
Item_processing_data * | parent_item_data | ||
) |
Item_processing_data::~Item_processing_data | ( | ) |
bool Item_processing_data::call_completion_callback_at_end | ( | ) |
bool Item_processing_data::end_processing | ( | ) |
Chain_data * Item_processing_data::get_chain | ( | ) | const |
Returns chain data in which this item is being processed.
Item_processing_data * Item_processing_data::get_parent_item_data | ( | ) | const |
I_dump_task * Item_processing_data::get_process_task_object | ( | ) | const |
I_chain_element * Item_processing_data::get_processing_chain_element | ( | ) | const |
bool Item_processing_data::had_chain_created | ( | ) | const |
bool Item_processing_data::have_completion_callback | ( | ) |
void Item_processing_data::set_chain | ( | Chain_data * | chain_data | ) |
void Item_processing_data::set_had_chain_created | ( | ) |
void Item_processing_data::start_processing | ( | ) |
|
private |
Number of modules that have pending or are executing this task.
|
private |
Chain in which current processing item is processed.
|
private |
Instance of chain element that is processing specified element.
|
private |
Callback to call after element is fully processed to the output.
Can be NULL.
|
private |
Indicates if this item led to creation of at least one new chain.
|
private |
Link to item process information of parent module execution, if exists.
|
private |
Instance of task object that is being processing.