Loading sql/ha_ndbcluster.cc +2 −0 Original line number Diff line number Diff line Loading @@ -5848,6 +5848,7 @@ int ndbcluster_drop_database_impl(const char *path) while ((tabname=it++)) { tablename_to_filename(tabname, tmp, FN_REFLEN - (tmp - full_path)-1); VOID(pthread_mutex_lock(&LOCK_open)); if (ha_ndbcluster::delete_table(0, ndb, full_path, dbname, tabname)) { const NdbError err= dict->getNdbError(); Loading @@ -5857,6 +5858,7 @@ int ndbcluster_drop_database_impl(const char *path) ret= ndb_to_mysql_error(&err); } } VOID(pthread_mutex_unlock(&LOCK_open)); } DBUG_RETURN(ret); } Loading sql/ha_ndbcluster_binlog.cc +1 −0 Original line number Diff line number Diff line Loading @@ -286,6 +286,7 @@ ndbcluster_binlog_open_table(THD *thd, NDB_SHARE *share, int error; DBUG_ENTER("ndbcluster_binlog_open_table"); safe_mutex_assert_owner(&LOCK_open); init_tmp_table_share(table_share, share->db, 0, share->table_name, share->key); if ((error= open_table_def(thd, table_share, 0))) Loading Loading
sql/ha_ndbcluster.cc +2 −0 Original line number Diff line number Diff line Loading @@ -5848,6 +5848,7 @@ int ndbcluster_drop_database_impl(const char *path) while ((tabname=it++)) { tablename_to_filename(tabname, tmp, FN_REFLEN - (tmp - full_path)-1); VOID(pthread_mutex_lock(&LOCK_open)); if (ha_ndbcluster::delete_table(0, ndb, full_path, dbname, tabname)) { const NdbError err= dict->getNdbError(); Loading @@ -5857,6 +5858,7 @@ int ndbcluster_drop_database_impl(const char *path) ret= ndb_to_mysql_error(&err); } } VOID(pthread_mutex_unlock(&LOCK_open)); } DBUG_RETURN(ret); } Loading
sql/ha_ndbcluster_binlog.cc +1 −0 Original line number Diff line number Diff line Loading @@ -286,6 +286,7 @@ ndbcluster_binlog_open_table(THD *thd, NDB_SHARE *share, int error; DBUG_ENTER("ndbcluster_binlog_open_table"); safe_mutex_assert_owner(&LOCK_open); init_tmp_table_share(table_share, share->db, 0, share->table_name, share->key); if ((error= open_table_def(thd, table_share, 0))) Loading