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