public:
ut_put_sink(){}
virtual ~ut_put_sink(){}
- int handle_data(bufferlist& bl, off_t ofs, void **phandle, rgw_obj *pobj, bool *again) override
+ int handle_data(bufferlist& bl, off_t ofs, void **phandle, rgw_raw_obj *pobj, bool *again) override
{
sink << boost::string_ref(bl.c_str(),bl.length());
*again = false;
return 0;
}
- int throttle_data(void *handle, const rgw_obj& obj, uint64_t size, bool need_to_wait) override
+ int throttle_data(void *handle, const rgw_raw_obj& obj, uint64_t size, bool need_to_wait) override
{
return 0;
}
bl.append(input.c_str()+pos, size);
void* handle;
bool again = false;
- rgw_obj ro;
+ rgw_raw_obj ro;
encrypt.handle_data(bl, 0, &handle, nullptr, &again);
encrypt.throttle_data(handle, ro, size, false);
bl.append((char*)test_in, test_size);
void* handle;
bool again = false;
- rgw_obj ro;
+ rgw_raw_obj ro;
encrypt.handle_data(bl, 0, &handle, nullptr, &again);
encrypt.throttle_data(handle, ro, test_size, false);
bl.clear();