Lines Matching refs:agg
2534 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf, in dtrace_aggregate() argument
2538 dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec; in dtrace_aggregate()
2552 if (!agg->dtag_hasarg) { in dtrace_aggregate()
2564 action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION; in dtrace_aggregate()
2565 size = rec->dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2569 data = dbuf->dtb_tomax + offset + agg->dtag_base; in dtrace_aggregate()
2617 ASSERT(agg->dtag_first != NULL); in dtrace_aggregate()
2618 ASSERT(agg->dtag_first->dta_intuple); in dtrace_aggregate()
2629 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2630 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2666 for (act = agg->dtag_first; act->dta_intuple; in dtrace_aggregate()
2668 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2699 agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg); in dtrace_aggregate()
2735 *((dtrace_aggid_t *)kdata) = agg->dtag_id; in dtrace_aggregate()
2745 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) { in dtrace_aggregate()
2751 i = act->dta_rec.dtrd_offset - agg->dtag_base; in dtrace_aggregate()
2780 *((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial; in dtrace_aggregate()
2781 agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg); in dtrace_aggregate()
7396 dtrace_aggregation_t *agg; in dtrace_probe() local
7398 agg = (dtrace_aggregation_t *)act; in dtrace_probe()
7415 dtrace_aggregate(agg, buf, in dtrace_probe()
11145 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_resize() local
11148 ASSERT(agg->dtag_first != NULL); in dtrace_ecb_resize()
11153 agg->dtag_base = aggbase; in dtrace_ecb_resize()
11217 dtrace_aggregation_t *agg; in dtrace_ecb_aggregation_create() local
11225 agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP); in dtrace_ecb_aggregation_create()
11226 agg->dtag_ecb = ecb; in dtrace_ecb_aggregation_create()
11232 agg->dtag_initial = INT64_MAX; in dtrace_ecb_aggregation_create()
11233 agg->dtag_aggregate = dtrace_aggregate_min; in dtrace_ecb_aggregation_create()
11237 agg->dtag_initial = INT64_MIN; in dtrace_ecb_aggregation_create()
11238 agg->dtag_aggregate = dtrace_aggregate_max; in dtrace_ecb_aggregation_create()
11242 agg->dtag_aggregate = dtrace_aggregate_count; in dtrace_ecb_aggregation_create()
11246 agg->dtag_aggregate = dtrace_aggregate_quantize; in dtrace_ecb_aggregation_create()
11255 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
11256 agg->dtag_aggregate = dtrace_aggregate_lquantize; in dtrace_ecb_aggregation_create()
11272 agg->dtag_initial = desc->dtad_arg; in dtrace_ecb_aggregation_create()
11273 agg->dtag_aggregate = dtrace_aggregate_llquantize; in dtrace_ecb_aggregation_create()
11294 agg->dtag_aggregate = dtrace_aggregate_avg; in dtrace_ecb_aggregation_create()
11299 agg->dtag_aggregate = dtrace_aggregate_stddev; in dtrace_ecb_aggregation_create()
11304 agg->dtag_aggregate = dtrace_aggregate_sum; in dtrace_ecb_aggregation_create()
11311 agg->dtag_action.dta_rec.dtrd_size = size; in dtrace_ecb_aggregation_create()
11327 agg->dtag_first = act; in dtrace_ecb_aggregation_create()
11337 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_create()
11352 agg->dtag_hasarg = 1; in dtrace_ecb_aggregation_create()
11386 state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg; in dtrace_ecb_aggregation_create()
11388 frec = &agg->dtag_first->dta_rec; in dtrace_ecb_aggregation_create()
11392 for (act = agg->dtag_first; act != NULL; act = act->dta_next) { in dtrace_ecb_aggregation_create()
11397 return (&agg->dtag_action); in dtrace_ecb_aggregation_create()
11403 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act; in dtrace_ecb_aggregation_destroy() local
11405 dtrace_aggid_t aggid = agg->dtag_id; in dtrace_ecb_aggregation_destroy()
11410 ASSERT(state->dts_aggregations[aggid - 1] == agg); in dtrace_ecb_aggregation_destroy()
11413 kmem_free(agg, sizeof (dtrace_aggregation_t)); in dtrace_ecb_aggregation_destroy()
11938 dtrace_aggregation_t *agg; in dtrace_aggid2agg() local
11939 #pragma unused(agg) /* __APPLE__ */ in dtrace_aggid2agg()
11947 ASSERT((agg = state->dts_aggregations[id - 1]) == NULL || in dtrace_aggid2agg()
11948 agg->dtag_id == id); in dtrace_aggid2agg()
17969 dtrace_aggregation_t *agg; in dtrace_ioctl() local
17982 if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) { in dtrace_ioctl()
17987 aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid; in dtrace_ioctl()
17992 offs = agg->dtag_base; in dtrace_ioctl()
17993 lrec = &agg->dtag_action.dta_rec; in dtrace_ioctl()
17996 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
18009 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
18015 if (act == &agg->dtag_action) in dtrace_ioctl()
18034 for (act = agg->dtag_first; ; act = act->dta_next) { in dtrace_ioctl()
18042 ASSERT(agg->dtag_hasarg); in dtrace_ioctl()
18053 if (act == &agg->dtag_action) in dtrace_ioctl()