Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
794d6dffb1
|
||
|
|
c3d210cf16
|
||
|
|
e79242118f
|
||
|
|
0a62dc06b3
|
||
|
|
79c90cbd4f
|
||
|
|
f829708e5a
|
||
|
|
1ce84b63ec
|
||
|
|
7159c4b07a
|
||
|
|
c07463122a
|
||
|
|
2e97c879e1
|
||
|
|
64543a8729
|
||
|
|
8d1eadb017
|
||
|
|
cdab359b4e
|
||
|
|
c3b3ff1e4d
|
||
|
|
2addbc68b5
|
||
|
|
6294d1e520
|
||
|
|
2f8769012b
|
||
|
|
57891ed230
|
||
|
|
fce4946369
|
||
|
|
7f41676795
|
||
|
|
634064161f
|
||
|
|
0d9b623f9d
|
||
|
|
828efdda01
|
||
|
|
3cf2f27569
|
||
|
|
2b8fc16537
|
||
|
|
8f1100d64d
|
||
|
|
973365a849
|
||
|
|
e2d14bcc0d
|
||
|
|
25e0076c8d
|
||
|
|
aba483c9e1
|
||
|
|
e9febc6faa
|
||
|
|
c83a4e654b
|
||
|
|
2fad2e18b5
|
||
|
|
3415347072
|
||
|
|
5611618126
|
||
|
|
c2399c5b8f
|
||
|
|
f35680738c
|
No files matched your search
+49
@@ -0,0 +1,49 @@
|
||||
image: archlinux
|
||||
packages:
|
||||
- rustup
|
||||
- cargo-tarpaulin
|
||||
sources:
|
||||
- https://git.sr.ht/~swaits/vivaldi-nc
|
||||
artifacts:
|
||||
- vivaldi-nc/tarpaulin-report.html
|
||||
tasks:
|
||||
- setup: |
|
||||
rustup toolchain install nightly stable
|
||||
cd vivaldi-nc/
|
||||
rustup run stable cargo fetch
|
||||
- format: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo fmt --verbose --check
|
||||
- lint: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo clippy --verbose
|
||||
- coverage: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo tarpaulin --verbose --all-features --out Html
|
||||
- stable: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo build --verbose
|
||||
cargo test --verbose --all-features
|
||||
- nightly: |
|
||||
rustup default nightly
|
||||
cd vivaldi-nc/
|
||||
cargo clippy --verbose ||:
|
||||
cargo build --verbose ||:
|
||||
cargo test --verbose --all-features ||:
|
||||
- bench: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo bench --verbose --all-features
|
||||
- examples: |
|
||||
rustup default stable
|
||||
cd vivaldi-nc/
|
||||
cargo run --verbose --all-features --example planetlab
|
||||
cargo run --verbose --all-features --example planetlab --release
|
||||
- docs: |
|
||||
cd vivaldi-nc/
|
||||
rustup run stable cargo doc --no-deps
|
||||
rustup run nightly cargo doc --no-deps ||:
|
||||
-142
@@ -1,142 +0,0 @@
|
||||
# Changelog
|
||||
|
||||
All notable changes to this project will be documented in this file.
|
||||
|
||||
## [0.6.12] - 2023-11-01
|
||||
|
||||
### Miscellaneous Tasks
|
||||
|
||||
- Update dependencies
|
||||
|
||||
## [0.6.11]
|
||||
|
||||
### Miscellaneous Tasks
|
||||
|
||||
- Finally add CHANGELOG.md
|
||||
|
||||
## [0.6.4]
|
||||
|
||||
### Miscellaneous Tasks
|
||||
|
||||
- Add MSRV (1.60)
|
||||
- Upgrade dependencies
|
||||
|
||||
## [0.6.3]
|
||||
|
||||
### Styling
|
||||
|
||||
- Format Cargo.toml
|
||||
- More Cargo.toml formatting
|
||||
- Move clippy allows to specific lines of code
|
||||
|
||||
### Testing
|
||||
|
||||
- Add (and fix) more deny lints
|
||||
- Add audit, deny, outdated, and udeps to CI
|
||||
- Fix cargo audit advisory db location
|
||||
- Make accepted licenses explicit
|
||||
|
||||
## [0.6.2]
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
- Allow clippy lints on specific tests
|
||||
|
||||
### Refactor
|
||||
|
||||
- Change std::time::Duration to std::core::Duration
|
||||
- Change unwrap()s to expects() and deny in clippy
|
||||
- Clean up by using cfg-if where possible
|
||||
|
||||
### Testing
|
||||
|
||||
- Use prop_assert* macros where appropriate
|
||||
|
||||
### Dev
|
||||
|
||||
- Add husky for pre-commit hook generation
|
||||
|
||||
## [0.6.1]
|
||||
|
||||
### Refactor
|
||||
|
||||
- Switch to array-init
|
||||
|
||||
## [0.6.0]
|
||||
|
||||
### Testing
|
||||
|
||||
- Add more stuff to CI
|
||||
- Add examples to CI
|
||||
- Get to 100% coverage, clean up cargo features
|
||||
|
||||
## [0.5.4]
|
||||
|
||||
### Performance
|
||||
|
||||
- Add benchmark, optimize
|
||||
|
||||
## [0.5.3]
|
||||
|
||||
### Documentation
|
||||
|
||||
- Updates to NetworkCoordinate
|
||||
|
||||
## [0.5.2]
|
||||
|
||||
### Features
|
||||
|
||||
- F32/f64 cargo features added
|
||||
|
||||
## [0.5.1]
|
||||
|
||||
### Documentation
|
||||
|
||||
- Udpate crate description
|
||||
- Minor updates re: type aliases, crate to 0.5.1
|
||||
|
||||
## [0.5.0]
|
||||
|
||||
### Features
|
||||
|
||||
- Improve ergonomics for serialization format
|
||||
- Type aliases for 2D/3D NetworkCoordinates
|
||||
|
||||
## [0.4.1]
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
- Exclude examples from crate
|
||||
|
||||
## [0.4.0]
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
- Add numeric stability
|
||||
|
||||
### Features
|
||||
|
||||
- Add PlanetLab example
|
||||
|
||||
### Testing
|
||||
|
||||
- Add proptest, make vec mul/div scalar safer
|
||||
- Add property tests to HeightVector
|
||||
- Add test for NetworkCoordinate::estimate_rtt
|
||||
|
||||
### Misc
|
||||
|
||||
- Formatting
|
||||
|
||||
## [0.3.1]
|
||||
|
||||
### Documentation
|
||||
|
||||
- Add link to docs.rs in README
|
||||
- Add link to ticket tracker
|
||||
|
||||
### Features
|
||||
|
||||
- Add serde
|
||||
|
||||
<!-- generated by git-cliff -->
|
||||
+15
-23
@@ -1,6 +1,6 @@
|
||||
[package]
|
||||
name = "vivaldi-nc"
|
||||
version = "0.6.13"
|
||||
version = "0.6.1"
|
||||
edition = "2021"
|
||||
authors = ["Stephen Waits <steve@waits.net>"]
|
||||
description = "Vivaldi network coordinates for fast, distributed latency estimates in multinode networks, with a clean and simple interface."
|
||||
@@ -9,10 +9,11 @@ keywords = ["vivaldi", "network", "coordinates", "distributed", "p2p"]
|
||||
categories = ["algorithms", "network-programming"]
|
||||
documentation = "https://docs.rs/vivaldi-nc/"
|
||||
readme = "README.md"
|
||||
homepage = "https://git.swaits.com/swaits/vivaldi-nc"
|
||||
repository = "https://git.swaits.com/swaits/vivaldi-nc"
|
||||
exclude = ["examples/*"]
|
||||
rust-version = "1.65"
|
||||
homepage = "https://sr.ht/~swaits/vivaldi-nc/"
|
||||
repository = "https://git.sr.ht/~swaits/vivaldi-nc"
|
||||
exclude = [
|
||||
"examples/*",
|
||||
]
|
||||
|
||||
[features]
|
||||
default = []
|
||||
@@ -24,28 +25,19 @@ debug = true
|
||||
[profile.release]
|
||||
debug = true
|
||||
|
||||
[dev-dependencies]
|
||||
assert_approx_eq = "1.1.0"
|
||||
criterion = "0.4.0"
|
||||
proptest = "1.0.0"
|
||||
serde_json = "1.0.91"
|
||||
|
||||
[[bench]]
|
||||
name = "million-updates"
|
||||
harness = false
|
||||
|
||||
[dev-dependencies]
|
||||
assert_approx_eq = "1.1.0"
|
||||
criterion = "0.5.1"
|
||||
cargo-husky = { version = "1.5.0", features = [
|
||||
"run-for-all",
|
||||
"precommit-hook",
|
||||
"run-cargo-test",
|
||||
"run-cargo-check",
|
||||
"run-cargo-clippy",
|
||||
"run-cargo-fmt",
|
||||
] }
|
||||
proptest = "1.4.0"
|
||||
serde_json = "1.0.114"
|
||||
|
||||
[dependencies]
|
||||
array-init = "2.1.0"
|
||||
cfg-if = "1.0.0"
|
||||
num-traits = "0.2.18"
|
||||
num-traits = "0.2.15"
|
||||
rand = "0.8.5"
|
||||
serde = { version = "1.0.197", features = ["serde_derive"] }
|
||||
serde_with = "3.6.1"
|
||||
serde = {version = "1.0.152", features = ["serde_derive"]}
|
||||
serde_with = "2.2.0"
|
||||
@@ -1,22 +1,6 @@
|
||||
# vivaldi-nc - Vivaldi Network Coordinates
|
||||
|
||||
 [](https://docs.rs/vivaldi-nc/) [](https://git.swaits.com/swaits/vivaldi-nc/actions) [](https://crates.io/crates/vivaldi-nc)  
|
||||
|
||||
<!--toc:start-->
|
||||
- [vivaldi-nc - Vivaldi Network Coordinates](#vivaldi-nc-vivaldi-network-coordinates)
|
||||
- [Introduction](#introduction)
|
||||
- [Addressing the Drawbacks](#addressing-the-drawbacks)
|
||||
- [Usage](#usage)
|
||||
- [Getting Started](#getting-started)
|
||||
- [Cargo Features](#cargo-features)
|
||||
- [Examples](#examples)
|
||||
- [Dependencies](#dependencies)
|
||||
- [Design Goals & Alternatives](#design-goals-alternatives)
|
||||
- [Other Vivaldi NC Implementations](#other-vivaldi-nc-implementations)
|
||||
- [Other NC Algorithms](#other-nc-algorithms)
|
||||
- [Getting Help or Contributing](#getting-help-or-contributing)
|
||||
- [License](#license)
|
||||
<!--toc:end-->
|
||||
[](https://docs.rs/vivaldi-nc/) [](https://builds.sr.ht/~swaits/vivaldi-nc?) [](https://crates.io/crates/vivaldi-nc)  
|
||||
|
||||
## Introduction
|
||||
|
||||
@@ -38,20 +22,20 @@ According to the [Vivaldi coordinates article on Wikipedia](https://en.wikipedia
|
||||
> has a prime use in networking. The algorithm behind the system uses a
|
||||
> distributed technique to estimate propagation times between peers in the
|
||||
> network.
|
||||
>
|
||||
>
|
||||
> Through this scheme, network topology awareness can be used to tune the
|
||||
> network behaviour to more efficiently distribute data. For example, in a
|
||||
> peer-to-peer network, more responsive identification and delivery of content
|
||||
> can be achieved. In the Azureus application, Vivaldi is used to improve the
|
||||
> performance of the distributed hash table that facilitates query matches.
|
||||
>
|
||||
> performance of the distributed hash table that facilitates query matches.
|
||||
>
|
||||
> **Advantages**
|
||||
>
|
||||
>
|
||||
> - Vivaldi is a fully distributed scheme, which achieves good scalability.
|
||||
> - The Vivaldi algorithm is simple and easy to implement.
|
||||
>
|
||||
>
|
||||
> **Drawbacks**
|
||||
>
|
||||
>
|
||||
> - Vivaldi is based on the Euclidean distance model, which requires the
|
||||
> predicted distances to obey the triangle inequality. However, there are
|
||||
> many triangle inequality violations (TIVs) on the Internet.
|
||||
@@ -174,7 +158,7 @@ Adding some detail to these three fields:
|
||||
To run the example, first clone the repository locally:
|
||||
|
||||
```bash
|
||||
git clone https://git.swaits.com/swaits/vivaldi-nc
|
||||
git clone https://git.sr.ht/~swaits/vivaldi-nc
|
||||
```
|
||||
|
||||
Then `cd` into the local clone and run the example:
|
||||
@@ -208,8 +192,6 @@ This crate depends on:
|
||||
operations for the internal `Vector` so much nicer. Once we have
|
||||
`feature(array_zip)` stabilized, we could use that instead. Until then, this
|
||||
works well with zero performance impact.
|
||||
- [`cfg-if`](https://crates.io/crates/cfg-if): Compile-time only macro which
|
||||
makes using `cfg` parameters much nicer in code.
|
||||
|
||||
## Design Goals & Alternatives
|
||||
|
||||
@@ -258,12 +240,15 @@ find many more.
|
||||
|
||||
## Getting Help or Contributing
|
||||
|
||||
To get help, discuss this crate, or report a bug, [open an
|
||||
issue](https://git.swaits.com/swaits/vivaldi-nc/issues).
|
||||
To get help or discuss this crate, [submit a
|
||||
ticket](https://todo.sr.ht/~swaits/vivaldi-nc) or post on
|
||||
[`vivaldi-nc-discuss@`](https://lists.sr.ht/~swaits/vivaldi-nc-discuss).
|
||||
|
||||
If you want to contribute code enhancements or fixes directly, fork the
|
||||
repository on [git.swaits.com](https://git.swaits.com/swaits/vivaldi-nc) and
|
||||
open a pull request.
|
||||
Discussion related to development or patch submissions should go to
|
||||
[`vivaldi-nc-devel@`](https://lists.sr.ht/~swaits/vivaldi-nc-devel).
|
||||
|
||||
Patchsets should use [git-send-email](https://git-send-email.io/) or the [sr.ht
|
||||
UI](https://git.sr.ht/~swaits/vivaldi-nc/send-email) (easiest IMO).
|
||||
|
||||
Patch submitters implicitly agree that all contributions they submit fall under
|
||||
the MIT license.
|
||||
@@ -271,19 +256,19 @@ the MIT license.
|
||||
## License
|
||||
|
||||
> MIT License
|
||||
>
|
||||
>
|
||||
> Copyright (c) 2023 Stephen Waits
|
||||
>
|
||||
>
|
||||
> Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
> of this software and associated documentation files (the "Software"), to deal
|
||||
> in the Software without restriction, including without limitation the rights
|
||||
> to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
> copies of the Software, and to permit persons to whom the Software is
|
||||
> furnished to do so, subject to the following conditions:
|
||||
>
|
||||
>
|
||||
> The above copyright notice and this permission notice shall be included in all
|
||||
> copies or substantial portions of the Software.
|
||||
>
|
||||
>
|
||||
> THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
> IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
> FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
use core::time::Duration;
|
||||
use std::time::Duration;
|
||||
|
||||
use criterion::{criterion_group, criterion_main, Criterion};
|
||||
use vivaldi_nc::{NetworkCoordinate2D, NetworkCoordinate3D};
|
||||
|
||||
-83
@@ -1,83 +0,0 @@
|
||||
# git-cliff ~ default configuration file
|
||||
# https://git-cliff.org/docs/configuration
|
||||
#
|
||||
# Lines starting with "#" are comments.
|
||||
# Configuration options are organized into tables and keys.
|
||||
# See documentation for more information on available options.
|
||||
|
||||
[changelog]
|
||||
# changelog header
|
||||
header = """
|
||||
# Changelog\n
|
||||
All notable changes to this project will be documented in this file.\n
|
||||
"""
|
||||
# template for the changelog body
|
||||
# https://keats.github.io/tera/docs/#introduction
|
||||
body = """
|
||||
{% if version %}\
|
||||
## [{{ version | trim_start_matches(pat="v") }}] - {{ timestamp | date(format="%Y-%m-%d") }}
|
||||
{% else %}\
|
||||
## [unreleased]
|
||||
{% endif %}\
|
||||
{% for group, commits in commits | group_by(attribute="group") %}
|
||||
### {{ group | upper_first }}
|
||||
{% for commit in commits %}
|
||||
- {% if commit.breaking %}[**breaking**] {% endif %}{{ commit.message | upper_first }}\
|
||||
{% endfor %}
|
||||
{% endfor %}\n
|
||||
"""
|
||||
# remove the leading and trailing whitespace from the template
|
||||
trim = true
|
||||
# changelog footer
|
||||
footer = """
|
||||
<!-- generated by git-cliff -->
|
||||
"""
|
||||
# postprocessors
|
||||
postprocessors = [
|
||||
# { pattern = '<REPO>', replace = "https://github.com/orhun/git-cliff" }, # replace repository URL
|
||||
]
|
||||
[git]
|
||||
# parse the commits based on https://www.conventionalcommits.org
|
||||
conventional_commits = true
|
||||
# filter out the commits that are not conventional
|
||||
filter_unconventional = true
|
||||
# process each line of a commit as an individual commit
|
||||
split_commits = false
|
||||
# regex for preprocessing the commit messages
|
||||
commit_preprocessors = [
|
||||
# { pattern = '\((\w+\s)?#([0-9]+)\)', replace = "([#${2}](<REPO>/issues/${2}))"}, # replace issue numbers
|
||||
]
|
||||
# regex for parsing and grouping commits
|
||||
commit_parsers = [
|
||||
{ message = "^feat", group = "Features" },
|
||||
{ message = "^fix", group = "Bug Fixes" },
|
||||
{ message = "^doc", group = "Documentation" },
|
||||
{ message = "^perf", group = "Performance" },
|
||||
{ message = "^refactor", group = "Refactor" },
|
||||
{ message = "^style", group = "Styling" },
|
||||
{ message = "^test", group = "Testing" },
|
||||
{ message = "^chore\\(release\\): prepare for", skip = true },
|
||||
{ message = "^chore\\(deps\\)", skip = true },
|
||||
{ message = "^chore\\(pr\\)", skip = true },
|
||||
{ message = "^chore\\(pull\\)", skip = true },
|
||||
{ message = "^chore|ci", group = "Miscellaneous Tasks" },
|
||||
{ body = ".*security", group = "Security" },
|
||||
{ message = "^revert", group = "Revert" },
|
||||
]
|
||||
# protect breaking changes from being skipped due to matching a skipping commit_parser
|
||||
protect_breaking_commits = false
|
||||
# filter out the commits that are not matched by commit parsers
|
||||
filter_commits = false
|
||||
# regex for matching git tags
|
||||
tag_pattern = "v[0-9].*"
|
||||
|
||||
# regex for skipping tags
|
||||
skip_tags = "v0.1.0-beta.1"
|
||||
# regex for ignoring tags
|
||||
ignore_tags = ""
|
||||
# sort the tags topologically
|
||||
topo_order = false
|
||||
# sort the commits inside sections by oldest/newest order
|
||||
sort_commits = "oldest"
|
||||
# limit the number of commits included in the changelog.
|
||||
# limit_commits = 42
|
||||
@@ -1,270 +0,0 @@
|
||||
# This template contains all of the possible sections and their default values
|
||||
|
||||
# Note that all fields that take a lint level have these possible values:
|
||||
# * deny - An error will be produced and the check will fail
|
||||
# * warn - A warning will be produced, but the check will not fail
|
||||
# * allow - No warning or error will be produced, though in some cases a note
|
||||
# will be
|
||||
|
||||
# The values provided in this template are the default values that will be used
|
||||
# when any section or field is not specified in your own configuration
|
||||
|
||||
# Root options
|
||||
|
||||
# If 1 or more target triples (and optionally, target_features) are specified,
|
||||
# only the specified targets will be checked when running `cargo deny check`.
|
||||
# This means, if a particular package is only ever used as a target specific
|
||||
# dependency, such as, for example, the `nix` crate only being used via the
|
||||
# `target_family = "unix"` configuration, that only having windows targets in
|
||||
# this list would mean the nix crate, as well as any of its exclusive
|
||||
# dependencies not shared by any other crates, would be ignored, as the target
|
||||
# list here is effectively saying which targets you are building for.
|
||||
targets = [
|
||||
# The triple can be any string, but only the target triples built in to
|
||||
# rustc (as of 1.40) can be checked against actual config expressions
|
||||
#{ triple = "x86_64-unknown-linux-musl" },
|
||||
# You can also specify which target_features you promise are enabled for a
|
||||
# particular target. target_features are currently not validated against
|
||||
# the actual valid features supported by the target architecture.
|
||||
#{ triple = "wasm32-unknown-unknown", features = ["atomics"] },
|
||||
]
|
||||
# When creating the dependency graph used as the source of truth when checks are
|
||||
# executed, this field can be used to prune crates from the graph, removing them
|
||||
# from the view of cargo-deny. This is an extremely heavy hammer, as if a crate
|
||||
# is pruned from the graph, all of its dependencies will also be pruned unless
|
||||
# they are connected to another crate in the graph that hasn't been pruned,
|
||||
# so it should be used with care. The identifiers are [Package ID Specifications]
|
||||
# (https://doc.rust-lang.org/cargo/reference/pkgid-spec.html)
|
||||
#exclude = []
|
||||
# If true, metadata will be collected with `--all-features`. Note that this can't
|
||||
# be toggled off if true, if you want to conditionally enable `--all-features` it
|
||||
# is recommended to pass `--all-features` on the cmd line instead
|
||||
all-features = false
|
||||
# If true, metadata will be collected with `--no-default-features`. The same
|
||||
# caveat with `all-features` applies
|
||||
no-default-features = false
|
||||
# If set, these feature will be enabled when collecting metadata. If `--features`
|
||||
# is specified on the cmd line they will take precedence over this option.
|
||||
#features = []
|
||||
# When outputting inclusion graphs in diagnostics that include features, this
|
||||
# option can be used to specify the depth at which feature edges will be added.
|
||||
# This option is included since the graphs can be quite large and the addition
|
||||
# of features from the crate(s) to all of the graph roots can be far too verbose.
|
||||
# This option can be overridden via `--feature-depth` on the cmd line
|
||||
feature-depth = 1
|
||||
|
||||
# This section is considered when running `cargo deny check advisories`
|
||||
# More documentation for the advisories section can be found here:
|
||||
# https://embarkstudios.github.io/cargo-deny/checks/advisories/cfg.html
|
||||
[advisories]
|
||||
# The path where the advisory database is cloned/fetched into
|
||||
db-path = "~/.cargo/advisory-db"
|
||||
# The url(s) of the advisory databases to use
|
||||
db-urls = ["https://github.com/rustsec/advisory-db"]
|
||||
# The lint level for security vulnerabilities
|
||||
vulnerability = "deny"
|
||||
# The lint level for unmaintained crates
|
||||
unmaintained = "warn"
|
||||
# The lint level for crates that have been yanked from their source registry
|
||||
yanked = "warn"
|
||||
# The lint level for crates with security notices. Note that as of
|
||||
# 2019-12-17 there are no security notice advisories in
|
||||
# https://github.com/rustsec/advisory-db
|
||||
notice = "warn"
|
||||
# A list of advisory IDs to ignore. Note that ignored advisories will still
|
||||
# output a note when they are encountered.
|
||||
ignore = [
|
||||
#"RUSTSEC-0000-0000",
|
||||
]
|
||||
# Threshold for security vulnerabilities, any vulnerability with a CVSS score
|
||||
# lower than the range specified will be ignored. Note that ignored advisories
|
||||
# will still output a note when they are encountered.
|
||||
# * None - CVSS Score 0.0
|
||||
# * Low - CVSS Score 0.1 - 3.9
|
||||
# * Medium - CVSS Score 4.0 - 6.9
|
||||
# * High - CVSS Score 7.0 - 8.9
|
||||
# * Critical - CVSS Score 9.0 - 10.0
|
||||
#severity-threshold =
|
||||
|
||||
# If this is true, then cargo deny will use the git executable to fetch advisory database.
|
||||
# If this is false, then it uses a built-in git library.
|
||||
# Setting this to true can be helpful if you have special authentication requirements that cargo-deny does not support.
|
||||
# See Git Authentication for more information about setting up git authentication.
|
||||
#git-fetch-with-cli = true
|
||||
|
||||
# This section is considered when running `cargo deny check licenses`
|
||||
# More documentation for the licenses section can be found here:
|
||||
# https://embarkstudios.github.io/cargo-deny/checks/licenses/cfg.html
|
||||
[licenses]
|
||||
# The lint level for crates which do not have a detectable license
|
||||
unlicensed = "deny"
|
||||
# List of explicitly allowed licenses
|
||||
# See https://spdx.org/licenses/ for list of possible licenses
|
||||
# [possible values: any SPDX 3.11 short identifier (+ optional exception)].
|
||||
allow = [
|
||||
"Apache-2.0",
|
||||
"BSD-3-Clause",
|
||||
"MIT",
|
||||
"Unicode-DFS-2016",
|
||||
]
|
||||
# List of explicitly disallowed licenses
|
||||
# See https://spdx.org/licenses/ for list of possible licenses
|
||||
# [possible values: any SPDX 3.11 short identifier (+ optional exception)].
|
||||
deny = [
|
||||
#"Nokia",
|
||||
]
|
||||
# Lint level for licenses considered copyleft
|
||||
copyleft = "deny"
|
||||
# Blanket approval or denial for OSI-approved or FSF Free/Libre licenses
|
||||
# * both - The license will be approved if it is both OSI-approved *AND* FSF
|
||||
# * either - The license will be approved if it is either OSI-approved *OR* FSF
|
||||
# * osi-only - The license will be approved if is OSI-approved *AND NOT* FSF
|
||||
# * fsf-only - The license will be approved if is FSF *AND NOT* OSI-approved
|
||||
# * neither - This predicate is ignored and the default lint level is used
|
||||
allow-osi-fsf-free = "neither"
|
||||
# Lint level used when no other predicates are matched
|
||||
# 1. License isn't in the allow or deny lists
|
||||
# 2. License isn't copyleft
|
||||
# 3. License isn't OSI/FSF, or allow-osi-fsf-free = "neither"
|
||||
default = "deny"
|
||||
# The confidence threshold for detecting a license from license text.
|
||||
# The higher the value, the more closely the license text must be to the
|
||||
# canonical license text of a valid SPDX license file.
|
||||
# [possible values: any between 0.0 and 1.0].
|
||||
confidence-threshold = 0.8
|
||||
# Allow 1 or more licenses on a per-crate basis, so that particular licenses
|
||||
# aren't accepted for every possible crate as with the normal allow list
|
||||
exceptions = [
|
||||
# Each entry is the crate and version constraint, and its specific allow
|
||||
# list
|
||||
#{ allow = ["Zlib"], name = "adler32", version = "*" },
|
||||
]
|
||||
|
||||
# Some crates don't have (easily) machine readable licensing information,
|
||||
# adding a clarification entry for it allows you to manually specify the
|
||||
# licensing information
|
||||
#[[licenses.clarify]]
|
||||
# The name of the crate the clarification applies to
|
||||
#name = "ring"
|
||||
# The optional version constraint for the crate
|
||||
#version = "*"
|
||||
# The SPDX expression for the license requirements of the crate
|
||||
#expression = "MIT AND ISC AND OpenSSL"
|
||||
# One or more files in the crate's source used as the "source of truth" for
|
||||
# the license expression. If the contents match, the clarification will be used
|
||||
# when running the license check, otherwise the clarification will be ignored
|
||||
# and the crate will be checked normally, which may produce warnings or errors
|
||||
# depending on the rest of your configuration
|
||||
#license-files = [
|
||||
# Each entry is a crate relative path, and the (opaque) hash of its contents
|
||||
#{ path = "LICENSE", hash = 0xbd0eed23 }
|
||||
#]
|
||||
|
||||
[licenses.private]
|
||||
# If true, ignores workspace crates that aren't published, or are only
|
||||
# published to private registries.
|
||||
# To see how to mark a crate as unpublished (to the official registry),
|
||||
# visit https://doc.rust-lang.org/cargo/reference/manifest.html#the-publish-field.
|
||||
ignore = false
|
||||
# One or more private registries that you might publish crates to, if a crate
|
||||
# is only published to private registries, and ignore is true, the crate will
|
||||
# not have its license(s) checked
|
||||
registries = [
|
||||
#"https://sekretz.com/registry
|
||||
]
|
||||
|
||||
# This section is considered when running `cargo deny check bans`.
|
||||
# More documentation about the 'bans' section can be found here:
|
||||
# https://embarkstudios.github.io/cargo-deny/checks/bans/cfg.html
|
||||
[bans]
|
||||
# Lint level for when multiple versions of the same crate are detected
|
||||
multiple-versions = "warn"
|
||||
# Lint level for when a crate version requirement is `*`
|
||||
wildcards = "allow"
|
||||
# The graph highlighting used when creating dotgraphs for crates
|
||||
# with multiple versions
|
||||
# * lowest-version - The path to the lowest versioned duplicate is highlighted
|
||||
# * simplest-path - The path to the version with the fewest edges is highlighted
|
||||
# * all - Both lowest-version and simplest-path are used
|
||||
highlight = "all"
|
||||
# The default lint level for `default` features for crates that are members of
|
||||
# the workspace that is being checked. This can be overriden by allowing/denying
|
||||
# `default` on a crate-by-crate basis if desired.
|
||||
workspace-default-features = "allow"
|
||||
# The default lint level for `default` features for external crates that are not
|
||||
# members of the workspace. This can be overriden by allowing/denying `default`
|
||||
# on a crate-by-crate basis if desired.
|
||||
external-default-features = "allow"
|
||||
# List of crates that are allowed. Use with care!
|
||||
allow = [
|
||||
#{ name = "ansi_term", version = "=0.11.0" },
|
||||
]
|
||||
# List of crates to deny
|
||||
deny = [
|
||||
# Each entry the name of a crate and a version range. If version is
|
||||
# not specified, all versions will be matched.
|
||||
#{ name = "ansi_term", version = "=0.11.0" },
|
||||
#
|
||||
# Wrapper crates can optionally be specified to allow the crate when it
|
||||
# is a direct dependency of the otherwise banned crate
|
||||
#{ name = "ansi_term", version = "=0.11.0", wrappers = [] },
|
||||
]
|
||||
|
||||
# List of features to allow/deny
|
||||
# Each entry the name of a crate and a version range. If version is
|
||||
# not specified, all versions will be matched.
|
||||
#[[bans.features]]
|
||||
#name = "reqwest"
|
||||
# Features to not allow
|
||||
#deny = ["json"]
|
||||
# Features to allow
|
||||
#allow = [
|
||||
# "rustls",
|
||||
# "__rustls",
|
||||
# "__tls",
|
||||
# "hyper-rustls",
|
||||
# "rustls",
|
||||
# "rustls-pemfile",
|
||||
# "rustls-tls-webpki-roots",
|
||||
# "tokio-rustls",
|
||||
# "webpki-roots",
|
||||
#]
|
||||
# If true, the allowed features must exactly match the enabled feature set. If
|
||||
# this is set there is no point setting `deny`
|
||||
#exact = true
|
||||
|
||||
# Certain crates/versions that will be skipped when doing duplicate detection.
|
||||
skip = [
|
||||
#{ name = "ansi_term", version = "=0.11.0" },
|
||||
]
|
||||
# Similarly to `skip` allows you to skip certain crates during duplicate
|
||||
# detection. Unlike skip, it also includes the entire tree of transitive
|
||||
# dependencies starting at the specified crate, up to a certain depth, which is
|
||||
# by default infinite.
|
||||
skip-tree = [
|
||||
#{ name = "ansi_term", version = "=0.11.0", depth = 20 },
|
||||
]
|
||||
|
||||
# This section is considered when running `cargo deny check sources`.
|
||||
# More documentation about the 'sources' section can be found here:
|
||||
# https://embarkstudios.github.io/cargo-deny/checks/sources/cfg.html
|
||||
[sources]
|
||||
# Lint level for what to happen when a crate from a crate registry that is not
|
||||
# in the allow list is encountered
|
||||
unknown-registry = "warn"
|
||||
# Lint level for what to happen when a crate from a git repository that is not
|
||||
# in the allow list is encountered
|
||||
unknown-git = "warn"
|
||||
# List of URLs for allowed crate registries. Defaults to the crates.io index
|
||||
# if not specified. If it is specified but empty, no registries are allowed.
|
||||
allow-registry = ["https://github.com/rust-lang/crates.io-index"]
|
||||
# List of URLs for allowed Git repositories
|
||||
allow-git = []
|
||||
|
||||
[sources.allow-org]
|
||||
# 1 or more github.com organizations to allow git sources for
|
||||
github = [""]
|
||||
# 1 or more gitlab.com organizations to allow git sources for
|
||||
gitlab = [""]
|
||||
# 1 or more bitbucket.org organizations to allow git sources for
|
||||
bitbucket = [""]
|
||||
+26
-36
@@ -47,21 +47,19 @@ use core::ops::{Add, Mul, Sub};
|
||||
use rand::prelude::*;
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
use crate::vector::Vector;
|
||||
use crate::vector::{self, Vector};
|
||||
|
||||
//
|
||||
// **** Features ****
|
||||
//
|
||||
|
||||
cfg_if::cfg_if! {
|
||||
if #[cfg(feature = "f32")] {
|
||||
/// `FloatType` is a type alias for either `f32` or `f64` depending on cargo features
|
||||
type FloatType = f32;
|
||||
} else {
|
||||
/// `FloatType` is a type alias for either `f32` or `f64` depending on cargo features
|
||||
type FloatType = f64;
|
||||
}
|
||||
}
|
||||
/// `FloatType` is a type alias for either `f32` or `f64` depending on cargo features
|
||||
#[cfg(feature = "f32")]
|
||||
type FloatType = f32;
|
||||
|
||||
/// `FloatType` is a type alias for either `f32` or `f64` depending on cargo features
|
||||
#[cfg(not(feature = "f32"))]
|
||||
type FloatType = f64;
|
||||
|
||||
//
|
||||
// **** Constants ****
|
||||
@@ -96,7 +94,7 @@ pub struct HeightVector<const N: usize> {
|
||||
impl<const N: usize> HeightVector<N> {
|
||||
/// A new height vector is a random unit vector
|
||||
pub(crate) fn random() -> Self {
|
||||
let mut rng = thread_rng();
|
||||
let mut rng = rand::thread_rng();
|
||||
let mut vec = [0.0; N];
|
||||
for i in vec.iter_mut().take(N) {
|
||||
*i = rng.gen::<FloatType>() - 0.5;
|
||||
@@ -160,7 +158,7 @@ impl<const N: usize> Default for HeightVector<N> {
|
||||
/// Default value for a Vivaldi height vector is just the defaults of its children types.
|
||||
fn default() -> Self {
|
||||
Self {
|
||||
position: Vector::default(),
|
||||
position: vector::Vector::default(),
|
||||
height: Default::default(),
|
||||
}
|
||||
}
|
||||
@@ -236,37 +234,32 @@ impl<const N: usize> Mul<FloatType> for HeightVector<N> {
|
||||
//
|
||||
// **** Tests ****
|
||||
//
|
||||
#[allow(clippy::ignored_unit_patterns)]
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use super::*;
|
||||
use assert_approx_eq::assert_approx_eq;
|
||||
use proptest::prelude::*;
|
||||
|
||||
fn approx_eq(a: FloatType, b: FloatType, margin: FloatType) -> bool {
|
||||
(a - b).abs() <= margin
|
||||
}
|
||||
|
||||
proptest! {
|
||||
#[test]
|
||||
fn proptest_len(x: FloatType, y: FloatType, h: FloatType) {
|
||||
let len = x.hypot(y) + h.abs();
|
||||
let a = HeightVector::<2>::from(([x,y],h));
|
||||
println!("a = {a:#?}");
|
||||
if x.is_nan() || x.is_infinite() || y.is_nan() || y.is_infinite() || h.is_nan() || h.is_infinite() || h < 0.0 {
|
||||
// we should've gottne a random univ vector here
|
||||
prop_assert!(approx_eq(a.len(), 1.0, 0.0001));
|
||||
assert_approx_eq!(a.len(), 1.0);
|
||||
} else {
|
||||
// `HeightVector` we created from proptest values should be valid and have a length
|
||||
if len.is_nan() || len.is_infinite() {
|
||||
prop_assert!(a.len().is_nan() || a.len().is_infinite());
|
||||
assert!(a.len().is_nan() || a.len().is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(a.len(), len, 0.0001));
|
||||
assert_approx_eq!(a.len(), len);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#[test]
|
||||
#[allow(clippy::cast_lossless, clippy::cast_precision_loss)]
|
||||
fn proptest_add(x0 in -1_000_000_000..1_000_000_000i32, y0 in -1_000_000_000..1_000_000_000i32, h0 in 0..1_000_000_000i32, x1 in -1_000_000_000..1_000_000_000i32, y1 in -1_000_000_000..1_000_000_000i32, h1 in 0..1_000_000i32) {
|
||||
// convert our integer range inputs to FloatType
|
||||
let (fx0,fy0,fh0) = (x0 as FloatType / 1_000.0, y0 as FloatType / 1_000.0, h0 as FloatType / 1_000.0);
|
||||
@@ -275,13 +268,12 @@ mod tests {
|
||||
let a = HeightVector::<2>::from(([fx0 ,fy0 ],fh0 ));
|
||||
let b = HeightVector::<2>::from(([fx1 ,fy1 ],fh1 ));
|
||||
let c = a+b;
|
||||
prop_assert!(approx_eq(c.position[0], fx0 + fx1, 0.0001));
|
||||
prop_assert!(approx_eq(c.position[1], fy0 + fy1, 0.0001));
|
||||
prop_assert!(approx_eq(c.height, fh0 + fh1, 0.0001));
|
||||
assert_approx_eq!(c.position[0], fx0 + fx1);
|
||||
assert_approx_eq!(c.position[1], fy0 + fy1);
|
||||
assert_approx_eq!(c.height, fh0 + fh1);
|
||||
}
|
||||
|
||||
#[test]
|
||||
#[allow(clippy::cast_lossless, clippy::cast_precision_loss)]
|
||||
fn proptest_sub(x0 in -1_000_000_000..1_000_000_000i32, y0 in -1_000_000_000..1_000_000_000i32, h0 in 0..1_000_000_000i32, x1 in -1_000_000_000..1_000_000_000i32, y1 in -1_000_000_000..1_000_000_000i32, h1 in 0..1_000_000i32) {
|
||||
// convert our integer range inputs to FloatType
|
||||
let (fx0,fy0,fh0) = (x0 as FloatType / 1_000.0, y0 as FloatType / 1_000.0, h0 as FloatType / 1_000.0);
|
||||
@@ -290,13 +282,12 @@ mod tests {
|
||||
let a = HeightVector::<2>::from(([fx0 ,fy0 ],fh0 ));
|
||||
let b = HeightVector::<2>::from(([fx1 ,fy1 ],fh1 ));
|
||||
let c = a-b;
|
||||
prop_assert!(approx_eq(c.position[0], fx0 - fx1, 0.0001));
|
||||
prop_assert!(approx_eq(c.position[1], fy0 - fy1, 0.0001));
|
||||
prop_assert!(approx_eq(c.height, fh0 + fh1, 0.0001));
|
||||
assert_approx_eq!(c.position[0], fx0 - fx1);
|
||||
assert_approx_eq!(c.position[1], fy0 - fy1);
|
||||
assert_approx_eq!(c.height, fh0 + fh1);
|
||||
}
|
||||
|
||||
#[test]
|
||||
#[allow(clippy::cast_lossless, clippy::cast_precision_loss)]
|
||||
fn proptest_mul(x in -1_000_000_000..1_000_000_000i32, y in -1_000_000_000..1_000_000_000i32, h in 0..1_000_000_000i32, m in -1_000_000_000..1_000_000_000i32) {
|
||||
// convert our integer range inputs to FloatType
|
||||
let (fx,fy,fh,fm) = (x as FloatType / 1_000.0, y as FloatType / 1_000.0, h as FloatType / 1_000.0, m as FloatType / 1_000.0);
|
||||
@@ -304,11 +295,11 @@ mod tests {
|
||||
let a = HeightVector::<2>::from(([fx, fy], fh));
|
||||
let b = a * fm;
|
||||
if fm < 0.0 {
|
||||
prop_assert!(approx_eq(b.len(), 1.0, 0.0001));
|
||||
assert_approx_eq!(b.len(), 1.0);
|
||||
} else {
|
||||
prop_assert!(approx_eq(b.position[0], fx * fm, 0.0001));
|
||||
prop_assert!(approx_eq(b.position[1], fy * fm, 0.0001));
|
||||
prop_assert!(approx_eq(b.height, fh * fm, 0.0001));
|
||||
assert_approx_eq!(b.position[0], fx * fm);
|
||||
assert_approx_eq!(b.position[1], fy * fm);
|
||||
assert_approx_eq!(b.height, fh * fm);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -373,15 +364,14 @@ mod tests {
|
||||
fn test_serde() {
|
||||
// start with JSON, deserialize it
|
||||
let s = "{\"position\":[1.0,2.0,3.0],\"height\":4.0}";
|
||||
let a: HeightVector<3> =
|
||||
serde_json::from_str(s).expect("deserialization failed during test");
|
||||
let a: HeightVector<3> = serde_json::from_str(s).unwrap();
|
||||
|
||||
// make sure it's the right length and works like we expect a normal NC
|
||||
assert_approx_eq!(a.len(), 7.741_657, 0.001);
|
||||
|
||||
// serialize it into a new JSON string and make sure it matches the original
|
||||
let t = serde_json::to_string(&a);
|
||||
assert_eq!(t.as_ref().expect("serialization failed during test"), s);
|
||||
assert_eq!(t.as_ref().unwrap(), s);
|
||||
}
|
||||
|
||||
#[test]
|
||||
|
||||
+10
-28
@@ -93,35 +93,17 @@
|
||||
//! ```
|
||||
//!
|
||||
|
||||
#![deny(
|
||||
clippy::all,
|
||||
clippy::correctness,
|
||||
clippy::style,
|
||||
clippy::suspicious,
|
||||
clippy::complexity,
|
||||
clippy::perf,
|
||||
clippy::cargo,
|
||||
clippy::pedantic,
|
||||
clippy::nursery,
|
||||
clippy::unwrap_used
|
||||
)]
|
||||
#![deny(
|
||||
anonymous_parameters,
|
||||
missing_copy_implementations,
|
||||
missing_debug_implementations,
|
||||
missing_docs,
|
||||
nonstandard_style,
|
||||
rust_2018_idioms,
|
||||
single_use_lifetimes,
|
||||
trivial_casts,
|
||||
trivial_numeric_casts,
|
||||
// unreachable_pub, // disagrees with clippy::nurclippy::nursery as of 13-02-2023
|
||||
unused_extern_crates,
|
||||
unused_qualifications,
|
||||
variant_size_differences
|
||||
)]
|
||||
#![deny(clippy::all)]
|
||||
#![deny(clippy::correctness)]
|
||||
#![deny(clippy::style)]
|
||||
#![deny(clippy::suspicious)]
|
||||
#![deny(clippy::complexity)]
|
||||
#![deny(clippy::perf)]
|
||||
#![deny(clippy::cargo)]
|
||||
#![deny(clippy::pedantic)]
|
||||
#![deny(clippy::nursery)]
|
||||
#![allow(clippy::type_repetition_in_bounds)]
|
||||
#![allow(single_use_lifetimes)]
|
||||
#![allow(clippy::module_name_repetitions)]
|
||||
|
||||
mod height_vector;
|
||||
mod vector;
|
||||
|
||||
+22
-29
@@ -2,7 +2,7 @@
|
||||
//!
|
||||
//! For usage explanation and examples, please see the main [`crate`] documentation.
|
||||
|
||||
use core::time::Duration;
|
||||
use std::time::Duration;
|
||||
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
@@ -63,14 +63,12 @@ pub struct NetworkCoordinate<const N: usize> {
|
||||
///
|
||||
/// This type alias is just for convenience. It's functionally equivalent to
|
||||
/// `NetworkCoordinate<2>`. For more information, see [`NetworkCoordinate`].
|
||||
#[allow(clippy::module_name_repetitions)]
|
||||
pub type NetworkCoordinate2D = NetworkCoordinate<2>;
|
||||
|
||||
/// A 3D [`NetworkCoordinate`]. Includes a 3D Euclidean position and a height.
|
||||
///
|
||||
/// This type alias is just for convenience. It's functionally equivalent to
|
||||
/// `NetworkCoordinate<3>`. For more information, see [`NetworkCoordinate`].
|
||||
#[allow(clippy::module_name_repetitions)]
|
||||
pub type NetworkCoordinate3D = NetworkCoordinate<3>;
|
||||
|
||||
//
|
||||
@@ -126,13 +124,11 @@ impl<const N: usize> NetworkCoordinate<N> {
|
||||
#[must_use]
|
||||
pub fn estimated_rtt(&self, rhs: &Self) -> Duration {
|
||||
// estimated rss is euclidean distance between the two plus the sum of the heights
|
||||
cfg_if::cfg_if! {
|
||||
if #[cfg(feature = "f32")] {
|
||||
Duration::from_secs_f32((self.heightvec - rhs.heightvec).len() / 1000.0)
|
||||
} else {
|
||||
Duration::from_secs_f64((self.heightvec - rhs.heightvec).len() / 1000.0)
|
||||
}
|
||||
}
|
||||
#[cfg(feature = "f32")]
|
||||
return Duration::from_secs_f32((self.heightvec - rhs.heightvec).len() / 1000.0);
|
||||
|
||||
#[cfg(not(feature = "f32"))]
|
||||
return Duration::from_secs_f64((self.heightvec - rhs.heightvec).len() / 1000.0);
|
||||
}
|
||||
|
||||
/// Given another Vivaldi [`NetworkCoordinate`], adjust our coordinateto better represent the actual round
|
||||
@@ -150,7 +146,7 @@ impl<const N: usize> NetworkCoordinate<N> {
|
||||
/// # Example
|
||||
///
|
||||
/// ```
|
||||
/// use core::time::Duration;
|
||||
/// use std::time::Duration;
|
||||
/// use vivaldi_nc::NetworkCoordinate;
|
||||
///
|
||||
/// // We always have our own NC:
|
||||
@@ -194,15 +190,15 @@ impl<const N: usize> NetworkCoordinate<N> {
|
||||
///
|
||||
pub fn update(&mut self, rhs: &Self, rtt: Duration) -> &Self {
|
||||
// convert Durations into FloatType as fractional milliseconds for convenience
|
||||
cfg_if::cfg_if! {
|
||||
if #[cfg(feature = "f32")] {
|
||||
let rtt_ms = rtt.as_secs_f32() * 1000.0;
|
||||
let rtt_estimated_ms = self.estimated_rtt(rhs).as_secs_f32() * 1000.0;
|
||||
} else {
|
||||
let rtt_ms = rtt.as_secs_f64() * 1000.0;
|
||||
let rtt_estimated_ms = self.estimated_rtt(rhs).as_secs_f64() * 1000.0;
|
||||
}
|
||||
}
|
||||
#[cfg(feature = "f32")]
|
||||
let rtt_ms = rtt.as_secs_f32() * 1000.0;
|
||||
#[cfg(feature = "f32")]
|
||||
let rtt_estimated_ms = self.estimated_rtt(rhs).as_secs_f32() * 1000.0;
|
||||
|
||||
#[cfg(not(feature = "f32"))]
|
||||
let rtt_ms = rtt.as_secs_f64() * 1000.0;
|
||||
#[cfg(not(feature = "f32"))]
|
||||
let rtt_estimated_ms = self.estimated_rtt(rhs).as_secs_f64() * 1000.0;
|
||||
|
||||
// rtt needs to be positive
|
||||
if rtt_ms < 0.0 {
|
||||
@@ -356,6 +352,7 @@ mod tests {
|
||||
|
||||
// compute and test the root mean squared error
|
||||
let error = slc.error + nyc.error + lax.error + mad.error;
|
||||
println!("error = {error}");
|
||||
assert!(error < 5.0);
|
||||
}
|
||||
|
||||
@@ -363,8 +360,7 @@ mod tests {
|
||||
fn test_serde() {
|
||||
// start with JSON, deserialize it
|
||||
let s = "{\"position\":[1.5,0.5,2.0],\"height\":0.1,\"error\":1.0}";
|
||||
let a: NetworkCoordinate<3> =
|
||||
serde_json::from_str(s).expect("deserialization failed during test");
|
||||
let a: NetworkCoordinate<3> = serde_json::from_str(s).unwrap();
|
||||
|
||||
// make sure it's the right length and works like we expect a normal NC
|
||||
assert_approx_eq!(a.heightvec.len(), 2.649_509, 0.001);
|
||||
@@ -373,18 +369,16 @@ mod tests {
|
||||
|
||||
// serialize it into a new JSON string and make sure it matches the original
|
||||
let t = serde_json::to_string(&a);
|
||||
assert_eq!(t.as_ref().expect("serialization failed during test"), s);
|
||||
assert_eq!(t.as_ref().unwrap(), s);
|
||||
}
|
||||
|
||||
#[test]
|
||||
fn test_estimated_rtt() {
|
||||
// start with JSON, deserialize it
|
||||
let s = "{\"position\":[1.5,0.5,2.0],\"height\":25.0,\"error\":1.0}";
|
||||
let a: NetworkCoordinate<3> =
|
||||
serde_json::from_str(s).expect("deserialization failed during test");
|
||||
let a: NetworkCoordinate<3> = serde_json::from_str(s).unwrap();
|
||||
let s = "{\"position\":[-1.5,-0.5,-2.0],\"height\":50.0,\"error\":1.0}";
|
||||
let b: NetworkCoordinate<3> =
|
||||
serde_json::from_str(s).expect("deserialization failed during test");
|
||||
let b: NetworkCoordinate<3> = serde_json::from_str(s).unwrap();
|
||||
|
||||
let estimate = a.estimated_rtt(&b);
|
||||
assert_approx_eq!(estimate.as_secs_f32(), 0.080_099);
|
||||
@@ -393,8 +387,7 @@ mod tests {
|
||||
#[test]
|
||||
fn test_error_getter() {
|
||||
let s = "{\"position\":[1.5,0.5,2.0],\"height\":25.0,\"error\":1.0}";
|
||||
let a: NetworkCoordinate<3> =
|
||||
serde_json::from_str(s).expect("deserialization failed during test");
|
||||
let a: NetworkCoordinate<3> = serde_json::from_str(s).unwrap();
|
||||
assert_approx_eq!(a.error(), 1.0);
|
||||
}
|
||||
}
|
||||
+20
-28
@@ -8,7 +8,7 @@ use num_traits::Float;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_with::serde_as;
|
||||
|
||||
use core::ops::{Add, Div, Index, Mul, Sub};
|
||||
use std::ops::{Add, Div, Index, Mul, Sub};
|
||||
|
||||
//
|
||||
// **** Structs ****
|
||||
@@ -150,7 +150,6 @@ where
|
||||
// **** Tests ****
|
||||
//
|
||||
|
||||
#[allow(clippy::ignored_unit_patterns)]
|
||||
#[cfg(test)]
|
||||
mod tests {
|
||||
use super::*;
|
||||
@@ -158,20 +157,16 @@ mod tests {
|
||||
use assert_approx_eq::assert_approx_eq;
|
||||
use proptest::prelude::*;
|
||||
|
||||
fn approx_eq(a: f32, b: f32, margin: f32) -> bool {
|
||||
(a - b).abs() <= margin
|
||||
}
|
||||
|
||||
proptest! {
|
||||
#[test]
|
||||
fn proptest_new(x: f32, y: f32, z: f32){
|
||||
let v = Vector::<f32, 3>::from([x,y,z]);
|
||||
prop_assert!(approx_eq(v[0], x, 0.0001));
|
||||
prop_assert!(approx_eq(v[1], y, 0.0001));
|
||||
prop_assert!(approx_eq(v[2], z, 0.0001));
|
||||
prop_assert!(v[0].is_finite());
|
||||
prop_assert!(v[1].is_finite());
|
||||
prop_assert!(v[1].is_finite());
|
||||
assert_approx_eq!(v[0], x);
|
||||
assert_approx_eq!(v[1], y);
|
||||
assert_approx_eq!(v[2], z);
|
||||
assert!(v[0].is_finite());
|
||||
assert!(v[1].is_finite());
|
||||
assert!(v[1].is_finite());
|
||||
}
|
||||
|
||||
#[test]
|
||||
@@ -181,21 +176,21 @@ mod tests {
|
||||
|
||||
let (x,y,z) = (v[0]*m, v[1]*m, v[2]*m);
|
||||
if x.is_nan() || x.is_infinite() {
|
||||
prop_assert!(w[0].is_nan() || w[0].is_infinite());
|
||||
assert!(w[0].is_nan() || w[0].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[0], x, 0.0001));
|
||||
assert_approx_eq!(w[0], x);
|
||||
}
|
||||
|
||||
if y.is_nan() || y.is_infinite() {
|
||||
prop_assert!(w[1].is_nan() || w[1].is_infinite());
|
||||
assert!(w[1].is_nan() || w[1].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[1], y, 0.0001));
|
||||
assert_approx_eq!(w[1], y);
|
||||
}
|
||||
|
||||
if z.is_nan() || z.is_infinite() {
|
||||
prop_assert!(w[2].is_nan() || w[2].is_infinite());
|
||||
assert!(w[2].is_nan() || w[2].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[2], z, 0.0001));
|
||||
assert_approx_eq!(w[2], z);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -206,21 +201,21 @@ mod tests {
|
||||
|
||||
let (x,y,z) = (v[0]/d, v[1]/d, v[2]/d);
|
||||
if x.is_nan() || x.is_infinite() {
|
||||
prop_assert!(w[0].is_nan() ||w[0].is_infinite());
|
||||
assert!(w[0].is_nan() ||w[0].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[0], x, 0.0001));
|
||||
assert_approx_eq!(w[0], x);
|
||||
}
|
||||
|
||||
if y.is_nan() || y.is_infinite() {
|
||||
prop_assert!(w[1].is_nan() || w[1].is_infinite());
|
||||
assert!(w[1].is_nan() || w[1].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[1], y, 0.0001));
|
||||
assert_approx_eq!(w[1], y);
|
||||
}
|
||||
|
||||
if z.is_nan() || z.is_infinite() {
|
||||
prop_assert!(w[2].is_nan() || w[2].is_infinite());
|
||||
assert!(w[2].is_nan() || w[2].is_infinite());
|
||||
} else {
|
||||
prop_assert!(approx_eq(w[2], z, 0.0001));
|
||||
assert_approx_eq!(w[2], z);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -286,10 +281,7 @@ mod tests {
|
||||
fn test_serde() {
|
||||
let a = Vector::<f32, 3>::from([1.0, 2.0, 3.0]);
|
||||
let s = serde_json::to_string(&a);
|
||||
assert_eq!(
|
||||
s.as_ref().expect("serialization failed in test"),
|
||||
"{\"position\":[1.0,2.0,3.0]}"
|
||||
);
|
||||
assert_eq!(s.as_ref().unwrap(), "{\"position\":[1.0,2.0,3.0]}");
|
||||
assert!(s.is_ok());
|
||||
}
|
||||
}
|
||||
@@ -1,22 +0,0 @@
|
||||
// This is just for basic interface and happy path testing. It doesn't do anything other than make
|
||||
// sure the expected public interface exists and works.
|
||||
|
||||
use array_init::array_init;
|
||||
use core::time::Duration;
|
||||
use vivaldi_nc::NetworkCoordinate;
|
||||
|
||||
const NUM_NODES: usize = 100;
|
||||
|
||||
#[test]
|
||||
fn basic_usage() {
|
||||
let mut nc: [NetworkCoordinate<2>; NUM_NODES] = array_init(|_| NetworkCoordinate::<2>::new());
|
||||
for i in 0..NUM_NODES {
|
||||
for j in 0..NUM_NODES {
|
||||
if i == j {
|
||||
continue;
|
||||
}
|
||||
let other = nc[j].clone();
|
||||
nc[i].update(&other, Duration::from_millis(100));
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user