提交 d8e05039 编写于 作者: P Pavel Shilovsky 提交者: Steve French

CIFS: Add readpage support for SMB2

Signed-off-by: NPavel Shilovsky <pshilovsky@samba.org>
Signed-off-by: NSteve French <smfrench@gmail.com>
上级 f9c6e234
...@@ -393,6 +393,17 @@ smb2_read_data_length(char *buf) ...@@ -393,6 +393,17 @@ smb2_read_data_length(char *buf)
return le32_to_cpu(rsp->DataLength); return le32_to_cpu(rsp->DataLength);
} }
static int
smb2_sync_read(const unsigned int xid, struct cifsFileInfo *cfile,
struct cifs_io_parms *parms, unsigned int *bytes_read,
char **buf, int *buf_type)
{
parms->persistent_fid = cfile->fid.persistent_fid;
parms->volatile_fid = cfile->fid.volatile_fid;
return SMB2_read(xid, parms, bytes_read, buf, buf_type);
}
struct smb_version_operations smb21_operations = { struct smb_version_operations smb21_operations = {
.setup_request = smb2_setup_request, .setup_request = smb2_setup_request,
.setup_async_request = smb2_setup_async_request, .setup_async_request = smb2_setup_async_request,
...@@ -435,6 +446,7 @@ struct smb_version_operations smb21_operations = { ...@@ -435,6 +446,7 @@ struct smb_version_operations smb21_operations = {
.flush = smb2_flush_file, .flush = smb2_flush_file,
.async_readv = smb2_async_readv, .async_readv = smb2_async_readv,
.async_writev = smb2_async_writev, .async_writev = smb2_async_writev,
.sync_read = smb2_sync_read,
}; };
struct smb_version_values smb21_values = { struct smb_version_values smb21_values = {
......
...@@ -1329,6 +1329,57 @@ smb2_async_readv(struct cifs_readdata *rdata) ...@@ -1329,6 +1329,57 @@ smb2_async_readv(struct cifs_readdata *rdata)
return rc; return rc;
} }
int
SMB2_read(const unsigned int xid, struct cifs_io_parms *io_parms,
unsigned int *nbytes, char **buf, int *buf_type)
{
int resp_buftype, rc = -EACCES;
struct smb2_read_rsp *rsp = NULL;
struct kvec iov[1];
*nbytes = 0;
rc = smb2_new_read_req(iov, io_parms, 0, 0);
if (rc)
return rc;
rc = SendReceive2(xid, io_parms->tcon->ses, iov, 1,
&resp_buftype, CIFS_LOG_ERROR);
rsp = (struct smb2_read_rsp *)iov[0].iov_base;
if (rsp->hdr.Status == STATUS_END_OF_FILE) {
free_rsp_buf(resp_buftype, iov[0].iov_base);
return 0;
}
if (rc) {
cifs_stats_fail_inc(io_parms->tcon, SMB2_READ_HE);
cERROR(1, "Send error in read = %d", rc);
} else {
*nbytes = le32_to_cpu(rsp->DataLength);
if ((*nbytes > CIFS_MAX_MSGSIZE) ||
(*nbytes > io_parms->length)) {
cFYI(1, "bad length %d for count %d", *nbytes,
io_parms->length);
rc = -EIO;
*nbytes = 0;
}
}
if (*buf) {
memcpy(*buf, (char *)rsp->hdr.ProtocolId + rsp->DataOffset,
*nbytes);
free_rsp_buf(resp_buftype, iov[0].iov_base);
} else if (resp_buftype != CIFS_NO_BUFFER) {
*buf = iov[0].iov_base;
if (resp_buftype == CIFS_SMALL_BUFFER)
*buf_type = CIFS_SMALL_BUFFER;
else if (resp_buftype == CIFS_LARGE_BUFFER)
*buf_type = CIFS_LARGE_BUFFER;
}
return rc;
}
/* /*
* Check the mid_state and signature on received buffer (if any), and queue the * Check the mid_state and signature on received buffer (if any), and queue the
* workqueue completion task. * workqueue completion task.
......
...@@ -98,6 +98,8 @@ extern int SMB2_get_srv_num(const unsigned int xid, struct cifs_tcon *tcon, ...@@ -98,6 +98,8 @@ extern int SMB2_get_srv_num(const unsigned int xid, struct cifs_tcon *tcon,
u64 persistent_fid, u64 volatile_fid, u64 persistent_fid, u64 volatile_fid,
__le64 *uniqueid); __le64 *uniqueid);
extern int smb2_async_readv(struct cifs_readdata *rdata); extern int smb2_async_readv(struct cifs_readdata *rdata);
extern int SMB2_read(const unsigned int xid, struct cifs_io_parms *io_parms,
unsigned int *nbytes, char **buf, int *buf_type);
extern int smb2_async_writev(struct cifs_writedata *wdata); extern int smb2_async_writev(struct cifs_writedata *wdata);
extern int SMB2_echo(struct TCP_Server_Info *server); extern int SMB2_echo(struct TCP_Server_Info *server);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册