svn commit: samba r14795 - in branches/SAMBA_4_0/source/ntvfs/posix: .

[tridge at samba.org]

Author: tridge
Date: 2006-03-30 02:25:38 +0000 (Thu, 30 Mar 2006)
New Revision: 14795

WebSVN: http://websvn.samba.org/cgi-bin/viewcvs.cgi?view=rev&root=samba&rev=14795

Log:

queue notify requests on the same handle

Modified:
   branches/SAMBA_4_0/source/ntvfs/posix/pvfs_notify.c


Changeset:
Modified: branches/SAMBA_4_0/source/ntvfs/posix/pvfs_notify.c
===================================================================
--- branches/SAMBA_4_0/source/ntvfs/posix/pvfs_notify.c	2006-03-30 02:25:04 UTC (rev 14794)
+++ branches/SAMBA_4_0/source/ntvfs/posix/pvfs_notify.c	2006-03-30 02:25:38 UTC (rev 14795)
@@ -24,6 +24,7 @@
 #include "vfs_posix.h"
 #include "lib/messaging/irpc.h"
 #include "messaging/messaging.h"
+#include "dlinklist.h"
 
 /* pending notifies buffer, hung off struct pvfs_file for open directories
    that have used change notify */
@@ -33,11 +34,13 @@
 	struct notify_changes *changes;
 	uint32_t max_buffer_size;
 	uint32_t current_buffer_size;
-	
-	/* these last two are only present when a notify request is
-	   pending */
-	struct ntvfs_request *req;
-	struct smb_notify *info;
+
+	/* a list of requests waiting for events on this handle */
+	struct notify_pending {
+		struct notify_pending *next, *prev;
+		struct ntvfs_request *req;
+		struct smb_notify *info;
+	} *pending;
 };
 
 /*
@@ -45,18 +48,25 @@
 */
 static void pvfs_notify_send(struct pvfs_notify_buffer *notify_buffer, NTSTATUS status)
 {
-	struct ntvfs_request *req = notify_buffer->req;
-	struct smb_notify *info = notify_buffer->info;
+	struct notify_pending *pending = notify_buffer->pending;
+	struct ntvfs_request *req;
+	struct smb_notify *info;
 
+	if (pending == NULL) return;
+
+	DLIST_REMOVE(notify_buffer->pending, pending);
+
+	req = pending->req;
+	info = pending->info;
+
 	info->out.num_changes = notify_buffer->num_changes;
 	info->out.changes = talloc_steal(req, notify_buffer->changes);
 	notify_buffer->num_changes = 0;
 	notify_buffer->changes = NULL;
 	notify_buffer->current_buffer_size = 0;
-	
-	notify_buffer->req = NULL;
-	notify_buffer->info = NULL;
 
+	talloc_free(pending);
+
 	DEBUG(0,("sending %d changes\n", info->out.num_changes));
 
 	if (info->out.num_changes != 0) {
@@ -75,9 +85,7 @@
 	struct pvfs_notify_buffer *n = talloc_get_type(ptr, struct pvfs_notify_buffer);
 	notify_remove(n->f->pvfs->notify_context, n);
 	n->f->notify_buffer = NULL;
-	if (n->req) {
-		pvfs_notify_send(n, NT_STATUS_OK);
-	}
+	pvfs_notify_send(n, NT_STATUS_OK);
 	return 0;
 }
 
@@ -96,9 +104,7 @@
 
 	DEBUG(0,("got notify for '%s' action=%d\n", ev->path, ev->action));
 
-	if (n->req != NULL) {
-		pvfs_notify_send(n, NT_STATUS_OK);
-	}
+	pvfs_notify_send(n, NT_STATUS_OK);
 }
 
 /*
@@ -135,14 +141,8 @@
 */
 static void pvfs_notify_end(void *private, enum pvfs_wait_notice reason)
 {
-	struct pvfs_notify_buffer *notify_buffer = talloc_get_type(private, struct pvfs_notify_buffer);
-	struct ntvfs_request *req = notify_buffer->req;
-
-	if (req == NULL) {
-		/* nothing to do, nobody is waiting */
-		return;
-	}
-
+	struct pvfs_notify_buffer *notify_buffer = talloc_get_type(private, 
+								   struct pvfs_notify_buffer);
 	if (reason == PVFS_WAIT_CANCEL) {
 		pvfs_notify_send(notify_buffer, NT_STATUS_CANCELLED);
 	} else {
@@ -160,6 +160,7 @@
 						  struct pvfs_state);
 	struct pvfs_file *f;
 	NTSTATUS status;
+	struct notify_pending *pending;
 
 	f = pvfs_find_fd(pvfs, req, info->in.file.fnum);
 	if (!f) {
@@ -186,16 +187,14 @@
 		NT_STATUS_NOT_OK_RETURN(status);
 	}
 
-	req->async_states->status = NT_STATUS_OK;
-	
-	if (f->notify_buffer->req != NULL) {
-		DEBUG(0,("Notify already setup\n"));
-		pvfs_notify_send(f->notify_buffer, NT_STATUS_CANCELLED);
-	}
+	pending = talloc(f->notify_buffer, struct notify_pending);
+	NT_STATUS_HAVE_NO_MEMORY(pending);
 
-	f->notify_buffer->req = talloc_reference(f->notify_buffer, req);
-	f->notify_buffer->info = info;
+	pending->req = talloc_reference(pending, req);
+	pending->info = info;
 
+	DLIST_ADD_END(f->notify_buffer->pending, pending, struct notify_pending *);
+
 	/* if the buffer is empty then start waiting */
 	if (f->notify_buffer->num_changes == 0) {
 		void *wait_handle =