summaryrefslogtreecommitdiff
path: root/sql
diff options
context:
space:
mode:
authorOleksandr Byelkin <sanja@mariadb.com>2021-10-28 13:57:15 +0200
committerOleksandr Byelkin <sanja@mariadb.com>2021-10-28 13:57:15 +0200
commit89f69c62cfc2fb88de8fd4f5c9e4deaf0a27db73 (patch)
treeb7c175c014238c50d55a306698f89036ffeeb643 /sql
parent3a79e5fd317316c293baa459e8296fdb0744c280 (diff)
parent2ddea602ce18054ad5b6130a692b509506d2bde7 (diff)
downloadmariadb-git-89f69c62cfc2fb88de8fd4f5c9e4deaf0a27db73.tar.gz
Merge branch '10.3' into 10.4
Diffstat (limited to 'sql')
-rw-r--r--sql/sql_cursor.h4
-rw-r--r--sql/sql_prepare.h4
-rw-r--r--sql/threadpool_generic.cc4
3 files changed, 8 insertions, 4 deletions
diff --git a/sql/sql_cursor.h b/sql/sql_cursor.h
index 00b9cd4e67a..b9d0b41ea19 100644
--- a/sql/sql_cursor.h
+++ b/sql/sql_cursor.h
@@ -39,7 +39,7 @@ class JOIN;
its base class.
*/
-class Server_side_cursor: protected Query_arena, public Sql_alloc
+class Server_side_cursor: protected Query_arena
{
protected:
/** Row destination used for fetch */
@@ -61,6 +61,8 @@ public:
}
virtual ~Server_side_cursor();
+ static void *operator new(size_t size, MEM_ROOT *mem_root)
+ { return alloc_root(mem_root, size); }
static void operator delete(void *ptr, size_t size);
static void operator delete(void *, MEM_ROOT *){}
};
diff --git a/sql/sql_prepare.h b/sql/sql_prepare.h
index f1c4e5e4be9..acdaa9a67a7 100644
--- a/sql/sql_prepare.h
+++ b/sql/sql_prepare.h
@@ -115,7 +115,7 @@ class Ed_row;
automatic type conversion.
*/
-class Ed_result_set: public Sql_alloc
+class Ed_result_set
{
public:
operator List<Ed_row>&() { return *m_rows; }
@@ -129,6 +129,8 @@ public:
size_t get_field_count() const { return m_column_count; }
+ static void *operator new(size_t size, MEM_ROOT *mem_root)
+ { return alloc_root(mem_root, size); }
static void operator delete(void *ptr, size_t size) throw ();
static void operator delete(void *, MEM_ROOT *){}
private:
diff --git a/sql/threadpool_generic.cc b/sql/threadpool_generic.cc
index 3f4997b8238..c129f518674 100644
--- a/sql/threadpool_generic.cc
+++ b/sql/threadpool_generic.cc
@@ -1791,9 +1791,9 @@ static void print_pool_blocked_message(bool max_threads_reached)
if (now > pool_block_start + BLOCK_MSG_DELAY && !msg_written)
{
if (max_threads_reached)
- sql_print_error(MAX_THREADS_REACHED_MSG);
+ sql_print_warning(MAX_THREADS_REACHED_MSG);
else
- sql_print_error(CREATE_THREAD_ERROR_MSG, my_errno);
+ sql_print_warning(CREATE_THREAD_ERROR_MSG, my_errno);
sql_print_information("Threadpool has been blocked for %u seconds\n",
(uint)((now- pool_block_start)/1000000));