diff options
| author |   Ronnie Sahlberg <lsahlber@redhat.com> | 2018-06-01 10:53:08 +1000 |
|---|---|---|
| committer |   Steve French <smfrench@gmail.com> | 2018-06-02 18:36:26 -0500 |
| commit | 8ce79ec359ad9f9d94aabf16c1ea5b8f28481c0f (patch) | |
| tree | 1a723d4c75b30ccf4d407d6556ecf96db54c03e0 /fs/cifs/connect.c | |
| parent | cifs: remove header_preamble_size where it is always 0 (diff) | |
| download | linux-dev-8ce79ec359ad9f9d94aabf16c1ea5b8f28481c0f.tar.xz linux-dev-8ce79ec359ad9f9d94aabf16c1ea5b8f28481c0f.zip | |
cifs: update multiplex loop to handle compounded responses
Signed-off-by: Ronnie Sahlberg <lsahlber@redhat.com>
Signed-off-by: Steve French <smfrench@gmail.com>
Diffstat (limited to '')
| -rw-r--r-- | fs/cifs/connect.c | 24 |
1 files changed, 20 insertions, 4 deletions
diff --git a/fs/cifs/connect.c b/fs/cifs/connect.c index b68c5b9ffbea..adc97d0be7c0 100644 --- a/fs/cifs/connect.c +++ b/fs/cifs/connect.c @@ -856,6 +856,7 @@ cifs_demultiplex_thread(void *p) int length; struct TCP_Server_Info *server = p; unsigned int pdu_length; + unsigned int next_offset; char *buf = NULL; struct task_struct *task_to_wake = NULL; struct mid_q_entry *mid_entry; @@ -893,17 +894,18 @@ cifs_demultiplex_thread(void *p) * so we can now interpret the length field. */ pdu_length = get_rfc1002_length(buf); - server->pdu_size = pdu_length; cifs_dbg(FYI, "RFC1002 header 0x%x\n", pdu_length); if (!is_smb_response(server, buf[0])) continue; +next_pdu: + server->pdu_size = pdu_length; /* make sure we have enough to get to the MID */ - if (pdu_length < HEADER_SIZE(server) - 1 - + if (server->pdu_size < HEADER_SIZE(server) - 1 - server->vals->header_preamble_size) { cifs_dbg(VFS, "SMB response too short (%u bytes)\n", - pdu_length); + server->pdu_size); cifs_reconnect(server); wake_up(&server->response_q); continue; @@ -918,6 +920,12 @@ cifs_demultiplex_thread(void *p) continue; server->total_read += length; + if (server->ops->next_header) { + next_offset = server->ops->next_header(buf); + if (next_offset) + server->pdu_size = next_offset; + } + if (server->ops->is_transform_hdr && server->ops->receive_transform && server->ops->is_transform_hdr(buf)) { @@ -963,7 +971,15 @@ cifs_demultiplex_thread(void *p) server->ops->dump_detail(buf, server); cifs_dump_mids(server); #endif /* CIFS_DEBUG2 */ - + } + if (pdu_length > server->pdu_size) { + if (!allocate_buffers(server)) + continue; + pdu_length -= server->pdu_size; + server->total_read = 0; + server->large_buf = false; + buf = server->smallbuf; + goto next_pdu; } } /* end while !EXITING */ |