Commit 8d0d5094 authored by Steve French's avatar Steve French
Browse files

[CIFS] Change Notify support part 1 - add dnotify thread for processing 


notify responses.

Signed-off-by: default avatarAsser Ferno <asser@diku.dk>
Signed-off-by: default avatarSteve French <sfrench@us.ibm.com>
parent f191401f

fs/cifs/cifsfs.c

+29 −3
Original line number Diff line number Diff line
@@ -59,6 +59,8 @@ unsigned int ntlmv2_support = 0; 
unsigned int sign_CIFS_PDUs = 1;

extern struct task_struct * oplockThread; /* remove sparse warning */

struct task_struct * oplockThread = NULL;

extern struct task_struct * dnotifyThread; /* remove sparse warning */

struct task_struct * dnotifyThread = NULL;

unsigned int CIFSMaxBufSize = CIFS_MAX_MSGSIZE;

module_param(CIFSMaxBufSize, int, 0);

MODULE_PARM_DESC(CIFSMaxBufSize,"Network buffer size (not including header). Default: 16384 Range: 8192 to 130048");
@@ -73,6 +75,7 @@ module_param(cifs_max_pending, int, 0); 
MODULE_PARM_DESC(cifs_max_pending,"Simultaneous requests to server. Default: 50 Range: 2 to 256");



static DECLARE_COMPLETION(cifs_oplock_exited);

static DECLARE_COMPLETION(cifs_dnotify_exited);



extern mempool_t *cifs_sm_req_poolp;

extern mempool_t *cifs_req_poolp;
@@ -838,6 +841,19 @@ static int cifs_oplock_thread(void * dummyarg) 
	complete_and_exit (&cifs_oplock_exited, 0);

}



static int cifs_dnotify_thread(void * dummyarg)

{

	daemonize("cifsdnotifyd");

	allow_signal(SIGTERM);



	dnotifyThread = current;

	do {

		set_current_state(TASK_INTERRUPTIBLE);

		schedule_timeout(39*HZ);

	} while(!signal_pending(current));

	complete_and_exit (&cifs_dnotify_exited, 0);

}



static int __init

init_cifs(void)

{
@@ -884,11 +900,17 @@ init_cifs(void) 
				if (!rc) {                

					rc = (int)kernel_thread(cifs_oplock_thread, NULL, 

						CLONE_FS | CLONE_FILES | CLONE_VM);

					if(rc > 0) {

						rc = (int)kernel_thread(cifs_dnotify_thread, NULL,

							CLONE_FS | CLONE_FILES | CLONE_VM);

						if(rc > 0)

							return 0;

						else

							cERROR(1,("error %d create dnotify thread", rc));

					} else {

						cERROR(1,("error %d create oplock thread",rc));

					}

				}

				cifs_destroy_request_bufs();

			}

			cifs_destroy_mids();
@@ -916,6 +938,10 @@ exit_cifs(void) 
		send_sig(SIGTERM, oplockThread, 1);

		wait_for_completion(&cifs_oplock_exited);

	}

	if(dnotifyThread) {

		send_sig(SIGTERM, dnotifyThread, 1);

		wait_for_completion(&cifs_dnotify_exited);

	}

}



MODULE_AUTHOR("Steve French <sfrench@us.ibm.com>");