Lines Matching refs:agg

2291 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf,  in dtrace_aggregate()  argument
2294 dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec; in dtrace_aggregate()
2308 if (!agg->dtag_hasarg) { in dtrace_aggregate()
2320 action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION; in dtrace_aggregate()
2321 size = rec->dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2325 data = dbuf->dtb_tomax + offset + agg->dtag_base; in dtrace_aggregate()
2373 ASSERT(agg->dtag_first != NULL); in dtrace_aggregate()
2374 ASSERT(agg->dtag_first->dta_intuple); in dtrace_aggregate()
2385 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2386 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2422 for (act = agg->dtag_first; act->dta_intuple; in dtrace_aggregate()
2424 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2455 agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg); in dtrace_aggregate()
2491 *((dtrace_aggid_t *)kdata) = agg->dtag_id; in dtrace_aggregate()
2501 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2507 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2536 *((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial; in dtrace_aggregate()
2537 agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg); in dtrace_aggregate()
6915 dtrace_aggregation_t *agg; in dtrace_probe() local
6917 agg = (dtrace_aggregation_t *)act; in dtrace_probe()
6934 dtrace_aggregate(agg, buf, in dtrace_probe()
10452 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_resize() local
10455 ASSERT(agg->dtag_first != NULL); in dtrace_ecb_resize()
10460 agg->dtag_base = aggbase; in dtrace_ecb_resize()
10521 dtrace_aggregation_t *agg; in dtrace_ecb_aggregation_create() local
10529 agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP); in dtrace_ecb_aggregation_create()
10530 agg->dtag_ecb = ecb; in dtrace_ecb_aggregation_create()
10536 agg->dtag_initial = INT64_MAX; in dtrace_ecb_aggregation_create()
10537 agg->dtag_aggregate = dtrace_aggregate_min; in dtrace_ecb_aggregation_create()
10541 agg->dtag_initial = INT64_MIN; in dtrace_ecb_aggregation_create()
10542 agg->dtag_aggregate = dtrace_aggregate_max; in dtrace_ecb_aggregation_create()
10546 agg->dtag_aggregate = dtrace_aggregate_count; in dtrace_ecb_aggregation_create()
10550 agg->dtag_aggregate = dtrace_aggregate_quantize; in dtrace_ecb_aggregation_create()
10559 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
10560 agg->dtag_aggregate = dtrace_aggregate_lquantize; in dtrace_ecb_aggregation_create()
10576 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
10577 agg->dtag_aggregate = dtrace_aggregate_llquantize; in dtrace_ecb_aggregation_create()
10599 agg->dtag_aggregate = dtrace_aggregate_avg; in dtrace_ecb_aggregation_create()
10604 agg->dtag_aggregate = dtrace_aggregate_stddev; in dtrace_ecb_aggregation_create()
10609 agg->dtag_aggregate = dtrace_aggregate_sum; in dtrace_ecb_aggregation_create()
10616 agg->dtag_action.dta_rec.dtrd_size = size; in dtrace_ecb_aggregation_create()
10632 agg->dtag_first = act; in dtrace_ecb_aggregation_create()
10642 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_create()
10657 agg->dtag_hasarg = 1; in dtrace_ecb_aggregation_create()
10691 state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg; in dtrace_ecb_aggregation_create()
10693 frec = &agg->dtag_first->dta_rec; in dtrace_ecb_aggregation_create()
10697 for (act = agg->dtag_first; act != NULL; act = act->dta_next) { in dtrace_ecb_aggregation_create()
10702 return (&agg->dtag_action); in dtrace_ecb_aggregation_create()
10708 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_aggregation_destroy() local
10710 dtrace_aggid_t aggid = agg->dtag_id; in dtrace_ecb_aggregation_destroy()
10715 ASSERT(state->dts_aggregations[aggid - 1] == agg); in dtrace_ecb_aggregation_destroy()
10718 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_destroy()
11234 dtrace_aggregation_t *agg; in dtrace_aggid2agg() local
11242 ASSERT((agg = state->dts_aggregations[id - 1]) == NULL || in dtrace_aggid2agg()
11243 agg->dtag_id == id); in dtrace_aggid2agg()
16208 dtrace_aggregation_t *agg; in dtrace_ioctl() local
16221 if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) { in dtrace_ioctl()
16226 aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid; in dtrace_ioctl()
16231 offs = agg->dtag_base; in dtrace_ioctl()
16232 lrec = &agg->dtag_action.dta_rec; in dtrace_ioctl()
16235 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
16248 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
16254 if (act == &agg->dtag_action) in dtrace_ioctl()
16273 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
16281 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
16292 if (act == &agg->dtag_action) in dtrace_ioctl()