Fix typos to pass the CI. (#2177)

* Fix typos to pass the CI.

Signed-off-by: ChenYing Kuo <evshary@gmail.com>

* Fix the missing typos

Signed-off-by: ChenYing Kuo <evshary@gmail.com>

---------

Signed-off-by: ChenYing Kuo <evshary@gmail.com>

Author: evshary

_typos.toml

@@ -8,5 +8,7 @@ extend-exclude = [
 
 
 [default.extend-words]
-mis = "mis" # mismatch
-thr = "thr" # throughput
+Closee = "Closee" # Closee
+closee = "closee" # closee
+mis = "mis"       # mismatch
+thr = "thr"       # throughput

commons/zenoh-config/src/include.rs

@@ -165,7 +165,7 @@ where
         }
     }
 
-    // if external file was incluided, add it's content to values
+    // if external file was included, add it's content to values
     if let Some(mut include_values) = include_object {
         values.append(include_values.as_object_mut().unwrap());
     }

commons/zenoh-keyexpr/src/key_expr/format/mod.rs

@@ -21,7 +21,7 @@
 //! as the [`keformat`](https://docs.rs/zenoh/latest/zenoh/key_expr/format/macro.keformat.htmll) and [`kewrite`](https://docs.rs/zenoh/latest/zenoh/key_expr/format/macro.kewrite.html) macros will be able to tell you if you're attempting to set fields of the format that do not exist.
 //!
 //! ## The format syntax
-//! KE formats are defined following a syntax that extends the [`keyexpr`] syntax. In addition to existing chunk types, KE formmats support "specification" chunks.
+//! KE formats are defined following a syntax that extends the [`keyexpr`] syntax. In addition to existing chunk types, KE formats support "specification" chunks.
 //! These chunks must follow the one of the following syntaxes: `${id:pattern}`, `${id:pattern#default}`, `$#{id:pattern}#`, or `$#{id:pattern#default}#`, where:
 //! - `id` is the chunk identifier: it cannot contain the `:` character, and is used to name the chunk in accessors.
 //! - `pattern` must be a valid KE (and therefore cannot contain `#`) and defines the range of values that the chunk may adopt.
@@ -71,7 +71,7 @@ use support::{IterativeConstructor, Spec};
 /// as the [`keformat`](https://docs.rs/zenoh/latest/zenoh/key_expr/format/macro.keformat.html) and [`kewrite`](https://docs.rs/zenoh/latest/zenoh/macro.kewrite.html) macros will be able to tell you if you're attempting to set fields of the format that do not exist.
 ///
 /// ## The format syntax
-/// KE formats are defined following a syntax that extends the [`keyexpr`] syntax. In addition to existing chunk types, KE formmats support "specification" chunks.
+/// KE formats are defined following a syntax that extends the [`keyexpr`] syntax. In addition to existing chunk types, KE formats support "specification" chunks.
 /// These chunks must follow the one of the following syntaxes: `${id:pattern}`, `${id:pattern#default}`, `$#{id:pattern}#`, or `$#{id:pattern#default}#`, where:
 /// - `id` is the chunk identifier: it cannot contain the `:` character, and is used to name the chunk in accessors.
 /// - `pattern` must be a valid KE (and therefore cannot contain `#`) and defines the range of values that the chunk may adopt.

commons/zenoh-macros/src/lib.rs

