libdtrace_jni/common/dtj_consume.c

116 	JNIEnv *jenv = jc->dtjj_jenv;
120 	if ((*jenv)->ExceptionCheck(jenv)) {
121 		WRAP_EXCEPTION(jenv);
125 	(*jenv)->MonitorEnter(jenv, g_caller_jc);
126 	if ((*jenv)->ExceptionCheck(jenv)) {
127 		WRAP_EXCEPTION(jenv);
132 	(*jenv)->MonitorExit(jenv, g_caller_jc);
133 	if ((*jenv)->ExceptionCheck(jenv)) {
134 		WRAP_EXCEPTION(jenv);
202 	JNIEnv *jenv;
211 	jenv = jc->dtjj_jenv;
213 	msg = dtj_NewStringNative(jenv, data->dtdda_msg);
214 	if ((*jenv)->ExceptionCheck(jenv)) {
251 	kind = (*jenv)->NewStringUTF(jenv, dropkind);
252 	if ((*jenv)->ExceptionCheck(jenv)) {
253 		(*jenv)->DeleteLocalRef(jenv, msg);
256 	drop = (*jenv)->NewObject(jenv, g_drop_jc, g_dropinit_jm,
258 	(*jenv)->DeleteLocalRef(jenv, kind);
259 	(*jenv)->DeleteLocalRef(jenv, msg);
260 	if ((*jenv)->ExceptionCheck(jenv)) {
263 	(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller, g_drop_jm, drop);
264 	(*jenv)->DeleteLocalRef(jenv, drop);
265 	if ((*jenv)->ExceptionCheck(jenv)) {
277 	JNIEnv *jenv;
288 	jenv = jc->dtjj_jenv;
296 		fault = (*jenv)->NewStringUTF(jenv, f);
297 		if ((*jenv)->ExceptionCheck(jenv)) {
298 			(*jenv)->DeleteLocalRef(jenv, probe);
311 	msg = dtj_NewStringNative(jenv, data->dteda_msg);
312 	if ((*jenv)->ExceptionCheck(jenv)) {
313 		(*jenv)->DeleteLocalRef(jenv, probe);
314 		(*jenv)->DeleteLocalRef(jenv, fault);
317 	error = (*jenv)->NewObject(jenv, g_error_jc, g_errinit_jm,
324 	(*jenv)->DeleteLocalRef(jenv, msg);
325 	(*jenv)->DeleteLocalRef(jenv, fault);
326 	(*jenv)->DeleteLocalRef(jenv, probe);
327 	if ((*jenv)->ExceptionCheck(jenv)) {
330 	(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller, g_error_jm, error);
331 	(*jenv)->DeleteLocalRef(jenv, error);
332 	if ((*jenv)->ExceptionCheck(jenv)) {
350 	JNIEnv *jenv;
365 	jenv = jc->dtjj_jenv;
382 			signalName = (*jenv)->NewStringUTF(jenv, signame);
383 			if ((*jenv)->ExceptionCheck(jenv)) {
411 	status = (*jenv)->NewStringUTF(jenv, statusname);
412 	if ((*jenv)->ExceptionCheck(jenv)) {
413 		(*jenv)->DeleteLocalRef(jenv, signalName);
417 		message = dtj_NewStringNative(jenv, msg);
419 			(*jenv)->DeleteLocalRef(jenv, status);
420 			(*jenv)->DeleteLocalRef(jenv, signalName);
424 	process = (*jenv)->NewObject(jenv, g_process_jc, g_procinit_jm,
426 	(*jenv)->DeleteLocalRef(jenv, status);
427 	(*jenv)->DeleteLocalRef(jenv, signalName);
428 	(*jenv)->DeleteLocalRef(jenv, message);
429 	if ((*jenv)->ExceptionCheck(jenv)) {
434 		(*jenv)->CallVoidMethod(jenv, process, g_procexit_jm, exit);
435 		if ((*jenv)->ExceptionCheck(jenv)) {
436 			(*jenv)->DeleteLocalRef(jenv, process);
440 	(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller, g_proc_jm, process);
441 	(*jenv)->DeleteLocalRef(jenv, process);
445 	if ((*jenv)->ExceptionCheck(jenv)) {
450 			jthrowable e = (*jenv)->ExceptionOccurred(jenv);
453 		(*jenv)->ExceptionClear(jenv);
476 dtj_bytedata(JNIEnv *jenv, uint32_t nbytes, caddr_t addr)
489 		return ((*jenv)->NewStringUTF(jenv, ""));
525 			return (dtj_NewStringNative(jenv, (char *)addr));
538 			dtj_throw_out_of_memory(jenv,
544 		jobj = dtj_NewStringNative(jenv, s);
550 	jobj = (*jenv)->NewByteArray(jenv, nbytes);
551 	if ((*jenv)->ExceptionCheck(jenv)) {
554 	(*jenv)->SetByteArrayRegion(jenv, (jbyteArray)jobj, 0, nbytes,
556 	if ((*jenv)->ExceptionCheck(jenv)) {
557 		WRAP_EXCEPTION(jenv);
558 		(*jenv)->DeleteLocalRef(jenv, jobj);
571 	JNIEnv *jenv = jc->dtjj_jenv;
577 		jobj = (*jenv)->NewObject(jenv, g_int_jc,
581 		jobj = (*jenv)->NewObject(jenv, g_int_jc,
586 		jobj = (*jenv)->NewObject(jenv, g_int_jc,
591 		jobj = (*jenv)->NewObject(jenv, g_long_jc,
596 		jobj = dtj_bytedata(jenv, size, addr);
604 	jrec = (*jenv)->NewObject(jenv, g_scalar_jc,
606 	(*jenv)->DeleteLocalRef(jenv, jobj);
630 	JNIEnv *jenv = jc->dtjj_jenv;
689 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
692 		if ((*jenv)->ExceptionCheck(jenv)) {
693 			WRAP_EXCEPTION(jenv);
705 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
707 			if ((*jenv)->ExceptionCheck(jenv)) {
708 				WRAP_EXCEPTION(jenv);
711 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller,
713 			(*jenv)->DeleteLocalRef(jenv, jc->dtjj_probedata);
715 			if ((*jenv)->ExceptionCheck(jenv)) {
723 		(*jenv)->DeleteLocalRef(jenv, jc->dtjj_printa_buffer);
748 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
751 		if ((*jenv)->ExceptionCheck(jenv)) {
752 			WRAP_EXCEPTION(jenv);
762 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
764 		if ((*jenv)->ExceptionCheck(jenv)) {
765 			WRAP_EXCEPTION(jenv);
774 		if ((*jenv)->ExceptionCheck(jenv)) {
775 			WRAP_EXCEPTION(jenv);
778 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
782 		if ((*jenv)->ExceptionCheck(jenv)) {
783 			WRAP_EXCEPTION(jenv);
791 			jbuf = (*jenv)->NewObject(jenv, g_buf_jc,
807 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
810 		if ((*jenv)->ExceptionCheck(jenv)) {
811 			WRAP_EXCEPTION(jenv);
832 	JNIEnv *jenv = jc->dtjj_jenv;
875 			jflowkind = (*jenv)->NewStringUTF(jenv, kind);
876 			if ((*jenv)->ExceptionCheck(jenv)) {
877 				WRAP_EXCEPTION(jenv);
878 				(*jenv)->DeleteLocalRef(jenv, jprobe);
886 			jflow = (*jenv)->NewObject(jenv, g_flow_jc,
888 			(*jenv)->DeleteLocalRef(jenv, jflowkind);
889 			if ((*jenv)->ExceptionCheck(jenv)) {
890 				WRAP_EXCEPTION(jenv);
891 				(*jenv)->DeleteLocalRef(jenv, jprobe);
898 	jpdata = (*jenv)->NewObject(jenv, g_pdata_jc, g_pdatainit_jm,
900 	(*jenv)->DeleteLocalRef(jenv, jprobe);
901 	(*jenv)->DeleteLocalRef(jenv, jflow);
902 	if ((*jenv)->ExceptionCheck(jenv)) {
903 		WRAP_EXCEPTION(jenv);
936 			if ((*jenv)->ExceptionCheck(jenv)) {
937 				WRAP_EXCEPTION(jenv);
938 				(*jenv)->DeleteLocalRef(jenv, jpdata);
943 		(*jenv)->CallVoidMethod(jenv, jpdata, g_pdataadd_jm, jobj);
944 		(*jenv)->DeleteLocalRef(jenv, jobj);
945 		if ((*jenv)->ExceptionCheck(jenv)) {
946 			WRAP_EXCEPTION(jenv);
947 			(*jenv)->DeleteLocalRef(jenv, jpdata);
953 		dtj_throw_illegal_state(jenv, "unfinished probedata");
954 		WRAP_EXCEPTION(jenv);
955 		(*jenv)->DeleteLocalRef(jenv, jpdata);
964 	if ((*jenv)->ExceptionCheck(jenv)) {
965 		WRAP_EXCEPTION(jenv);
1037 	JNIEnv *jenv;
1052 	jenv = jc->dtjj_jenv;
1060 	if ((*jenv)->ExceptionCheck(jenv)) {
1087 		jstr = dtj_NewStringNative(jenv, s);
1088 		if ((*jenv)->ExceptionCheck(jenv)) {
1089 			WRAP_EXCEPTION(jenv);
1092 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1094 		(*jenv)->DeleteLocalRef(jenv, jstr);
1095 		if ((*jenv)->ExceptionCheck(jenv)) {
1096 			WRAP_EXCEPTION(jenv);
1104 		jstr = (*jenv)->NewStringUTF(jenv, s);
1109 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1112 		(*jenv)->DeleteLocalRef(jenv, jstr);
1113 		if ((*jenv)->ExceptionCheck(jenv)) {
1114 			WRAP_EXCEPTION(jenv);
1124 		jstr = (*jenv)->NewStringUTF(jenv, s);
1129 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1132 		(*jenv)->DeleteLocalRef(jenv, jstr);
1133 		if ((*jenv)->ExceptionCheck(jenv)) {
1134 			WRAP_EXCEPTION(jenv);
1196 		JNIEnv *jenv = jc->dtjj_jenv;
1200 		jname = (*jenv)->NewStringUTF(jenv, aggdesc->dtagd_name);
1206 		cleared = (*jenv)->CallBooleanMethod(jenv,
1208 		(*jenv)->DeleteLocalRef(jenv, jname);
1209 		if ((*jenv)->ExceptionCheck(jenv)) {
1210 			WRAP_EXCEPTION(jenv);
1247 dtj_stddev_total_squares(JNIEnv *jenv, caddr_t addr, uint64_t normal)
1255 		val128 = (*jenv)->CallStaticObjectMethod(jenv, g_bigint_jc,
1258 		val128 = dtj_int128(jenv, data[3], data[2]);
1264 			divisor = (*jenv)->CallStaticObjectMethod(jenv,
1267 			val128 = (*jenv)->CallObjectMethod(jenv, tmp,
1269 			(*jenv)->DeleteLocalRef(jenv, tmp);
1270 			(*jenv)->DeleteLocalRef(jenv, divisor);
1282 dtj_stddev(JNIEnv *jenv, caddr_t addr, uint64_t normal)
1287 	total_squares = dtj_stddev_total_squares(jenv, addr, normal);
1288 	stddev = (*jenv)->NewObject(jenv, g_aggstddev_jc, g_aggstddevinit_jm,
1290 	(*jenv)->DeleteLocalRef(jenv, total_squares);
1311 	JNIEnv *jenv = jc->dtjj_jenv;
1324 	jstr = dtj_NewStringNative(jenv, s);
1325 	if ((*jenv)->ExceptionCheck(jenv)) {
1326 		(*jenv)->DeleteLocalRef(jenv, jobj);
1329 	frames = (*jenv)->CallStaticObjectMethod(jenv, g_stack_jc,
1331 	(*jenv)->DeleteLocalRef(jenv, jstr);
1332 	if ((*jenv)->ExceptionCheck(jenv)) {
1333 		(*jenv)->DeleteLocalRef(jenv, jobj);
1337 	(*jenv)->DeleteLocalRef(jenv, frames);
1338 	if ((*jenv)->ExceptionCheck(jenv)) {
1339 		WRAP_EXCEPTION(jenv);
1361 	JNIEnv *jenv = jc->dtjj_jenv;
1374 	jstr = (*jenv)->NewStringUTF(jenv, s);
1377 		(*jenv)->DeleteLocalRef(jenv, jobj);
1381 	tstr = (*jenv)->CallObjectMethod(jenv, jstr, g_trim_jm);
1383 	(*jenv)->DeleteLocalRef(jenv, jstr);
1388 	(*jenv)->DeleteLocalRef(jenv, jstr);
1389 	if ((*jenv)->ExceptionCheck(jenv)) {
1390 		WRAP_EXCEPTION(jenv);
1414 	JNIEnv *jenv = jc->dtjj_jenv;
1429 	raw = (*jenv)->NewByteArray(jenv, size);
1433 	(*jenv)->SetByteArrayRegion(jenv, raw, 0, size,
1435 	if ((*jenv)->ExceptionCheck(jenv)) {
1436 		WRAP_EXCEPTION(jenv);
1437 		(*jenv)->DeleteLocalRef(jenv, raw);
1445 		stack = (*jenv)->NewObject(jenv, g_stack_jc,
1453 		stack = (*jenv)->NewObject(jenv, g_ustack_jc,
1457 		dtj_throw_illegal_argument(jenv,
1460 	(*jenv)->DeleteLocalRef(jenv, raw);
1461 	if ((*jenv)->ExceptionCheck(jenv)) {
1462 		WRAP_EXCEPTION(jenv);
1472 	JNIEnv *jenv = jc->dtjj_jenv;
1486 		symbol = (*jenv)->NewObject(jenv, g_symbol_jc,
1496 		symbol = (*jenv)->NewObject(jenv, g_usymbol_jc,
1500 		dtj_throw_illegal_argument(jenv,
1503 	if ((*jenv)->ExceptionCheck(jenv)) {
1504 		WRAP_EXCEPTION(jenv);
1517 	JNIEnv *jenv = jc->dtjj_jenv;
1551 		dtj_throw_illegal_state(jenv,
1554 		WRAP_EXCEPTION(jenv);
1558 	jbuckets = (*jenv)->NewLongArray(jenv, n);
1563 		(*jenv)->SetLongArrayRegion(jenv, jbuckets, 0, n, aggbuckets);
1565 		if ((*jenv)->ExceptionCheck(jenv)) {
1566 			WRAP_EXCEPTION(jenv);
1567 			(*jenv)->DeleteLocalRef(jenv, jbuckets);
1574 		jdist = (*jenv)->NewObject(jenv, g_ldist_jc, g_ldistinit_jm,
1577 		jdist = (*jenv)->NewObject(jenv, g_dist_jc, g_distinit_jm,
1581 	(*jenv)->DeleteLocalRef(jenv, jbuckets);
1587 		(*jenv)->CallVoidMethod(jenv, jdist, g_dist_normal_jm, normal);
1588 		if ((*jenv)->ExceptionCheck(jenv)) {
1589 			WRAP_EXCEPTION(jenv);
1590 			(*jenv)->DeleteLocalRef(jenv, jdist);
1601 	JNIEnv *jenv = jc->dtjj_jenv;
1603 	if ((*jenv)->IsInstanceOf(jenv, stack, g_stack_jc)) {
1604 		(*jenv)->CallVoidMethod(jenv, stack, g_stackset_frames_jm,
1606 	} else if ((*jenv)->IsInstanceOf(jenv, stack, g_ustack_jc)) {
1607 		(*jenv)->CallVoidMethod(jenv, stack, g_ustackset_frames_jm,
1615 	JNIEnv *jenv = jc->dtjj_jenv;
1617 	if ((*jenv)->IsInstanceOf(jenv, symbol, g_symbol_jc)) {
1618 		(*jenv)->CallVoidMethod(jenv, symbol, g_symbolset_name_jm, s);
1619 	} else if ((*jenv)->IsInstanceOf(jenv, symbol, g_usymbol_jc)) {
1620 		(*jenv)->CallVoidMethod(jenv, symbol, g_usymbolset_name_jm, s);
1634 	JNIEnv *jenv = jc->dtjj_jenv;
1647 		dtj_throw_illegal_state(jenv, "null aggdata");
1648 		WRAP_EXCEPTION(jenv);
1661 		dtj_throw_illegal_argument(jenv, "negative aggregation ID");
1662 		WRAP_EXCEPTION(jenv);
1668 		jstring jstr = dtj_NewStringNative(jenv, s);
1669 		if ((*jenv)->ExceptionCheck(jenv)) {
1670 			WRAP_EXCEPTION(jenv);
1677 		jobj = (*jenv)->CallObjectMethod(jenv,
1679 		(*jenv)->DeleteLocalRef(jenv, jstr);
1680 		(*jenv)->DeleteLocalRef(jenv, jobj);
1681 		if ((*jenv)->ExceptionCheck(jenv)) {
1682 			WRAP_EXCEPTION(jenv);
1694 			if ((*jenv)->ExceptionCheck(jenv)) {
1695 				WRAP_EXCEPTION(jenv);
1741 			jc->dtjj_tuple = (*jenv)->NewObject(jenv,
1774 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_tuple,
1776 		(*jenv)->DeleteLocalRef(jenv, jobj);
1777 		if ((*jenv)->ExceptionCheck(jenv)) {
1778 			WRAP_EXCEPTION(jenv);
1798 			WRAP_EXCEPTION(jenv);
1801 		aggval = dtj_aggval_create(jenv, jvalue, aggdesc->dtagd_name,
1805 			(*jenv)->DeleteLocalRef(jenv, jvalue);
1810 			dtj_aggval_destroy(aggval, jenv);
1811 			dtj_throw_out_of_memory(jenv, "Failed to add aggval");
1831 			jc->dtjj_tuple = (*jenv)->GetStaticObjectField(jenv,
1834 				dtj_throw_out_of_memory(jenv,
1841 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1846 		tuple_member_count = (*jenv)->CallIntMethod(jenv,
1850 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1852 			(*jenv)->DeleteLocalRef(jenv, jc->dtjj_tuple);
1864 			jrec = (*jenv)->NewObject(jenv, g_aggrec_jc,
1867 			(*jenv)->DeleteLocalRef(jenv, aggval->dtja_value);
1871 				WRAP_EXCEPTION(jenv);
1876 			jname = (*jenv)->NewStringUTF(jenv,
1880 				(*jenv)->DeleteLocalRef(jenv, jrec);
1891 				(*jenv)->CallVoidMethod(jenv,
1897 				(*jenv)->CallVoidMethod(jenv,
1902 			(*jenv)->DeleteLocalRef(jenv, jrec);
1903 			(*jenv)->DeleteLocalRef(jenv, jname);
1904 			if ((*jenv)->ExceptionCheck(jenv)) {
1905 				WRAP_EXCEPTION(jenv);
1911 		    jenv);
1919 			jstring jstr = (*jenv)->CallObjectMethod(jenv,
1921 			if ((*jenv)->ExceptionCheck(jenv)) {
1922 				WRAP_EXCEPTION(jenv);
1930 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_printa_buffer,
1933 			(*jenv)->CallVoidMethod(jenv, jc->dtjj_probedata,
1935 			(*jenv)->DeleteLocalRef(jenv, jstr);
1936 			if ((*jenv)->ExceptionCheck(jenv)) {
1937 				WRAP_EXCEPTION(jenv);
1942 		(*jenv)->DeleteLocalRef(jenv, jc->dtjj_tuple);
1957 	JNIEnv *jenv = jc->dtjj_jenv;
1964 		aggname = (*jenv)->NewStringUTF(jenv, aggdesc->dtagd_name);
1970 		included = (*jenv)->CallBooleanMethod(jenv,
1973 		(*jenv)->DeleteLocalRef(jenv, aggname);
1974 		if ((*jenv)->ExceptionCheck(jenv)) {
1975 			WRAP_EXCEPTION(jenv);
1993 	JNIEnv *jenv = jc->dtjj_jenv;
2017 			jvalue = (*jenv)->NewObject(jenv, g_aggcount_jc,
2021 			jvalue = (*jenv)->NewObject(jenv, g_aggsum_jc,
2025 			jvalue = (*jenv)->NewObject(jenv, g_aggavg_jc,
2030 			jvalue = (*jenv)->NewObject(jenv, g_aggmin_jc,
2034 			jvalue = (*jenv)->NewObject(jenv, g_aggmax_jc,
2038 			jvalue = dtj_stddev(jenv, addr, normal);
2042 			dtj_throw_illegal_argument(jenv,
2058 	JNIEnv *jenv;
2070 	jenv = jc->dtjj_jenv;
2071 	e = (*jenv)->ExceptionOccurred(jenv);
2073 		(*jenv)->ExceptionClear(jenv);
2076 	(*jenv)->MonitorEnter(jenv, g_caller_jc);
2077 	if ((*jenv)->ExceptionCheck(jenv)) {
2086 	(*jenv)->MonitorExit(jenv, g_caller_jc);
2087 	if ((*jenv)->ExceptionCheck(jenv)) {
2092 		(*jenv)->MonitorEnter(jenv, g_caller_jc);
2093 		if ((*jenv)->ExceptionCheck(jenv)) {
2102 		(*jenv)->MonitorExit(jenv, g_caller_jc);
2109 		if ((*jenv)->ExceptionCheck(jenv)) {
2114 			(*jenv)->ExceptionClear(jenv);
2116 		(*jenv)->Throw(jenv, e);
2117 		(*jenv)->DeleteLocalRef(jenv, e);
2127 	JNIEnv *jenv = jc->dtjj_jenv;
2134 	if ((*jenv)->ExceptionCheck(jenv)) {
2135 		WRAP_EXCEPTION(jenv);
2146 	(*jenv)->MonitorEnter(jenv, jc->dtjj_consumer_lock);
2147 	if ((*jenv)->ExceptionCheck(jenv)) {
2148 		WRAP_EXCEPTION(jenv);
2153 	if ((*jenv)->ExceptionCheck(jenv)) {
2154 		WRAP_EXCEPTION(jenv);
2156 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2177 		if ((*jenv)->ExceptionCheck(jenv)) {
2180 			(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2189 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2193 	if ((*jenv)->ExceptionCheck(jenv)) {
2200 		WRAP_EXCEPTION(jenv);
2202 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2207 	aggregate = (*jenv)->NewObject(jenv, g_agg_jc, g_agginit_jm,
2209 	if ((*jenv)->ExceptionCheck(jenv)) {
2210 		WRAP_EXCEPTION(jenv);
2212 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2239 	if ((*jenv)->ExceptionCheck(jenv)) {
2240 		WRAP_EXCEPTION(jenv);
2242 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2249 			(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2257 			(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2263 	if ((*jenv)->ExceptionCheck(jenv)) {
2264 		WRAP_EXCEPTION(jenv);
2266 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2277 	if ((*jenv)->ExceptionCheck(jenv)) {
2278 		WRAP_EXCEPTION(jenv);
2280 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2290 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2294 	(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2295 	if ((*jenv)->ExceptionCheck(jenv)) {
2296 		WRAP_EXCEPTION(jenv);
2357 	JNIEnv *jenv = jc->dtjj_jenv;
2370 			if ((*jenv)->ExceptionCheck(jenv)) {
2399 		if ((*jenv)->ExceptionCheck(jenv)) {
2400 			WRAP_EXCEPTION(jenv);
2408 		(*jenv)->MonitorEnter(jenv, jc->dtjj_consumer_lock);
2409 		if ((*jenv)->ExceptionCheck(jenv)) {
2410 			WRAP_EXCEPTION(jenv);
2413 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller,
2415 		if ((*jenv)->ExceptionCheck(jenv)) {
2417 			(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2432 			if ((*jenv)->ExceptionCheck(jenv)) {
2440 				(*jenv)->MonitorExit(jenv,
2449 				(*jenv)->MonitorExit(jenv,
2459 				(*jenv)->MonitorExit(jenv,
2468 		if ((*jenv)->ExceptionCheck(jenv)) {
2474 			(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2482 		(*jenv)->CallVoidMethod(jenv, jc->dtjj_caller,
2484 		(*jenv)->MonitorExit(jenv, jc->dtjj_consumer_lock);
2485 		if ((*jenv)->ExceptionCheck(jenv)) {
2498 			(*jenv)->Throw(jenv, jc->dtjj_exception);
2499 			(*jenv)->DeleteLocalRef(jenv, jc->dtjj_exception);