fs/zfs/dsl_pool.c

80  * txg (dp_dirty_pertxg[]) and poolwide (dp_dirty_total) accounting of
83  * relevant, the per-txg value is useful for debugging. The tunable
88  * ensure that there is a txg syncing (see the comment in txg.c for a full
108  * If there is at least this much dirty data, push out a txg.
158     "Force a txg if the number of dirty buffer bytes exceed this value");
249 dsl_pool_open_impl(spa_t *spa, uint64_t txg)
258 	txg_init(dp, txg);
279 dsl_pool_init(spa_t *spa, uint64_t txg, dsl_pool_t **dpp)
282 	dsl_pool_t *dp = dsl_pool_open_impl(spa, txg);
440 dsl_pool_create(spa_t *spa, nvlist_t *zplprops, uint64_t txg)
443 	dsl_pool_t *dp = dsl_pool_open_impl(spa, txg);
444 	dmu_tx_t *tx = dmu_tx_create_assigned(dp, txg);
461 	VERIFY0(dsl_scan_init(dp, txg));
562 dsl_pool_sync(dsl_pool_t *dp, uint64_t txg)
574 	tx = dmu_tx_create_assigned(dp, txg);
580 	while ((ds = txg_list_remove(&dp->dp_dirty_datasets, txg)) != NULL) {
599 	dsl_pool_undirty_space(dp, dp->dp_dirty_pertxg[txg & TXG_MASK], txg);
618 	while ((ds = txg_list_remove(&dp->dp_dirty_datasets, txg)) != NULL) {
636 		ASSERT(!dmu_objset_is_dirty(os, txg));
639 	while ((dd = txg_list_remove(&dp->dp_dirty_dirs, txg)) != NULL) {
659 	if (list_head(&mos->os_dirty_dnodes[txg & TXG_MASK]) != NULL ||
660 	    list_head(&mos->os_free_dnodes[txg & TXG_MASK]) != NULL) {
665 	 * If we modify a dataset in the same txg that we want to destroy it,
673 	if (!txg_list_empty(&dp->dp_sync_tasks, txg)) {
680 		while ((dst = txg_list_remove(&dp->dp_sync_tasks, txg)) != NULL)
686 	DTRACE_PROBE2(dsl_pool_sync__done, dsl_pool_t *dp, dp, uint64_t, txg);
690 dsl_pool_sync_done(dsl_pool_t *dp, uint64_t txg)
694 	while (zilog = txg_list_remove(&dp->dp_dirty_zilogs, txg)) {
696 		zil_clean(zilog, txg);
697 		ASSERT(!dmu_objset_is_dirty(zilog->zl_os, txg));
700 	ASSERT(!dmu_objset_is_dirty(dp->dp_meta_objset, txg));
759 dsl_pool_undirty_space(dsl_pool_t *dp, int64_t space, uint64_t txg)
765 	if (dp->dp_dirty_pertxg[txg & TXG_MASK] < space) {
767 		space = dp->dp_dirty_pertxg[txg & TXG_MASK];
769 	ASSERT3U(dp->dp_dirty_pertxg[txg & TXG_MASK], >=, space);
770 	dp->dp_dirty_pertxg[txg & TXG_MASK] -= space;