fix android build

Signed-off-by: 21pages <pages21@163.com>
This commit is contained in:
21pages 2023-05-12 14:01:56 +08:00
parent ea802ff74f
commit 5738f3a949
3 changed files with 23 additions and 18 deletions

View File

@ -49,12 +49,11 @@ impl FrameRaw {
self.enable = value; self.enable = value;
} }
fn update(&mut self, data: &mut [u8]) { fn update(&mut self, data: *mut u8) {
if self.enable.not() { if self.enable.not() {
return; return;
} }
self.len = data.len(); self.ptr.store(data, SeqCst);
self.ptr.store(data.as_mut_ptr(), SeqCst);
self.last_update = Instant::now(); self.last_update = Instant::now();
} }
@ -99,7 +98,7 @@ pub extern "system" fn Java_com_carriez_flutter_1hbb_MainService_onVideoFrameUpd
buffer: JObject, buffer: JObject,
) { ) {
let jb = JByteBuffer::from(buffer); let jb = JByteBuffer::from(buffer);
let slice = env.get_direct_buffer_address(jb).unwrap(); let slice = env.get_direct_buffer_address(&jb).unwrap();
VIDEO_RAW.lock().unwrap().update(slice); VIDEO_RAW.lock().unwrap().update(slice);
} }
@ -110,7 +109,7 @@ pub extern "system" fn Java_com_carriez_flutter_1hbb_MainService_onAudioFrameUpd
buffer: JObject, buffer: JObject,
) { ) {
let jb = JByteBuffer::from(buffer); let jb = JByteBuffer::from(buffer);
let slice = env.get_direct_buffer_address(jb).unwrap(); let slice = env.get_direct_buffer_address(&jb).unwrap();
AUDIO_RAW.lock().unwrap().update(slice); AUDIO_RAW.lock().unwrap().update(slice);
} }
@ -121,7 +120,8 @@ pub extern "system" fn Java_com_carriez_flutter_1hbb_MainService_setFrameRawEnab
name: JString, name: JString,
value: jboolean, value: jboolean,
) { ) {
if let Ok(name) = env.get_string(name) { let mut env = env;
if let Ok(name) = env.get_string(&name) {
let name: String = name.into(); let name: String = name.into();
let value = value.eq(&1); let value = value.eq(&1);
if name.eq("video") { if name.eq("video") {
@ -152,7 +152,7 @@ pub fn call_main_service_mouse_input(mask: i32, x: i32, y: i32) -> JniResult<()>
JVM.read().unwrap().as_ref(), JVM.read().unwrap().as_ref(),
MAIN_SERVICE_CTX.read().unwrap().as_ref(), MAIN_SERVICE_CTX.read().unwrap().as_ref(),
) { ) {
let env = jvm.attach_current_thread_as_daemon()?; let mut env = jvm.attach_current_thread_as_daemon()?;
env.call_method( env.call_method(
ctx, ctx,
"rustMouseInput", "rustMouseInput",
@ -170,17 +170,18 @@ pub fn call_main_service_get_by_name(name: &str) -> JniResult<String> {
JVM.read().unwrap().as_ref(), JVM.read().unwrap().as_ref(),
MAIN_SERVICE_CTX.read().unwrap().as_ref(), MAIN_SERVICE_CTX.read().unwrap().as_ref(),
) { ) {
let env = jvm.attach_current_thread_as_daemon()?; let mut env = jvm.attach_current_thread_as_daemon()?;
let name = env.new_string(name)?; let name = env.new_string(name)?;
let res = env let res = env
.call_method( .call_method(
ctx, ctx,
"rustGetByName", "rustGetByName",
"(Ljava/lang/String;)Ljava/lang/String;", "(Ljava/lang/String;)Ljava/lang/String;",
&[JValue::Object(name.into())], &[JValue::Object(&JObject::from(name))],
)? )?
.l()?; .l()?;
let res = env.get_string(res.into())?; let res = JString::from(res);
let res = env.get_string(&res)?;
let res = res.to_string_lossy().to_string(); let res = res.to_string_lossy().to_string();
return Ok(res); return Ok(res);
} else { } else {
@ -197,7 +198,7 @@ pub fn call_main_service_set_by_name(
JVM.read().unwrap().as_ref(), JVM.read().unwrap().as_ref(),
MAIN_SERVICE_CTX.read().unwrap().as_ref(), MAIN_SERVICE_CTX.read().unwrap().as_ref(),
) { ) {
let env = jvm.attach_current_thread_as_daemon()?; let mut env = jvm.attach_current_thread_as_daemon()?;
let name = env.new_string(name)?; let name = env.new_string(name)?;
let arg1 = env.new_string(arg1.unwrap_or(""))?; let arg1 = env.new_string(arg1.unwrap_or(""))?;
let arg2 = env.new_string(arg2.unwrap_or(""))?; let arg2 = env.new_string(arg2.unwrap_or(""))?;
@ -207,9 +208,9 @@ pub fn call_main_service_set_by_name(
"rustSetByName", "rustSetByName",
"(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V",
&[ &[
JValue::Object(name.into()), JValue::Object(&JObject::from(name)),
JValue::Object(arg1.into()), JValue::Object(&JObject::from(arg1)),
JValue::Object(arg2.into()), JValue::Object(&JObject::from(arg2)),
], ],
)?; )?;
return Ok(()); return Ok(());

View File

@ -754,6 +754,7 @@ pub struct AudioHandler {
#[cfg(not(any(target_os = "android", target_os = "linux")))] #[cfg(not(any(target_os = "android", target_os = "linux")))]
audio_stream: Option<Box<dyn StreamTrait>>, audio_stream: Option<Box<dyn StreamTrait>>,
channels: u16, channels: u16,
#[cfg(not(any(target_os = "android", target_os = "linux")))]
device_channel: u16, device_channel: u16,
#[cfg(not(any(target_os = "android", target_os = "linux")))] #[cfg(not(any(target_os = "android", target_os = "linux")))]
ready: Arc<std::sync::Mutex<bool>>, ready: Arc<std::sync::Mutex<bool>>,

View File

@ -35,7 +35,7 @@ fn initialize(app_dir: &str) {
{ {
android_logger::init_once( android_logger::init_once(
android_logger::Config::default() android_logger::Config::default()
.with_min_level(log::Level::Debug) // limit log level .with_max_level(log::LevelFilter::Debug) // limit log level
.with_tag("ffi"), // logs will show under mytag tag .with_tag("ffi"), // logs will show under mytag tag
); );
#[cfg(feature = "mediacodec")] #[cfg(feature = "mediacodec")]
@ -1607,7 +1607,8 @@ pub mod server_side {
app_dir: JString, app_dir: JString,
) { ) {
log::debug!("startServer from jvm"); log::debug!("startServer from jvm");
if let Ok(app_dir) = env.get_string(app_dir) { let mut env = env;
if let Ok(app_dir) = env.get_string(&app_dir) {
*config::APP_DIR.write().unwrap() = app_dir.into(); *config::APP_DIR.write().unwrap() = app_dir.into();
} }
std::thread::spawn(move || start_server(true)); std::thread::spawn(move || start_server(true));
@ -1630,14 +1631,16 @@ pub mod server_side {
locale: JString, locale: JString,
input: JString, input: JString,
) -> jstring { ) -> jstring {
let res = if let (Ok(input), Ok(locale)) = (env.get_string(input), env.get_string(locale)) { let mut env = env;
let res = if let (Ok(input), Ok(locale)) = (env.get_string(&input), env.get_string(&locale))
{
let input: String = input.into(); let input: String = input.into();
let locale: String = locale.into(); let locale: String = locale.into();
crate::client::translate_locale(input, &locale) crate::client::translate_locale(input, &locale)
} else { } else {
"".into() "".into()
}; };
return env.new_string(res).unwrap_or(input).into_inner(); return env.new_string(res).unwrap_or(input).into_raw();
} }
#[no_mangle] #[no_mangle]