Deleted Added
full compact
dsl_synctask.c (225736) dsl_synctask.c (243674)
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

--- 147 unchanged lines hidden (view full) ---

156
157void
158dsl_sync_task_group_sync(dsl_sync_task_group_t *dstg, dmu_tx_t *tx)
159{
160 dsl_sync_task_t *dst;
161 dsl_pool_t *dp = dstg->dstg_pool;
162 uint64_t quota, used;
163
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

--- 147 unchanged lines hidden (view full) ---

156
157void
158dsl_sync_task_group_sync(dsl_sync_task_group_t *dstg, dmu_tx_t *tx)
159{
160 dsl_sync_task_t *dst;
161 dsl_pool_t *dp = dstg->dstg_pool;
162 uint64_t quota, used;
163
164 ASSERT3U(dstg->dstg_err, ==, 0);
164 ASSERT0(dstg->dstg_err);
165
166 /*
167 * Check for sufficient space. We just check against what's
168 * on-disk; we don't want any in-flight accounting to get in our
169 * way, because open context may have already used up various
170 * in-core limits (arc_tempreserve, dsl_pool_tempreserve).
171 */
172 quota = dsl_pool_adjustedsize(dp, B_FALSE) -

--- 50 unchanged lines hidden (view full) ---

223 return (err);
224}
225
226void
227dsl_sync_task_do_nowait(dsl_pool_t *dp,
228 dsl_checkfunc_t *checkfunc, dsl_syncfunc_t *syncfunc,
229 void *arg1, void *arg2, int blocks_modified, dmu_tx_t *tx)
230{
165
166 /*
167 * Check for sufficient space. We just check against what's
168 * on-disk; we don't want any in-flight accounting to get in our
169 * way, because open context may have already used up various
170 * in-core limits (arc_tempreserve, dsl_pool_tempreserve).
171 */
172 quota = dsl_pool_adjustedsize(dp, B_FALSE) -

--- 50 unchanged lines hidden (view full) ---

223 return (err);
224}
225
226void
227dsl_sync_task_do_nowait(dsl_pool_t *dp,
228 dsl_checkfunc_t *checkfunc, dsl_syncfunc_t *syncfunc,
229 void *arg1, void *arg2, int blocks_modified, dmu_tx_t *tx)
230{
231 dsl_sync_task_group_t *dstg;
232
233 if (!spa_writeable(dp->dp_spa))
234 return;
235
236 dstg = dsl_sync_task_group_create(dp);
231 dsl_sync_task_group_t *dstg = dsl_sync_task_group_create(dp);
237 dsl_sync_task_create(dstg, checkfunc, syncfunc,
238 arg1, arg2, blocks_modified);
239 dsl_sync_task_group_nowait(dstg, tx);
240}
232 dsl_sync_task_create(dstg, checkfunc, syncfunc,
233 arg1, arg2, blocks_modified);
234 dsl_sync_task_group_nowait(dstg, tx);
235}