T::finalize_watch();
T::finalize();
}
- int distribute(const string& normal_name, rgw_obj& obj, ObjectCacheInfo& obj_info, int op);
+ int distribute_cache(const string& normal_name, rgw_obj& obj, ObjectCacheInfo& obj_info, int op);
int watch_cb(int opcode, uint64_t ver, bufferlist& bl);
public:
RGWCache() {}
cache.remove(name);
ObjectCacheInfo info;
- distribute(name, obj, info, REMOVE_OBJ);
+ distribute_cache(name, obj, info, REMOVE_OBJ);
return T::delete_obj(ctx, obj);
}
string name = normal_name(bucket, oid);
if (ret >= 0) {
cache.put(name, info);
- int r = distribute(name, obj, info, UPDATE_OBJ);
+ int r = distribute_cache(name, obj, info, UPDATE_OBJ);
if (r < 0)
mydout(0) << "ERROR: failed to distribute cache for " << obj << dendl;
} else {
string name = normal_name(bucket, oid);
if (ret >= 0) {
cache.put(name, info);
- int r = distribute(name, obj, info, UPDATE_OBJ);
+ int r = distribute_cache(name, obj, info, UPDATE_OBJ);
if (r < 0)
mydout(0) << "ERROR: failed to distribute cache for " << obj << dendl;
} else {
string name = normal_name(bucket, oid);
if (ret >= 0) {
cache.put(name, info);
- int r = distribute(name, obj, info, UPDATE_OBJ);
+ int r = distribute_cache(name, obj, info, UPDATE_OBJ);
if (r < 0)
mydout(0) << "ERROR: failed to distribute cache for " << obj << dendl;
} else {
string name = normal_name(bucket, oid);
if (ret >= 0) {
cache.put(name, info);
- int r = distribute(name, obj, info, UPDATE_OBJ);
+ int r = distribute_cache(name, obj, info, UPDATE_OBJ);
if (r < 0)
mydout(0) << "ERROR: failed to distribute cache for " << obj << dendl;
} else {
}
template <class T>
-int RGWCache<T>::distribute(const string& normal_name, rgw_obj& obj, ObjectCacheInfo& obj_info, int op)
+int RGWCache<T>::distribute_cache(const string& normal_name, rgw_obj& obj, ObjectCacheInfo& obj_info, int op)
{
RGWCacheNotifyInfo info;
ret = 0;
perfcounter->finc(l_rgw_get_lat,
(ceph_clock_now(s->cct) - start_time));
- send_response(bl);
+ send_response_data(bl);
start_time = ceph_clock_now(s->cct);
}
perfcounter->finc(l_rgw_get_lat,
(ceph_clock_now(s->cct) - start_time));
- ret = send_response(bl);
+ ret = send_response_data(bl);
bl.clear();
if (ret < 0) {
dout(0) << "NOTICE: failed to send response to client" << dendl;
return;
done:
- send_response(bl);
+ send_response_data(bl);
store->finish_get_obj(&handle);
}