include/sys/bqueue.h

   1 /*
   2  * CDDL HEADER START
   3  *
   4  * This file and its contents are supplied under the terms of the
   5  * Common Development and Distribution License ("CDDL"), version 1.0.
   6  * You may only use this file in accordance with the terms of version
   7  * 1.0 of the CDDL.
   8  *
   9  * A full copy of the text of the CDDL should have accompanied this
  10  * source.  A copy of the CDDL is also available via the Internet at
  11  * http://www.illumos.org/license/CDDL.
  12  *
  13  * CDDL HEADER END
  14  */
  15 /*
  16  * Copyright (c) 2014, 2018 by Delphix. All rights reserved.
  17  */
  18
  19 #ifndef _BQUEUE_H
  20 #define _BQUEUE_H
  21
  22 #ifdef  __cplusplus
  23 extern "C" {
  24 #endif
  25
  26 #include        <sys/zfs_context.h>
  27
  28 typedef struct bqueue {
  29         list_t bq_list;
  30         size_t bq_size;
  31         list_t bq_dequeuing_list;
  32         size_t bq_dequeuing_size;
  33         list_t bq_enqueuing_list;
  34         size_t bq_enqueuing_size;
  35         kmutex_t bq_lock;
  36         kcondvar_t bq_add_cv;
  37         kcondvar_t bq_pop_cv;
  38         size_t bq_maxsize;
  39         uint_t bq_fill_fraction;
  40         size_t bq_node_offset;
  41 } bqueue_t;
  42
  43 typedef struct bqueue_node {
  44         list_node_t bqn_node;
  45         size_t bqn_size;
  46 } bqueue_node_t;
  47
  48
  49 int bqueue_init(bqueue_t *, uint_t, size_t, size_t);
  50 void bqueue_destroy(bqueue_t *);
  51 void bqueue_enqueue(bqueue_t *, void *, size_t);
  52 void bqueue_enqueue_flush(bqueue_t *, void *, size_t);
  53 void *bqueue_dequeue(bqueue_t *);
  54
  55 #ifdef  __cplusplus
  56 }
  57 #endif
  58
  59 #endif  /* _BQUEUE_H */