Commit da76c1bd authored by Marko Mäkelä's avatar Marko Mäkelä

Minor cleanup

parent ce3ffefc
/***************************************************************************** /*****************************************************************************
Copyright (c) 1995, 2015, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 1995, 2015, Oracle and/or its affiliates. All Rights Reserved.
Copyright (c) 2013, 2017, MariaDB Corporation. All Rights Reserved. Copyright (c) 2013, 2017, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify it under 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 the terms of the GNU General Public License as published by the Free Software
...@@ -168,8 +168,7 @@ doublewrite buffer is placed on the trx system header page. ...@@ -168,8 +168,7 @@ doublewrite buffer is placed on the trx system header page.
@return true if successful, false if not. */ @return true if successful, false if not. */
MY_ATTRIBUTE((warn_unused_result)) MY_ATTRIBUTE((warn_unused_result))
bool bool
buf_dblwr_create(void) buf_dblwr_create()
/*==================*/
{ {
buf_block_t* block2; buf_block_t* block2;
buf_block_t* new_block; buf_block_t* new_block;
...@@ -510,7 +509,7 @@ buf_dblwr_init_or_load_pages( ...@@ -510,7 +509,7 @@ buf_dblwr_init_or_load_pages(
/** Process and remove the double write buffer pages for all tablespaces. */ /** Process and remove the double write buffer pages for all tablespaces. */
void void
buf_dblwr_process(void) buf_dblwr_process()
{ {
ulint page_no_dblwr = 0; ulint page_no_dblwr = 0;
byte* read_buf; byte* read_buf;
...@@ -527,9 +526,7 @@ buf_dblwr_process(void) ...@@ -527,9 +526,7 @@ buf_dblwr_process(void)
i != recv_dblwr.pages.end(); i != recv_dblwr.pages.end();
++i, ++page_no_dblwr) { ++i, ++page_no_dblwr) {
byte* page = *i; byte* page = *i;
ulint page_no = page_get_page_no(page);
ulint space_id = page_get_space_id(page); ulint space_id = page_get_space_id(page);
fil_space_t* space = fil_space_get(space_id); fil_space_t* space = fil_space_get(space_id);
if (space == NULL) { if (space == NULL) {
...@@ -540,6 +537,7 @@ buf_dblwr_process(void) ...@@ -540,6 +537,7 @@ buf_dblwr_process(void)
fil_space_open_if_needed(space); fil_space_open_if_needed(space);
const ulint page_no = page_get_page_no(page);
const page_id_t page_id(space_id, page_no); const page_id_t page_id(space_id, page_no);
if (page_no >= space->size) { if (page_no >= space->size) {
...@@ -676,8 +674,7 @@ buf_dblwr_process(void) ...@@ -676,8 +674,7 @@ buf_dblwr_process(void)
/****************************************************************//** /****************************************************************//**
Frees doublewrite buffer. */ Frees doublewrite buffer. */
void void
buf_dblwr_free(void) buf_dblwr_free()
/*================*/
{ {
/* Free the double write data structures. */ /* Free the double write data structures. */
ut_a(buf_dblwr != NULL); ut_a(buf_dblwr != NULL);
...@@ -932,8 +929,7 @@ important to call this function after a batch of writes has been posted, ...@@ -932,8 +929,7 @@ important to call this function after a batch of writes has been posted,
and also when we may have to wait for a page latch! Otherwise a deadlock and also when we may have to wait for a page latch! Otherwise a deadlock
of threads can occur. */ of threads can occur. */
void void
buf_dblwr_flush_buffered_writes(void) buf_dblwr_flush_buffered_writes()
/*=================================*/
{ {
byte* write_buf; byte* write_buf;
ulint first_free; ulint first_free;
......
/***************************************************************************** /*****************************************************************************
Copyright (c) 1995, 2016, Oracle and/or its affiliates. All Rights Reserved. Copyright (c) 1995, 2016, Oracle and/or its affiliates. All Rights Reserved.
Copyright (c) 2017, MariaDB Corporation. All Rights Reserved. Copyright (c) 2017, MariaDB Corporation.
This program is free software; you can redistribute it and/or modify it under 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 the terms of the GNU General Public License as published by the Free Software
...@@ -44,8 +44,7 @@ doublewrite buffer is placed on the trx system header page. ...@@ -44,8 +44,7 @@ doublewrite buffer is placed on the trx system header page.
@return true if successful, false if not. */ @return true if successful, false if not. */
MY_ATTRIBUTE((warn_unused_result)) MY_ATTRIBUTE((warn_unused_result))
bool bool
buf_dblwr_create(void); buf_dblwr_create();
/*==================*/
/****************************************************************//** /****************************************************************//**
At a database startup initializes the doublewrite buffer memory structure if At a database startup initializes the doublewrite buffer memory structure if
...@@ -61,13 +60,13 @@ buf_dblwr_init_or_load_pages( ...@@ -61,13 +60,13 @@ buf_dblwr_init_or_load_pages(
/** Process and remove the double write buffer pages for all tablespaces. */ /** Process and remove the double write buffer pages for all tablespaces. */
void void
buf_dblwr_process(void); buf_dblwr_process();
/****************************************************************//** /****************************************************************//**
frees doublewrite buffer. */ frees doublewrite buffer. */
void void
buf_dblwr_free(void); buf_dblwr_free();
/*================*/
/********************************************************************//** /********************************************************************//**
Updates the doublewrite buffer when an IO request is completed. */ Updates the doublewrite buffer when an IO request is completed. */
void void
...@@ -105,8 +104,8 @@ important to call this function after a batch of writes has been posted, ...@@ -105,8 +104,8 @@ important to call this function after a batch of writes has been posted,
and also when we may have to wait for a page latch! Otherwise a deadlock and also when we may have to wait for a page latch! Otherwise a deadlock
of threads can occur. */ of threads can occur. */
void void
buf_dblwr_flush_buffered_writes(void); buf_dblwr_flush_buffered_writes();
/*=================================*/
/********************************************************************//** /********************************************************************//**
Writes a page to the doublewrite buffer on disk, sync it, then write Writes a page to the doublewrite buffer on disk, sync it, then write
the page to the datafile and sync the datafile. This function is used the page to the datafile and sync the datafile. This function is used
......
...@@ -2986,7 +2986,7 @@ recv_init_missing_space(dberr_t err, const recv_spaces_t::const_iterator& i) ...@@ -2986,7 +2986,7 @@ recv_init_missing_space(dberr_t err, const recv_spaces_t::const_iterator& i)
@return error code or DB_SUCCESS */ @return error code or DB_SUCCESS */
static MY_ATTRIBUTE((warn_unused_result)) static MY_ATTRIBUTE((warn_unused_result))
dberr_t dberr_t
recv_init_crash_recovery_spaces(void) recv_init_crash_recovery_spaces()
{ {
typedef std::set<ulint> space_set_t; typedef std::set<ulint> space_set_t;
bool flag_deleted = false; bool flag_deleted = false;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment