libdtrace_jni/common/dtj_consume.c

117 	dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
147 	dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
185 	jc->dtjj_consumer->dtjc_flow = (optval != DTRACEOPT_UNSET);
387 		++jc->dtjj_consumer->dtjc_procs_ended;
391 		++jc->dtjj_consumer->dtjc_procs_ended;
399 		++jc->dtjj_consumer->dtjc_procs_ended;
465 		jc->dtjj_consumer->dtjc_flow =
667 		for (r = jc->dtjj_consumer->dtjc_probedata_rec_i;
688 	if (jc->dtjj_consumer->dtjc_probedata_act == DTRACEACT_PRINTF) {
691 		    jc->dtjj_consumer->dtjc_probedata_rec_i, r - 1);
731 	jc->dtjj_consumer->dtjc_probedata_act = act;
732 	jc->dtjj_consumer->dtjc_probedata_rec_i = r;
750 		    jc->dtjj_consumer->dtjc_probedata_rec_i);
780 		    jc->dtjj_consumer->dtjc_printa_snaptime,
809 		    jc->dtjj_consumer->dtjc_probedata_rec_i);
858 	if (jc->dtjj_consumer->dtjc_flow) {
961 	jc->dtjj_consumer->dtjc_probedata_rec_i = 0;
962 	jc->dtjj_consumer->dtjc_probedata_act = DTRACEACT_NONE;
1111 		    jc->dtjj_consumer->dtjc_probedata_rec_i, jstr);
1131 		    jc->dtjj_consumer->dtjc_probedata_rec_i, jstr);
1401 	jc->dtjj_consumer->dtjc_aggid = -1;
1402 	jc->dtjj_consumer->dtjc_expected = -1;
1666 	if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1691 		if (aggid != jc->dtjj_consumer->dtjc_aggid) {
1692 			jc->dtjj_consumer->dtjc_included =
1699 		if (!jc->dtjj_consumer->dtjc_included) {
1703 	jc->dtjj_consumer->dtjc_aggid = aggid;
1725 	if (jc->dtjj_consumer->dtjc_expected < 0) {
1734 		jc->dtjj_consumer->dtjc_expected = r - 1;
1826 		if (jc->dtjj_consumer->dtjc_expected == 0) {
1849 		    jc->dtjj_consumer->dtjc_expected) {
1889 			if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1914 		if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1944 		jc->dtjj_consumer->dtjc_expected = -1;
2062 	switch (jc->dtjj_consumer->dtjc_state) {
2081 	rc = dtrace_status(jc->dtjj_consumer->dtjc_dtp);
2083 		rc = dtrace_stop(jc->dtjj_consumer->dtjc_dtp);
2099 		    dtrace_errmsg(jc->dtjj_consumer->dtjc_dtp,
2100 		    dtrace_errno(jc->dtjj_consumer->dtjc_dtp)));
2104 		jc->dtjj_consumer->dtjc_state = DTJ_CONSUMER_STOP;
2169 	if (dtrace_aggregate_snap(jc->dtjj_consumer->dtjc_dtp) != 0) {
2238 	rc = dtrace_aggregate_print(jc->dtjj_consumer->dtjc_dtp, NULL, NULL);
2276 	rc = dtrace_aggregate_walk(jc->dtjj_consumer->dtjc_dtp, dtj_clear, jc);
2315 	uu_list_t *list = jc->dtjj_consumer->dtjc_request_list;
2316 	pthread_mutex_t *list_lock = &jc->dtjj_consumer->
2330 			if (dtrace_setopt(jc->dtjj_consumer->dtjc_dtp, opt,
2335 				    dtrace_errmsg(jc->dtjj_consumer->dtjc_dtp,
2336 				    dtrace_errno(jc->dtjj_consumer->dtjc_dtp)));
2358 	dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
2363 		if (!jc->dtjj_consumer->dtjc_interrupt) {
2367 		if (jc->dtjj_consumer->dtjc_interrupt) {
2377 		} else if (jc->dtjj_consumer->dtjc_process_list != NULL) {
2378 			int nprocs = uu_list_numnodes(jc->dtjj_consumer->
2380 			if (jc->dtjj_consumer->dtjc_procs_ended == nprocs) {
2420 		jc->dtjj_consumer->dtjc_printa_snaptime = gethrtime();
2437 				jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2447 				jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2457 				jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2472 			jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2477 		jc->dtjj_consumer->dtjc_printa_snaptime = 0;