MySQL 8.0.39
Source Code Documentation
|
A packet to wait for queue consumption. More...
#include <applier.h>
Public Member Functions | |
Queue_checkpoint_packet (std::shared_ptr< Continuation > checkpoint_condition_arg) | |
Create a new Queue_checkpoint_packet packet. More... | |
void | signal_checkpoint_reached () |
Public Member Functions inherited from Action_packet | |
Action_packet (enum_packet_action action) | |
Create a new action packet. More... | |
~Action_packet () override=default | |
Public Member Functions inherited from Packet | |
Packet (int type) | |
Create a new generic packet of a certain type. More... | |
virtual | ~Packet ()=default |
int | get_packet_type () |
Private Attributes | |
std::shared_ptr< Continuation > | checkpoint_condition |
If we discard a packet. More... | |
Additional Inherited Members | |
Public Attributes inherited from Action_packet | |
enum_packet_action | packet_action |
A packet to wait for queue consumption.
|
inline |
Create a new Queue_checkpoint_packet packet.
|
inline |
|
private |
If we discard a packet.