Home | History | Annotate | Line # | Download | only in dmover
dmover_request.c revision 1.1 
      1 /*	$NetBSD: dmover_request.c,v 1.1 2002/08/02 00:30:39 thorpej Exp $	*/
      2 
      3 /*
      4  * Copyright (c) 2002 Wasabi Systems, Inc.
      5  * All rights reserved.
      6  *
      7  * Written by Jason R. Thorpe for Wasabi Systems, Inc.
      8  *
      9  * Redistribution and use in source and binary forms, with or without
     10  * modification, are permitted provided that the following conditions
     11  * are met:
     12  * 1. Redistributions of source code must retain the above copyright
     13  *    notice, this list of conditions and the following disclaimer.
     14  * 2. Redistributions in binary form must reproduce the above copyright
     15  *    notice, this list of conditions and the following disclaimer in the
     16  *    documentation and/or other materials provided with the distribution.
     17  * 3. All advertising materials mentioning features or use of this software
     18  *    must display the following acknowledgement:
     19  *	This product includes software developed for the NetBSD Project by
     20  *	Wasabi Systems, Inc.
     21  * 4. The name of Wasabi Systems, Inc. may not be used to endorse
     22  *    or promote products derived from this software without specific prior
     23  *    written permission.
     24  *
     25  * THIS SOFTWARE IS PROVIDED BY WASABI SYSTEMS, INC. ``AS IS'' AND
     26  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     27  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     28  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL WASABI SYSTEMS, INC
     29  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     30  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     31  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     32  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     33  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     34  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     35  * POSSIBILITY OF SUCH DAMAGE.
     36  */
     37 
     38 /*
     39  * dmover_request.c: Request management functions for dmover-api.
     40  */
     41 
     42 #include <sys/cdefs.h>
     43 __KERNEL_RCSID(0, "$NetBSD: dmover_request.c,v 1.1 2002/08/02 00:30:39 thorpej Exp $");
     44 
     45 #include <sys/param.h>
     46 #include <sys/lock.h>
     47 #include <sys/pool.h>
     48 #include <sys/systm.h>
     49 #include <sys/malloc.h>
     50 
     51 #include <dev/dmover/dmovervar.h>
     52 
     53 struct pool dmover_request_pool;
     54 struct pool_cache dmover_request_cache;
     55 
     56 static int initialized;
     57 static struct simplelock initialized_slock = SIMPLELOCK_INITIALIZER;
     58 
     59 void
     60 dmover_request_initialize(void)
     61 {
     62 	int s;
     63 
     64 	s = splbio();
     65 	simple_lock(&initialized_slock);
     66 	if (__predict_true(initialized == 0)) {
     67 		pool_init(&dmover_request_pool, sizeof(struct dmover_request),
     68 		    0, 0, 0, "dmreq", NULL);
     69 		pool_cache_init(&dmover_request_cache, &dmover_request_pool,
     70 		    NULL, NULL, NULL);
     71 		initialized = 1;
     72 	}
     73 	simple_unlock(&initialized_slock);
     74 	splx(s);
     75 }
     76 
     77 /*
     78  * dmover_request_alloc:	[client interface function]
     79  *
     80  *	Allocate a tranform request for the specified session.
     81  */
     82 struct dmover_request *
     83 dmover_request_alloc(struct dmover_session *dses, dmover_buffer *inbuf)
     84 {
     85 	struct dmover_request *dreq;
     86 	int s, inputs = dses->dses_ninputs;
     87 
     88 	if (__predict_false(initialized == 0)) {
     89 		int error;
     90 
     91 		s = splbio();
     92 		simple_lock(&initialized_slock);
     93 		error = (initialized == 0);
     94 		simple_unlock(&initialized_slock);
     95 		splx(s);
     96 
     97 		if (error)
     98 			return (NULL);
     99 	}
    100 
    101 	s = splbio();
    102 	dreq = pool_cache_get(&dmover_request_cache, PR_NOWAIT);
    103 	splx(s);
    104 	if (dreq == NULL)
    105 		return (NULL);
    106 
    107 	memset(dreq, 0, sizeof(*dreq));
    108 
    109 	if (inputs != 0) {
    110 		if (inbuf == NULL) {
    111 			inbuf = malloc(sizeof(dmover_buffer) * inputs,
    112 			    M_DEVBUF, M_NOWAIT);
    113 			if (inbuf == NULL) {
    114 				s = splbio();
    115 				pool_cache_put(&dmover_request_cache, dreq);
    116 				splx(s);
    117 				return (NULL);
    118 			}
    119 		}
    120 		dreq->dreq_flags |= __DMOVER_REQ_INBUF_FREE;
    121 		dreq->dreq_inbuf = inbuf;
    122 	}
    123 
    124 	dreq->dreq_session = dses;
    125 
    126 	return (dreq);
    127 }
    128 
    129 /*
    130  * dmover_request_free:		[client interface function]
    131  *
    132  *	Free a dmover request.
    133  */
    134 void
    135 dmover_request_free(struct dmover_request *dreq)
    136 {
    137 	int s;
    138 
    139 	if (dreq->dreq_flags & __DMOVER_REQ_INBUF_FREE)
    140 		free(dreq->dreq_inbuf, M_DEVBUF);
    141 
    142 	s = splbio();
    143 	pool_cache_put(&dmover_request_cache, dreq);
    144 	splx(s);
    145 }
    146