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.
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.
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]
23 * Copyright (c) 2009, 2010, Oracle and/or its affiliates. All rights reserved.
26 #include <sys/zfs_context.h>
31 #include <sys/dmu_tx.h>
32 #include <util/sscanf.h>
34 int ddt_zap_leaf_blockshift
= 12;
35 int ddt_zap_indirect_blockshift
= 12;
38 ddt_zap_create(objset_t
*os
, uint64_t *objectp
, dmu_tx_t
*tx
, boolean_t prehash
)
40 zap_flags_t flags
= ZAP_FLAG_HASH64
| ZAP_FLAG_UINT64_KEY
;
43 flags
|= ZAP_FLAG_PRE_HASHED_KEY
;
45 *objectp
= zap_create_flags(os
, 0, flags
, DMU_OT_DDT_ZAP
,
46 ddt_zap_leaf_blockshift
, ddt_zap_indirect_blockshift
,
49 return (*objectp
== 0 ? ENOTSUP
: 0);
53 ddt_zap_destroy(objset_t
*os
, uint64_t object
, dmu_tx_t
*tx
)
55 return (zap_destroy(os
, object
, tx
));
59 ddt_zap_lookup(objset_t
*os
, uint64_t object
, ddt_entry_t
*dde
)
65 cbuf
= kmem_alloc(sizeof (dde
->dde_phys
) + 1, KM_SLEEP
);
67 error
= zap_length_uint64(os
, object
, (uint64_t *)&dde
->dde_key
,
68 DDT_KEY_WORDS
, &one
, &csize
);
73 ASSERT(csize
<= sizeof (cbuf
));
75 error
= zap_lookup_uint64(os
, object
, (uint64_t *)&dde
->dde_key
,
76 DDT_KEY_WORDS
, 1, csize
, cbuf
);
80 ddt_decompress(cbuf
, dde
->dde_phys
, csize
, sizeof (dde
->dde_phys
));
82 kmem_free(cbuf
, sizeof (dde
->dde_phys
) + 1);
88 ddt_zap_prefetch(objset_t
*os
, uint64_t object
, ddt_entry_t
*dde
)
90 (void) zap_prefetch_uint64(os
, object
, (uint64_t *)&dde
->dde_key
,
95 ddt_zap_update(objset_t
*os
, uint64_t object
, ddt_entry_t
*dde
, dmu_tx_t
*tx
)
97 uchar_t cbuf
[sizeof (dde
->dde_phys
) + 1];
100 csize
= ddt_compress(dde
->dde_phys
, cbuf
,
101 sizeof (dde
->dde_phys
), sizeof (cbuf
));
103 return (zap_update_uint64(os
, object
, (uint64_t *)&dde
->dde_key
,
104 DDT_KEY_WORDS
, 1, csize
, cbuf
, tx
));
108 ddt_zap_remove(objset_t
*os
, uint64_t object
, ddt_entry_t
*dde
, dmu_tx_t
*tx
)
110 return (zap_remove_uint64(os
, object
, (uint64_t *)&dde
->dde_key
,
115 ddt_zap_walk(objset_t
*os
, uint64_t object
, ddt_entry_t
*dde
, uint64_t *walk
)
121 zap_cursor_init_serialized(&zc
, os
, object
, *walk
);
122 if ((error
= zap_cursor_retrieve(&zc
, &za
)) == 0) {
123 uchar_t cbuf
[sizeof (dde
->dde_phys
) + 1];
124 uint64_t csize
= za
.za_num_integers
;
125 ASSERT(za
.za_integer_length
== 1);
126 error
= zap_lookup_uint64(os
, object
, (uint64_t *)za
.za_name
,
127 DDT_KEY_WORDS
, 1, csize
, cbuf
);
130 ddt_decompress(cbuf
, dde
->dde_phys
, csize
,
131 sizeof (dde
->dde_phys
));
132 dde
->dde_key
= *(ddt_key_t
*)za
.za_name
;
134 zap_cursor_advance(&zc
);
135 *walk
= zap_cursor_serialize(&zc
);
137 zap_cursor_fini(&zc
);
142 ddt_zap_count(objset_t
*os
, uint64_t object
)
146 VERIFY(zap_count(os
, object
, &count
) == 0);
151 const ddt_ops_t ddt_zap_ops
= {