Skip to content

merge #18

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ybbh merged 2 commits into from
Apr 10, 2026
Merged

merge #18

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a7c69e3
SQL interface
ybbh Apr 9, 2026
62a32f9
command mod
ybbh Apr 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
60 changes: 30 additions & 30 deletions example/vote/src/generated/procedure.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -337,8 +337,8 @@ pub async fn mudu_inner_p2_create_user(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_create_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_create_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -353,8 +353,8 @@ pub fn mudu_argv_desc_create_user(
})
}

pub fn mudu_result_desc_create_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_create_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -426,8 +426,8 @@ pub async fn mudu_inner_p2_cast_vote(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_cast_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_cast_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -464,8 +464,8 @@ pub fn mudu_argv_desc_cast_vote(
})
}

pub fn mudu_result_desc_cast_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_cast_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -532,8 +532,8 @@ pub async fn mudu_inner_p2_get_vote_result(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_get_vote_result(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_get_vote_result()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -548,8 +548,8 @@ pub fn mudu_argv_desc_get_vote_result(
})
}

pub fn mudu_result_desc_get_vote_result(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_get_vote_result()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -617,8 +617,8 @@ pub async fn mudu_inner_p2_get_voting_history(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_get_voting_history(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_get_voting_history()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -633,8 +633,8 @@ pub fn mudu_argv_desc_get_voting_history(
})
}

pub fn mudu_result_desc_get_voting_history(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_get_voting_history()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -649,8 +649,8 @@ pub fn mudu_result_desc_get_voting_history(
})
}

pub fn mudu_proc_desc_get_voting_history(
) -> &'static ::mudu_contract::procedure::proc_desc::ProcDesc {
pub fn mudu_proc_desc_get_voting_history()
-> &'static ::mudu_contract::procedure::proc_desc::ProcDesc {
static _PROC_DESC: std::sync::OnceLock<::mudu_contract::procedure::proc_desc::ProcDesc> =
std::sync::OnceLock::new();
_PROC_DESC.get_or_init(|| {
Expand Down Expand Up @@ -709,8 +709,8 @@ pub async fn mudu_inner_p2_add_option(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_add_option(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_add_option()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -726,8 +726,8 @@ pub fn mudu_argv_desc_add_option(
})
}

pub fn mudu_result_desc_add_option(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_add_option()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -799,8 +799,8 @@ pub async fn mudu_inner_p2_create_vote(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_create_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_create_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -849,8 +849,8 @@ pub fn mudu_argv_desc_create_vote(
})
}

pub fn mudu_result_desc_create_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_create_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -918,8 +918,8 @@ pub async fn mudu_inner_p2_withdraw_vote(
Ok(::mudu_contract::procedure::procedure_result::ProcedureResult::from(tuple, &return_desc)?)
}

pub fn mudu_argv_desc_withdraw_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_withdraw_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -934,8 +934,8 @@ pub fn mudu_argv_desc_withdraw_vote(
})
}

pub fn mudu_result_desc_withdraw_vote(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_withdraw_vote()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down
48 changes: 24 additions & 24 deletions example/wallet/src/generated/procedures.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -435,8 +435,8 @@ pub async fn mudu_inner_p2_create_user(
}
}

pub fn mudu_argv_desc_create_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_create_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -458,8 +458,8 @@ pub fn mudu_argv_desc_create_user(
})
}

pub fn mudu_result_desc_create_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_create_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -555,8 +555,8 @@ pub fn mudu_argv_desc_purchase() -> &'static ::mudu_contract::tuple::tuple_field
})
}

pub fn mudu_result_desc_purchase(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_purchase()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -627,8 +627,8 @@ pub async fn mudu_inner_p2_delete_user(
}
}

pub fn mudu_argv_desc_delete_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_delete_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -642,8 +642,8 @@ pub fn mudu_argv_desc_delete_user(
})
}

pub fn mudu_result_desc_delete_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_delete_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -734,8 +734,8 @@ pub fn mudu_argv_desc_deposit() -> &'static ::mudu_contract::tuple::tuple_field_
})
}

pub fn mudu_result_desc_deposit(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_deposit()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -808,8 +808,8 @@ pub async fn mudu_inner_p2_transfer_funds(
}
}

pub fn mudu_argv_desc_transfer_funds(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_transfer_funds()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -831,8 +831,8 @@ pub fn mudu_argv_desc_transfer_funds(
})
}

pub fn mudu_result_desc_transfer_funds(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_transfer_funds()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -905,8 +905,8 @@ pub async fn mudu_inner_p2_update_user(
}
}

pub fn mudu_argv_desc_update_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_argv_desc_update_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static ARGV_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand All @@ -928,8 +928,8 @@ pub fn mudu_argv_desc_update_user(
})
}

pub fn mudu_result_desc_update_user(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_update_user()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -1020,8 +1020,8 @@ pub fn mudu_argv_desc_withdraw() -> &'static ::mudu_contract::tuple::tuple_field
})
}

pub fn mudu_result_desc_withdraw(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_withdraw()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down Expand Up @@ -1117,8 +1117,8 @@ pub fn mudu_argv_desc_transfer() -> &'static ::mudu_contract::tuple::tuple_field
})
}

pub fn mudu_result_desc_transfer(
) -> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
pub fn mudu_result_desc_transfer()
-> &'static ::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc {
static RESULT_DESC: std::sync::OnceLock<
::mudu_contract::tuple::tuple_field_desc::TupleFieldDesc,
> = std::sync::OnceLock::new();
Expand Down
4 changes: 2 additions & 2 deletions example/ycsb/src/bin/ycsb_benchmark.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,15 +2,15 @@ use clap::Parser;
use mudu::common::result::RS;
use mudu::common::xid::XID;
use mudu_binding::universal::uni_session_open_argv::UniSessionOpenArgv;
use mudu_cli::management::{fetch_server_topology, ServerTopology};
use mudu_cli::management::{ServerTopology, fetch_server_topology};
use mudu_contract::database::sql_stmt_text::SQLStmtText;
use mudu_utils::debug::debug_serve;
use mudu_utils::notifier::NotifyWait;
use mudu_utils::task::spawn_task;
use mudu_utils::task_trace;
use std::sync::atomic::{AtomicUsize, Ordering};
use std::sync::Arc;
use std::sync::Barrier as StdBarrier;
use std::sync::atomic::{AtomicUsize, Ordering};
use std::thread;
use std::time::{Duration, Instant};
use sys_interface::async_api::{
Expand Down
17 changes: 5 additions & 12 deletions mudu/src/common/_arb_de_en.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
use crate::common::bc::{hdr_size, tail_size};
use crate::common::bc_dec::{Decode, decode_binary};
use crate::common::bc_enc::{Encode, encode_binary};
use crate::common::codec::{Decode, Encode};
#[cfg(any(test, feature = "test"))]
use arbitrary::{Arbitrary, Unstructured};
use std::fmt::Debug;
Expand All @@ -17,20 +15,15 @@ pub fn _fuzz_decode_and_encode<'a, T: Arbitrary<'a> + Decode + Encode + Eq + Deb
break;
}
};
let _r = encode_binary(&t);
let b = match _r {
Ok(b) => b,
Err(_e) => {
panic!("{:?}", _e);
}
};
let mut b = Vec::new();
t.encode(&mut b).unwrap();
let _size = t.size().unwrap();
if _size != b.len() {
let _ = t.size().unwrap();
}

assert_eq!(b.len(), _size + hdr_size() + tail_size());
let _r = decode_binary::<T>(&b);
assert_eq!(b.len(), _size);
let _r = T::decode(&mut (b.clone(), 0));
let _t = match _r {
Ok(_t) => _t,
Err(_e) => {
Expand Down
Loading
Loading