Fix typos found by codespell

cpp/include/ucxx/component.h

@@ -12,7 +12,7 @@ namespace ucxx {
  * @brief A UCXX component class to prevent early destruction of parent object.
  *
  * A UCXX component class storing a pointer of its parent to prevent it from being
- * destroyed while child is stil alive.
+ * destroyed while child is still alive.
  */
 class Component : public std::enable_shared_from_this<Component> {
  protected:

cpp/include/ucxx/context.h

@@ -154,7 +154,7 @@ class Context : public Component {
    * 3. Start with `^` (disable all listed transports) and _NOT_ contain a field named
    *    either `cuda` or `cuda_copy`.
    *
-   * @return Whether CUDA support is availale.
+   * @return Whether CUDA support is available.
    */
   bool hasCudaSupport() const;
 

cpp/include/ucxx/request_tag_multi.h

@@ -83,7 +83,7 @@ class RequestTagMulti : public Request {
    * Construct multi-buffer tag receive request, registering the request to the
    * `std::shared_ptr<Endpoint>` parent so that it may be canceled if necessary. This
    * constructor is responsible for creating a Python future that can be later awaited
-   * in Python asynchronous code, which is indenpendent of the Python futures used by
+   * in Python asynchronous code, which is independent of the Python futures used by
    * the underlying `ucxx::RequestTag` object, which will be invisible to the user. Once
    * the initial setup is complete, `callback()` is called to initiate receiving by posting
    * the first request to receive a header.

cpp/include/ucxx/worker.h

@@ -97,7 +97,7 @@ class Worker : public Component {
    * @param[in] ep  the endpoint handle where receiving the message, the same handle that
    *                will later be used to reply to the message.
    * @param[in] createAmRecvRequestFunction function to create a new request if one is not
-   *                                        already availale in the pool.
+   *                                        already available in the pool.
    *
    * @returns Request to be subsequently checked for the completion state and data.
    */

cpp/python/include/ucxx/python/notifier.h

@@ -20,7 +20,7 @@ namespace python {
 /**
  * @brief Specialized Python implementation of a `ucxx::Notifier`.
  *
- * Specialized Python implemenation of a `ucxx::Notifier`, providing support for notifying
+ * Specialized Python implementation of a `ucxx::Notifier`, providing support for notifying
  * Python futures.
  */
 class Notifier : public ::ucxx::Notifier {

cpp/python/include/ucxx/python/python_future.h

@@ -22,7 +22,7 @@ namespace python {
 /**
  * @brief Specialized Python implementation of a `ucxx::Future`.
  *
- * Specialized Python implemenation of a `ucxx::Future`, where the future being handled is
+ * Specialized Python implementation of a `ucxx::Future`, where the future being handled is
  * an instance of `asyncio.Future`.
  */
 class Future : public ::ucxx::Future {

cpp/python/include/ucxx/python/worker.h

@@ -23,7 +23,7 @@ namespace python {
 /**
  * @brief Specialized Python implementation of a `ucxx::Worker`.
  *
- * Specialized Python implemenation of a `ucxx::Worker`, providing Python-specific
+ * Specialized Python implementation of a `ucxx::Worker`, providing Python-specific
  * functionality, such as notification of Python futures.
  */
 class Worker : public ::ucxx::Worker {

cpp/src/worker.cpp

@@ -555,7 +555,7 @@ std::shared_ptr<Listener> Worker::createListener(uint16_t port,
 void Worker::registerAmAllocator(ucs_memory_type_t memoryType, AmAllocatorType allocator)
 {
   if (_amData == nullptr)
-    throw std::runtime_error("Active Messages wasn not enabled during context creation");
+    throw std::runtime_error("Active Messages was not enabled during context creation");
   _amData->_allocators.insert_or_assign(memoryType, allocator);
 }
 

python/distributed-ucxx/distributed_ucxx/tests/test_ucxx.py

@@ -95,7 +95,7 @@ async def test_ucxx_specific(ucxx_loop):
     """
     # TODO:
     # 1. ensure exceptions in handle_comm fail the test
-    # 2. Use dict in read / write, put seralization there.
+    # 2. Use dict in read / write, put serialization there.
     # 3. Test peer_address
     # 4. Test cleanup
     address = f"ucxx://{HOST}:{0}"

python/ucxx/_lib/tests/test_server_client.py

@@ -38,7 +38,7 @@ def _echo_server(get_queue, put_queue, transfer_api, msg_size, progress_mode):
     """Server that send received message back to the client
 
     Notice, since it is illegal to call progress() in call-back functions,
-    we keep a reference to the listener's endpoint and execute tranfers
+    we keep a reference to the listener's endpoint and execute transfers
     outside of the callback function.
     """
     feature_flags = [ucx_api.Feature.WAKEUP]

python/ucxx/_lib_async/continuous_ucx_progress.py

@@ -9,7 +9,7 @@ class ProgressTask(object):
     def __init__(self, worker, event_loop):
         """Creates a task that keeps calling worker.progress()
 
-        Notice, class and created task is carefull not to hold a
+        Notice, class and created task is careful not to hold a
         reference to `worker` so that a danling progress task will
         not prevent `worker` to be garbage collected.
 

python/ucxx/_lib_async/endpoint.py

@@ -456,7 +456,7 @@ async def recv_obj(self, tag=None, allocator=bytearray):
         Data is received into a buffer allocated by `allocator`.
 
         The transfer includes an extra message containing the size of `obj`,
-        which increses the overhead slightly.
+        which increases the overhead slightly.
 
         Parameters
         ----------

python/ucxx/benchmarks/asyncssh.py

@@ -29,7 +29,7 @@ def connection_lost(self, exc):
                 logger.error(f"SSH session error: {exc}", file=sys.stderr)
             else:
                 logger.debug(
-                    f"SSH connection terminated succesfully {self.out_queue.empty()=}"
+                    f"SSH connection terminated successfully {self.out_queue.empty()=}"
                 )
 
     class SSHServerProc(SSHProc):