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
2 changes: 1 addition & 1 deletion rustecal-core/src/components.rs
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
//!
//! The flags can be combined using bitwise OR operations (e.g., `PUBLISHER | LOGGING`).
//!
//! These flags are passed to [`crate::ecal::core::Ecal::initialize`] to enable
//! These flags are passed to [`crate::Ecal::initialize`] to enable
//! or disable subsystems for performance, resource usage, or system design reasons.

use bitflags::bitflags;
Expand Down
2 changes: 1 addition & 1 deletion rustecal-core/src/log.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ impl Log {
let logs = unsafe {
let logging = &*raw_ptr;
let raw_messages = logging.log_messages;
let len = logging.log_messages_length as usize;
let len = logging.log_messages_length;

let entries = slice::from_raw_parts(raw_messages, len)
.iter()
Expand Down
10 changes: 5 additions & 5 deletions rustecal-core/src/monitoring.rs
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ impl Monitoring {
// 5) Build the snapshot and free the C‑allocated memory
let snapshot = unsafe {
let processes = {
let cnt = (*raw).processes_length as usize;
let cnt = (*raw).processes_length;
let ptr = (*raw).processes;
slice::from_raw_parts(ptr, cnt)
.iter()
Expand All @@ -58,7 +58,7 @@ impl Monitoring {
};

let publishers = {
let cnt = (*raw).publishers_length as usize;
let cnt = (*raw).publishers_length;
let ptr = (*raw).publishers;
slice::from_raw_parts(ptr, cnt)
.iter()
Expand All @@ -67,7 +67,7 @@ impl Monitoring {
};

let subscribers = {
let cnt = (*raw).subscribers_length as usize;
let cnt = (*raw).subscribers_length;
let ptr = (*raw).subscribers;
slice::from_raw_parts(ptr, cnt)
.iter()
Expand All @@ -76,7 +76,7 @@ impl Monitoring {
};

let servers = {
let cnt = (*raw).servers_length as usize;
let cnt = (*raw).servers_length;
let ptr = (*raw).servers;
slice::from_raw_parts(ptr, cnt)
.iter()
Expand All @@ -85,7 +85,7 @@ impl Monitoring {
};

let clients = {
let cnt = (*raw).clients_length as usize;
let cnt = (*raw).clients_length;
let ptr = (*raw).clients;
slice::from_raw_parts(ptr, cnt)
.iter()
Expand Down
6 changes: 6 additions & 0 deletions rustecal-service/src/types.rs
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,12 @@ pub struct ServiceId {
}

impl ServiceId {
/// Constructs a `ServiceId` from its FFI representation.
///
/// # Safety
/// - `raw` must refer to a valid, properly initialized `eCAL_SServiceId`.
/// - Any pointers inside `raw` must be non-null and correctly aligned.
/// - The memory behind `raw` must remain valid for the duration of this call.
pub unsafe fn from_ffi(raw: &eCAL_SServiceId) -> Self {
Self {
service_id: raw.service_id,
Expand Down
8 changes: 3 additions & 5 deletions rustecal/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,9 @@
//! use rustecal::{Ecal, TypedPublisher};
//! use rustecal_types_string::StringMessage;
//!
//! fn main() {
//! Ecal::initialize(Some("example node"), EcalComponents::DEFAULT, None).unwrap();
//! let pub_ = TypedPublisher::<StringMessage>::new("hello topic").unwrap();
//! pub_.send(&StringMessage{data: "Hello!".into()}, Timestamp::Auto);
//! }
//! Ecal::initialize(Some("example node"), EcalComponents::DEFAULT, None).unwrap();
//! let pub_ = TypedPublisher::<StringMessage>::new("hello topic").unwrap();
//! pub_.send(&StringMessage{data: "Hello!".into()}, Timestamp::Auto);
//! ```
//!

Expand Down