Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
1 change: 0 additions & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

4 changes: 2 additions & 2 deletions contrib/codeql/lib/policy.qll
Original file line number Diff line number Diff line change
Expand Up @@ -52,9 +52,9 @@ predicate isSecretType(TypeItem t) {
t.getName().getText() = "Fr"
) and
// A share *of a signature* is published, so it holds nothing to protect. Excluded by
// exact name because `SecretKeyShare` and `RawShare` match the same Share substring
// exact name because `BlsSkShare` and `RawShare` match the same Share substring
// and do carry secret scalars.
not t.getName().getText() = "SignatureShare" and
not t.getName().getText() = "BlsSigShare" and
// Serde artifact to deserialize a tagged enum.
not t.getName().getText() = "__Seed"
}
Expand Down
2 changes: 1 addition & 1 deletion contrib/codeql/zeroize.ql
Original file line number Diff line number Diff line change
Expand Up @@ -299,7 +299,7 @@ predicate variableTimeSecretTest(Function f, string how) {
* this query exists to examine unchecked.
*/
predicate secretType(TypeItem t) {
isSecretType(t) and
(isSecretType(t) or wipesSelf(t)) and
fileOf(t).fromSource() and
not isTestCode(t)
}
Expand Down
67 changes: 6 additions & 61 deletions pkgs/pkc/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,9 @@ blst = { version = "0.3", default-features = false, optional = true }
cfg-if = "1"
dash-num = { version = "0.0.0", path = "../num" }
dash-types = { version = "0.0.0", path = "../types", default-features = false }
hex-conservative = { version = "0.3", optional = true }
hex-literal = "0.4"
hex-conservative = { version = "0.3", default-features = false, features = [
"alloc",
] }
k256 = { version = "0.13", default-features = false, features = [
"arithmetic",
"ecdsa",
Expand Down Expand Up @@ -51,10 +52,10 @@ std = [
"rand_core/getrandom",
]
bls = ["dep:blst", "dep:sha2"]
ecdsa = ["dep:k256", "dep:hex-conservative"]
serde = ["dep:serde", "dep:hex-conservative", "dash-num/serde", "dash-types/serde"]
ecdsa = ["dep:k256"]
serde = ["dep:serde", "dash-num/serde", "dash-types/serde"]
full = ["ecdsa", "bls", "serde", "std", "tests"]
tests = ["std", "dep:hex-conservative", "dep:rstest"]
tests = ["std", "dep:rstest"]

[lints]
workspace = true
Expand All @@ -68,59 +69,3 @@ path = "bench/main.rs"
harness = false
required-features = ["tests"]

[[test]]
name = "bls_chia_aggregate"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_dh"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_keygen"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_llmq"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_ser"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_sign"
required-features = ["bls", "tests"]

[[test]]
name = "bls_chia_threshold"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_aggregate"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_dh"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_keygen"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_llmq"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_pop"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_sign"
required-features = ["bls", "tests"]

[[test]]
name = "bls_ietf_threshold"
required-features = ["bls", "tests"]

243 changes: 243 additions & 0 deletions pkgs/pkc/bench/bls.rs
Original file line number Diff line number Diff line change
@@ -0,0 +1,243 @@
//
// Copyright (c) 2026-present, The Dash Core developers
// SPDX-License-Identifier: MIT
// See the accompanying file LICENSE or https://opensource.org/license/MIT
//

//! Benchmarks for BLS schemes.

use dash_pkc::bls::tests::{sequential_ids, test_ikm, test_msg};
use dash_pkc::bls::{BlsPublicKey, BlsScChia, BlsScIetf, BlsScheme, BlsSecretKey, BlsSigShare, BlsSignature};
use divan::{counter::ItemsCount, Bencher};
use rand_core::OsRng;

/// Single signature creation.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn sign<S: BlsScheme>(bencher: Bencher) {
let sk = BlsSecretKey::<S>::generate(&test_ikm(1)).unwrap();
bencher
.counter(ItemsCount::new(1u32))
.bench(|| sk.sign(S::msg_ref(&test_msg(42))));
}

/// Single signature verification.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn verify<S: BlsScheme>(bencher: Bencher) {
let sk = BlsSecretKey::<S>::generate(&test_ikm(2)).unwrap();
let msg = test_msg(99);
let sig = sk.sign(S::msg_ref(&msg));
let pk = sk.public_key();
bencher
.counter(ItemsCount::new(1u32))
.bench(|| sig.verify(S::msg_ref(&msg), &pk));
}

/// Public key aggregation at various quorum sizes.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [2, 5, 25, 50, 100])]
fn aggregate_pk_n<S: BlsScheme>(bencher: Bencher, n: usize) {
let pks: Vec<_> = (0..n)
.map(|i| BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap().public_key())
.collect();
let pk_refs: Vec<_> = pks.iter().collect();
bencher
.counter(ItemsCount::new(n))
.bench(|| BlsPublicKey::<S>::aggregate(&pk_refs));
}

/// Signature aggregation at various batch sizes.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [2, 10, 100])]
fn aggregate_sig_n<S: BlsScheme>(bencher: Bencher, n: usize) {
let keys: Vec<_> = (0..n)
.map(|i| BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap())
.collect();
let sigs: Vec<_> = keys
.iter()
.enumerate()
.map(|(i, key)| key.sign(S::msg_ref(&test_msg(i as u8))))
.collect();
let sig_refs: Vec<&BlsSignature<S>> = sigs.iter().collect();
bencher
.counter(ItemsCount::new(n))
.bench(|| BlsSignature::<S>::aggregate(&sig_refs));
}

/// N individual verifications in a loop.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [100, 1000])]
fn verify_n_individual<S: BlsScheme>(bencher: Bencher, n: usize) {
let keys: Vec<_> = (0..n)
.map(|i| BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap())
.collect();
let msgs: Vec<[u8; 32]> = (0..n).map(|i| test_msg(i as u8)).collect();
let pks: Vec<_> = keys.iter().map(BlsSecretKey::public_key).collect();
let sigs: Vec<_> = keys
.iter()
.zip(&msgs)
.map(|(key, msg)| key.sign(S::msg_ref(msg)))
.collect();

bencher.counter(ItemsCount::new(n)).bench(|| {
for i in 0..n {
let _ = sigs[i].verify(S::msg_ref(&msgs[i]), &pks[i]);
}
});
}

/// Fast aggregate verification over a shared message.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [10, 100, 1000])]
fn fast_verify_n<S: BlsScheme>(bencher: Bencher, n: usize) {
let keys: Vec<_> = (0..n)
.map(|i| BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap())
.collect();
let msg = test_msg(42);
let pks: Vec<_> = keys.iter().map(BlsSecretKey::public_key).collect();
let sigs: Vec<_> = keys.iter().map(|key| key.sign(S::msg_ref(&msg))).collect();
let sig_refs: Vec<&BlsSignature<S>> = sigs.iter().collect();
let aggregate = BlsSignature::<S>::aggregate(&sig_refs).unwrap();
let pk_refs: Vec<_> = pks.iter().collect();

bencher
.counter(ItemsCount::new(n))
.bench(|| aggregate.fast_verify_aggregates(S::msg_ref(&msg), &pk_refs));
}

/// Public key serialization.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn ser_pk<S: BlsScheme>(bencher: Bencher) {
let pk = BlsSecretKey::<S>::generate(&test_ikm(1)).unwrap().public_key();
bencher.bench(|| pk.to_bytes());
}

