return &insert.first->second;
}
-int RGWMetadataManager::store_md_log_entries(list<cls_log_entry>& entries,
- const std::string& period, int shard_id,
- librados::AioCompletion *completion)
-{
- auto md_log = get_log(period);
- return md_log->store_entries_in_shard(entries, shard_id, completion);
-}
-
int RGWMetadataManager::register_handler(RGWMetadataHandler *handler)
{
string type = handler->get_type();
RGWMetadataHandler *get_handler(const string& type);
- int store_md_log_entries(list<cls_log_entry>& entries, const std::string& period,
- int shard_id, librados::AioCompletion *completion);
-
int put_entry(RGWMetadataHandler *handler, const string& key, bufferlist& bl, bool exclusive,
RGWObjVersionTracker *objv_tracker, time_t mtime, map<string, bufferlist> *pattrs = NULL);
int remove_entry(RGWMetadataHandler *handler, string& key, RGWObjVersionTracker *objv_tracker);
RGWAioCompletionNotifier *cn = stack->create_completion_notifier();
- RGWRados *store = sync_env->store;
- int ret = store->meta_mgr->store_md_log_entries(dest_entries, shard_id, cn->completion());
+ int ret = mdlog->store_entries_in_shard(dest_entries, shard_id, cn->completion());
if (ret < 0) {
cn->put();
ldout(cct, 10) << "failed to store md log entries shard_id=" << shard_id << " ret=" << ret << dendl;