diff options
author | mkaruza <mario.karuza@galeracluster.com> | 2021-11-22 13:04:40 +0100 |
---|---|---|
committer | Jan Lindström <jan.lindstrom@mariadb.com> | 2022-08-02 17:24:28 +0300 |
commit | 9743d0043e8fc248043e2d98e7fa4197557ac59d (patch) | |
tree | 538ced1c84e51f7511649701a9ced11a0792891a /sql/wsrep_allowlist_service.cc | |
parent | b3372d642265237aaa25e45c73d337068c1d5d1a (diff) | |
download | mariadb-git-9743d0043e8fc248043e2d98e7fa4197557ac59d.tar.gz |
MDEV-27246 Implement a method to add IPs to allowlist for Galera Cluster node addresses that can make SST/IST requests
Reviewed-by: Jan Lindström <jan.lindstrom@mariadb.com>
Diffstat (limited to 'sql/wsrep_allowlist_service.cc')
-rw-r--r-- | sql/wsrep_allowlist_service.cc | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/sql/wsrep_allowlist_service.cc b/sql/wsrep_allowlist_service.cc new file mode 100644 index 00000000000..22b7edfd23b --- /dev/null +++ b/sql/wsrep_allowlist_service.cc @@ -0,0 +1,54 @@ +/* Copyright 2021 Codership Oy <info@codership.com> + + 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 St, Fifth Floor, Boston, MA 02110-1301 USA */ + +#include "wsrep_allowlist_service.h" + +#include "my_global.h" +#include "wsrep_mysqld.h" +#include "wsrep_priv.h" + +#include <algorithm> +#include <memory> +#include <vector> + +class Wsrep_allowlist_service : public wsrep::allowlist_service +{ +public: + bool allowlist_cb(wsrep::allowlist_service::allowlist_key key, + const wsrep::const_buffer& value) WSREP_NOEXCEPT override; +}; + +bool Wsrep_allowlist_service::allowlist_cb ( + wsrep::allowlist_service::allowlist_key key, + const wsrep::const_buffer& value) + WSREP_NOEXCEPT +{ + std::string string_value(value.data()); + return (wsrep_schema->allowlist_check(key, string_value)); +} + +std::unique_ptr<wsrep::allowlist_service> entrypoint; + +wsrep::allowlist_service* wsrep_allowlist_service_init() +{ + entrypoint = std::unique_ptr<wsrep::allowlist_service>(new Wsrep_allowlist_service); + return entrypoint.get(); +} + +void wsrep_allowlist_service_deinit() +{ + entrypoint.reset(); +} + |