MySQL  8.0.18
Source Code Documentation
pipeline_stats.h
Go to the documentation of this file.
1 /* Copyright (c) 2016, 2019, Oracle and/or its affiliates. All rights reserved.
2 
3  This program is free software; you can redistribute it and/or modify
4  it under the terms of the GNU General Public License, version 2.0,
5  as published by the Free Software Foundation.
6 
7  This program is also distributed with certain software (including
8  but not limited to OpenSSL) that is licensed under separate terms,
9  as designated in a particular file or component or in included license
10  documentation. The authors of MySQL hereby grant you an additional
11  permission to link the program and your derivative works with the
12  separately licensed software that they have included with MySQL.
13 
14  This program is distributed in the hope that it will be useful,
15  but WITHOUT ANY WARRANTY; without even the implied warranty of
16  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17  GNU General Public License, version 2.0, for more details.
18 
19  You should have received a copy of the GNU General Public License
20  along with this program; if not, write to the Free Software
21  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
22 
23 #ifndef PIPELINE_STATS_INCLUDED
24 #define PIPELINE_STATS_INCLUDED
25 
26 #include <map>
27 #include <string>
28 #include <vector>
29 
30 #include "my_inttypes.h"
33 
34 /**
35  Flow control modes:
36  FCM_DISABLED flow control disabled
37  FCM_QUOTA introduces a delay only on transactions the exceed a quota
38 */
40 
41 /**
42  @class Pipeline_stats_member_message
43 
44  Describes all statistics sent by members.
45 */
47  public:
49  // This type should not be used anywhere.
51 
52  // Length of the payload item: 4 bytes
54 
55  // Length of the payload item: 4 bytes
57 
58  // Length of the payload item: 8 bytes
60 
61  // Length of the payload item: 8 bytes
63 
64  // Length of the payload item: 8 bytes
66 
67  // Length of the payload item: 8 bytes
69 
70  // Length of the payload item: 8 bytes
72 
73  // Length of the payload item: variable
75 
76  // Length of the payload item: variable
78 
79  // Length of the payload item: 8 bytes
81 
82  // Length of the payload item: 1 byte
84 
85  // Length of the payload item: 1 byte
87 
88  // No valid type codes can appear after this one.
89  PIT_MAX = 13
90  };
91 
92  /**
93  Message constructor
94 
95  @param[in] transactions_waiting_certification
96  Number of transactions pending certification
97  @param[in] transactions_waiting_apply
98  Number of remote transactions waiting apply
99  @param[in] transactions_certified
100  Number of transactions already certified
101  @param[in] transactions_applied
102  Number of remote transactions applied
103  @param[in] transactions_local
104  Number of local transactions
105  @param[in] transactions_negative_certified
106  Number of transactions that were negatively certified
107  @param[in] transactions_rows_validating
108  Number of transactions with which certification will be done
109  against
110  @param[in] transaction_gtids
111  Flag to indicate whether or not the transaction ids have been
112  updated
113  @param[in] transactions_committed_all_members
114  Set of transactions committed on all members
115  @param[in] transactions_last_conflict_free
116  Latest transaction certified without conflicts
117  @param[in] transactions_local_rollback
118  Number of local transactions that were negatively certified
119  @param[in] mode
120  Flow-control mode
121  */
123  int32 transactions_waiting_certification,
124  int32 transactions_waiting_apply, int64 transactions_certified,
125  int64 transactions_applied, int64 transactions_local,
126  int64 transactions_negative_certified, int64 transactions_rows_validating,
127  bool transaction_gtids,
128  const std::string &transactions_committed_all_members,
129  const std::string &transactions_last_conflict_free,
130  int64 transactions_local_rollback, Flow_control_mode mode);
131 
132  /**
133  Message constructor for raw data
134 
135  @param[in] buf raw data
136  @param[in] len raw length
137  */
138  Pipeline_stats_member_message(const unsigned char *buf, size_t len);
139 
140  /**
141  Message destructor
142  */
144 
145  /**
146  Get transactions waiting certification counter value.
147 
148  @return the counter value
149  */
151 
152  /**
153  Get transactions waiting apply counter value.
154 
155  @return the counter value
156  */
158 
159  /**
160  Get transactions certified.
161 
162  @return the counter value
163  */
165 
166  /**
167  Get transactions applied.
168 
169  @return the counter value
170  */
172 
173  /**
174  Get local transactions that member tried to commmit.
175 
176  @return the counter value
177  */
179 
180  /**
181  Get negatively certfied transaction by member.
182 
183  @return the counter value
184  */
186 
187  /**
188  Get size of conflict detection database.
189 
190  @return the counter value
191  */
193 
194  /**
195  Returns a flag indicating whether or not the GTIDs on this stats message
196  are updated/present.
197 
198  @return the flag indicating the presence of valid GTIDs on this message.
199  */
200  bool get_transation_gtids_present() const;
201 
202  /**
203  Get set of stable group transactions.
204 
205  @return the transaction identifier.
206  */
207  const std::string &get_transaction_committed_all_members();
208 
209  /**
210  Get last positive certified transaction.
211 
212  @return the transaction identifier.
213  */
214  const std::string &get_transaction_last_conflict_free();
215 
216  /**
217  Get local transactions rolled back by the member.
218 
219  @return the transaction identifiers.
220  */
222 
223  /**
224  Get flow-control mode of member.
225 
226  @return the mode value
227  */
229 
230  protected:
231  /**
232  Encodes the message contents for transmission.
233 
234  @param[out] buffer the message buffer to be written
235  */
236  void encode_payload(std::vector<unsigned char> *buffer) const;
237 
238  /**
239  Message decoding method
240 
241  @param[in] buffer the received data
242  @param[in] end the end of the buffer
243  */
244  void decode_payload(const unsigned char *buffer, const unsigned char *end);
245 
246  private:
259 };
260 
261 /**
262  @class Pipeline_stats_member_collector
263 
264  The pipeline collector for the local member stats.
265 */
267  public:
268  /**
269  Default constructor.
270  */
272 
273  /**
274  Destructor.
275  */
277 
278  /**
279  Increment transactions waiting apply counter value.
280  */
282 
283  /**
284  Decrement transactions waiting apply counter value.
285  */
287 
288  /**
289  Increment transactions certified counter value.
290  */
292 
293  /**
294  Increment transactions applied counter value.
295  */
297 
298  /**
299  Increment local transactions counter value.
300  */
302 
303  /**
304  Increment local rollback transactions counter value.
305  */
307 
308  /**
309  Send member statistics to group.
310  */
312 
313  /**
314  Increment local recovery transactions counter value.
315  */
317 
318  /**
319  @returns transactions waiting to be applied during recovery.
320  */
322 
323  /**
324  Increment delivered transactions during recovery counter value.
325  */
327 
328  /**
329  Increment certified transactions during recovery counter value.
330  */
332 
333  /**
334  Increment negatively certified transactions during recovery counter value.
335  */
337 
338  /**
339  @returns transactions waiting to be certified during recovery.
340  */
342 
343  /**
344  Compute the transactions applied during last flow-control tick
345  while the member is in recovery.
346  */
348 
349  /**
350  @returns transactions applied during last flow-control tick
351  while the member is in recovery.
352  */
354 
355  /**
356  @returns transactions waiting to be applied.
357  */
359 
360  /**
361  @returns transactions certified.
362  */
364 
365  /**
366  @returns transactions applied of local member.
367  */
369 
370  /**
371  @returns local transactions proposed by member.
372  */
374 
375  /**
376  @returns local transactions rollback due to Negative certification
377  */
379 
380  /**
381  Send Transaction Identifiers or not.
382  Once Transactions identifiers are sent, variable will be reset to FALSE
383  So need to set each time Transactions identifiers needs to be transmitted
384  */
386 
387  private:
388  std::atomic<int32> m_transactions_waiting_apply;
389  std::atomic<int64> m_transactions_certified;
390  std::atomic<int64> m_transactions_applied;
391  std::atomic<int64> m_transactions_local;
392  std::atomic<int64> m_transactions_local_rollback;
393  /* Includes both positively and negatively certified. */
400 
403 };
404 
405 /**
406  @class Pipeline_member_stats
407 
408  Computed statistics per member.
409 */
411  public:
412  /**
413  Default constructor.
414  */
416 
417  /**
418  Constructor.
419  */
421 
422  /**
423  Updates member statistics with a new message from the network
424  */
426 
427  /**
428  Returns true if the node is behind on some user-defined criteria
429  */
430  bool is_flow_control_needed();
431 
432  /**
433  Get transactions waiting certification counter value.
434 
435  @return the counter value
436  */
438 
439  /**
440  Get transactions waiting apply counter value.
441 
442  @return the counter value
443  */
445 
446  /**
447  Get transactions certified counter value.
448 
449  @return the counter value
450  */
452 
453  /**
454  Get transactions applied counter value.
455 
456  @return the counter value
457  */
459 
460  /**
461  Get local member transactions proposed counter value.
462 
463  @return the counter value
464  */
466 
467  /**
468  Get transactions negatively certified.
469 
470  @return the counter value
471  */
473 
474  /**
475  Get certification database counter value.
476 
477  @return the counter value
478  */
480 
481  /**
482  Get set of stable group transactions.
483 
484  @return the transaction identifier.
485  */
486  const std::string &get_transaction_committed_all_members();
487 
488  /**
489  Get last positive certified transaction.
490 
491  @return the transaction identifier.
492  */
493  const std::string &get_transaction_last_conflict_free();
494 
495  /**
496  Get local member transactions negatively certified.
497 
498  @return the counter value
499  */
501 
502  /**
503  Get transactions certified since last stats message.
504 
505  @return the counter value
506  */
508 
509  /**
510  Get transactions applied since last stats message.
511 
512  @return the counter value
513  */
515 
516  /**
517  Get local transactions that member tried to commmit
518  since last stats message.
519 
520  @return the counter value
521  */
523 
524  /**
525  Get flow_control_mode of a member.
526 
527  @return the mode value
528  */
530 
531  /**
532  Get the last stats update stamp.
533 
534  @return the counter value
535  */
536  uint64 get_stamp();
537 
538 #ifndef DBUG_OFF
539  void debug(const char *member, int64 quota_size, int64 quota_used);
540 #endif
541 
542  private:
558 };
559 
560 /**
561  Data type that holds all members stats.
562  The key value is the GCS member_id.
563 */
564 typedef std::map<std::string, Pipeline_member_stats> Flow_control_module_info;
565 
566 /**
567  @class Flow_control_module
568 
569  The pipeline stats aggregator of all group members stats and
570  flow control module.
571 */
573  public:
574  static const int64 MAXTPS;
575 
576  /**
577  Default constructor.
578  */
580 
581  /**
582  Destructor.
583  */
584  virtual ~Flow_control_module();
585 
586  /**
587  Handles a Pipeline_stats_message, updating the
588  Flow_control_module_info and the delay, if needed.
589 
590  @param[in] data the packet data
591  @param[in] len the packet length
592  @param[in] member_id the GCS member_id which sent the message
593 
594  @return the operation status
595  @retval 0 OK
596  @retval !=0 Error on queue
597  */
598  int handle_stats_data(const uchar *data, size_t len,
599  const std::string &member_id);
600 
601  /**
602  Evaluate the information received in the last flow control period
603  and adjust the system parameters accordingly
604  */
606 
607  /**
608  Returns copy of individual member stats information.
609  @note Its caller responsibility to clean up allocated memory.
610 
611  @param[in] member_id GCS Type Member Id, i.e. format HOST:PORT
612  @return the reference to class Pipeline_member_stats of memberID
613  storing network(GCS Broadcasted) received information
614  */
615  Pipeline_member_stats *get_pipeline_stats(const std::string &member_id);
616 
617  /**
618  Compute and wait the amount of time in microseconds that must
619  be elapsed before a new message is sent.
620  If there is no need to wait, the method returns immediately.
621 
622  @return the wait time
623  @retval 0 No wait was done
624  @retval >0 The wait time
625  */
626  int32 do_wait();
627 
628  private:
631 
633 
634  /*
635  Number of members that did have waiting transactions on
636  certification and/or apply.
637  */
638  std::atomic<int32> m_holds_in_period;
639 
640  /*
641  FCM_QUOTA
642  */
643  std::atomic<int64> m_quota_used;
644  std::atomic<int64> m_quota_size;
645 
646  /*
647  Counter incremented on every flow control step.
648  */
650 
651  /*
652  Remaining seconds to skip flow-control steps
653  */
655 };
656 
657 #endif /* PIPELINE_STATS_INCLUDED */
enum_payload_item_type
Definition: pipeline_stats.h:48
int64 get_transactions_local()
Definition: pipeline_stats.cc:391
int32 get_transactions_waiting_certification()
Get transactions waiting certification counter value.
Definition: pipeline_stats.cc:608
int64 m_transactions_rows_validating
Definition: pipeline_stats.h:552
unsigned char uchar
Definition: my_inttypes.h:51
int64 m_transactions_certified
Definition: pipeline_stats.h:545
bool m_transaction_gtids_present
Definition: pipeline_stats.h:254
int64 m_transactions_negative_certified
Definition: pipeline_stats.h:252
uint64 m_stamp
Definition: pipeline_stats.h:649
void increment_transactions_applied()
Increment transactions applied counter value.
Definition: pipeline_stats.cc:367
void update_member_stats(Pipeline_stats_member_message &msg, uint64 stamp)
Updates member statistics with a new message from the network.
Definition: pipeline_stats.cc:555
std::string m_transactions_committed_all_members
Definition: pipeline_stats.h:553
const std::string & get_transaction_committed_all_members()
Get set of stable group transactions.
Definition: pipeline_stats.cc:653
The pipeline stats aggregator of all group members stats and flow control module. ...
Definition: pipeline_stats.h:572
uint64 m_stamp
Definition: pipeline_stats.h:557
std::atomic< int32 > m_holds_in_period
Definition: pipeline_stats.h:638
int64 get_transactions_certified()
Get transactions certified.
Definition: pipeline_stats.cc:113
Pipeline_member_stats()
Default constructor.
Definition: pipeline_stats.cc:517
char buffer[STRING_BUFFER]
Definition: test_sql_9_sessions.cc:57
int64 get_transactions_local_rollback()
Definition: pipeline_stats.cc:395
Definition: pipeline_stats.h:89
An instrumented cond structure.
Definition: mysql_cond_bits.h:49
int64 get_transactions_certified()
Definition: pipeline_stats.cc:383
void debug(const char *member, int64 quota_size, int64 quota_used)
Definition: pipeline_stats.cc:668
Some integer typedefs for easier portability.
static const int64 MAXTPS
Definition: pipeline_stats.h:574
std::atomic< int64 > m_transactions_local
Definition: pipeline_stats.h:391
std::atomic< int64 > m_transactions_local_rollback
Definition: pipeline_stats.h:392
uint64 get_delta_transactions_applied_during_recovery()
Definition: pipeline_stats.cc:428
Flow_control_mode
Flow control modes: FCM_DISABLED flow control disabled FCM_QUOTA introduces a delay only on transacti...
Definition: pipeline_stats.h:39
int64 get_transactions_applied()
Definition: pipeline_stats.cc:387
void increment_transactions_local()
Increment local transactions counter value.
Definition: pipeline_stats.cc:371
int32 m_transactions_waiting_certification
Definition: pipeline_stats.h:247
int64 get_transactions_rows_validating()
Get size of conflict detection database.
Definition: pipeline_stats.cc:138
int32 get_transactions_waiting_apply()
Get transactions waiting apply counter value.
Definition: pipeline_stats.cc:118
This is the base GCS plugin message.
Definition: gcs_plugin_messages.h:63
int64 m_transactions_certified
Definition: pipeline_stats.h:249
int64 get_transactions_negative_certified()
Get negatively certfied transaction by member.
Definition: pipeline_stats.cc:133
Pipeline_stats_member_collector()
Default constructor.
Definition: pipeline_stats.cc:328
mysql_mutex_t m_flow_control_lock
Definition: pipeline_stats.h:629
void increment_transactions_delivered_during_recovery()
Increment delivered transactions during recovery counter value.
Definition: pipeline_stats.cc:454
Describes all statistics sent by members.
Definition: pipeline_stats.h:46
std::atomic< uint64 > m_transactions_applied_during_recovery
Definition: pipeline_stats.h:396
int64 m_transactions_negative_certified
Definition: pipeline_stats.h:551
Flow_control_module()
Default constructor.
Definition: pipeline_stats.cc:680
Flow_control_mode get_flow_control_mode()
Get flow_control_mode of a member.
Definition: pipeline_stats.cc:661
int64 m_delta_transactions_applied
Definition: pipeline_stats.h:548
uint64 get_stamp()
Get the last stats update stamp.
Definition: pipeline_stats.cc:665
void decrement_transactions_waiting_apply()
Decrement transactions waiting apply counter value.
Definition: pipeline_stats.cc:356
Pipeline_stats_member_message(int32 transactions_waiting_certification, int32 transactions_waiting_apply, int64 transactions_certified, int64 transactions_applied, int64 transactions_local, int64 transactions_negative_certified, int64 transactions_rows_validating, bool transaction_gtids, const std::string &transactions_committed_all_members, const std::string &transactions_last_conflict_free, int64 transactions_local_rollback, Flow_control_mode mode)
Message constructor.
Definition: pipeline_stats.cc:66
std::atomic< int64 > m_transactions_applied
Definition: pipeline_stats.h:390
std::atomic< int32 > m_transactions_waiting_apply
Definition: pipeline_stats.h:388
void increment_transactions_certified_negatively_during_recovery()
Increment negatively certified transactions during recovery counter value.
Definition: pipeline_stats.cc:409
int64 get_transactions_certified()
Get transactions certified counter value.
Definition: pipeline_stats.cc:628
bool send_transaction_identifiers
Definition: pipeline_stats.h:401
void decode_payload(const unsigned char *buffer, const unsigned char *end)
Message decoding method.
Definition: pipeline_stats.cc:226
int64 m_transactions_rows_validating
Definition: pipeline_stats.h:253
int64 m_transactions_local_rollback
Definition: pipeline_stats.h:257
int32 m_transactions_waiting_certification
Definition: pipeline_stats.h:543
Pipeline_member_stats * get_pipeline_stats(const std::string &member_id)
Returns copy of individual member stats information.
Definition: pipeline_stats.cc:924
Flow_control_mode m_flow_control_mode
Definition: pipeline_stats.h:556
int64 m_transactions_local
Definition: pipeline_stats.h:549
int32 get_transactions_waiting_apply()
Definition: pipeline_stats.cc:379
int64 m_transactions_applied
Definition: pipeline_stats.h:250
const std::string & get_transaction_committed_all_members()
Get set of stable group transactions.
Definition: pipeline_stats.cc:153
void increment_transactions_waiting_apply()
Increment transactions waiting apply counter value.
Definition: pipeline_stats.cc:349
int handle_stats_data(const uchar *data, size_t len, const std::string &member_id)
Handles a Pipeline_stats_message, updating the Flow_control_module_info and the delay, if needed.
Definition: pipeline_stats.cc:889
Flow_control_mode m_flow_control_mode
Definition: pipeline_stats.h:258
mysql_cond_t m_flow_control_cond
Definition: pipeline_stats.h:630
Definition: pipeline_stats.h:50
mysql_mutex_t m_transactions_waiting_apply_lock
Definition: pipeline_stats.h:402
int64 m_transactions_local
Definition: pipeline_stats.h:251
void increment_transactions_local_rollback()
Increment local rollback transactions counter value.
Definition: pipeline_stats.cc:375
void send_stats_member_message(Flow_control_mode mode)
Send member statistics to group.
Definition: pipeline_stats.cc:466
Cursor end()
A past-the-end Cursor.
Definition: rules_table_service.cc:188
void encode_payload(std::vector< unsigned char > *buffer) const
Encodes the message contents for transmission.
Definition: pipeline_stats.cc:169
int64_t int64
Definition: my_inttypes.h:67
std::atomic< uint64 > m_delta_transactions_applied_during_recovery
Definition: pipeline_stats.h:398
The pipeline collector for the local member stats.
Definition: pipeline_stats.h:266
int64 get_delta_transactions_applied()
Get transactions applied since last stats message.
Definition: pipeline_stats.cc:620
Flow_control_mode get_flow_control_mode()
Get flow-control mode of member.
Definition: pipeline_stats.cc:164
int32 do_wait()
Compute and wait the amount of time in microseconds that must be elapsed before a new message is sent...
Definition: pipeline_stats.cc:934
bool get_transation_gtids_present() const
Returns a flag indicating whether or not the GTIDs on this stats message are updated/present.
Definition: pipeline_stats.cc:143
virtual ~Pipeline_stats_member_message()
Message destructor.
Definition: pipeline_stats.cc:106
std::map< std::string, Pipeline_member_stats > Flow_control_module_info
Data type that holds all members stats.
Definition: pipeline_stats.h:564
virtual ~Pipeline_stats_member_collector()
Destructor.
Definition: pipeline_stats.cc:345
int32 get_transactions_waiting_apply()
Get transactions waiting apply counter value.
Definition: pipeline_stats.cc:612
std::string m_transaction_last_conflict_free
Definition: pipeline_stats.h:256
char msg[1024]
Definition: test_sql_9_sessions.cc:281
std::atomic< int64 > m_quota_size
Definition: pipeline_stats.h:644
int64 get_transactions_local_rollback()
Get local member transactions negatively certified.
Definition: pipeline_stats.cc:648
uint64 get_transactions_waiting_certification_during_recovery()
Definition: pipeline_stats.cc:459
int64 get_transactions_negative_certified()
Get transactions negatively certified.
Definition: pipeline_stats.cc:640
int64 m_delta_transactions_certified
Definition: pipeline_stats.h:546
void increment_transactions_certified()
Increment transactions certified counter value.
Definition: pipeline_stats.cc:363
Definition: pipeline_stats.h:39
std::atomic< int64 > m_transactions_certified
Definition: pipeline_stats.h:389
virtual ~Flow_control_module()
Destructor.
Definition: pipeline_stats.cc:692
int64 get_delta_transactions_certified()
Get transactions certified since last stats message.
Definition: pipeline_stats.cc:616
int64 get_transactions_applied()
Get transactions applied.
Definition: pipeline_stats.cc:123
int32 get_transactions_waiting_certification()
Get transactions waiting certification counter value.
Definition: pipeline_stats.cc:108
void flow_control_step(Pipeline_stats_member_collector *)
Evaluate the information received in the last flow control period and adjust the system parameters ac...
Definition: pipeline_stats.cc:697
std::atomic< int64 > m_quota_used
Definition: pipeline_stats.h:643
const std::string & get_transaction_last_conflict_free()
Get last positive certified transaction.
Definition: pipeline_stats.cc:159
Definition: pipeline_stats.h:39
int64 get_delta_transactions_local()
Get local transactions that member tried to commmit since last stats message.
Definition: pipeline_stats.cc:624
const std::string & get_transaction_last_conflict_free()
Get last positive certified transaction.
Definition: pipeline_stats.cc:657
void set_send_transaction_identifiers()
Send Transaction Identifiers or not.
Definition: pipeline_stats.cc:399
An instrumented mutex structure.
Definition: mysql_mutex_bits.h:49
int32 m_transactions_waiting_apply
Definition: pipeline_stats.h:248
std::string m_transaction_last_conflict_free
Definition: pipeline_stats.h:554
void increment_transactions_certified_during_recovery()
Increment certified transactions during recovery counter value.
Definition: pipeline_stats.cc:404
bool is_flow_control_needed()
Returns true if the node is behind on some user-defined criteria.
Definition: pipeline_stats.cc:600
int64 m_transactions_local_rollback
Definition: pipeline_stats.h:555
int32_t int32
Definition: my_inttypes.h:65
int64 get_transactions_local()
Get local member transactions proposed counter value.
Definition: pipeline_stats.cc:636
void compute_transactions_deltas_during_recovery()
Compute the transactions applied during last flow-control tick while the member is in recovery...
Definition: pipeline_stats.cc:419
uint64 get_transactions_waiting_apply_during_recovery()
Definition: pipeline_stats.cc:433
void increment_transactions_applied_during_recovery()
Increment local recovery transactions counter value.
Definition: pipeline_stats.cc:414
int seconds_to_skip
Definition: pipeline_stats.h:654
int64 get_transactions_local()
Get local transactions that member tried to commmit.
Definition: pipeline_stats.cc:128
uint64 m_previous_transactions_applied_during_recovery
Definition: pipeline_stats.h:397
std::atomic< uint64 > m_transactions_delivered_during_recovery
Definition: pipeline_stats.h:399
int32 m_transactions_waiting_apply
Definition: pipeline_stats.h:544
int64 get_transactions_applied()
Get transactions applied counter value.
Definition: pipeline_stats.cc:632
std::atomic< uint64 > m_transactions_certified_during_recovery
Definition: pipeline_stats.h:394
int64 get_transactions_rows_validating()
Get certification database counter value.
Definition: pipeline_stats.cc:644
int64 m_delta_transactions_local
Definition: pipeline_stats.h:550
std::string m_transactions_committed_all_members
Definition: pipeline_stats.h:255
int64 m_transactions_applied
Definition: pipeline_stats.h:547
uint64_t uint64
Definition: my_inttypes.h:68
int64 get_transactions_local_rollback()
Get local transactions rolled back by the member.
Definition: pipeline_stats.cc:147
Computed statistics per member.
Definition: pipeline_stats.h:410
std::atomic< uint64 > m_transactions_certified_negatively_during_recovery
Definition: pipeline_stats.h:395
Flow_control_module_info m_info
Definition: pipeline_stats.h:632