mirror of
https://github.com/MariaDB/server.git
synced 2025-08-27 04:41:35 +02:00
e29ad9929a
buf_read_page(): Return a pointer to a buffer-fixed, non-read-fixed page, or nullptr in case of an error. buf_inc_get(): Wrapper for buf_inc_get(ha_handler_stats*), to read the thread-local variable mariadb_stats before updating it. IORequest::read_complete(): Assert that the page is both read-fixed and buffer-fixed. Sample recv_sys.recovery_on only once. Buffer-unfix the page when the asynchronous read completes. buf_page_t::read_complete(): Assert that the page is both read-fixed and buffer-fixed. buf_page_t::read_wait(): Wait for a read-fixed and buffer-fixed page to be only buffer-fixed, by acquiring a shared latch. buf_page_init_for_read(): Return a pointer to a buffer-fixed block descriptor pointer, bitwise-ORed with 1 in case the block already exists in the buffer pool. buf_read_ahead_update(), buf_read_ahead_update_sql(): Common code for updating some statistics counters. buf_read_page_low(): Replace the parameter sync with err, which will return an error code to a synchronous caller. Add a parameter for thread-local mariadb_stats. Return the pointer to the block, or the special values nullptr (read failure) or -1 or -2 for asynchronous reads. Increment the statistics when a synchronous read was requested. In a synchronous read, if the page has already been allocated in the buffer pool but it is read-fixed, wait for the read to complete. buf_page_get_zip(): Get a buffer-fixed page from buf_read_page(), and unfix() it. Our caller is relying solely on a page latch. buf_read_page_background(): Update the statistics if supplied.
118 lines
2.9 KiB
C++
118 lines
2.9 KiB
C++
/*****************************************************************************
|
|
|
|
Copyright (c) 2023, MariaDB Foundation
|
|
|
|
This program is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU General Public License as published by the Free Software
|
|
Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful, but WITHOUT
|
|
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
|
|
FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along with
|
|
this program; if not, write to the Free Software Foundation, Inc.,
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA
|
|
|
|
*****************************************************************************/
|
|
|
|
#pragma once
|
|
|
|
#include "ha_handler_stats.h"
|
|
#include "my_rdtsc.h"
|
|
|
|
/* We do not want a dynamic initialization function to be
|
|
conditionally invoked on each access to a C++11 extern thread_local. */
|
|
#if __cplusplus >= 202002L
|
|
# define simple_thread_local constinit thread_local
|
|
#else
|
|
# define simple_thread_local IF_WIN(__declspec(thread),__thread)
|
|
#endif
|
|
|
|
/** Pointer to handler::active_handler_stats or nullptr (via .tbss) */
|
|
extern simple_thread_local ha_handler_stats *mariadb_stats;
|
|
|
|
/*
|
|
Returns nonzero if MariaDB wants engine status
|
|
*/
|
|
|
|
inline uint mariadb_stats_active()
|
|
{
|
|
if (ha_handler_stats *stats= mariadb_stats)
|
|
return stats->active;
|
|
return 0;
|
|
}
|
|
|
|
/* The following functions increment different engine status */
|
|
|
|
inline void mariadb_increment_pages_accessed(ha_handler_stats *stats)
|
|
{
|
|
if (stats)
|
|
stats->pages_accessed++;
|
|
}
|
|
|
|
inline void mariadb_increment_pages_accessed()
|
|
{
|
|
mariadb_increment_pages_accessed(mariadb_stats);
|
|
}
|
|
|
|
inline void mariadb_increment_pages_updated(ulonglong count)
|
|
{
|
|
if (ha_handler_stats *stats= mariadb_stats)
|
|
stats->pages_updated+= count;
|
|
}
|
|
|
|
inline void mariadb_increment_pages_read(ha_handler_stats *stats)
|
|
{
|
|
if (stats)
|
|
stats->pages_read_count++;
|
|
}
|
|
|
|
inline void mariadb_increment_pages_read()
|
|
{
|
|
mariadb_increment_pages_read(mariadb_stats);
|
|
}
|
|
|
|
inline void mariadb_increment_undo_records_read()
|
|
{
|
|
if (ha_handler_stats *stats= mariadb_stats)
|
|
stats->undo_records_read++;
|
|
}
|
|
|
|
inline void mariadb_increment_pages_prefetched(ulint n_pages)
|
|
{
|
|
if (ha_handler_stats *stats= mariadb_stats)
|
|
stats->pages_prefetched += n_pages;
|
|
}
|
|
|
|
/*
|
|
The following has to be identical code as measure() in sql_analyze_stmt.h
|
|
|
|
One should only call this if mariadb_stats_active() is true.
|
|
*/
|
|
|
|
inline ulonglong mariadb_measure()
|
|
{
|
|
#if (MY_TIMER_ROUTINE_CYCLES)
|
|
return my_timer_cycles();
|
|
#else
|
|
return my_timer_microseconds();
|
|
#endif
|
|
}
|
|
|
|
/*
|
|
Helper class to set mariadb_stats temporarly for one call in handler.cc
|
|
*/
|
|
|
|
class mariadb_set_stats
|
|
{
|
|
public:
|
|
mariadb_set_stats(ha_handler_stats *stats)
|
|
{
|
|
mariadb_stats= stats;
|
|
}
|
|
~mariadb_set_stats()
|
|
{
|
|
mariadb_stats= nullptr;
|
|
}
|
|
};
|