Lines Matching refs:ws_meta
34 wsrep_trx_meta_t ws_meta; in node_trx_execute() local
54 cert = wsrep->certify(wsrep, conn_id, &ws_handle, ws_flags, &ws_meta); in node_trx_execute()
66 if (ws_meta.gtid.seqno > 0) in node_trx_execute()
68 ret = wsrep->commit_order_enter(wsrep, &ws_handle, &ws_meta); in node_trx_execute()
72 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
79 node_store_commit(store, ws_handle.trx_id, &ws_meta.gtid); in node_trx_execute()
81 node_store_update_gtid(store, &ws_meta.gtid); in node_trx_execute()
83 ret = wsrep->commit_order_leave(wsrep, &ws_handle, &ws_meta, NULL); in node_trx_execute()
87 "%d", (long long)(ws_meta.gtid.seqno), ret); in node_trx_execute()
116 const wsrep_trx_meta_t* const ws_meta, in node_trx_apply() argument
120 assert(ws_meta->gtid.seqno > 0); in node_trx_apply()
143 ret = wsrep->commit_order_enter(wsrep, ws_handle, ws_meta); in node_trx_apply()
149 if (!app_err) node_store_commit(store, trx_id, &ws_meta->gtid); in node_trx_apply()
150 else node_store_update_gtid(store, &ws_meta->gtid); in node_trx_apply()
152 ret = wsrep->commit_order_leave(wsrep, ws_handle, ws_meta, &err_buf); in node_trx_apply()