sys/cddl/contrib/opensolaris/uts/common/fs/zfs/bplist.c

   1 /*
   2  * CDDL HEADER START
   3  *
   4  * The contents of this file are subject to the terms of the
   5  * Common Development and Distribution License (the "License").
   6  * You may not use this file except in compliance with the License.
   7  *
   8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
   9  * or http://www.opensolaris.org/os/licensing.
  10  * See the License for the specific language governing permissions
  11  * and limitations under the License.
  12  *
  13  * When distributing Covered Code, include this CDDL HEADER in each
  14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
  15  * If applicable, add the following below this CDDL HEADER, with the
  16  * fields enclosed by brackets "[]" replaced with your own identifying
  17  * information: Portions Copyright [yyyy] [name of copyright owner]
  18  *
  19  * CDDL HEADER END
  20  */
  21 /*
  22  * Copyright (c) 2005, 2010, Oracle and/or its affiliates. All rights reserved.
  23  */
  24
  25 #include <sys/bplist.h>
  26 #include <sys/zfs_context.h>
  27
  28
  29 void
  30 bplist_create(bplist_t *bpl)
  31 {
  32         mutex_init(&bpl->bpl_lock, NULL, MUTEX_DEFAULT, NULL);
  33         list_create(&bpl->bpl_list, sizeof (bplist_entry_t),
  34             offsetof(bplist_entry_t, bpe_node));
  35 }
  36
  37 void
  38 bplist_destroy(bplist_t *bpl)
  39 {
  40         list_destroy(&bpl->bpl_list);
  41         mutex_destroy(&bpl->bpl_lock);
  42 }
  43
  44 void
  45 bplist_append(bplist_t *bpl, const blkptr_t *bp)
  46 {
  47         bplist_entry_t *bpe = kmem_alloc(sizeof (*bpe), KM_SLEEP);
  48
  49         mutex_enter(&bpl->bpl_lock);
  50         bpe->bpe_blk = *bp;
  51         list_insert_tail(&bpl->bpl_list, bpe);
  52         mutex_exit(&bpl->bpl_lock);
  53 }
  54
  55 void
  56 bplist_iterate(bplist_t *bpl, bplist_itor_t *func, void *arg, dmu_tx_t *tx)
  57 {
  58         bplist_entry_t *bpe;
  59
  60         mutex_enter(&bpl->bpl_lock);
  61         while (bpe = list_head(&bpl->bpl_list)) {
  62                 list_remove(&bpl->bpl_list, bpe);
  63                 mutex_exit(&bpl->bpl_lock);
  64                 func(arg, &bpe->bpe_blk, tx);
  65                 kmem_free(bpe, sizeof (*bpe));
  66                 mutex_enter(&bpl->bpl_lock);
  67         }
  68         mutex_exit(&bpl->bpl_lock);
  69 }