polardbxengine/storage/innobase/include/fsp0space.h

215 lines
6.4 KiB
C++

/*****************************************************************************
Copyright (c) 2013, 2019, Oracle and/or its affiliates. All Rights Reserved.
This program is free software; you can redistribute it and/or modify it under
the terms of the GNU General Public License, version 2.0, as published by the
Free Software Foundation.
This program is also distributed with certain software (including but not
limited to OpenSSL) that is licensed under separate terms, as designated in a
particular file or component or in included license documentation. The authors
of MySQL hereby grant you an additional permission to link the program and
your derivative works with the separately licensed software that they have
included with MySQL.
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, version 2.0,
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 St, Fifth Floor, Boston, MA 02110-1301 USA
*****************************************************************************/
/** @file include/fsp0space.h
General shared tablespace implementation.
Created 2013-7-26 by Kevin Lewis
*******************************************************/
#ifndef fsp0space_h
#define fsp0space_h
#include "fsp0file.h"
#include "fsp0fsp.h"
#include "fsp0types.h"
#include "univ.i"
#include "ut0new.h"
#include <vector>
/** Data structure that contains the information about shared tablespaces.
Currently this can be the system tablespace or a temporary table tablespace */
class Tablespace {
public:
typedef std::vector<Datafile, ut_allocator<Datafile>> files_t;
/** Data file information - each Datafile can be accessed globally */
files_t m_files;
Tablespace()
: m_files(),
m_name(),
m_space_id(SPACE_UNKNOWN),
m_path(),
m_flags(),
m_ignore_read_only(false) {
/* No op */
}
virtual ~Tablespace() {
shutdown();
ut_ad(m_files.empty());
ut_ad(m_space_id == SPACE_UNKNOWN);
if (m_name != NULL) {
ut_free(m_name);
m_name = NULL;
}
if (m_path != NULL) {
ut_free(m_path);
m_path = NULL;
}
}
// Disable copying
Tablespace(const Tablespace &);
Tablespace &operator=(const Tablespace &);
/** Set tablespace name
@param[in] name tablespace name */
void set_name(const char *name) {
ut_ad(m_name == NULL);
m_name = mem_strdup(name);
ut_ad(m_name != NULL);
}
/** Get tablespace name
@return tablespace name */
const char *name() const { return (m_name); }
/** Set tablespace path and filename members.
@param[in] path where tablespace file(s) resides
@param[in] len length of the file path */
void set_path(const char *path, size_t len) {
ut_ad(m_path == NULL);
m_path = mem_strdupl(path, len);
ut_ad(m_path != NULL);
Fil_path::normalize(m_path);
}
/** Set tablespace path and filename members.
@param[in] path where tablespace file(s) resides */
void set_path(const char *path) { set_path(path, strlen(path)); }
/** Get tablespace path
@return tablespace path */
const char *path() const { return (m_path); }
/** Set the space id of the tablespace
@param[in] space_id tablespace ID to set */
void set_space_id(space_id_t space_id) {
ut_ad(m_space_id == SPACE_UNKNOWN);
m_space_id = space_id;
}
/** Get the space id of the tablespace
@return m_space_id space id of the tablespace */
space_id_t space_id() const { return (m_space_id); }
/** Set the tablespace flags
@param[in] fsp_flags tablespace flags */
void set_flags(uint32_t fsp_flags) {
ut_ad(fsp_flags_is_valid(fsp_flags));
m_flags = fsp_flags;
}
/** Get the tablespace flags
@return m_flags tablespace flags */
uint32_t flags() const { return (m_flags); }
/** Set Ignore Read Only Status for tablespace.
@param[in] read_only_status read only status indicator */
void set_ignore_read_only(bool read_only_status) {
m_ignore_read_only = read_only_status;
}
/** Free the memory allocated by the Tablespace object */
void shutdown();
/** @return the sum of the file sizes of each Datafile */
page_no_t get_sum_of_sizes() const {
page_no_t sum = 0;
for (files_t::const_iterator it = m_files.begin(); it != m_files.end();
++it) {
sum += it->m_size;
}
return (sum);
}
/** Open or Create the data files if they do not exist.
@param[in] is_temp whether this is a temporary tablespace
@return DB_SUCCESS or error code */
dberr_t open_or_create(bool is_temp) MY_ATTRIBUTE((warn_unused_result));
/** Delete all the data files. */
void delete_files();
/** Check if two tablespaces have common data file names.
@param[in] other_space Tablespace to check against this.
@return true if they have the same data filenames and paths */
bool intersection(const Tablespace *other_space);
/** Use the ADD DATAFILE path to create a Datafile object and add
it to the front of m_files. Parse the datafile path into a path
and a basename with extension 'ibd'. This datafile_path provided
may be an absolute or relative path, but it must end with the
extension .ibd and have a basename of at least 1 byte.
Set tablespace m_path member and add a Datafile with the filename.
@param[in] datafile_added full path of the tablespace file. */
dberr_t add_datafile(const char *datafile_added);
/* Return a pointer to the first Datafile for this Tablespace
@return pointer to the first Datafile for this Tablespace*/
Datafile *first_datafile() {
ut_a(!m_files.empty());
return (&m_files.front());
}
private:
/**
@param[in] filename Name to lookup in the data files.
@return true if the filename exists in the data files */
bool find(const char *filename);
/** Note that the data file was found.
@param[in] file data file object */
void file_found(Datafile &file);
/* DATA MEMBERS */
/** Name of the tablespace. */
char *m_name;
/** Tablespace ID */
space_id_t m_space_id;
/** Path where tablespace files will reside, not including a filename.*/
char *m_path;
/** Tablespace flags */
uint32_t m_flags;
protected:
/** Ignore server read only configuration for this tablespace. */
bool m_ignore_read_only;
};
#endif /* fsp0space_h */