common/dtrace/dtrace.c

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);
7599 				dtrace_aggregation_t *agg;
7601 				agg = (dtrace_aggregation_t *)act;
7618 				dtrace_aggregate(agg, buf,
11219 			dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
11222 			ASSERT(agg->dtag_first != NULL);
11227 			agg->dtag_base = aggbase;
11295 	dtrace_aggregation_t *agg;
11303 	agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP);
11304 	agg->dtag_ecb = ecb;
11310 		agg->dtag_initial = INT64_MAX;
11311 		agg->dtag_aggregate = dtrace_aggregate_min;
11315 		agg->dtag_initial = INT64_MIN;
11316 		agg->dtag_aggregate = dtrace_aggregate_max;
11320 		agg->dtag_aggregate = dtrace_aggregate_count;
11324 		agg->dtag_aggregate = dtrace_aggregate_quantize;
11333 		agg->dtag_initial = desc->dtad_arg;
11334 		agg->dtag_aggregate = dtrace_aggregate_lquantize;
11350 		agg->dtag_initial = desc->dtad_arg;
11351 		agg->dtag_aggregate = dtrace_aggregate_llquantize;
11373 		agg->dtag_aggregate = dtrace_aggregate_avg;
11378 		agg->dtag_aggregate = dtrace_aggregate_stddev;
11383 		agg->dtag_aggregate = dtrace_aggregate_sum;
11390 	agg->dtag_action.dta_rec.dtrd_size = size;
11406 			agg->dtag_first = act;
11416 	kmem_free(agg, sizeof (dtrace_aggregation_t));
11431 			agg->dtag_hasarg = 1;
11469 	state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg;
11471 	frec = &agg->dtag_first->dta_rec;
11475 	for (act = agg->dtag_first; act != NULL; act = act->dta_next) {
11480 	return (&agg->dtag_action);
11486 	dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
11488 	dtrace_aggid_t aggid = agg->dtag_id;
11497 	ASSERT(state->dts_aggregations[aggid - 1] == agg);
11500 	kmem_free(agg, sizeof (dtrace_aggregation_t));
12023 	dtrace_aggregation_t *agg;
12031 	ASSERT((agg = state->dts_aggregations[id - 1]) == NULL ||
12032 	    agg->dtag_id == id);
17575 		dtrace_aggregation_t *agg;
17588 		if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) {
17593 		aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid;
17598 		offs = agg->dtag_base;
17599 		lrec = &agg->dtag_action.dta_rec;
17602 		for (act = agg->dtag_first; ; act = act->dta_next) {
17615 				ASSERT(agg->dtag_hasarg);
17621 			if (act == &agg->dtag_action)
17640 		for (act = agg->dtag_first; ; act = act->dta_next) {
17648 				ASSERT(agg->dtag_hasarg);
17659 			if (act == &agg->dtag_action)