sys/dmu_impl.h

Go to the documentation of this file.

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright 2010 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 * Copyright (c) 2012, Joyent, Inc. All rights reserved.
 * Copyright (c) 2012, Martin Matuska <mm@FreeBSD.org>. All rights reserved.
 */

#ifndef _SYS_DMU_IMPL_H
#define _SYS_DMU_IMPL_H

#include <sys/txg_impl.h>
#include <sys/zio.h>
#include <sys/dnode.h>
#include <sys/kstat.h>
#include <sys/zfs_context.h>
#include <sys/zfs_ioctl.h>

#ifdef  __cplusplus
extern "C" {
#endif

struct objset;
struct dmu_pool;

typedef struct dmu_xuio {
        int next;
        int cnt;
        struct arc_buf **bufs;
        iovec_t *iovp;
} dmu_xuio_t;

typedef struct xuio_stats {
        kstat_named_t xuiostat_onloan_rbuf;
        kstat_named_t xuiostat_onloan_wbuf;
        kstat_named_t xuiostat_rbuf_copied;
        kstat_named_t xuiostat_rbuf_nocopy;
        kstat_named_t xuiostat_wbuf_copied;
        kstat_named_t xuiostat_wbuf_nocopy;
} xuio_stats_t;

static xuio_stats_t xuio_stats = {
        { "onloan_read_buf",    KSTAT_DATA_UINT64 },
        { "onloan_write_buf",   KSTAT_DATA_UINT64 },
        { "read_buf_copied",    KSTAT_DATA_UINT64 },
        { "read_buf_nocopy",    KSTAT_DATA_UINT64 },
        { "write_buf_copied",   KSTAT_DATA_UINT64 },
        { "write_buf_nocopy",   KSTAT_DATA_UINT64 }
};

#define XUIOSTAT_INCR(stat, val)        \
        atomic_add_64(&xuio_stats.stat.value.ui64, (val))
#define XUIOSTAT_BUMP(stat)     XUIOSTAT_INCR(stat, 1)

/*
 * The list of data whose inclusion in a send stream can be pending from
 * one call to backup_cb to another.  Multiple calls to dump_free() and
 * dump_freeobjects() can be aggregated into a single DRR_FREE or
 * DRR_FREEOBJECTS replay record.
 */
typedef enum {
        PENDING_NONE,
        PENDING_FREE,
        PENDING_FREEOBJECTS
} dmu_pendop_t;

typedef struct dmu_sendarg {
        list_node_t dsa_link;
        dmu_replay_record_t *dsa_drr;
        kthread_t *dsa_td;
        struct file *dsa_fp;
        int dsa_outfd;
        struct proc *dsa_proc;
        offset_t *dsa_off;
        objset_t *dsa_os;
        zio_cksum_t dsa_zc;
        uint64_t dsa_toguid;
        int dsa_err;
        dmu_pendop_t dsa_pending_op;
} dmu_sendarg_t;


#ifdef  __cplusplus
}
#endif

#endif  /* _SYS_DMU_IMPL_H */