Lines Matching defs:dp
108 static void txg_sync_thread(dsl_pool_t *dp);
109 static void txg_quiesce_thread(dsl_pool_t *dp);
117 txg_init(dsl_pool_t *dp, uint64_t txg)
119 tx_state_t *tx = &dp->dp_tx;
155 txg_fini(dsl_pool_t *dp)
157 tx_state_t *tx = &dp->dp_tx;
193 txg_sync_start(dsl_pool_t *dp)
195 tx_state_t *tx = &dp->dp_tx;
199 dprintf("pool %p\n", dp);
206 dp, 0, &p0, TS_RUN, minclsyspri);
214 dp, 0, &p0, TS_RUN, minclsyspri);
255 txg_sync_stop(dsl_pool_t *dp)
257 tx_state_t *tx = &dp->dp_tx;
259 dprintf("pool %p\n", dp);
268 txg_wait_synced(dp, tx->tx_open_txg + TXG_DEFER_SIZE);
292 txg_hold_open(dsl_pool_t *dp, txg_handle_t *th)
294 tx_state_t *tx = &dp->dp_tx;
353 txg_quiesce(dsl_pool_t *dp, uint64_t txg)
355 tx_state_t *tx = &dp->dp_tx;
369 DTRACE_PROBE2(txg__quiescing, dsl_pool_t *, dp, uint64_t, txg);
370 DTRACE_PROBE2(txg__opened, dsl_pool_t *, dp, uint64_t, tx->tx_open_txg);
408 txg_dispatch_callbacks(dsl_pool_t *dp, uint64_t txg)
411 tx_state_t *tx = &dp->dp_tx;
447 txg_sync_thread(dsl_pool_t *dp)
449 spa_t *spa = dp->dp_spa;
450 tx_state_t *tx = &dp->dp_tx;
468 while (!dsl_scan_active(dp->dp_scan) &&
472 dp->dp_dirty_total < zfs_dirty_data_sync) {
473 dprintf("waiting; tx_synced=%llu waiting=%llu dp=%p\n",
474 tx->tx_synced_txg, tx->tx_sync_txg_waiting, dp);
502 DTRACE_PROBE2(txg__syncing, dsl_pool_t *, dp, uint64_t, txg);
516 DTRACE_PROBE2(txg__synced, dsl_pool_t *, dp, uint64_t, txg);
522 txg_dispatch_callbacks(dp, txg);
527 txg_quiesce_thread(dsl_pool_t *dp)
529 tx_state_t *tx = &dp->dp_tx;
557 txg_quiesce(dp, txg);
565 DTRACE_PROBE2(txg__quiesced, dsl_pool_t *, dp, uint64_t, txg);
577 txg_delay(dsl_pool_t *dp, uint64_t txg, hrtime_t delay, hrtime_t resolution)
579 tx_state_t *tx = &dp->dp_tx;
594 tx->tx_syncing_txg < txg-1 && !txg_stalled(dp)) {
603 txg_wait_synced(dsl_pool_t *dp, uint64_t txg)
605 tx_state_t *tx = &dp->dp_tx;
607 ASSERT(!dsl_pool_config_held(dp));
619 "tx_synced=%llu waiting=%llu dp=%p\n",
620 tx->tx_synced_txg, tx->tx_sync_txg_waiting, dp);
628 txg_wait_open(dsl_pool_t *dp, uint64_t txg)
630 tx_state_t *tx = &dp->dp_tx;
632 ASSERT(!dsl_pool_config_held(dp));
654 txg_kick(dsl_pool_t *dp)
656 tx_state_t *tx = &dp->dp_tx;
658 ASSERT(!dsl_pool_config_held(dp));
672 txg_stalled(dsl_pool_t *dp)
674 tx_state_t *tx = &dp->dp_tx;
679 txg_sync_waiting(dsl_pool_t *dp)
681 tx_state_t *tx = &dp->dp_tx;