Home
last modified time | relevance | path

Searched refs:thd_ndb (Results 1 – 25 of 121) sorted by relevance

12345

/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/plugin/
H A Dndb_global_schema_lock.cc333 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 Dndb_global_schema_lock.cc196 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 Dndb_thd_ndb.cc40 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 Dndb_global_schema_lock.cc196 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 Dndb_thd_ndb.cc40 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 Dndb_global_schema_lock.cc196 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 Dndb_thd_ndb.cc40 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 Dndb_global_schema_lock.cc196 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 Dndb_thd_ndb.cc40 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_thd.cc42 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_thd.cc42 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 Dndb_global_schema_lock.cc199 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 Dndb_thd_ndb.cc41 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 Dndb_global_schema_lock.cc196 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 Dndb_thd_ndb.cc40 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()

12345