Lines Matching refs:agg
2257 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf, in dtrace_aggregate() argument
2260 dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec; in dtrace_aggregate()
2274 if (!agg->dtag_hasarg) { in dtrace_aggregate()
2286 action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION; in dtrace_aggregate()
2287 size = rec->dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2291 data = dbuf->dtb_tomax + offset + agg->dtag_base; in dtrace_aggregate()
2339 ASSERT(agg->dtag_first != NULL); in dtrace_aggregate()
2340 ASSERT(agg->dtag_first->dta_intuple); in dtrace_aggregate()
2351 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2352 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2388 for (act = agg->dtag_first; act->dta_intuple; in dtrace_aggregate()
2390 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2421 agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg); in dtrace_aggregate()
2457 *((dtrace_aggid_t *)kdata) = agg->dtag_id; in dtrace_aggregate()
2467 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2473 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2502 *((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial; in dtrace_aggregate()
2503 agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg); in dtrace_aggregate()
6856 dtrace_aggregation_t *agg; in dtrace_probe() local
6858 agg = (dtrace_aggregation_t *)act; in dtrace_probe()
6875 dtrace_aggregate(agg, buf, in dtrace_probe()
10335 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_resize() local
10338 ASSERT(agg->dtag_first != NULL); in dtrace_ecb_resize()
10343 agg->dtag_base = aggbase; in dtrace_ecb_resize()
10404 dtrace_aggregation_t *agg; in dtrace_ecb_aggregation_create() local
10412 agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP); in dtrace_ecb_aggregation_create()
10413 agg->dtag_ecb = ecb; in dtrace_ecb_aggregation_create()
10419 agg->dtag_initial = INT64_MAX; in dtrace_ecb_aggregation_create()
10420 agg->dtag_aggregate = dtrace_aggregate_min; in dtrace_ecb_aggregation_create()
10424 agg->dtag_initial = INT64_MIN; in dtrace_ecb_aggregation_create()
10425 agg->dtag_aggregate = dtrace_aggregate_max; in dtrace_ecb_aggregation_create()
10429 agg->dtag_aggregate = dtrace_aggregate_count; in dtrace_ecb_aggregation_create()
10433 agg->dtag_aggregate = dtrace_aggregate_quantize; in dtrace_ecb_aggregation_create()
10442 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
10443 agg->dtag_aggregate = dtrace_aggregate_lquantize; in dtrace_ecb_aggregation_create()
10459 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
10460 agg->dtag_aggregate = dtrace_aggregate_llquantize; in dtrace_ecb_aggregation_create()
10482 agg->dtag_aggregate = dtrace_aggregate_avg; in dtrace_ecb_aggregation_create()
10487 agg->dtag_aggregate = dtrace_aggregate_stddev; in dtrace_ecb_aggregation_create()
10492 agg->dtag_aggregate = dtrace_aggregate_sum; in dtrace_ecb_aggregation_create()
10499 agg->dtag_action.dta_rec.dtrd_size = size; in dtrace_ecb_aggregation_create()
10515 agg->dtag_first = act; in dtrace_ecb_aggregation_create()
10525 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_create()
10540 agg->dtag_hasarg = 1; in dtrace_ecb_aggregation_create()
10574 state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg; in dtrace_ecb_aggregation_create()
10576 frec = &agg->dtag_first->dta_rec; in dtrace_ecb_aggregation_create()
10580 for (act = agg->dtag_first; act != NULL; act = act->dta_next) { in dtrace_ecb_aggregation_create()
10585 return (&agg->dtag_action); in dtrace_ecb_aggregation_create()
10591 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_aggregation_destroy() local
10593 dtrace_aggid_t aggid = agg->dtag_id; in dtrace_ecb_aggregation_destroy()
10598 ASSERT(state->dts_aggregations[aggid - 1] == agg); in dtrace_ecb_aggregation_destroy()
10601 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_destroy()
11117 dtrace_aggregation_t *agg; in dtrace_aggid2agg() local
11125 ASSERT((agg = state->dts_aggregations[id - 1]) == NULL || in dtrace_aggid2agg()
11126 agg->dtag_id == id); in dtrace_aggid2agg()
16077 dtrace_aggregation_t *agg; in dtrace_ioctl() local
16090 if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) { in dtrace_ioctl()
16095 aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid; in dtrace_ioctl()
16100 offs = agg->dtag_base; in dtrace_ioctl()
16101 lrec = &agg->dtag_action.dta_rec; in dtrace_ioctl()
16104 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
16117 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
16123 if (act == &agg->dtag_action) in dtrace_ioctl()
16142 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
16150 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
16161 if (act == &agg->dtag_action) in dtrace_ioctl()