Я пытаюсь создать веб-рабочего из Rust, вызывая функцию в рабочем файле и передавая некоторые данные в основной поток.
main.rs
mod externs;
extern crate libc;
fn main() {
println!("starting worker");
let worker = externs::create_worker("./worker.js");
externs::call_worker(worker, "worker_fn", "", 0);
println!("worker called");
}
worker.rs
#![feature(link_args)]
#[link_args = "-s EXPORTED_FUNCTIONS=['_worker_fn'] -s BUILD_AS_WORKER=1"]
extern crate libc;
mod externs;
extern {}
fn main() {
println!("worker main");
}
#[no_mangle]
pub extern fn worker_fn() {
println!("hello from the other side!");
}
Когда я компилирую рабочий и основные файлы, я могу видеть сообщение от main.rs
и даже сообщение "worker main" в рабочем файле. Я также вижу, что браузер отправляет запрос на worker.js
, но похоже, что основной поток не вызывает worker_fn
внутри рабочего файла.
Это файл externs
:
use std::ffi::CString;
use libc::*;
use std::str::FromStr;
/// Creating web worker
pub fn create_worker(url: &str) -> ffi::worker_handle {
let url = CString::new(url).unwrap();
let ptr = url.as_ptr();
unsafe { ffi::emscripten_create_worker(ptr) }
}
extern "C" fn do_something_handler(arg1: *mut c_char, arg2: c_int, arg3: *mut c_void) {
println!("worker done!");
}
/// Creating web worker
pub fn call_worker(worker: ffi::worker_handle, func_name: &str, data: &str, size: i32) {
let func_name = CString::new(func_name).unwrap();
let mut string = String::from_str(data).unwrap();
let bytes = string.into_bytes();
let mut cchar : Vec<c_char> = bytes.iter().map(|&w| w as c_char).collect();
let data_slice = cchar.as_mut_slice();
let mut state = 42;
let state_ptr: *mut c_void = &mut state as *mut _ as *mut c_void;
unsafe {
ffi::emscripten_call_worker(
worker,
func_name.as_ptr(),
data_slice.as_mut_ptr(),
size as c_int,
Some(do_something_handler),
state_ptr
)
};
}
// This is mostly standard Rust-C FFI stuff.
mod ffi {
use libc::*;
pub type worker_handle = c_int;
pub type em_worker_callback_func = Option<unsafe extern "C" fn(arg1: *mut c_char,
arg2: c_int,
arg3: *mut c_void)>;
extern "C" {
pub fn emscripten_run_script_int(x: *const c_char) -> c_int;
pub fn emscripten_create_worker(url: *const c_char) -> worker_handle;
pub fn emscripten_call_worker(
worker: worker_handle,
funcname: *const c_char,
data: *mut c_char,
size: c_int,
callback: em_worker_callback_func,
arg: *mut c_void
);
pub fn emscripten_worker_respond(data: *mut c_char, size: c_int);
pub fn emscripten_worker_respond_provisionally(data: *mut c_char, size: c_int);
}
}
Я не понимаю, в чем проблема. Должен ли я каким-либо образом изменить рабочий файл или, возможно, даже link_args
?