Examples Folder

Cargo.toml

@@ -4,6 +4,11 @@ resolver = "2"
 members = [
   "rodbus",
   "rodbus-client",
+  # example binaries
+  "examples/client",
+  "examples/server",
+  "examples/perf",
+  # FFI crates
   "ffi/rodbus-bindings",
   "ffi/rodbus-ffi",
   "ffi/rodbus-ffi-java",

examples/client/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "example-client"
+version = "1.4.0"
+
+# inherit from workspace
+authors.workspace = true
+rust-version.workspace = true
+edition.workspace = true
+license-file.workspace = true
+homepage.workspace = true
+repository.workspace = true
+keywords.workspace = true
+categories.workspace = true
+
+[dependencies]
+rodbus = { path = "../../rodbus", features = ["tls", "serial"] }
+clap = { version = "4.1.8", features = ["derive"] }
+tokio = { workspace = true, features = ["net", "sync", "io-util", "io-std", "time", "rt", "rt-multi-thread", "macros"] }
+tokio-stream = "0.1"
+tokio-util = { version = "0.7", features = ["codec"] }
+tracing = { workspace = true }
+tracing-subscriber = { workspace = true }
+
+[features]
+default = ["tls", "serial"]
+tls = []
+serial = []

rodbus/examples/client.rs → examples/client/src/main.rs

@@ -63,7 +63,7 @@ where
 async fn run_tcp() -> Result<(), Box<dyn std::error::Error>> {
     // ANCHOR: create_tcp_channel
     let channel = spawn_tcp_client_task(
-        HostAddr::ip(IpAddr::V4(Ipv4Addr::LOCALHOST), 502),
+        HostAddr::ip(IpAddr::V4(Ipv4Addr::LOCALHOST), 2000),
         1,
         default_retry_strategy(),
         DecodeLevel::default(),
@@ -98,7 +98,7 @@ async fn run_rtu() -> Result<(), Box<dyn std::error::Error>> {
 async fn run_tls(tls_config: TlsClientConfig) -> Result<(), Box<dyn std::error::Error>> {
     // ANCHOR: create_tls_channel
     let channel = spawn_tls_client_task(
-        HostAddr::ip(IpAddr::V4(Ipv4Addr::LOCALHOST), 802),
+        HostAddr::ip(IpAddr::V4(Ipv4Addr::LOCALHOST), 2000),
         1,
         default_retry_strategy(),
         tls_config,

examples/perf/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "example-perf"
+version = "1.4.0"
+
+# inherit from workspace
+authors.workspace = true
+rust-version.workspace = true
+edition.workspace = true
+license-file.workspace = true
+homepage.workspace = true
+repository.workspace = true
+keywords.workspace = true
+categories.workspace = true
+
+[dependencies]
+rodbus = { path = "../../rodbus", features = ["tls", "serial"] }
+clap = { version = "4.1.8", features = ["derive"] }
+tokio = { workspace = true, features = ["net", "sync", "io-util", "io-std", "time", "rt", "rt-multi-thread", "macros"] }
+tokio-stream = "0.1"
+tokio-util = { version = "0.7", features = ["codec"] }
+tracing = { workspace = true }
+tracing-subscriber = { workspace = true }
+
+[features]
+default = ["tls", "serial"]
+tls = []
+serial = []

examples/server/Cargo.toml

@@ -0,0 +1,27 @@
+[package]
+name = "example-server"
+version = "1.4.0"
+
+# inherit from workspace
+authors.workspace = true
+rust-version.workspace = true
+edition.workspace = true
+license-file.workspace = true
+homepage.workspace = true
+repository.workspace = true
+keywords.workspace = true
+categories.workspace = true
+
+[dependencies]
+rodbus = { path = "../../rodbus", features = ["tls", "serial"] }
+clap = { version = "4.1.8", features = ["derive"] }
+tokio = { workspace = true, features = ["net", "sync", "io-util", "io-std", "time", "rt", "rt-multi-thread", "macros"] }
+tokio-stream = "0.1"
+tokio-util = { version = "0.7", features = ["codec"] }
+tracing = { workspace = true }
+tracing-subscriber = { workspace = true }
+
+[features]
+default = ["tls", "serial"]
+tls = []
+serial = []

rodbus/examples/server.rs → examples/server/src/main.rs

@@ -169,7 +169,7 @@ async fn run_tcp() -> Result<(), Box<dyn std::error::Error>> {
     // ANCHOR: tcp_server_create
     let server = rodbus::server::spawn_tcp_server_task(
         1,
-        "127.0.0.1:502".parse()?,
+        "127.0.0.1:2000".parse()?,
         map,
         AddressFilter::Any,
         DecodeLevel::default(),
@@ -208,7 +208,7 @@ async fn run_tls(tls_config: TlsServerConfig) -> Result<(), Box<dyn std::error::
     // ANCHOR: tls_server_create
     let server = rodbus::server::spawn_tls_server_task_with_authz(
         1,
-        "127.0.0.1:802".parse()?,
+        "127.0.0.1:2000".parse()?,
         map,
         ReadOnlyAuthorizationHandler::create(),
         tls_config,

ffi/rodbus-ffi/src/iterator.rs

@@ -30,7 +30,7 @@ impl<'a> RegisterValueIterator<'a> {
 }
 
 pub(crate) unsafe fn bit_value_iterator_next(
-    it: *mut crate::BitValueIterator,
+    it: *mut crate::BitValueIterator<'_>,
 ) -> Option<&crate::ffi::BitValue> {
     match it.as_mut() {
         Some(it) => match it.inner.next() {
@@ -46,7 +46,7 @@ pub(crate) unsafe fn bit_value_iterator_next(
 }
 
 pub(crate) unsafe fn register_value_iterator_next(
-    it: *mut crate::RegisterValueIterator,
+    it: *mut crate::RegisterValueIterator<'_>,
 ) -> Option<&crate::ffi::RegisterValue> {
     match it.as_mut() {
         Some(it) => match it.inner.next() {

guide/docs/api/client/requests.mdx

@@ -58,9 +58,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:request_param}}
+{{#include ../examples/client/src/main.rs:request_param}}
 
-{{#include ../rodbus/examples/client.rs:read_coils}}
+{{#include ../examples/client/src/main.rs:read_coils}}
 ```
 
 </TabItem>
@@ -149,9 +149,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:request_param}}
+{{#include ../examples/client/src/main.rs:request_param}}
 
-{{#include ../rodbus/examples/client.rs:write_single_coil}}
+{{#include ../examples/client/src/main.rs:write_single_coil}}
 ```
 
 </TabItem>
@@ -211,9 +211,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:request_param}}
+{{#include ../examples/client/src/main.rs:request_param}}
 
-{{#include ../rodbus/examples/client.rs:write_multiple_registers}}
+{{#include ../examples/client/src/main.rs:write_multiple_registers}}
 ```
 
 </TabItem>

guide/docs/api/client/rtu_client.mdx

@@ -33,7 +33,7 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:create_rtu_channel}}
+{{#include ../examples/client/src/main.rs:create_rtu_channel}}
 ```
 
 </TabItem>

guide/docs/api/client/tcp_client.mdx

@@ -29,7 +29,7 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:create_tcp_channel}}
+{{#include ../examples/client/src/main.rs:create_tcp_channel}}
 ```
 
 </TabItem>

guide/docs/api/client/tls_client.mdx

@@ -29,9 +29,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:tls_ca_chain_config}}
+{{#include ../examples/client/src/main.rs:tls_ca_chain_config}}
 
-{{#include ../rodbus/examples/client.rs:create_tls_channel}}
+{{#include ../examples/client/src/main.rs:create_tls_channel}}
 ```
 
 </TabItem>
@@ -89,9 +89,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:tls_self_signed_config}}
+{{#include ../examples/client/src/main.rs:tls_self_signed_config}}
 
-{{#include ../rodbus/examples/client.rs:create_tls_channel}}
+{{#include ../examples/client/src/main.rs:create_tls_channel}}
 ```
 
 </TabItem>

guide/docs/api/logging.mdx

@@ -38,7 +38,7 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:logging}}
+{{#include ../examples/client/src/main.rs:logging}}
 ```
 
 </TabItem>
@@ -126,4 +126,3 @@ Protocol decoding is always output at the *Info* log level. If left enabled, it
 try adjusting the application-layer decoding first to gain visibility into the messages being exchanged on one channel at a time.
 :::
 
-

guide/docs/api/runtime.mdx

@@ -39,7 +39,7 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/client.rs:runtime_init}}
+{{#include ../examples/client/src/main.rs:runtime_init}}
     // do things within the context of the runtime
     // it is automatically shut down when this async fn returns
 }

guide/docs/api/server/rtu_server.mdx

@@ -65,9 +65,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/server.rs:handler_map_create}}
+{{#include ../examples/server/src/main.rs:handler_map_create}}
 
-{{#include ../rodbus/examples/server.rs:rtu_server_create}}
+{{#include ../examples/server/src/main.rs:rtu_server_create}}
 ```
 
 </TabItem>

guide/docs/api/server/tcp_server.mdx

@@ -54,9 +54,9 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/server.rs:handler_map_create}}
+{{#include ../examples/server/src/main.rs:handler_map_create}}
 
-{{#include ../rodbus/examples/server.rs:tcp_server_create}}
+{{#include ../examples/server/src/main.rs:tcp_server_create}}
 ```
 
 </TabItem>

guide/docs/api/server/tls_server.mdx

@@ -36,11 +36,11 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/server.rs:handler_map_create}}
+{{#include ../examples/server/src/main.rs:handler_map_create}}
 
-{{#include ../rodbus/examples/server.rs:tls_ca_chain_config}}
+{{#include ../examples/server/src/main.rs:tls_ca_chain_config}}
 
-{{#include ../rodbus/examples/server.rs:tls_server_create}}
+{{#include ../examples/server/src/main.rs:tls_server_create}}
 ```
 
 </TabItem>
@@ -112,11 +112,11 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/server.rs:handler_map_create}}
+{{#include ../examples/server/src/main.rs:handler_map_create}}
 
-{{#include ../rodbus/examples/server.rs:tls_self_signed_config}}
+{{#include ../examples/server/src/main.rs:tls_self_signed_config}}
 
-{{#include ../rodbus/examples/server.rs:tls_server_create}}
+{{#include ../examples/server/src/main.rs:tls_server_create}}
 ```
 
 </TabItem>

guide/docs/api/server/write_handler.mdx

@@ -50,7 +50,7 @@ values={[
 <TabItem value="Rust">
 
 ```rust
-{{#include ../rodbus/examples/server.rs:request_handler}}
+{{#include ../examples/server/src/main.rs:request_handler}}
 ```
 
 </TabItem>

guide/docs/examples/summary.mdx

@@ -25,7 +25,7 @@ We pull these code blocks from the example programs when we generate this guide.
 
 The following links redirect to language-specific examples for the current version on Github:
 
-* <a href={`${sitedata.github_url}/tree/${sitedata.version}/rodbus/examples`}>Rust</a>
+* <a href={`${sitedata.github_url}/tree/${sitedata.version}/examples`}>Rust</a>
 * <a href={`${sitedata.github_url}/tree/${sitedata.version}/ffi/bindings/c`}>C and C++</a>
 * <a href={`${sitedata.github_url}/tree/${sitedata.version}/ffi/bindings/dotnet/examples`}>C#</a>
 * <a href={`${sitedata.github_url}/tree/${sitedata.version}/ffi/bindings/java/examples/src/main/java/io/stepfunc/rodbus/examples`}>Java</a>

rodbus/src/types.rs

@@ -383,7 +383,7 @@ mod tests {
 
     #[test]
     fn address_start_max_count_of_one_is_allowed() {
-        AddressRange::try_from(std::u16::MAX, 1).unwrap();
+        AddressRange::try_from(u16::MAX, 1).unwrap();
     }
 
     #[test]