return -CEPHFS_ENOTCONN;
}
+ /* We can't return bytes written larger than INT_MAX, clamp len to that */
+ len = std::min(len, (loff_t)INT_MAX);
+
+ std::scoped_lock lock(client_lock);
if (fh == NULL || !_ll_fh_exists(fh)) {
ldout(cct, 3) << "(fh)" << fh << " is invalid" << dendl;
return -CEPHFS_EBADF;
tout(cct) << off << std::endl;
tout(cct) << len << std::endl;
- /* We can't return bytes written larger than INT_MAX, clamp len to that */
- len = std::min(len, (loff_t)INT_MAX);
- std::scoped_lock lock(client_lock);
-
int r = _read(fh, off, len, bl);
ldout(cct, 3) << "ll_read " << fh << " " << off << "~" << len << " = " << r
<< dendl;
return -CEPHFS_ENOTCONN;
}
+ /* We can't return bytes written larger than INT_MAX, clamp len to that */
+ len = std::min(len, (loff_t)INT_MAX);
+
+ std::scoped_lock lock(client_lock);
if (fh == NULL || !_ll_fh_exists(fh)) {
ldout(cct, 3) << "(fh)" << fh << " is invalid" << dendl;
return -CEPHFS_EBADF;
tout(cct) << off << std::endl;
tout(cct) << len << std::endl;
- /* We can't return bytes written larger than INT_MAX, clamp len to that */
- len = std::min(len, (loff_t)INT_MAX);
- std::scoped_lock lock(client_lock);
-
int r = _write(fh, off, len, data, NULL, 0);
ldout(cct, 3) << "ll_write " << fh << " " << off << "~" << len << " = " << r
<< dendl;
return -CEPHFS_ENOTCONN;
}
+ std::scoped_lock cl(client_lock);
if (fh == NULL || !_ll_fh_exists(fh)) {
ldout(cct, 3) << "(fh)" << fh << " is invalid" << dendl;
return -CEPHFS_EBADF;
}
-
- std::scoped_lock cl(client_lock);
return _preadv_pwritev_locked(fh, iov, iovcnt, off, true, false);
}
return -CEPHFS_ENOTCONN;
}
+ std::scoped_lock cl(client_lock);
if (fh == NULL || !_ll_fh_exists(fh)) {
ldout(cct, 3) << "(fh)" << fh << " is invalid" << dendl;
return -CEPHFS_EBADF;
}
-
- std::scoped_lock cl(client_lock);
return _preadv_pwritev_locked(fh, iov, iovcnt, off, false, false);
}