std::string create_one_pool_pp(const std::string &pool_name, Rados &cluster)
{
- char *id = getenv("CEPH_CLIENT_ID");
- if (id) std::cerr << "Client id is: " << id << std::endl;
-
- int ret;
- ret = cluster.init(id);
- if (ret) {
- std::ostringstream oss;
- oss << "cluster.init failed with error " << ret;
- return oss.str();
- }
- ret = cluster.conf_read_file(NULL);
- if (ret) {
- cluster.shutdown();
- std::ostringstream oss;
- oss << "cluster.conf_read_file failed with error " << ret;
- return oss.str();
- }
- cluster.conf_parse_env(NULL);
- ret = cluster.connect();
- if (ret) {
- cluster.shutdown();
- std::ostringstream oss;
- oss << "cluster.connect failed with error " << ret;
- return oss.str();
- }
- ret = cluster.pool_create(pool_name.c_str());
+ std::string err = connect_cluster_pp(cluster);
+ if (err.length())
+ return err;
+ int ret = cluster.pool_create(pool_name.c_str());
if (ret) {
cluster.shutdown();
std::ostringstream oss;