Searched refs:STATE_SEQNO (Results 1 – 3 of 3) sorted by relevance
21 wsrep_seqno_t const local_seqno(STATE_SEQNO()); in state_transfer_required()472 wsrep_seqno_t const local_seqno(STATE_SEQNO()); in prepare_for_IST()635 st_.set(state_uuid_, STATE_SEQNO(), safe_to_bootstrap_); in send_state_request()736 if (STATE_SEQNO() < group_seqno) in request_state_transfer()738 log_info << "Receiving IST: " << (group_seqno - STATE_SEQNO()) in request_state_transfer()739 << " writesets, seqnos " << STATE_SEQNO() in request_state_transfer()
293 wsrep_seqno_t const seqno(STATE_SEQNO()); in connect()437 assert(trx->global_seqno() > STATE_SEQNO()); in apply_trx()776 assert(trx->global_seqno() > STATE_SEQNO()); in pre_commit()850 assert(trx->global_seqno() > STATE_SEQNO()); in replay_trx()1043 assert(trx->global_seqno() > STATE_SEQNO()); in to_isolation_begin()1438 << "\n\tLocal state: " << state_uuid_<< ":" << STATE_SEQNO(); in process_conf_change()1479 if (STATE_SEQNO() > 0) service_thd_.release_seqno(STATE_SEQNO()); in process_conf_change()1559 st_.set (state_uuid_, STATE_SEQNO(), safe_to_bootstrap_); in process_conf_change()1651 wsrep_seqno_t const ret(STATE_SEQNO()); in pause()1758 bool const applicable(trx->global_seqno() > STATE_SEQNO()); in cert()
458 wsrep_seqno_t STATE_SEQNO(void) { return apply_monitor_.last_left(); } in STATE_SEQNO() function in galera::ReplicatorSMM