FnMut -> Fn in create_scalar_function

Change FnMut to Fn in InnerConnection::create_scalar_function

cast user data as shared reference
This commit is contained in:
patr0nus 2023-09-08 00:30:00 +08:00 committed by branchseer
parent 67cb6f1576
commit 5f6ac80e7a

View File

@ -446,7 +446,7 @@ impl Connection {
x_func: F, x_func: F,
) -> Result<()> ) -> Result<()>
where where
F: FnMut(&Context<'_>) -> Result<T> + Send + 'static, F: Fn(&Context<'_>) -> Result<T> + Send + 'static,
T: SqlFnOutput, T: SqlFnOutput,
{ {
self.db self.db
@ -549,7 +549,7 @@ impl InnerConnection {
x_func: F, x_func: F,
) -> Result<()> ) -> Result<()>
where where
F: FnMut(&Context<'_>) -> Result<T> + Send + 'static, F: Fn(&Context<'_>) -> Result<T> + Send + 'static,
T: SqlFnOutput, T: SqlFnOutput,
{ {
unsafe extern "C" fn call_boxed_closure<F, T>( unsafe extern "C" fn call_boxed_closure<F, T>(
@ -557,12 +557,12 @@ impl InnerConnection {
argc: c_int, argc: c_int,
argv: *mut *mut sqlite3_value, argv: *mut *mut sqlite3_value,
) where ) where
F: FnMut(&Context<'_>) -> Result<T>, F: Fn(&Context<'_>) -> Result<T>,
T: SqlFnOutput, T: SqlFnOutput,
{ {
let args = slice::from_raw_parts(argv, argc as usize); let args = slice::from_raw_parts(argv, argc as usize);
let r = catch_unwind(|| { let r = catch_unwind(|| {
let boxed_f: *mut F = ffi::sqlite3_user_data(ctx).cast::<F>(); let boxed_f: *const F = ffi::sqlite3_user_data(ctx).cast::<F>();
assert!(!boxed_f.is_null(), "Internal error - null function pointer"); assert!(!boxed_f.is_null(), "Internal error - null function pointer");
let ctx = Context { ctx, args }; let ctx = Context { ctx, args };
(*boxed_f)(&ctx) (*boxed_f)(&ctx)