On Wed, Jun 20, 2012 at 12:00 AM, Jeff Layton <jlayton@xxxxxxxxxx> wrote:
> On Tue, 19 Jun 2012 23:53:06 +0400
> Pavel Shilovsky <pshilovsky@xxxxxxxxx> wrote:
>
>> 2012/6/19 Jeff Layton <jlayton@xxxxxxxxxx>:
>> > On Sat, 9 Jun 2012 10:26:01 +0400
>> > Pavel Shilovsky <pshilovsky@xxxxxxxxx> wrote:
>> >
>> >> Split all requests to echos, oplocks and others - each group uses
>> >> its own credit slot. This is indicated by new flags
>> >>
>> >> CIFS_ECHO_OP and CIFS_OBREAK_OP
>> >>
>> >> that are not used now for CIFS. This change is required to support
>> >> SMB2 protocol because of different processing of these commands.
>> >>
>> >> Signed-off-by: Pavel Shilovsky <pshilovsky@xxxxxxxxx>
>> >> ---
>> >> fs/cifs/cifsglob.h | 16 +++++++++++---
>> >> fs/cifs/cifsproto.h | 2 +-
>> >> fs/cifs/cifssmb.c | 21 ++++++++++---------
>> >> fs/cifs/smb1ops.c | 12 +++++++++-
>> >> fs/cifs/transport.c | 54 +++++++++++++++++++++++++++++---------------------
>> >> 5 files changed, 65 insertions(+), 40 deletions(-)
>> >>
>> >> diff --git a/fs/cifs/cifsglob.h b/fs/cifs/cifsglob.h
>> >> index 2aac4e5..844b77c 100644
>> >> --- a/fs/cifs/cifsglob.h
>> >> +++ b/fs/cifs/cifsglob.h
>> >> @@ -171,9 +171,11 @@ struct smb_version_operations {
>> >> /* check response: verify signature, map error */
>> >> int (*check_receive)(struct mid_q_entry *, struct TCP_Server_Info *,
>> >> bool);
>> >> - void (*add_credits)(struct TCP_Server_Info *, const unsigned int);
>> >> + void (*add_credits)(struct TCP_Server_Info *, const unsigned int,
>> >> + const int);
>> >> void (*set_credits)(struct TCP_Server_Info *, const int);
>> >> - int * (*get_credits_field)(struct TCP_Server_Info *);
>> >> + int * (*get_credits_field)(struct TCP_Server_Info *, const int);
>> >> + unsigned int (*get_credits)(struct mid_q_entry *);
>> >> __u64 (*get_next_mid)(struct TCP_Server_Info *);
>> >> /* data offset from read response message */
>> >> unsigned int (*read_data_offset)(char *);
>> >> @@ -392,9 +394,10 @@ has_credits(struct TCP_Server_Info *server, int *credits)
>> >> }
>> >>
>> >> static inline void
>> >> -add_credits(struct TCP_Server_Info *server, const unsigned int add)
>> >> +add_credits(struct TCP_Server_Info *server, const unsigned int add,
>> >> + const int optype)
>> >> {
>> >> - server->ops->add_credits(server, add);
>> >> + server->ops->add_credits(server, add, optype);
>> >> }
>> >>
>> >> static inline void
>> >> @@ -957,6 +960,11 @@ static inline void free_dfs_info_array(struct dfs_info3_param *param,
>> >> #define CIFS_LARGE_BUF_OP 0x020 /* large request buffer */
>> >> #define CIFS_NO_RESP 0x040 /* no response buffer required */
>> >>
>> >> +/* Type of request operation */
>> >> +#define CIFS_ECHO_OP 0x080 /* echo request */
>> >> +#define CIFS_OBREAK_OP 0x0100 /* oplock break request */
>> >> +#define CIFS_OP_MASK 0x0180 /* mask request type */
>> >> +
>> >> /* Security Flags: indicate type of session setup needed */
>> >> #define CIFSSEC_MAY_SIGN 0x00001
>> >> #define CIFSSEC_MAY_NTLM 0x00002
>> >> diff --git a/fs/cifs/cifsproto.h b/fs/cifs/cifsproto.h
>> >> index 0a6cbfe..8c1c7c1 100644
>> >> --- a/fs/cifs/cifsproto.h
>> >> +++ b/fs/cifs/cifsproto.h
>> >> @@ -71,7 +71,7 @@ extern void DeleteMidQEntry(struct mid_q_entry *midEntry);
>> >> extern int cifs_call_async(struct TCP_Server_Info *server, struct kvec *iov,
>> >> unsigned int nvec, mid_receive_t *receive,
>> >> mid_callback_t *callback, void *cbdata,
>> >> - bool ignore_pend);
>> >> + const int flags);
>> >> extern int SendReceive(const unsigned int /* xid */ , struct cifs_ses *,
>> >> struct smb_hdr * /* input */ ,
>> >> struct smb_hdr * /* out */ ,
>> >> diff --git a/fs/cifs/cifssmb.c b/fs/cifs/cifssmb.c
>> >> index 5b40073..58f1ab5 100644
>> >> --- a/fs/cifs/cifssmb.c
>> >> +++ b/fs/cifs/cifssmb.c
>> >> @@ -720,7 +720,7 @@ cifs_echo_callback(struct mid_q_entry *mid)
>> >> struct TCP_Server_Info *server = mid->callback_data;
>> >>
>> >> DeleteMidQEntry(mid);
>> >> - add_credits(server, 1);
>> >> + add_credits(server, 1, CIFS_ECHO_OP);
>> >> }
>> >>
>> >> int
>> >> @@ -747,7 +747,7 @@ CIFSSMBEcho(struct TCP_Server_Info *server)
>> >> iov.iov_len = be32_to_cpu(smb->hdr.smb_buf_length) + 4;
>> >>
>> >> rc = cifs_call_async(server, &iov, 1, NULL, cifs_echo_callback,
>> >> - server, true);
>> >> + server, CIFS_ASYNC_OP | CIFS_ECHO_OP);
>> >> if (rc)
>> >> cFYI(1, "Echo request failed: %d", rc);
>> >>
>> >> @@ -1563,7 +1563,7 @@ cifs_readv_callback(struct mid_q_entry *mid)
>> >>
>> >> queue_work(cifsiod_wq, &rdata->work);
>> >> DeleteMidQEntry(mid);
>> >> - add_credits(server, 1);
>> >> + add_credits(server, 1, 0);
>> >> }
>> >>
>> >> /* cifs_async_readv - send an async write, and set up mid to handle result */
>> >> @@ -1619,7 +1619,7 @@ cifs_async_readv(struct cifs_readdata *rdata)
>> >> kref_get(&rdata->refcount);
>> >> rc = cifs_call_async(tcon->ses->server, rdata->iov, 1,
>> >> cifs_readv_receive, cifs_readv_callback,
>> >> - rdata, false);
>> >> + rdata, 0);
>> >>
>> >> if (rc == 0)
>> >> cifs_stats_inc(&tcon->num_reads);
>> >> @@ -2010,7 +2010,7 @@ cifs_writev_callback(struct mid_q_entry *mid)
>> >>
>> >> queue_work(cifsiod_wq, &wdata->work);
>> >> DeleteMidQEntry(mid);
>> >> - add_credits(tcon->ses->server, 1);
>> >> + add_credits(tcon->ses->server, 1, 0);
>> >> }
>> >>
>> >> /* cifs_async_writev - send an async write, and set up mid to handle result */
>> >> @@ -2090,7 +2090,7 @@ cifs_async_writev(struct cifs_writedata *wdata)
>> >>
>> >> kref_get(&wdata->refcount);
>> >> rc = cifs_call_async(tcon->ses->server, iov, wdata->nr_pages + 1,
>> >> - NULL, cifs_writev_callback, wdata, false);
>> >> + NULL, cifs_writev_callback, wdata, 0);
>> >>
>> >> if (rc == 0)
>> >> cifs_stats_inc(&tcon->num_writes);
>> >> @@ -2268,7 +2268,7 @@ CIFSSMBLock(const int xid, struct cifs_tcon *tcon,
>> >> LOCK_REQ *pSMB = NULL;
>> >> /* LOCK_RSP *pSMBr = NULL; */ /* No response data other than rc to parse */
>> >> int bytes_returned;
>> >> - int timeout = 0;
>> >> + int flags = 0;
>> >> __u16 count;
>> >>
>> >> cFYI(1, "CIFSSMBLock timeout %d numLock %d", (int)waitFlag, numLock);
>> >> @@ -2278,10 +2278,11 @@ CIFSSMBLock(const int xid, struct cifs_tcon *tcon,
>> >> return rc;
>> >>
>> >> if (lockType == LOCKING_ANDX_OPLOCK_RELEASE) {
>> >> - timeout = CIFS_ASYNC_OP; /* no response expected */
>> >> + /* no response expected */
>> >> + flags = CIFS_ASYNC_OP | CIFS_OBREAK_OP;
>> >> pSMB->Timeout = 0;
>> >> } else if (waitFlag) {
>> >> - timeout = CIFS_BLOCKING_OP; /* blocking operation, no timeout */
>> >> + flags = CIFS_BLOCKING_OP; /* blocking operation, no timeout */
>> >> pSMB->Timeout = cpu_to_le32(-1);/* blocking - do not time out */
>> >> } else {
>> >> pSMB->Timeout = 0;
>> >> @@ -2314,7 +2315,7 @@ CIFSSMBLock(const int xid, struct cifs_tcon *tcon,
>> >> (struct smb_hdr *) pSMB, &bytes_returned);
>> >> cifs_small_buf_release(pSMB);
>> >> } else {
>> >> - rc = SendReceiveNoRsp(xid, tcon->ses, (char *)pSMB, timeout);
>> >> + rc = SendReceiveNoRsp(xid, tcon->ses, (char *)pSMB, flags);
>> >> /* SMB buffer freed by function above */
>> >> }
>> >> cifs_stats_inc(&tcon->num_locks);
>> >> diff --git a/fs/cifs/smb1ops.c b/fs/cifs/smb1ops.c
>> >> index 28359e7..f4f8394 100644
>> >> --- a/fs/cifs/smb1ops.c
>> >> +++ b/fs/cifs/smb1ops.c
>> >> @@ -101,7 +101,8 @@ cifs_find_mid(struct TCP_Server_Info *server, char *buffer)
>> >> }
>> >>
>> >> static void
>> >> -cifs_add_credits(struct TCP_Server_Info *server, const unsigned int add)
>> >> +cifs_add_credits(struct TCP_Server_Info *server, const unsigned int add,
>> >> + const int optype)
>> >> {
>> >> spin_lock(&server->req_lock);
>> >> server->credits += add;
>> >> @@ -120,11 +121,17 @@ cifs_set_credits(struct TCP_Server_Info *server, const int val)
>> >> }
>> >>
>> >> static int *
>> >> -cifs_get_credits_field(struct TCP_Server_Info *server)
>> >> +cifs_get_credits_field(struct TCP_Server_Info *server, const int optype)
>> >> {
>> >> return &server->credits;
>> >> }
>> >>
>> >> +static unsigned int
>> >> +cifs_get_credits(struct mid_q_entry *mid)
>> >> +{
>> >> + return 1;
>> >> +}
>> >> +
>> >> /*
>> >> * Find a free multiplex id (SMB mid). Otherwise there could be
>> >> * mid collisions which might cause problems, demultiplexing the
>> >> @@ -390,6 +397,7 @@ struct smb_version_operations smb1_operations = {
>> >> .add_credits = cifs_add_credits,
>> >> .set_credits = cifs_set_credits,
>> >> .get_credits_field = cifs_get_credits_field,
>> >> + .get_credits = cifs_get_credits,
>> >> .get_next_mid = cifs_get_next_mid,
>> >> .read_data_offset = cifs_read_data_offset,
>> >> .read_data_length = cifs_read_data_length,
>> >> diff --git a/fs/cifs/transport.c b/fs/cifs/transport.c
>> >> index 3097ee5..54cd8dd 100644
>> >> --- a/fs/cifs/transport.c
>> >> +++ b/fs/cifs/transport.c
>> >> @@ -254,13 +254,13 @@ smb_send(struct TCP_Server_Info *server, struct smb_hdr *smb_buffer,
>> >> }
>> >>
>> >> static int
>> >> -wait_for_free_credits(struct TCP_Server_Info *server, const int optype,
>> >> +wait_for_free_credits(struct TCP_Server_Info *server, const int long_op,
>> >> int *credits)
>> >> {
>> >> int rc;
>> >>
>> >> spin_lock(&server->req_lock);
>> >> - if (optype == CIFS_ASYNC_OP) {
>> >> + if (long_op == CIFS_ASYNC_OP) {
>> >> /* oplock breaks must not be held up */
>> >> server->in_flight++;
>> >> *credits -= 1;
>> >> @@ -290,7 +290,7 @@ wait_for_free_credits(struct TCP_Server_Info *server, const int optype,
>> >> */
>> >>
>> >> /* update # of requests on the wire to server */
>> >> - if (optype != CIFS_BLOCKING_OP) {
>> >> + if (long_op != CIFS_BLOCKING_OP) {
>> >> *credits -= 1;
>> >> server->in_flight++;
>> >> }
>> >
>> > Why rename the variable in this above function? "optype" seems like a better name...
>>
>> That was done to make variable names the same: 'optype' is used to
>> indicate if it is echo, oplock or other operation, 'long_op' is used
>> to indicate if we need any special behavior (aysnc, blocking).
>>
>> wait_for_free_request function (below) takes both 'optype' and
>> 'long_op' and passes 'long_op' to wait_for_free_credits. It is cleaner
>> if wait_for_free_credits uses the same name - 'long_op'.
>>
>> Of course, 'long_op' may be not so good name at all (I took it from
>> the old code) - suggestions are welcome.
>>
>
> Yeah, I think that's the confusion. "long_op" was from when those flags
> were supposed to indicate the length of the operation so the code could
> adjust the timeout. Maybe a better name is something generic like
> "flags" ?
"flags" is fine with me
--
Thanks,
Steve
--
To unsubscribe from this list: send the line "unsubscribe linux-cifs" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
