Lines Matching defs:sls

311 	for (spa_log_sm_t *sls = avl_last(&spa->spa_sm_logs_by_txg);
312 sls != NULL && steps < zfs_max_log_walking;
313 sls = AVL_PREV(&spa->spa_sm_logs_by_txg, sls)) {
314 if (sls->sls_txg == spa_syncing_txg(spa)) {
321 sum += sls->sls_nblocks;
379 for (spa_log_sm_t *sls = avl_first(&spa->spa_sm_logs_by_txg);
380 sls; sls = AVL_NEXT(&spa->spa_sm_logs_by_txg, sls)) {
381 ms_in_logs += sls->sls_mscount;
382 blk_in_logs += sls->sls_nblocks;
550 spa_log_sm_t *sls = avl_find(&spa->spa_sm_logs_by_txg,
553 if (sls == NULL) {
562 ASSERT(sls->sls_mscount > 0);
563 sls->sls_mscount--;
878 spa_log_sm_t *sls = avl_last(&spa->spa_sm_logs_by_txg);
879 ASSERT3U(sls->sls_txg, ==, spa_syncing_txg(spa));
881 sls->sls_nblocks = space_map_nblocks(spa_syncing_log_sm(spa));
882 spa->spa_unflushed_stats.sus_nblocks += sls->sls_nblocks;
890 ASSERT(sls->sls_nblocks != 0);
892 spa_log_summary_add_incoming_blocks(spa, sls->sls_nblocks);
928 for (spa_log_sm_t *sls = avl_first(&spa->spa_sm_logs_by_txg);
929 sls && sls->sls_txg < oldest_flushed_txg;
930 sls = avl_first(&spa->spa_sm_logs_by_txg)) {
931 ASSERT0(sls->sls_mscount);
932 avl_remove(&spa->spa_sm_logs_by_txg, sls);
933 space_map_free_obj(mos, sls->sls_sm_obj, tx);
934 VERIFY0(zap_remove_int(mos, spacemap_zap, sls->sls_txg, tx));
935 spa_log_summary_decrement_blkcount(spa, sls->sls_nblocks);
936 spa->spa_unflushed_stats.sus_nblocks -= sls->sls_nblocks;
937 kmem_free(sls, sizeof (spa_log_sm_t));
944 spa_log_sm_t *sls = kmem_zalloc(sizeof (*sls), KM_SLEEP);
945 sls->sls_sm_obj = sm_obj;
946 sls->sls_txg = txg;
947 return (sls);
1028 spa_log_sm_t *sls =
1030 avl_add(&spa->spa_sm_logs_by_txg, sls);
1044 spa_log_sm_t *sls = avl_find(&spa->spa_sm_logs_by_txg,
1048 * At this point if sls is zero it means that a bug occurred
1057 ASSERT(sls != NULL);
1058 if (sls == NULL) {
1065 sls->sls_mscount++;
1133 spa_log_sm_t *sls, *psls;
1149 for (sls = avl_first(&spa->spa_sm_logs_by_txg); sls;
1150 sls = AVL_NEXT(&spa->spa_sm_logs_by_txg, sls)) {
1151 dmu_prefetch_dnode(spa_meta_objset(spa), sls->sls_sm_obj,
1158 psls = sls = avl_first(&spa->spa_sm_logs_by_txg);
1159 while (sls != NULL) {
1170 (u_longlong_t)sls->sls_sm_obj, error);
1184 ASSERT0(sls->sls_nblocks);
1185 sls->sls_nblocks = space_map_nblocks(sls->sls_sm);
1186 spa->spa_unflushed_stats.sus_nblocks += sls->sls_nblocks;
1187 summary_add_data(spa, sls->sls_txg,
1188 sls->sls_mscount, 0, sls->sls_nblocks);
1196 .slls_txg = sls->sls_txg
1198 error = space_map_iterate(sls->sls_sm,
1199 space_map_length(sls->sls_sm), spa_ld_log_sm_cb, &vla);
1203 (u_longlong_t)sls->sls_sm_obj, error);
1208 ps -= space_map_length(sls->sls_sm);
1210 space_map_close(sls->sls_sm);
1211 sls->sls_sm = NULL;
1212 sls = AVL_NEXT(&spa->spa_sm_logs_by_txg, sls);
1228 for (spa_log_sm_t *sls = avl_first(&spa->spa_sm_logs_by_txg);
1229 sls; sls = AVL_NEXT(&spa->spa_sm_logs_by_txg, sls)) {
1230 if (sls->sls_sm) {
1231 space_map_close(sls->sls_sm);
1232 sls->sls_sm = NULL;