config: Move ks_meta_data implementation to .cc file

Move ks_meta_data code out of line in preparation for switching to the
user_types_metadata type that is defined in database.hh.

Signed-off-by: Pekka Enberg <penberg@cloudius-systems.com>
This commit is contained in:
Pekka Enberg
2015-05-18 15:40:25 +03:00
parent d9d16a37b3
commit c1aed8a712
3 changed files with 91 additions and 38 deletions

85
config/ks_meta_data.cc Normal file
View File

@@ -0,0 +1,85 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
/*
* Copyright 2015 Cloudius Systems
*
* Modified by Cloudius Systems
*/
#include "config/ks_meta_data.hh"
namespace config {
ks_meta_data::ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_)
: ks_meta_data{std::move(name_),
std::move(strategy_name_),
std::move(strategy_options_),
durable_writes_,
{}, ::make_shared<ut_meta_data>()}
{ }
ks_meta_data::ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_,
std::vector<schema_ptr> cf_defs)
: ks_meta_data{std::move(name_),
std::move(strategy_name_),
std::move(strategy_options_),
durable_writes_,
std::move(cf_defs),
::make_shared<ut_meta_data>()}
{ }
ks_meta_data::ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_,
std::vector<schema_ptr> cf_defs,
shared_ptr<ut_meta_data> user_types_)
: name{std::move(name_)}
, strategy_name{strategy_name_.empty() ? "NetworkTopologyStrategy" : strategy_name_}
, strategy_options{std::move(strategy_options_)}
, durable_writes{durable_writes_}
, user_types{std::move(user_types_)}
{
for (auto&& s : cf_defs) {
_cf_meta_data.emplace(s->cf_name(), s);
}
}
// For new user created keyspaces (through CQL)
lw_shared_ptr<ks_meta_data> ks_meta_data::new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durable_writes) {
#if 0
Class<? extends AbstractReplicationStrategy> cls = AbstractReplicationStrategy.getClass(strategyName);
if (cls.equals(LocalStrategy.class))
throw new ConfigurationException("Unable to use given strategy class: LocalStrategy is reserved for internal use.");
#endif
return new_keyspace(name, strategy_name, options, durable_writes, std::vector<schema_ptr>{});
}
lw_shared_ptr<ks_meta_data> ks_meta_data::new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durables_writes, std::vector<schema_ptr> cf_defs)
{
return ::make_lw_shared<ks_meta_data>(name, strategy_name, options, durables_writes, cf_defs, ::make_shared<ut_meta_data>());
}
}

View File

@@ -48,58 +48,25 @@ public:
ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_)
: ks_meta_data{std::move(name_),
std::move(strategy_name_),
std::move(strategy_options_),
durable_writes_,
{}, ::make_shared<ut_meta_data>()}
{ }
bool durable_writes_);
ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_,
std::vector<schema_ptr> cf_defs)
: ks_meta_data{std::move(name_),
std::move(strategy_name_),
std::move(strategy_options_),
durable_writes_,
std::move(cf_defs),
::make_shared<ut_meta_data>()}
{ }
std::vector<schema_ptr> cf_defs);
ks_meta_data(sstring name_,
sstring strategy_name_,
std::unordered_map<sstring, sstring> strategy_options_,
bool durable_writes_,
std::vector<schema_ptr> cf_defs,
shared_ptr<ut_meta_data> user_types_)
: name{std::move(name_)}
, strategy_name{strategy_name_.empty() ? "NetworkTopologyStrategy" : strategy_name_}
, strategy_options{std::move(strategy_options_)}
, durable_writes{durable_writes_}
, user_types{std::move(user_types_)}
{
for (auto&& s : cf_defs) {
_cf_meta_data.emplace(s->cf_name(), s);
}
}
shared_ptr<ut_meta_data> user_types_);
// For new user created keyspaces (through CQL)
static lw_shared_ptr<ks_meta_data> new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durable_writes) {
#if 0
Class<? extends AbstractReplicationStrategy> cls = AbstractReplicationStrategy.getClass(strategyName);
if (cls.equals(LocalStrategy.class))
throw new ConfigurationException("Unable to use given strategy class: LocalStrategy is reserved for internal use.");
#endif
return new_keyspace(name, strategy_name, options, durable_writes, std::vector<schema_ptr>{});
}
static lw_shared_ptr<ks_meta_data> new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durable_writes);
static lw_shared_ptr<ks_meta_data> new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durables_writes, std::vector<schema_ptr> cf_defs)
{
return ::make_lw_shared<ks_meta_data>(name, strategy_name, options, durables_writes, cf_defs, ::make_shared<ut_meta_data>());
}
static lw_shared_ptr<ks_meta_data> new_keyspace(sstring name, sstring strategy_name, std::unordered_map<sstring, sstring> options, bool durables_writes, std::vector<schema_ptr> cf_defs);
#if 0
public KSMetaData cloneWithTableRemoved(CFMetaData table)

View File

@@ -365,6 +365,7 @@ urchin_core = (['database.cc',
'sstables/partition.cc',
'log.cc',
'transport/server.cc',
'config/ks_meta_data.cc',
'cql3/abstract_marker.cc',
'cql3/cql3.cc',
'cql3/cql3_type.cc',