mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 13:02:28 +01:00
ebfc4e6ad0
copy of
commit 86587affafe77ef555f7c3839839de44f0f203f3
Author: Tian Xia <tianx@fb.com>
Date: Tue Oct 4 10:01:52 2016 -0700
Allow filtering of show commands through admission control
93 lines
2.6 KiB
C++
93 lines
2.6 KiB
C++
/*
|
|
Copyright (c) 2012,2015 Monty Program Ab
|
|
|
|
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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
#pragma once
|
|
|
|
/* C++ system header files */
|
|
#include <string>
|
|
|
|
/* MySQL includes */
|
|
#include "./m_ctype.h"
|
|
|
|
/* RocksDB header files */
|
|
#include "rocksdb/comparator.h"
|
|
|
|
namespace myrocks {
|
|
|
|
/*
|
|
The keys are in form: {index_number} {mem-comparable-key}
|
|
|
|
(todo: knowledge about this format is shared between this class and
|
|
Rdb_key_def)
|
|
*/
|
|
class Rdb_pk_comparator : public rocksdb::Comparator
|
|
{
|
|
public:
|
|
static int bytewise_compare(const rocksdb::Slice& a, const rocksdb::Slice& b)
|
|
{
|
|
size_t a_size= a.size();
|
|
size_t b_size= b.size();
|
|
size_t len= (a_size < b_size) ? a_size : b_size;
|
|
int res;
|
|
|
|
if ((res= memcmp(a.data(), b.data(), len)))
|
|
return res;
|
|
|
|
/* Ok, res== 0 */
|
|
if (a_size != b_size)
|
|
{
|
|
return a_size < b_size? -1 : 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
/* Override virtual methods of interest */
|
|
|
|
int Compare(const rocksdb::Slice& a, const rocksdb::Slice& b) const override
|
|
{
|
|
return bytewise_compare(a,b);
|
|
}
|
|
|
|
const char* Name() const override { return "RocksDB_SE_v3.10"; }
|
|
|
|
//TODO: advanced funcs:
|
|
// - FindShortestSeparator
|
|
// - FindShortSuccessor
|
|
|
|
// for now, do-nothing implementations:
|
|
void FindShortestSeparator(std::string* start,
|
|
const rocksdb::Slice& limit) const override {}
|
|
void FindShortSuccessor(std::string* key) const override {}
|
|
};
|
|
|
|
class Rdb_rev_comparator : public rocksdb::Comparator
|
|
{
|
|
public:
|
|
static int bytewise_compare(const rocksdb::Slice& a, const rocksdb::Slice& b)
|
|
{
|
|
return -Rdb_pk_comparator::bytewise_compare(a, b);
|
|
}
|
|
|
|
int Compare(const rocksdb::Slice& a, const rocksdb::Slice& b) const override
|
|
{
|
|
return -Rdb_pk_comparator::bytewise_compare(a, b);
|
|
}
|
|
const char* Name() const override { return "rev:RocksDB_SE_v3.10"; }
|
|
void FindShortestSeparator(std::string* start,
|
|
const rocksdb::Slice& limit) const override {}
|
|
void FindShortSuccessor(std::string* key) const override {}
|
|
};
|
|
|
|
} // namespace myrocks
|