From 384f87bd38c1133c90e2a57775f139532574e3cc Mon Sep 17 00:00:00 2001
From: Andrew Tridgell <tridge@samba.org>
Date: Mon, 18 Oct 2004 11:47:13 +0000
Subject: r3034:  - fixed a bug in message dispatch, when the dispatch function
 called messaging_deregister()

 - added a pvfs_lock_close_pending() hook to remove pending locks on file close

 - fixed the private ptr argument to messaging_deregister() in pvfs_wait

 - fixed a bug in continuing lock requests after a lock that is blocking a pending lock is removed

 - removed bogus brl_unlock() call in lock continue

 - corrected error code for LOCKING_ANDX_CHANGE_LOCKTYPE

 - expanded the lock cancel test suite to test lock cancel by unlock and by close

 - added a testsuite for LOCKING_ANDX_CHANGE_LOCKTYPE
(This used to be commit 5ef80f034d4aa4dd6810532c63ad041bfc019cb8)
---
 source4/ntvfs/posix/pvfs_lock.c | 46 +++++++++++++++++++++++++++++------------
 1 file changed, 33 insertions(+), 13 deletions(-)

(limited to 'source4/ntvfs/posix/pvfs_lock.c')

diff --git a/source4/ntvfs/posix/pvfs_lock.c b/source4/ntvfs/posix/pvfs_lock.c
index 100fc50e55..ead1371ebc 100644
--- a/source4/ntvfs/posix/pvfs_lock.c
+++ b/source4/ntvfs/posix/pvfs_lock.c
@@ -152,7 +152,7 @@ static void pvfs_pending_lock_continue(void *private, BOOL timed_out)
 
 	/* we've now got the pending lock. try and get the rest, which might
 	   lead to more pending locks */
-	for (i=pending->pending_lock;i<lck->lockx.in.lock_cnt;i++) {		
+	for (i=pending->pending_lock+1;i<lck->lockx.in.lock_cnt;i++) {		
 		if (pending) {
 			pending->pending_lock = i;
 		}
@@ -184,19 +184,36 @@ static void pvfs_pending_lock_continue(void *private, BOOL timed_out)
 		}
 	}
 
-	brl_unlock(pvfs->brl_context,
-		   &f->locking_key,
-		   req->smbpid,
-		   f->fnum,
-		   lck->lock.in.offset,
-		   lck->lock.in.count);
-
 	/* we've managed to get all the locks. Tell the client */
 	req->async.status = NT_STATUS_OK;
 	req->async.send_fn(req);
 }
 
 
+/*
+  called when we close a file that might have pending locks
+*/
+void pvfs_lock_close_pending(struct pvfs_state *pvfs, struct pvfs_file *f)
+{
+	struct pvfs_pending_lock *p, *next;
+	NTSTATUS status;
+
+	for (p=f->pending_list;p;p=next) {
+		next = p->next;
+		DLIST_REMOVE(f->pending_list, p);
+		status = brl_remove_pending(pvfs->brl_context, &f->locking_key, p);
+		if (!NT_STATUS_IS_OK(status)) {
+			DEBUG(0,("pvfs_lock_close_pending: failed to remove pending lock - %s\n", 
+				 nt_errstr(status)));
+		}
+		talloc_free(p->wait_handle);
+		p->req->async.status = NT_STATUS_RANGE_NOT_LOCKED;
+		p->req->async.send_fn(p->req);
+	}
+
+}
+
+
 /*
   cancel a set of locks
 */
@@ -303,11 +320,14 @@ NTSTATUS pvfs_lock(struct ntvfs_module_context *ntvfs,
 		return pvfs_lock_cancel(pvfs, req, lck, f);
 	}
 
-	if (lck->lockx.in.mode & 
-	    (LOCKING_ANDX_OPLOCK_RELEASE |
-	     LOCKING_ANDX_CHANGE_LOCKTYPE |
-	     LOCKING_ANDX_CANCEL_LOCK)) {
-		/* todo: need to add support for these */
+	if (lck->lockx.in.mode & LOCKING_ANDX_CHANGE_LOCKTYPE) {
+		/* this seems to not be supported by any windows server,
+		   or used by any clients */
+		return NT_STATUS_UNSUCCESSFUL;
+	}
+
+	if (lck->lockx.in.mode & LOCKING_ANDX_OPLOCK_RELEASE) {
+		DEBUG(0,("received unexpected oplock break\n"));
 		return NT_STATUS_NOT_IMPLEMENTED;
 	}
 
-- 
cgit