@@ -603,12 +603,37 @@ static ssize_t cifs_file_aio_read(struct kiocb
*iocb, const struct iovec *iov,
static ssize_t cifs_file_aio_write(struct kiocb *iocb, const struct iovec *iov,
unsigned long nr_segs, loff_t pos)
{
- struct inode *inode = iocb->ki_filp->f_path.dentry->d_inode;
- ssize_t written;
+ struct inode *inode;
+ struct cifs_sb_info *cifs_sb;
+ ssize_t written, cache_written;
+ loff_t saved_pos;
+
+ inode = iocb->ki_filp->f_path.dentry->d_inode;
+
+ if (CIFS_I(inode)->clientCanCacheAll)
+ return generic_file_aio_write(iocb, iov, nr_segs, pos);
+
+ cifs_sb = CIFS_SB(iocb->ki_filp->f_path.dentry->d_sb);
+
+ if ((cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO) == 0) {
+ written = generic_file_aio_write(iocb, iov, nr_segs, pos);
+ filemap_write_and_wait(inode->i_mapping);
+ return written;
+ }
+
+ saved_pos = pos;
+ written = cifs_user_write(iocb->ki_filp, iov->iov_base,
+ iov->iov_len, &pos);
+
+ if (written > 0) {
+ cache_written = generic_file_aio_write(iocb, iov,
+ nr_segs, saved_pos);
+ if (cache_written != written)
+ cERROR(1, "Cache written and server written data "
+ "lengths are different");
+ } else
+ iocb->ki_pos = pos;
- written = generic_file_aio_write(iocb, iov, nr_segs, pos);
- if (!CIFS_I(inode)->clientCanCacheAll)
- filemap_fdatawrite(inode->i_mapping);
return written;
}
@@ -1578,11 +1578,31 @@ static int cifs_write_end(struct file *file,
struct address_space *mapping,
struct page *page, void *fsdata)
{
int rc;
- struct inode *inode = mapping->host;
+ struct inode *inode;
+ struct cifs_sb_info *cifs_sb;
+
+ inode = mapping->host;
+ cifs_sb = CIFS_SB(inode->i_sb);
cFYI(1, "write_end for page %p from pos %lld with %d bytes",
page, pos, copied);
+ if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO) {
+ rc = copied;
+ pos += copied;
+
+ if (CIFS_I(inode)->clientCanCacheAll) {
+ SetPageUptodate(page);
+ set_page_dirty(page);
+ }
+
+ /* if we don't have an exclusive oplock the page data was
+ previously written to the server in cifs_file_aio_write,
+ so we don't need to do it again - goto exit */
+
+ goto exit;
+ }
+
if (PageChecked(page)) {
if (copied == len)