@@ -140,7 +140,7 @@ impl AnnotableItem {
 #[proc_macro_attribute]
 /// Adds only piece of documentation about the item being unstable but no unstable attribute itself.
 /// This is useful when the whole crate is supposed to be used in unstable mode only, it makes sense
-/// to mention it in dcoumentation for the crate items, but not to add `#[cfg(feature = "unstable")]` to every item.
+/// to mention it in documentation for the crate items, but not to add `#[cfg(feature = "unstable")]` to every item.
 pub fn unstable_doc(_attr: TokenStream, tokens: TokenStream) -> TokenStream {
     let mut item = match parse_annotable_item!(tokens) {
         Ok(item) => item,

commons/zenoh-shm/src/header/chunk_header.rs

@@ -24,7 +24,7 @@ use crate::api::provider::chunk::ChunkDescriptor;
 #[derive(Debug)]
 pub struct ChunkHeaderType {
     /*
-    TODO: We don't really need 32 bits here, but access to 16-bit felds with 1 byte alignment is less performant on most of the platforms.
+    TODO: We don't really need 32 bits here, but access to 16-bit fields with 1 byte alignment is less performant on most of the platforms.
     We need to bench and select reasonable integer sizes here once we have an implementation to bench
     */
     pub refcount: AtomicU32,

io/zenoh-transport/src/common/seq_num.rs

@@ -35,7 +35,7 @@ pub(crate) fn get_mask(resolution: Bits) -> TransportSn {
 ///
 /// The [`SeqNum`][SeqNum] encapsulates the sequence numbers along with a
 /// the comparison operators that check whether two sequence numbers are
-/// less, equeal or greater of each other.
+/// less, equal or greater of each other.
 ///
 #[derive(Clone, Copy, Debug)]
 pub(crate) struct SeqNum {

zenoh-ext/examples/examples/README.md

@@ -19,7 +19,7 @@
 ### z_advanced_pub
 
    Declares an AdvancedPublisher with a given key expression.  
-   All the publications are locally cached (with a configurable history size - i.e. max number of cached data per resource, default 1). The cache can be queried by an AdvancedSubscriber for hsitory
+   All the publications are locally cached (with a configurable history size - i.e. max number of cached data per resource, default 1). The cache can be queried by an AdvancedSubscriber for history
    or retransmission.
 
    Typical usage:

zenoh-ext/src/querying_subscriber.rs

@@ -405,24 +405,24 @@ where
 // and are considered as older than any sample with Timestamp.
 struct MergeQueue {
     untimestamped: VecDeque<Sample>,
-    timstamped: BTreeMap<Timestamp, Sample>,
+    timestamped: BTreeMap<Timestamp, Sample>,
 }
 
 impl MergeQueue {
     fn new() -> Self {
         MergeQueue {
             untimestamped: VecDeque::new(),
-            timstamped: BTreeMap::new(),
+            timestamped: BTreeMap::new(),
         }
     }
 
     fn len(&self) -> usize {
-        self.untimestamped.len() + self.timstamped.len()
+        self.untimestamped.len() + self.timestamped.len()
     }
 
     fn push(&mut self, sample: Sample) {
         if let Some(ts) = sample.timestamp() {
-            self.timstamped.entry(*ts).or_insert(sample);
+            self.timestamped.entry(*ts).or_insert(sample);
         } else {
             self.untimestamped.push_back(sample);
         }
@@ -432,25 +432,25 @@ impl MergeQueue {
         let mut vec = VecDeque::new();
         let mut queue = BTreeMap::new();
         swap(&mut self.untimestamped, &mut vec);
-        swap(&mut self.timstamped, &mut queue);
+        swap(&mut self.timestamped, &mut queue);
         MergeQueueValues {
             untimestamped: vec,
-            timstamped: queue.into_values(),
+            timestamped: queue.into_values(),
         }
     }
 }
 
 struct MergeQueueValues {
     untimestamped: VecDeque<Sample>,
-    timstamped: btree_map::IntoValues<Timestamp, Sample>,
+    timestamped: btree_map::IntoValues<Timestamp, Sample>,
 }
 
 impl Iterator for MergeQueueValues {
     type Item = Sample;
     fn next(&mut self) -> Option<Self::Item> {
         self.untimestamped
             .pop_front()
-            .or_else(|| self.timstamped.next())
+            .or_else(|| self.timestamped.next())
     }
 }
 
@@ -864,7 +864,7 @@ impl<Handler> FetchingSubscriber<Handler> {
 
                     // ensure the sample has a timestamp, thus it will always be sorted into the MergeQueue
                     // after any timestamped Sample possibly coming from a fetch reply.
-                    let now = SystemTime::now().duration_since(UNIX_EPOCH).unwrap().into(); // UNIX_EPOCH is Returns a Timespec::zero(), Unwrap Should be permissable here
+                    let now = SystemTime::now().duration_since(UNIX_EPOCH).unwrap().into(); // UNIX_EPOCH is Returns a Timespec::zero(), Unwrap Should be permissible here
                     let timestamp = s
                         .timestamp()
                         .cloned()

zenoh-ext/src/subscriber_ext.rs

@@ -316,7 +316,7 @@ impl<'a, 'b, Handler> SubscriberBuilderExt<'a, 'b, Handler>
     /// through the callback function. Those samples will be merged with the received publications and made available in the receiver.
     /// Later on, new fetches can be performed again, calling [`FetchingSubscriber::fetch()`](super::FetchingSubscriber::fetch()).
     ///
-    /// A typical usage of the fetching liveliness subscriber is to retrieve existing liveliness tokens while susbcribing to
+    /// A typical usage of the fetching liveliness subscriber is to retrieve existing liveliness tokens while subscribing to
     /// new liveness changes.
     ///
     /// # Examples
@@ -375,7 +375,7 @@ impl<'a, 'b, Handler> SubscriberBuilderExt<'a, 'b, Handler>
     /// The results of the query will be merged with the received publications and made available in the receiver.
     /// Later on, new fetches can be performed again, calling [`FetchingSubscriber::fetch()`](super::FetchingSubscriber::fetch()).
     ///
-    /// A typical usage of the fetching liveliness subscriber is to retrieve existing liveliness tokens while susbcribing to
+    /// A typical usage of the fetching liveliness subscriber is to retrieve existing liveliness tokens while subscribing to
     /// new liveness changes.
     ///
     /// # Examples

zenoh/src/api/loader.rs

@@ -93,7 +93,7 @@ pub(crate) fn start_plugins(runtime: &Runtime) {
             Err(e) => {
                 let report = match std::panic::catch_unwind(std::panic::AssertUnwindSafe(|| e.to_string())) {
                         Ok(s) => s,
-                        Err(_) => panic!("Formatting the error from plugin {} ({:?}) failed, this is likely due to ABI unstability.\r\nMake sure your plugin was built with the same version of cargo as zenohd", plugin.name(), plugin.path()),
+                        Err(_) => panic!("Formatting the error from plugin {} ({:?}) failed, this is likely due to ABI instability.\r\nMake sure your plugin was built with the same version of cargo as zenohd", plugin.name(), plugin.path()),
                     };
                 if required {
                     panic!(