/// Public key deserialization.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn deser_pk<S: BlsScheme>(bencher: Bencher) {
let bytes = BlsSecretKey::<S>::generate(&test_ikm(1))
.unwrap()
.public_key()
.to_bytes();
bencher.bench(|| BlsPublicKey::<S>::from_bytes(&bytes));
}

/// Signature serialization.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn ser_sig<S: BlsScheme>(bencher: Bencher) {
let sig = BlsSecretKey::<S>::generate(&test_ikm(1))
.unwrap()
.sign(S::msg_ref(&test_msg(0)));
bencher.bench(|| sig.to_bytes());
}

/// Signature deserialization.
#[divan::bench(types = [BlsScChia, BlsScIetf])]
fn deser_sig<S: BlsScheme>(bencher: Bencher) {
let bytes = BlsSecretKey::<S>::generate(&test_ikm(1))
.unwrap()
.sign(S::msg_ref(&test_msg(0)))
.to_bytes();
bencher.bench(|| BlsSignature::<S>::from_bytes(&bytes));
}

/// Threshold secret key splitting at various quorum sizes.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [5, 10, 50])]
fn split_threshold<S: BlsScheme>(bencher: Bencher, n: usize) {
let sk = BlsSecretKey::<S>::generate(&test_ikm(1)).unwrap();
let threshold = n.div_ceil(2);
let ids = sequential_ids(n);
bencher
.counter(ItemsCount::new(n))
.bench(|| sk.split(threshold, &ids, &mut OsRng));
}

