Lines Matching defs:agg

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