1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
/* Copyright (c) 2022, 2025, Oracle and/or its affiliates.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License, version 2.0,
as published by the Free Software Foundation.
This program is designed to work with certain software (including
but not limited to OpenSSL) that is licensed under separate terms,
as designated in a particular file or component or in included license
documentation. The authors of MySQL hereby grant you an additional
permission to link the program and your derivative works with the
separately licensed software that they have either included with
the program or referenced in the documentation.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License, version 2.0, for more details.
You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */
#ifndef XA_RECOVERY_H_INCLUDED
#define XA_RECOVERY_H_INCLUDED
#include "sql/handler.h" // XA_recover_txn
#include "sql/sql_class.h" // THD
#include "sql/xa.h" // Xid_commit_list, Xa_state_list, XID, ...
struct xarecover_st {
int len, found_foreign_xids, found_my_xids;
XA_recover_txn *list;
Xid_commit_list const *commit_list;
Xa_state_list *xa_list;
bool dry_run;
};
namespace xa {
namespace recovery {
/**
Callback to be invoked by `ha_recover` over each storage engine plugin.
1. It invokes `handler::recover_prepared_in_tc(XA_recover_txn[])`
callback from the plugin interface, in order to retrieve the list of
transactions that are, at the moment, in prepared in TC state within
the storage engine.
2. For all externally coordinated transactions that are in prepared in TC
state, adds each to the list of recoverable XA transactions
`xarecover_st::xa_list` in `PREPARED` state.
@param thd The THD session object to be used in recovering the
transactions.
@param plugin The plugin interface for the storage engine to recover the
transactions for.
@param arg A pointer to `struct xarecover_st` that hold the information
about the transaction coordinator state.
@return false if the recovery ended successfully, false otherwise.
*/
bool recover_prepared_in_tc_one_ht(THD *thd, plugin_ref plugin, void *arg);
/**
Callback to be invoked by `ha_recover` over each storage engine plugin.
1. It invokes `handler::recover(XA_recover_txn[])` callback from the
plugin interface, in order to retrieve the list of transactions that
are, at the moment, in prepared state within the storage engine.
2. Invokes `recover_one_internal_trx` for all the retrieved transactions
that are internally coordinated transactions.
3. Invokes `recover_one_external_trx` for all the retrieved transactions
that are externally coordinated transactions.
@param thd The THD session object to be used in recovering the
transactions.
@param plugin The plugin interface for the storage engine to recover the
transactions for.
@param arg A pointer to `struct xarecover_st` that hold the information
about the transaction coordinator state.
@return false if the recovery ended successfully, false otherwise.
*/
bool recover_one_ht(THD *thd, plugin_ref plugin, void *arg);
} // namespace recovery
} // namespace xa
#endif // XA_RECOVERY_H_INCLUDED
|