/// Threshold signature recovery via Lagrange interpolation.
#[divan::bench(types = [BlsScChia, BlsScIetf], args = [3, 5, 10])]
fn recover_threshold<S: BlsScheme>(bencher: Bencher, threshold: usize) {
let sk = BlsSecretKey::<S>::generate(&test_ikm(1)).unwrap();
let ids = sequential_ids(threshold * 2);
let shares = sk.split(threshold, &ids, &mut OsRng).unwrap();
let msg = test_msg(42);
let sig_shares: Vec<_> = shares.iter().map(|share| share.sign(S::msg_ref(&msg))).collect();
let subset: Vec<&BlsSigShare<S>> = sig_shares.iter().take(threshold).collect();
bencher
.counter(ItemsCount::new(threshold))
.bench(|| BlsSignature::<S>::recover(&subset));
}

/// IETF-only BLS operations.
mod ietf {
use super::*;

/// Aggregate signatures over distinct messages, then verify.
#[divan::bench(args = [10, 100, 1000])]
fn verify_aggregated_block(bencher: Bencher, n: usize) {
let keys: Vec<_> = (0..n)
.map(|i| BlsSecretKey::<BlsScIetf>::generate(&test_ikm(i as u8)).unwrap())
.collect();
let msgs: Vec<[u8; 32]> = (0..n).map(|i| test_msg(i as u8)).collect();
let pks: Vec<_> = keys.iter().map(BlsSecretKey::public_key).collect();
let sigs: Vec<_> = keys
.iter()
.zip(&msgs)
.map(|(key, msg)| key.sign(msg.as_slice()))
.collect();
let sig_refs: Vec<&BlsSignature<BlsScIetf>> = sigs.iter().collect();
let aggregate = BlsSignature::<BlsScIetf>::aggregate(&sig_refs).unwrap();
let pk_refs: Vec<_> = pks.iter().collect();
let msg_refs: Vec<&[u8]> = msgs.iter().map(|msg| msg.as_slice()).collect();
Comment thread
coderabbitai[bot] marked this conversation as resolved.

bencher
.counter(ItemsCount::new(n))
.bench(|| aggregate.verify_aggregates(&msg_refs, &pk_refs));
}

/// Proof of possession creation.
#[divan::bench]
fn prove_pop(bencher: Bencher) {
let sk = BlsSecretKey::<BlsScIetf>::generate(&test_ikm(1)).unwrap();
bencher.bench(|| sk.prove_possession());
}

/// Proof of possession verification.
#[divan::bench]
fn verify_pop(bencher: Bencher) {
let sk = BlsSecretKey::<BlsScIetf>::generate(&test_ikm(1)).unwrap();
let pop = sk.prove_possession();
let pk = sk.public_key();
bencher.bench(|| pk.verify_possession(&pop));
}
}

#[cfg(feature = "std")]
mod worker {
use super::*;

use dash_pkc::worker;

fn setup_sigs<S: BlsScheme>(n: usize) -> Vec<(BlsSignature<S>, BlsPublicKey<S>, [u8; 32])> {
(0..n)
.map(|i| {
let sk = BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap();
let msg = test_msg(i as u8);
let pk = sk.public_key();
let sig = sk.sign(S::msg_ref(&msg));
(sig, pk, msg)
})
.collect()
}

#[divan::bench(types = [BlsScChia, BlsScIetf], args = [100, 1000])]
fn verify_n<S: BlsScheme>(bencher: Bencher, n: usize) {
let tuples = setup_sigs::<S>(n);
bencher
.counter(ItemsCount::new(n))
.bench(|| worker::par_verify(&tuples, |(sig, pk, msg)| sig.verify(S::msg_ref(msg), pk).is_ok()));
}

#[divan::bench(types = [BlsScChia, BlsScIetf], args = [100, 1000])]
fn aggregate_pk_n<S: BlsScheme>(bencher: Bencher, n: usize) {
let pks: Vec<BlsPublicKey<S>> = (0..n)
.map(|i| BlsSecretKey::<S>::generate(&test_ikm(i as u8)).unwrap().public_key())
.collect();
bencher
.counter(ItemsCount::new(n))
.bench(|| worker::par_reduce(pks.clone(), |a, b| BlsPublicKey::<S>::aggregate(&[&a, &b]).unwrap()));
}
}
Loading
Loading