use std::{convert::From, sync::Arc};
use log::{debug, warn};
use crate::{errors::Result, objects::JObject, sys, JNIEnv, JavaVM};
#[derive(Clone)]
pub struct GlobalRef {
inner: Arc<GlobalRefGuard>,
}
struct GlobalRefGuard {
obj: JObject<'static>,
vm: JavaVM,
}
unsafe impl Send for GlobalRef {}
unsafe impl Sync for GlobalRef {}
impl<'a> From<&'a GlobalRef> for JObject<'a> {
fn from(other: &'a GlobalRef) -> JObject<'a> {
other.as_obj()
}
}
impl GlobalRef {
pub(crate) unsafe fn from_raw(vm: JavaVM, raw_global_ref: sys::jobject) -> Self {
GlobalRef {
inner: Arc::new(GlobalRefGuard::from_raw(vm, raw_global_ref)),
}
}
pub fn as_obj(&self) -> JObject {
self.inner.as_obj()
}
}
impl GlobalRefGuard {
unsafe fn from_raw(vm: JavaVM, obj: sys::jobject) -> Self {
GlobalRefGuard {
obj: JObject::from(obj),
vm,
}
}
pub fn as_obj(&self) -> JObject {
self.obj
}
}
impl Drop for GlobalRefGuard {
fn drop(&mut self) {
fn drop_impl(env: &JNIEnv, global_ref: JObject) -> Result<()> {
let internal = env.get_native_interface();
jni_unchecked!(internal, DeleteGlobalRef, global_ref.into_inner());
Ok(())
}
let res = match self.vm.get_env() {
Ok(env) => drop_impl(&env, self.as_obj()),
Err(_) => {
warn!("Dropping a GlobalRef in a detached thread. Fix your code if this message appears frequently (see the GlobalRef docs).");
self.vm
.attach_current_thread()
.and_then(|env| drop_impl(&env, self.as_obj()))
}
};
if let Err(err) = res {
debug!("error dropping global ref: {:#?}", err);
}
}
}