Lines Matching refs:dtjj_consumer

115 	dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
145 dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
183 jc->dtjj_consumer->dtjc_flow = (optval != DTRACEOPT_UNSET);
385 ++jc->dtjj_consumer->dtjc_procs_ended;
389 ++jc->dtjj_consumer->dtjc_procs_ended;
397 ++jc->dtjj_consumer->dtjc_procs_ended;
463 jc->dtjj_consumer->dtjc_flow =
665 for (r = jc->dtjj_consumer->dtjc_probedata_rec_i;
686 if (jc->dtjj_consumer->dtjc_probedata_act == DTRACEACT_PRINTF) {
689 jc->dtjj_consumer->dtjc_probedata_rec_i, r - 1);
729 jc->dtjj_consumer->dtjc_probedata_act = act;
730 jc->dtjj_consumer->dtjc_probedata_rec_i = r;
749 jc->dtjj_consumer->dtjc_probedata_rec_i);
779 jc->dtjj_consumer->dtjc_printa_snaptime,
808 jc->dtjj_consumer->dtjc_probedata_rec_i);
857 if (jc->dtjj_consumer->dtjc_flow) {
960 jc->dtjj_consumer->dtjc_probedata_rec_i = 0;
961 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;
1684 if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1709 if (aggid != jc->dtjj_consumer->dtjc_aggid) {
1710 jc->dtjj_consumer->dtjc_included =
1717 if (!jc->dtjj_consumer->dtjc_included) {
1721 jc->dtjj_consumer->dtjc_aggid = aggid;
1743 if (jc->dtjj_consumer->dtjc_expected < 0) {
1752 jc->dtjj_consumer->dtjc_expected = r - 1;
1844 if (jc->dtjj_consumer->dtjc_expected == 0) {
1867 jc->dtjj_consumer->dtjc_expected) {
1907 if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1932 if (jc->dtjj_consumer->dtjc_printa_snaptime) {
1962 jc->dtjj_consumer->dtjc_expected = -1;
2081 switch (jc->dtjj_consumer->dtjc_state) {
2100 rc = dtrace_status(jc->dtjj_consumer->dtjc_dtp);
2102 rc = dtrace_stop(jc->dtjj_consumer->dtjc_dtp);
2118 dtrace_errmsg(jc->dtjj_consumer->dtjc_dtp,
2119 dtrace_errno(jc->dtjj_consumer->dtjc_dtp)));
2123 jc->dtjj_consumer->dtjc_state = DTJ_CONSUMER_STOP;
2188 if (dtrace_aggregate_snap(jc->dtjj_consumer->dtjc_dtp) != 0) {
2257 rc = dtrace_aggregate_print(jc->dtjj_consumer->dtjc_dtp, NULL, NULL);
2295 rc = dtrace_aggregate_walk(jc->dtjj_consumer->dtjc_dtp, dtj_clear, jc);
2334 uu_list_t *list = jc->dtjj_consumer->dtjc_request_list;
2335 pthread_mutex_t *list_lock = &jc->dtjj_consumer->
2349 if (dtrace_setopt(jc->dtjj_consumer->dtjc_dtp, opt,
2354 dtrace_errmsg(jc->dtjj_consumer->dtjc_dtp,
2355 dtrace_errno(jc->dtjj_consumer->dtjc_dtp)));
2377 dtrace_hdl_t *dtp = jc->dtjj_consumer->dtjc_dtp;
2382 if (!jc->dtjj_consumer->dtjc_interrupt) {
2386 if (jc->dtjj_consumer->dtjc_interrupt) {
2396 } else if (jc->dtjj_consumer->dtjc_process_list != NULL) {
2397 int nprocs = uu_list_numnodes(jc->dtjj_consumer->
2399 if (jc->dtjj_consumer->dtjc_procs_ended == nprocs) {
2439 jc->dtjj_consumer->dtjc_printa_snaptime = gethrtime();
2456 jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2466 jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2476 jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2491 jc->dtjj_consumer->dtjc_printa_snaptime = 0;
2496 jc->dtjj_consumer->dtjc_printa_snaptime = 0;