common/dtrace/dtrace.c

1917 dtrace_aggregate(dtrace_aggregation_t *agg, dtrace_buffer_t *dbuf,
1920 	dtrace_recdesc_t *rec = &agg->dtag_action.dta_rec;
1934 	if (!agg->dtag_hasarg) {
1946 	action = agg->dtag_action.dta_kind - DTRACEACT_AGGREGATION;
1947 	size = rec->dtrd_offset - agg->dtag_base;
1951 	data = dbuf->dtb_tomax + offset + agg->dtag_base;
1999 	ASSERT(agg->dtag_first != NULL);
2000 	ASSERT(agg->dtag_first->dta_intuple);
2011 	for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2012 		i = act->dta_rec.dtrd_offset - agg->dtag_base;
2048 		for (act = agg->dtag_first; act->dta_intuple;
2050 			i = act->dta_rec.dtrd_offset - agg->dtag_base;
2081 		agg->dtag_aggregate((uint64_t *)(kdata + size), expr, arg);
2117 	*((dtrace_aggid_t *)kdata) = agg->dtag_id;
2127 	for (act = agg->dtag_first; act->dta_intuple; act = act->dta_next) {
2133 		i = act->dta_rec.dtrd_offset - agg->dtag_base;
2162 	*((uint64_t *)(key->dtak_data + size)) = agg->dtag_initial;
2163 	agg->dtag_aggregate((uint64_t *)(key->dtak_data + size), expr, arg);
5807 				dtrace_aggregation_t *agg;
5809 				agg = (dtrace_aggregation_t *)act;
5826 				dtrace_aggregate(agg, buf,
9263 			dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
9264 			dtrace_action_t *first = agg->dtag_first, *prev;
9270 			agg->dtag_base = aggbase;
9274 				agg = (dtrace_aggregation_t *)prev;
9275 				first = agg->dtag_first;
9331 	dtrace_aggregation_t *agg;
9339 	agg = kmem_zalloc(sizeof (dtrace_aggregation_t), KM_SLEEP);
9340 	agg->dtag_ecb = ecb;
9346 		agg->dtag_initial = INT64_MAX;
9347 		agg->dtag_aggregate = dtrace_aggregate_min;
9351 		agg->dtag_initial = INT64_MIN;
9352 		agg->dtag_aggregate = dtrace_aggregate_max;
9356 		agg->dtag_aggregate = dtrace_aggregate_count;
9360 		agg->dtag_aggregate = dtrace_aggregate_quantize;
9369 		agg->dtag_initial = desc->dtad_arg;
9370 		agg->dtag_aggregate = dtrace_aggregate_lquantize;
9380 		agg->dtag_aggregate = dtrace_aggregate_avg;
9385 		agg->dtag_aggregate = dtrace_aggregate_stddev;
9390 		agg->dtag_aggregate = dtrace_aggregate_sum;
9397 	agg->dtag_action.dta_rec.dtrd_size = size;
9413 			agg->dtag_first = act;
9423 	kmem_free(agg, sizeof (dtrace_aggregation_t));
9438 			agg->dtag_hasarg = 1;
9472 	state->dts_aggregations[(agg->dtag_id = aggid) - 1] = agg;
9474 	frec = &agg->dtag_first->dta_rec;
9478 	for (act = agg->dtag_first; act != NULL; act = act->dta_next) {
9483 	return (&agg->dtag_action);
9489 	dtrace_aggregation_t *agg = (dtrace_aggregation_t *)act;
9491 	dtrace_aggid_t aggid = agg->dtag_id;
9496 	ASSERT(state->dts_aggregations[aggid - 1] == agg);
9499 	kmem_free(agg, sizeof (dtrace_aggregation_t));
10012 	dtrace_aggregation_t *agg;
10020 	ASSERT((agg = state->dts_aggregations[id - 1]) == NULL ||
10021 	    agg->dtag_id == id);
14765 		dtrace_aggregation_t *agg;
14778 		if ((agg = dtrace_aggid2agg(state, aggdesc.dtagd_id)) == NULL) {
14783 		aggdesc.dtagd_epid = agg->dtag_ecb->dte_epid;
14788 		offs = agg->dtag_base;
14789 		lrec = &agg->dtag_action.dta_rec;
14792 		for (act = agg->dtag_first; ; act = act->dta_next) {
14805 				ASSERT(agg->dtag_hasarg);
14811 			if (act == &agg->dtag_action)
14830 		for (act = agg->dtag_first; ; act = act->dta_next) {
14838 				ASSERT(agg->dtag_hasarg);
14849 			if (act == &agg->dtag_action)