diff --git a/cpp/include/ucxx/component.h b/cpp/include/ucxx/component.h index 621725fc..5659876f 100644 --- a/cpp/include/ucxx/component.h +++ b/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 { protected: diff --git a/cpp/include/ucxx/context.h b/cpp/include/ucxx/context.h index 272f7eab..9f1c1890 100644 --- a/cpp/include/ucxx/context.h +++ b/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; diff --git a/cpp/include/ucxx/request_tag_multi.h b/cpp/include/ucxx/request_tag_multi.h index 991fca1b..4e9c3af8 100644 --- a/cpp/include/ucxx/request_tag_multi.h +++ b/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` 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. diff --git a/cpp/include/ucxx/worker.h b/cpp/include/ucxx/worker.h index 40916580..f6ad17cc 100644 --- a/cpp/include/ucxx/worker.h +++ b/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. */ diff --git a/cpp/python/include/ucxx/python/notifier.h b/cpp/python/include/ucxx/python/notifier.h index 76a5b6ac..5a49f422 100644 --- a/cpp/python/include/ucxx/python/notifier.h +++ b/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 { diff --git a/cpp/python/include/ucxx/python/python_future.h b/cpp/python/include/ucxx/python/python_future.h index 0d398d69..1ee94dce 100644 --- a/cpp/python/include/ucxx/python/python_future.h +++ b/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 { diff --git a/cpp/python/include/ucxx/python/worker.h b/cpp/python/include/ucxx/python/worker.h index 1c54bac9..a034bcc7 100644 --- a/cpp/python/include/ucxx/python/worker.h +++ b/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 { diff --git a/cpp/src/worker.cpp b/cpp/src/worker.cpp index ae9a1bbf..01ab34c1 100644 --- a/cpp/src/worker.cpp +++ b/cpp/src/worker.cpp @@ -555,7 +555,7 @@ std::shared_ptr 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); } diff --git a/python/distributed-ucxx/distributed_ucxx/tests/test_ucxx.py b/python/distributed-ucxx/distributed_ucxx/tests/test_ucxx.py index 16f7116a..1f820629 100644 --- a/python/distributed-ucxx/distributed_ucxx/tests/test_ucxx.py +++ b/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}" diff --git a/python/ucxx/_lib/tests/test_server_client.py b/python/ucxx/_lib/tests/test_server_client.py index c8df4e61..1092e476 100644 --- a/python/ucxx/_lib/tests/test_server_client.py +++ b/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] diff --git a/python/ucxx/_lib_async/continuous_ucx_progress.py b/python/ucxx/_lib_async/continuous_ucx_progress.py index 8c31fcd7..9763e222 100644 --- a/python/ucxx/_lib_async/continuous_ucx_progress.py +++ b/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. diff --git a/python/ucxx/_lib_async/endpoint.py b/python/ucxx/_lib_async/endpoint.py index 78952ca0..ba961596 100644 --- a/python/ucxx/_lib_async/endpoint.py +++ b/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 ---------- diff --git a/python/ucxx/benchmarks/asyncssh.py b/python/ucxx/benchmarks/asyncssh.py index 44d38a81..74ebb1a1 100644 --- a/python/ucxx/benchmarks/asyncssh.py +++ b/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):