| /* |
| * CDDL HEADER START |
| * |
| * This file and its contents are supplied under the terms of the |
| * Common Development and Distribution License ("CDDL"), version 1.0. |
| * You may only use this file in accordance with the terms of version |
| * 1.0 of the CDDL. |
| * |
| * A full copy of the text of the CDDL should have accompanied this |
| * source. A copy of the CDDL is also available via the Internet at |
| * http://www.illumos.org/license/CDDL. |
| * |
| * CDDL HEADER END |
| */ |
| /* |
| * Copyright (c) 2014 by Delphix. All rights reserved. |
| */ |
| |
| #ifndef _BQUEUE_H |
| #define _BQUEUE_H |
| |
| #ifdef __cplusplus |
| extern "C" { |
| #endif |
| |
| #include <sys/zfs_context.h> |
| |
| typedef struct bqueue { |
| list_t bq_list; |
| kmutex_t bq_lock; |
| kcondvar_t bq_add_cv; |
| kcondvar_t bq_pop_cv; |
| uint64_t bq_size; |
| uint64_t bq_maxsize; |
| size_t bq_node_offset; |
| } bqueue_t; |
| |
| typedef struct bqueue_node { |
| list_node_t bqn_node; |
| uint64_t bqn_size; |
| } bqueue_node_t; |
| |
| |
| int bqueue_init(bqueue_t *, uint64_t, size_t); |
| void bqueue_destroy(bqueue_t *); |
| void bqueue_enqueue(bqueue_t *, void *, uint64_t); |
| void *bqueue_dequeue(bqueue_t *); |
| boolean_t bqueue_empty(bqueue_t *); |
| |
| #ifdef __cplusplus |
| } |
| #endif |
| |
| #endif /* _BQUEUE_H */ |