Lines Matching defs:agg
2539 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf,
2542 dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec;
2556 if (!agg->dtag_hasarg) {
2568 action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION;
2569 size = rec->dtrd_offset - agg->dtag_base;
2573 data = dbuf->dtb_tomax + offset + agg->dtag_base;
2621 ASSERT(agg->dtag_first != NULL);
2622 ASSERT(agg->dtag_first->dta_intuple);
2633 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2634 i = act->dta_rec.dtrd_offset - agg->dtag_base;
2670 for (act = agg->dtag_first; act->dta_intuple;
2672 i = act->dta_rec.dtrd_offset - agg->dtag_base;
2703 agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg);
2739 *((dtrace_aggid_t *)kdata) = agg->dtag_id;
2749 for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2755 i = act->dta_rec.dtrd_offset - agg->dtag_base;
2784 *((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial;
2785 agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg);
7600 dtrace_aggregation_t *agg;
7602 agg = (dtrace_aggregation_t *)act;
7619 dtrace_aggregate(agg, buf,
11221 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
11224 ASSERT(agg->dtag_first != NULL);
11229 agg->dtag_base = aggbase;
11297 dtrace_aggregation_t *agg;
11305 agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP);
11306 agg->dtag_ecb = ecb;
11312 agg->dtag_initial = INT64_MAX;
11313 agg->dtag_aggregate = dtrace_aggregate_min;
11317 agg->dtag_initial = INT64_MIN;
11318 agg->dtag_aggregate = dtrace_aggregate_max;
11322 agg->dtag_aggregate = dtrace_aggregate_count;
11326 agg->dtag_aggregate = dtrace_aggregate_quantize;
11335 agg->dtag_initial = desc->dtad_arg;
11336 agg->dtag_aggregate = dtrace_aggregate_lquantize;
11352 agg->dtag_initial = desc->dtad_arg;
11353 agg->dtag_aggregate = dtrace_aggregate_llquantize;
11375 agg->dtag_aggregate = dtrace_aggregate_avg;
11380 agg->dtag_aggregate = dtrace_aggregate_stddev;
11385 agg->dtag_aggregate = dtrace_aggregate_sum;
11392 agg->dtag_action.dta_rec.dtrd_size = size;
11408 agg->dtag_first = act;
11418 kmem_free(agg, sizeof (dtrace_aggregation_t));
11433 agg->dtag_hasarg = 1;
11471 state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg;
11473 frec = &agg->dtag_first->dta_rec;
11477 for (act = agg->dtag_first; act != NULL; act = act->dta_next) {
11482 return (&agg->dtag_action);
11488 dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
11490 dtrace_aggid_t aggid = agg->dtag_id;
11499 ASSERT(state->dts_aggregations[aggid - 1] == agg);
11502 kmem_free(agg, sizeof (dtrace_aggregation_t));
12025 dtrace_aggregation_t *agg;
12033 ASSERT((agg = state->dts_aggregations[id - 1]) == NULL ||
12034 agg->dtag_id == id);
17568 dtrace_aggregation_t *agg;
17581 if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) {
17586 aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid;
17591 offs = agg->dtag_base;
17592 lrec = &agg->dtag_action.dta_rec;
17595 for (act = agg->dtag_first; ; act = act->dta_next) {
17608 ASSERT(agg->dtag_hasarg);
17614 if (act == &agg->dtag_action)
17633 for (act = agg->dtag_first; ; act = act->dta_next) {
17641 ASSERT(agg->dtag_hasarg);
17652 if (act == &agg->dtag_action)