RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-29 23:09:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

rgw:multisite: clean up RGWRemoteDataLog unused function

Browse Source 
'RGWRemoteDataLog::get_shard_info' function not used, drop it

Signed-off-by: Shasha Lu <lu.shasha@eisoo.com>
This commit is contained in:
lu.shasha 2017-07-10 16:14:55 +08:00
parent 5a197c5817
commit c8e07379b0
2 changed files with 0 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/rgw/rgw_data_sync.cc
View File

@ -635,28 +635,6 @@ void RGWRemoteDataLog::finish()
stop();
}
int RGWRemoteDataLog::get_shard_info(int shard_id)
{
char buf[32];
snprintf(buf, sizeof(buf), "%d", shard_id);
rgw_http_param_pair pairs[] = { { "type", "data" },
{ "id", buf },
{ "info", NULL },
{ NULL, NULL } };
RGWDataChangesLogInfo info;
int ret = sync_env.conn->get_json_resource("/admin/log", pairs, info);
if (ret < 0) {
ldout(store->ctx(), 0) << "ERROR: failed to fetch datalog info" << dendl;
return ret;
}
ldout(store->ctx(), 20) << "remote datalog, shard_id=" << shard_id << " marker=" << info.marker << dendl;
return 0;
}
int RGWRemoteDataLog::read_sync_status(rgw_data_sync_status *sync_status)
{
// cannot run concurrently with run_sync(), so run in a separate manager

1
src/rgw/rgw_data_sync.h
View File

@ -262,7 +262,6 @@ public:
int read_log_info(rgw_datalog_info *log_info);
int read_source_log_shards_info(map<int, RGWDataChangesLogInfo> *shards_info);
int read_source_log_shards_next(map<int, string> shard_markers, map<int, rgw_datalog_shard_data> *result);
int get_shard_info(int shard_id);
int read_sync_status(rgw_data_sync_status *sync_status);
int init_sync_status(int num_shards);
int run_sync(int num_shards);