read_error_lock("KeyValueStore::read_error_lock"),
m_keyvaluestore_queue_max_ops(g_conf->keyvaluestore_queue_max_ops),
m_keyvaluestore_queue_max_bytes(g_conf->keyvaluestore_queue_max_bytes),
- m_fail_eio(g_conf->filestore_fail_eio),
do_update(do_update)
{
ostringstream oss;
{
if (::statfs(basedir.c_str(), buf) < 0) {
int r = -errno;
- assert(!m_fail_eio || r != -EIO);
return r;
}
return 0;
TEMP_FAILURE_RETRY(::close(fsid_fd));
fsid_fd = -1;
done:
- assert(!m_fail_eio || ret != -EIO);
return ret;
}
r = backend->get_keys_with_header(*header, OBJECT_XATTR, &attrs);
if (r < 0 && r != -ENOENT) {
dout(10) << __func__ << " could not get attrs r = " << r << dendl;
- assert(!m_fail_eio || r != -EIO);
return r;
}
keys.insert(OBJECT_OMAP_HEADER_KEY);
int r = backend->get_values(c, hoid, OBJECT_OMAP_HEADER, keys, &got);
if (r < 0 && r != -ENOENT) {
- assert(allow_eio || !m_fail_eio || r != -EIO);
dout(10) << __func__ << " err r =" << r << dendl;
return r;
}
int r = backend->get_keys(c, hoid, OBJECT_OMAP, keys);
if (r < 0 && r != -ENOENT) {
- assert(!m_fail_eio || r != -EIO);
return r;
}
return 0;
int r = backend->get_values(c, hoid, OBJECT_OMAP, keys, out);
if (r < 0 && r != -ENOENT) {
- assert(!m_fail_eio || r != -EIO);
return r;
}
return 0;
int r = backend->check_keys(c, hoid, OBJECT_OMAP, keys, out);
if (r < 0 && r != -ENOENT) {
- assert(!m_fail_eio || r != -EIO);
return r;
}
return 0;
r = backend->get_keys_with_header(*header, OBJECT_OMAP, &keys);
if (r < 0 && r != -ENOENT) {
dout(10) << __func__ << " could not get omap_keys r = " << r << dendl;
- assert(!m_fail_eio || r != -EIO);
return r;
}