/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/plugin/ |
H A D | ndb_global_schema_lock.cc | 333 Thd_ndb *thd_ndb = get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 367 thd_ndb->global_schema_lock_trans = in ndbcluster_global_schema_lock() 378 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 421 Thd_ndb *thd_ndb = get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 422 if (unlikely(thd_ndb == NULL)) { in ndbcluster_global_schema_unlock() 445 Ndb *ndb = thd_ndb->ndb; in ndbcluster_global_schema_unlock() 450 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() 587 thd_ndb->global_schema_lock_trans = in try_lock() 595 thd_ndb->schema_locks_count++; in try_lock() 610 if (unlikely(thd_ndb == nullptr)) { in unlock() [all …]
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/ |
H A D | ndb_global_schema_lock.cc | 196 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 203 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 215 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 216 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 285 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 313 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 314 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 315 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 317 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 320 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 40 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 41 if (thd_ndb == NULL) in seize() 44 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 47 thd_ndb->ndb->getNdbError().code, in seize() 48 thd_ndb->ndb->getNdbError().message)); in seize() 50 delete thd_ndb; in seize() 51 thd_ndb= NULL; in seize() 53 DBUG_RETURN(thd_ndb); in seize() 58 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument 61 delete thd_ndb; in release()
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/ |
H A D | ndb_global_schema_lock.cc | 196 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 203 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 215 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 216 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 285 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 313 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 314 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 315 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 317 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 320 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 40 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 41 if (thd_ndb == NULL) in seize() 44 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 47 thd_ndb->ndb->getNdbError().code, in seize() 48 thd_ndb->ndb->getNdbError().message)); in seize() 50 delete thd_ndb; in seize() 51 thd_ndb= NULL; in seize() 53 DBUG_RETURN(thd_ndb); in seize() 58 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument 61 delete thd_ndb; in release()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/ |
H A D | ndb_global_schema_lock.cc | 196 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 203 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 215 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 216 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 285 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 313 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 314 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 315 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 317 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 320 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 40 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 41 if (thd_ndb == NULL) in seize() 44 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 47 thd_ndb->ndb->getNdbError().code, in seize() 48 thd_ndb->ndb->getNdbError().message)); in seize() 50 delete thd_ndb; in seize() 51 thd_ndb= NULL; in seize() 53 DBUG_RETURN(thd_ndb); in seize() 58 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument 61 delete thd_ndb; in release()
|
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/ |
H A D | ndb_global_schema_lock.cc | 196 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 203 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 215 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 216 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 285 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 313 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 314 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 315 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 317 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 320 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 40 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 41 if (thd_ndb == NULL) in seize() 44 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 47 thd_ndb->ndb->getNdbError().code, in seize() 48 thd_ndb->ndb->getNdbError().message)); in seize() 50 delete thd_ndb; in seize() 51 thd_ndb= NULL; in seize() 53 DBUG_RETURN(thd_ndb); in seize() 58 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument 61 delete thd_ndb; in release()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 assert(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
H A D | ndb_thd.cc | 42 Thd_ndb *thd_ndb= get_thd_ndb(thd); in check_ndb_in_thd() local 43 if (!thd_ndb) in check_ndb_in_thd() 45 if (!(thd_ndb= Thd_ndb::seize(thd))) in check_ndb_in_thd() 47 thd_set_thd_ndb(thd, thd_ndb); in check_ndb_in_thd() 50 else if (validate_ndb && !thd_ndb->valid_ndb()) in check_ndb_in_thd() 52 if (!thd_ndb->recycle_ndb()) in check_ndb_in_thd() 56 assert(thd_ndb->is_slave_thread() == thd->slave_thread); in check_ndb_in_thd() 58 return thd_ndb->ndb; in check_ndb_in_thd()
|
/dports/databases/percona57-client/percona-server-5.7.36-39/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 assert(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
/dports/databases/mysqlwsrep57-server/mysql-wsrep-wsrep_5.7.35-25.27/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 assert(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
/dports/databases/mysql57-client/mysql-5.7.36/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 assert(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 assert(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
H A D | ndb_thd.cc | 42 Thd_ndb *thd_ndb= get_thd_ndb(thd); in check_ndb_in_thd() local 43 if (!thd_ndb) in check_ndb_in_thd() 45 if (!(thd_ndb= Thd_ndb::seize(thd))) in check_ndb_in_thd() 47 thd_set_thd_ndb(thd, thd_ndb); in check_ndb_in_thd() 50 else if (validate_ndb && !thd_ndb->valid_ndb()) in check_ndb_in_thd() 52 if (!thd_ndb->recycle_ndb()) in check_ndb_in_thd() 56 assert(thd_ndb->is_slave_thread() == thd->slave_thread); in check_ndb_in_thd() 58 return thd_ndb->ndb; in check_ndb_in_thd()
|
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/ |
H A D | ndb_global_schema_lock.cc | 199 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 206 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 218 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 219 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 288 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 316 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 317 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 318 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 320 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 323 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 41 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 42 if (thd_ndb == NULL) in seize() 45 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 48 thd_ndb->ndb->getNdbError().code, in seize() 49 thd_ndb->ndb->getNdbError().message)); in seize() 51 delete thd_ndb; in seize() 52 thd_ndb= NULL; in seize() 56 thd_ndb->ndb->setCustomData64(thd_get_thread_id(thd)); in seize() 58 DBUG_RETURN(thd_ndb); in seize() 63 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument [all …]
|
/dports/databases/mysql56-client/mysql-5.6.51/sql/ |
H A D | ndb_global_schema_lock.cc | 196 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_lock() local 203 if (thd_ndb->global_schema_lock_count) in ndbcluster_global_schema_lock() 215 thd_ndb->global_schema_lock_count= 1; in ndbcluster_global_schema_lock() 216 thd_ndb->global_schema_lock_error= 0; in ndbcluster_global_schema_lock() 285 thd_ndb->schema_locks_count++; in ndbcluster_global_schema_lock() 313 Thd_ndb *thd_ndb= get_thd_ndb(thd); in ndbcluster_global_schema_unlock() local 314 DBUG_ASSERT(thd_ndb != 0); in ndbcluster_global_schema_unlock() 315 if (thd_ndb == 0 || (thd_ndb->options & TNO_NO_LOCK_SCHEMA_OP)) in ndbcluster_global_schema_unlock() 317 Ndb *ndb= thd_ndb->ndb; in ndbcluster_global_schema_unlock() 320 thd_ndb->global_schema_lock_count--; in ndbcluster_global_schema_unlock() [all …]
|
H A D | ndb_thd_ndb.cc | 40 Thd_ndb* thd_ndb= new Thd_ndb(thd); in seize() local 41 if (thd_ndb == NULL) in seize() 44 if (thd_ndb->ndb->init(MAX_TRANSACTIONS) != 0) in seize() 47 thd_ndb->ndb->getNdbError().code, in seize() 48 thd_ndb->ndb->getNdbError().message)); in seize() 50 delete thd_ndb; in seize() 51 thd_ndb= NULL; in seize() 53 DBUG_RETURN(thd_ndb); in seize() 58 Thd_ndb::release(Thd_ndb* thd_ndb) in release() argument 61 delete thd_ndb; in release()
|