Skip site navigation (1)Skip section navigation (2)
Date:      Wed, 12 Mar 2008 11:08:28 -0400
From:      Coleman Kane <cokane@cokane.org>
To:        obrien@FreeBSD.org
Cc:        arch@FreeBSD.org, "jh >> John Baldwin" <jhb@FreeBSD.org>
Subject:   Re: SMPTODO: remove timeout(9) from ffs_softdep.c
Message-ID:  <47D7F1EC.6040802@cokane.org>
In-Reply-To: <20080312145734.GB26812@dragon.NUXI.org>
References:  <47D7C25D.5070908@cokane.org> <200803120945.29018.jhb@freebsd.org> <47D7E5BF.2060102@cokane.org> <20080312145734.GB26812@dragon.NUXI.org>

next in thread | previous in thread | raw e-mail | index | archive | help
This is a multi-part message in MIME format.
--------------020807070709030700060709
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit

David O'Brien wrote:
> On Wed, Mar 12, 2008 at 10:16:31AM -0400, Coleman Kane wrote:
>   
>> I am attaching the revised patch.
>>     
> ..
>   
>> +		callout_reset(&softdep_callout, tickdelay > 2 ? tickdelay : 2, pause_timer, 0);
>>     
>
> Wrap long line.
>
>   
>> +	/* The callout_ API has acquired mtx and will hold it around this function call. */
>>     
>
> Ditto.
>
>   
>> +		callout_reset(&softdep_callout, tickdelay > 2 ? tickdelay : 2, pause_timer, 0);
>>     
>
> Ditto.
>   
Third try at the patch, properly adjusting my vim tabs to 8 spaces as 
they should be so that I can follow style(9).

--
Coleman Kane


--------------020807070709030700060709
Content-Type: text/x-patch;
 name="ffs_softdep.c-newcallout3.diff"
Content-Transfer-Encoding: 7bit
Content-Disposition: inline;
 filename="ffs_softdep.c-newcallout3.diff"

diff --git a/sys/ufs/ffs/ffs_softdep.c b/sys/ufs/ffs/ffs_softdep.c
index 3e8ba26..457ed49 100644
--- a/sys/ufs/ffs/ffs_softdep.c
+++ b/sys/ufs/ffs/ffs_softdep.c
@@ -664,7 +664,7 @@ static int maxindirdeps = 50;	/* max number of indirdeps before slowdown */
 static int tickdelay = 2;	/* number of ticks to pause during slowdown */
 static int proc_waiting;	/* tracks whether we have a timeout posted */
 static int *stat_countp;	/* statistic to count in proc_waiting timeout */
-static struct callout_handle handle; /* handle on posted proc_waiting timeout */
+static struct callout softdep_callout;
 static int req_pending;
 static int req_clear_inodedeps;	/* syncer process flush some inodedeps */
 #define FLUSH_INODES		1
@@ -1394,6 +1394,9 @@ softdep_initialize()
 	bioops.io_complete = softdep_disk_write_complete;
 	bioops.io_deallocate = softdep_deallocate_dependencies;
 	bioops.io_countdeps = softdep_count_dependencies;
+
+	/* Initialize the callout with an mtx. */
+	callout_init_mtx(&softdep_callout, &lk, 0);
 }
 
 /*
@@ -1404,6 +1407,7 @@ void
 softdep_uninitialize()
 {
 
+	callout_drain(&softdep_callout);
 	hashdestroy(pagedep_hashtbl, M_PAGEDEP, pagedep_hash);
 	hashdestroy(inodedep_hashtbl, M_INODEDEP, inodedep_hash);
 	hashdestroy(newblk_hashtbl, M_NEWBLK, newblk_hash);
@@ -5858,8 +5862,10 @@ request_cleanup(mp, resource)
 	 * We wait at most tickdelay before proceeding in any case.
 	 */
 	proc_waiting += 1;
-	if (handle.callout == NULL)
-		handle = timeout(pause_timer, 0, tickdelay > 2 ? tickdelay : 2);
+	if (callout_pending(&softdep_callout) == FALSE) {
+		callout_reset(&softdep_callout, tickdelay > 2 ? tickdelay : 2,
+		    pause_timer, 0);
+	}
 	msleep((caddr_t)&proc_waiting, &lk, PPAUSE, "softupdate", 0);
 	proc_waiting -= 1;
 	return (1);
@@ -5874,14 +5880,16 @@ pause_timer(arg)
 	void *arg;
 {
 
-	ACQUIRE_LOCK(&lk);
+	/*
+	 * The callout_ API has acquired mtx and will hold it around this
+	 * function call.
+	 */
 	*stat_countp += 1;
 	wakeup_one(&proc_waiting);
-	if (proc_waiting > 0)
-		handle = timeout(pause_timer, 0, tickdelay > 2 ? tickdelay : 2);
-	else
-		handle.callout = NULL;
-	FREE_LOCK(&lk);
+	if (proc_waiting > 0) {
+		callout_reset(&softdep_callout, tickdelay > 2 ? tickdelay : 2,
+		    pause_timer, 0);
+	}
 }
 
 /*

--------------020807070709030700060709--



Want to link to this message? Use this URL: <https://mail-archive.FreeBSD.org/cgi/mid.cgi?47D7F1EC.6040802>