common/dtrace/dtrace.c

2046 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf,
2049 	dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec;
2063 	if (!agg->dtag_hasarg) {
2075 	action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION;
2076 	size = rec->dtrd_offset - agg->dtag_base;
2080 	data = dbuf->dtb_tomax + offset + agg->dtag_base;
2128 	ASSERT(agg->dtag_first != NULL);
2129 	ASSERT(agg->dtag_first->dta_intuple);
2140 	for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2141 		i = act->dta_rec.dtrd_offset - agg->dtag_base;
2177 		for (act = agg->dtag_first; act->dta_intuple;
2179 			i = act->dta_rec.dtrd_offset - agg->dtag_base;
2210 		agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg);
2246 	*((dtrace_aggid_t *)kdata) = agg->dtag_id;
2256 	for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2262 		i = act->dta_rec.dtrd_offset - agg->dtag_base;
2291 	*((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial;
2292 	agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg);
6324 				dtrace_aggregation_t *agg;
6326 				agg = (dtrace_aggregation_t *)act;
6343 				dtrace_aggregate(agg, buf,
9928 			dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
9931 			ASSERT(agg->dtag_first != NULL);
9936 			agg->dtag_base = aggbase;
9997 	dtrace_aggregation_t *agg;
10005 	agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP);
10006 	agg->dtag_ecb = ecb;
10012 		agg->dtag_initial = INT64_MAX;
10013 		agg->dtag_aggregate = dtrace_aggregate_min;
10017 		agg->dtag_initial = INT64_MIN;
10018 		agg->dtag_aggregate = dtrace_aggregate_max;
10022 		agg->dtag_aggregate = dtrace_aggregate_count;
10026 		agg->dtag_aggregate = dtrace_aggregate_quantize;
10035 		agg->dtag_initial = desc->dtad_arg;
10036 		agg->dtag_aggregate = dtrace_aggregate_lquantize;
10052 		agg->dtag_initial = desc->dtad_arg;
10053 		agg->dtag_aggregate = dtrace_aggregate_llquantize;
10075 		agg->dtag_aggregate = dtrace_aggregate_avg;
10080 		agg->dtag_aggregate = dtrace_aggregate_stddev;
10085 		agg->dtag_aggregate = dtrace_aggregate_sum;
10092 	agg->dtag_action.dta_rec.dtrd_size = size;
10108 			agg->dtag_first = act;
10118 	kmem_free(agg, sizeof (dtrace_aggregation_t));
10133 			agg->dtag_hasarg = 1;
10171 	state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg;
10173 	frec = &agg->dtag_first->dta_rec;
10177 	for (act = agg->dtag_first; act != NULL; act = act->dta_next) {
10182 	return (&agg->dtag_action);
10188 	dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
10190 	dtrace_aggid_t aggid = agg->dtag_id;
10199 	ASSERT(state->dts_aggregations[aggid - 1] == agg);
10202 	kmem_free(agg, sizeof (dtrace_aggregation_t));
10726 	dtrace_aggregation_t *agg;
10734 	ASSERT((agg = state->dts_aggregations[id - 1]) == NULL ||
10735 	    agg->dtag_id == id);
16038 		dtrace_aggregation_t *agg;
16051 		if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) {
16056 		aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid;
16061 		offs = agg->dtag_base;
16062 		lrec = &agg->dtag_action.dta_rec;
16065 		for (act = agg->dtag_first; ; act = act->dta_next) {
16078 				ASSERT(agg->dtag_hasarg);
16084 			if (act == &agg->dtag_action)
16103 		for (act = agg->dtag_first; ; act = act->dta_next) {
16111 				ASSERT(agg->dtag_hasarg);
16122 			if (act == &agg->dtag_action)