Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 269944
b: refs/heads/master
c: e831e6c
h: refs/heads/master
v: v3
  • Loading branch information
Jeff Layton authored and Steve French committed Oct 13, 2011
1 parent 387919e commit f1c8ebe
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 10 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: e2218eab2050e879b253ca112aabd5f7167572af
refs/heads/master: e831e6cf3acb058d898411367a582deef80e32f8
17 changes: 8 additions & 9 deletions trunk/fs/cifs/connect.c
Original file line number Diff line number Diff line change
Expand Up @@ -359,16 +359,20 @@ allocate_buffers(char **bigbuf, char **smallbuf, unsigned int size,
}

static int
read_from_socket(struct TCP_Server_Info *server, struct msghdr *smb_msg,
read_from_socket(struct TCP_Server_Info *server,
struct kvec *iov, unsigned int to_read,
unsigned int *ptotal_read, bool is_header_read)
{
int length, rc = 0;
unsigned int total_read;
struct msghdr smb_msg;
char *buf = iov->iov_base;

smb_msg.msg_control = NULL;
smb_msg.msg_controllen = 0;

for (total_read = 0; total_read < to_read; total_read += length) {
length = kernel_recvmsg(server->ssocket, smb_msg, iov, 1,
length = kernel_recvmsg(server->ssocket, &smb_msg, iov, 1,
to_read - total_read, 0);
if (server->tcpStatus == CifsExiting) {
/* then will exit */
Expand Down Expand Up @@ -397,8 +401,6 @@ read_from_socket(struct TCP_Server_Info *server, struct msghdr *smb_msg,
iov->iov_base = (to_read - total_read) +
buf;
iov->iov_len = to_read - total_read;
smb_msg->msg_control = NULL;
smb_msg->msg_controllen = 0;
rc = 3;
} else
rc = 1;
Expand Down Expand Up @@ -634,7 +636,6 @@ cifs_demultiplex_thread(void *p)
unsigned int pdu_length, total_read;
char *buf = NULL, *bigbuf = NULL, *smallbuf = NULL;
struct smb_hdr *smb_buffer = NULL;
struct msghdr smb_msg;
struct kvec iov;
struct task_struct *task_to_wake = NULL;
struct mid_q_entry *mid_entry;
Expand Down Expand Up @@ -665,8 +666,6 @@ cifs_demultiplex_thread(void *p)
buf = smallbuf;
iov.iov_base = buf;
iov.iov_len = 4;
smb_msg.msg_control = NULL;
smb_msg.msg_controllen = 0;
pdu_length = 4; /* enough to get RFC1001 header */

incomplete_rcv:
Expand All @@ -681,7 +680,7 @@ cifs_demultiplex_thread(void *p)
continue;
}

rc = read_from_socket(server, &smb_msg, &iov, pdu_length,
rc = read_from_socket(server, &iov, pdu_length,
&total_read, true /* header read */);
if (rc == 3)
goto incomplete_rcv;
Expand Down Expand Up @@ -710,7 +709,7 @@ cifs_demultiplex_thread(void *p)

iov.iov_base = 4 + buf;
iov.iov_len = pdu_length;
rc = read_from_socket(server, &smb_msg, &iov, pdu_length,
rc = read_from_socket(server, &iov, pdu_length,
&total_read, false);
if (rc == 2)
break;
Expand Down

0 comments on commit f1c8ebe

Please sign in to comment.