fix typos

Part-of: <https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs/-/merge_requests/1170>

10 files changed, 15 insertions, 15 deletions

diff --git a/generic/sodium/src/decrypter/imp.rs b/generic/sodium/src/decrypter/imp.rs
index 6486f6d05..f722314ed 100644
--- a/generic/sodium/src/decrypter/imp.rs
+++ b/generic/sodium/src/decrypter/imp.rs
@@ -486,7 +486,7 @@ impl Decrypter {
         let block_size = {
             let mut mutex_state = self.state.lock().unwrap();
             // This will only be run after READY state,
-            // and will be guaranted to be initialized
+            // and will be guaranteed to be initialized
             let state = mutex_state.as_mut().unwrap();
             // Cleanup the adapter
             state.adapter.clear();
@@ -508,7 +508,7 @@ impl Decrypter {
 
         let mut state = self.state.lock().unwrap();
         // This will only be run after READY state,
-        // and will be guaranted to be initialized
+        // and will be guaranteed to be initialized
         let state = state.as_mut().unwrap();
 
         state.decrypt_into_adapter(self, &self.srcpad, &pulled_buffer, chunk_index)?;
diff --git a/generic/sodium/src/encrypter/imp.rs b/generic/sodium/src/encrypter/imp.rs
index f5f72db85..af99edde6 100644
--- a/generic/sodium/src/encrypter/imp.rs
+++ b/generic/sodium/src/encrypter/imp.rs
@@ -98,7 +98,7 @@ impl State {
             })?;
 
         // This env variable is only meant to bypass nonce regeneration during
-        // tests to get determinisic results. It should never be used outside
+        // tests to get deterministic results. It should never be used outside
         // of testing environments.
         let nonce = if let Ok(val) = std::env::var("GST_SODIUM_ENCRYPT_NONCE") {
             let bytes = hex::decode(val).expect("Failed to decode hex variable");
@@ -216,7 +216,7 @@ impl Encrypter {
                 let mut state_mutex = self.state.lock().unwrap();
                 let mut buffers = BufferVec::new();
                 // This will only be run after READY state,
-                // and will be guaranted to be initialized
+                // and will be guaranteed to be initialized
                 let state = state_mutex.as_mut().unwrap();
 
                 // Now that all the full size blocks are pushed, drain the
diff --git a/generic/threadshare/src/jitterbuffer/imp.rs b/generic/threadshare/src/jitterbuffer/imp.rs
index 289739bcc..881d68444 100644
--- a/generic/threadshare/src/jitterbuffer/imp.rs
+++ b/generic/threadshare/src/jitterbuffer/imp.rs
@@ -1057,7 +1057,7 @@ impl TaskImpl for JitterBufferTask {
     // It should also be possible to store latency and context_wait as
     // fields of JitterBufferTask so as to avoid locking the settings.
     // If latency can change during processing, a command based mechanism
-    // could be implemented. See the command implemention for ts-udpsink as
+    // could be implemented. See the command implementation for ts-udpsink as
     // an example.
     fn try_next(&mut self) -> BoxFuture<'_, Result<(), gst::FlowError>> {
         async move {
diff --git a/generic/threadshare/src/jitterbuffer/rtpjitterbuffer.c b/generic/threadshare/src/jitterbuffer/rtpjitterbuffer.c
index 35d258dd7..a3072285c 100644
--- a/generic/threadshare/src/jitterbuffer/rtpjitterbuffer.c
+++ b/generic/threadshare/src/jitterbuffer/rtpjitterbuffer.c
@@ -519,7 +519,7 @@ update_buffer_level (TsRTPJitterBuffer * jbuf, gint * percent)
  *    Cri    : The time of the clock at the receiver for packet i
  *    D + ni : The jitter when receiving packet i
  *
- * We see that the network delay is irrelevant here as we can elliminate D:
+ * We see that the network delay is irrelevant here as we can eliminate D:
  *
  *  recv_diff(i) = (Cri + ni) - (Cr0 + n0))
  *
diff --git a/generic/threadshare/src/queue/imp.rs b/generic/threadshare/src/queue/imp.rs
index 683066bcc..71cc631da 100644
--- a/generic/threadshare/src/queue/imp.rs
+++ b/generic/threadshare/src/queue/imp.rs
@@ -406,7 +406,7 @@ static CAT: Lazy<gst::DebugCategory> = Lazy::new(|| {
 });
 
 impl Queue {
-    /* Try transfering all the items from the pending queue to the DataQueue, then
+    /* Try transferring all the items from the pending queue to the DataQueue, then
      * the current item. Errors out if the DataQueue was full, or the pending queue
      * is already scheduled, in which case the current item should be added to the
      * pending queue */
diff --git a/generic/threadshare/src/runtime/executor/async_wrapper.rs b/generic/threadshare/src/runtime/executor/async_wrapper.rs
index 7da220010..f0e235f1a 100644
--- a/generic/threadshare/src/runtime/executor/async_wrapper.rs
+++ b/generic/threadshare/src/runtime/executor/async_wrapper.rs
@@ -649,7 +649,7 @@ impl Async<UdpSocket> {
 
     /// Sends data to the specified address.
     ///
-    /// Returns the number of bytes writen.
+    /// Returns the number of bytes written.
     pub async fn send_to<A: Into<SocketAddr>>(&self, buf: &[u8], addr: A) -> io::Result<usize> {
         let addr = addr.into();
         self.write_with(|io| io.send_to(buf, addr)).await
diff --git a/generic/threadshare/src/runtime/executor/context.rs b/generic/threadshare/src/runtime/executor/context.rs
index 8f4321514..c2fbb79d3 100644
--- a/generic/threadshare/src/runtime/executor/context.rs
+++ b/generic/threadshare/src/runtime/executor/context.rs
@@ -215,7 +215,7 @@ impl Context {
 
     /// Executes the provided function relatively to this [`Context`].
     ///
-    /// Usefull to initialze i/o sources and timers from outside
+    /// Usefull to initialize i/o sources and timers from outside
     /// of a [`Context`].
     ///
     /// # Panic
@@ -511,7 +511,7 @@ mod tests {
         });
 
         // Panic: task has failed
-        // (enforced by `async-task`, see comment in `Future` impl for `JoinHanlde`).
+        // (enforced by `async-task`, see comment in `Future` impl for `JoinHandle`).
         futures::executor::block_on(join_handle).unwrap_err();
     }
 
diff --git a/generic/threadshare/src/runtime/executor/scheduler.rs b/generic/threadshare/src/runtime/executor/scheduler.rs
index 8552a5201..a63830a13 100644
--- a/generic/threadshare/src/runtime/executor/scheduler.rs
+++ b/generic/threadshare/src/runtime/executor/scheduler.rs
@@ -394,7 +394,7 @@ impl Handle {
 
     /// Executes the provided function relatively to this [`Scheduler`]'s [`Reactor`].
     ///
-    /// Usefull to initialze i/o sources and timers from outside
+    /// Usefull to initialize i/o sources and timers from outside
     /// of a [`Scheduler`].
     ///
     /// # Panic
diff --git a/generic/threadshare/src/runtime/task.rs b/generic/threadshare/src/runtime/task.rs
index 0ac007746..bd1e9a863 100644
--- a/generic/threadshare/src/runtime/task.rs
+++ b/generic/threadshare/src/runtime/task.rs
@@ -373,7 +373,7 @@ pub trait TaskImpl: Send + 'static {
         future::ok(()).boxed()
     }
 
-    /// Handles an error occuring during the execution of the `Task` loop.
+    /// Handles an error occurring during the execution of the `Task` loop.
     ///
     /// This include errors returned by [`Self::try_next`] & [`Self::handle_item`].
     ///
@@ -410,7 +410,7 @@ pub trait TaskImpl: Send + 'static {
         .boxed()
     }
 
-    /// Handles an error occuring during the execution of a transition action.
+    /// Handles an error occurring during the execution of a transition action.
     ///
     /// This handler also catches errors returned by subtasks spawned by the transition action.
     ///
diff --git a/generic/threadshare/tests/pad.rs b/generic/threadshare/tests/pad.rs
index f6ab0bccd..3f9500228 100644
--- a/generic/threadshare/tests/pad.rs
+++ b/generic/threadshare/tests/pad.rs
@@ -505,7 +505,7 @@ mod imp_sink {
     impl ElementSinkTest {
         async fn forward_item(&self, item: Item) -> Result<gst::FlowSuccess, gst::FlowError> {
             if !self.flushing.load(Ordering::SeqCst) {
-                gst::debug!(SINK_CAT, imp: self, "Fowarding {:?}", item);
+                gst::debug!(SINK_CAT, imp: self, "Forwarding {:?}", item);
                 let mut sender = self
                     .sender
                     .lock()
@@ -522,7 +522,7 @@ mod imp_sink {
                 gst::debug!(
                     SINK_CAT,
                     imp: self,
-                    "Not fowarding {:?} due to flushing",
+                    "Not forwarding {:?} due to flushing",
                     item
                 );
                 Err(gst::FlowError::Flushing)