Author: lstewart
Date: Thu Apr  1 01:16:00 2010
New Revision: 206026
URL: http://svn.freebsd.org/changeset/base/206026

Log:
  - Factor code to destroy an ALQ out of alq_close() into a private 
alq_destroy().
  
  - Use the new alq_destroy() to properly handle a failure case in alq_open().
  
  Sponsored by: FreeBSD Foundation
  Reviewed by:  dwmalone, jeff, rpaulo, rwatson (as part of a larger patch)
  Approved by:  kmacy (mentor)
  MFC after:    1 month

Modified:
  head/sys/kern/kern_alq.c

Modified: head/sys/kern/kern_alq.c
==============================================================================
--- head/sys/kern/kern_alq.c    Thu Apr  1 00:38:38 2010        (r206025)
+++ head/sys/kern/kern_alq.c    Thu Apr  1 01:16:00 2010        (r206026)
@@ -103,6 +103,7 @@ static void ald_deactivate(struct alq *)
 
 /* Internal queue functions */
 static void alq_shutdown(struct alq *);
+static void alq_destroy(struct alq *);
 static int alq_doio(struct alq *);
 
 
@@ -263,6 +264,18 @@ alq_shutdown(struct alq *alq)
        crfree(alq->aq_cred);
 }
 
+void
+alq_destroy(struct alq *alq)
+{
+       /* Drain all pending IO. */
+       alq_shutdown(alq);
+
+       mtx_destroy(&alq->aq_mtx);
+       free(alq->aq_first, M_ALD);
+       free(alq->aq_entbuf, M_ALD);
+       free(alq, M_ALD);
+}
+
 /*
  * Flush all pending data to disk.  This operation will block.
  */
@@ -420,8 +433,11 @@ alq_open(struct alq **alqp, const char *
 
        alp->ae_next = alq->aq_first;
 
-       if ((error = ald_add(alq)) != 0)
+       if ((error = ald_add(alq)) != 0) {
+               alq_destroy(alq);
                return (error);
+       }
+
        *alqp = alq;
 
        return (0);
@@ -525,22 +541,9 @@ alq_flush(struct alq *alq)
 void
 alq_close(struct alq *alq)
 {
-       /*
-        * If we're already shuting down someone else will flush and close
-        * the vnode.
-        */
-       if (ald_rem(alq) != 0)
-               return;
-
-       /*
-        * Drain all pending IO.
-        */
-       alq_shutdown(alq);
-
-       mtx_destroy(&alq->aq_mtx);
-       free(alq->aq_first, M_ALD);
-       free(alq->aq_entbuf, M_ALD);
-       free(alq, M_ALD);
+       /* Only flush and destroy alq if not already shutting down. */
+       if (ald_rem(alq) == 0)
+               alq_destroy(alq);
 }
 
 static int
_______________________________________________
[email protected] mailing list
http://lists.freebsd.org/mailman/listinfo/svn-src-head
To unsubscribe, send any mail to "[email protected]"

Reply via email to