Commit 3ab68814 authored by Andris Mednis's avatar Andris Mednis

Fix spelling: occurred

parent ba3c32a8
...@@ -63,7 +63,7 @@ public: ...@@ -63,7 +63,7 @@ public:
std::set<std::string>& sigs) = 0; std::set<std::string>& sigs) = 0;
/// Called whenever a direct connection was closed or a /// Called whenever a direct connection was closed or a
/// node became unrechable for other reasons *before* /// node became unreachable for other reasons *before*
/// this node gets erased from the routing table. /// this node gets erased from the routing table.
/// @warning The implementing class must not modify the /// @warning The implementing class must not modify the
/// routing table from this callback. /// routing table from this callback.
...@@ -116,7 +116,7 @@ public: ...@@ -116,7 +116,7 @@ public:
instance(abstract_broker* parent, callee& lstnr); instance(abstract_broker* parent, callee& lstnr);
/// Handles received data and returns a config for receiving the /// Handles received data and returns a config for receiving the
/// next data or `none` if an error occured. /// next data or `none` if an error occurred.
connection_state handle(execution_unit* ctx, connection_state handle(execution_unit* ctx,
new_data_msg& dm, header& hdr, bool is_payload); new_data_msg& dm, header& hdr, bool is_payload);
......
...@@ -49,7 +49,7 @@ public: ...@@ -49,7 +49,7 @@ public:
/// Starts this acceptor, forwarding all incoming connections to /// Starts this acceptor, forwarding all incoming connections to
/// `manager`. The intrusive pointer will be released after the /// `manager`. The intrusive pointer will be released after the
/// acceptor has been closed or an IO error occured. /// acceptor has been closed or an IO error occurred.
void start(acceptor_manager* mgr); void start(acceptor_manager* mgr);
/// Activates the acceptor. /// Activates the acceptor.
......
...@@ -27,7 +27,7 @@ namespace caf::policy { ...@@ -27,7 +27,7 @@ namespace caf::policy {
struct tcp { struct tcp {
/// Reads up to `len` bytes from `fd,` writing the received data /// Reads up to `len` bytes from `fd,` writing the received data
/// to `buf`. Returns `true` as long as `fd` is readable and `false` /// to `buf`. Returns `true` as long as `fd` is readable and `false`
/// if the socket has been closed or an IO error occured. The number /// if the socket has been closed or an IO error occurred. The number
/// of read bytes is stored in `result` (can be 0). /// of read bytes is stored in `result` (can be 0).
static io::network::rw_state read_some(size_t& result, static io::network::rw_state read_some(size_t& result,
io::network::native_socket fd, io::network::native_socket fd,
...@@ -35,7 +35,7 @@ struct tcp { ...@@ -35,7 +35,7 @@ struct tcp {
/// Writes up to `len` bytes from `buf` to `fd`. /// Writes up to `len` bytes from `buf` to `fd`.
/// Returns `true` as long as `fd` is readable and `false` /// Returns `true` as long as `fd` is readable and `false`
/// if the socket has been closed or an IO error occured. The number /// if the socket has been closed or an IO error occurred. The number
/// of written bytes is stored in `result` (can be 0). /// of written bytes is stored in `result` (can be 0).
static io::network::rw_state write_some(size_t& result, static io::network::rw_state write_some(size_t& result,
io::network::native_socket fd, io::network::native_socket fd,
......
...@@ -570,7 +570,7 @@ void default_multiplexer::handle_socket_event(native_socket fd, int mask, ...@@ -570,7 +570,7 @@ void default_multiplexer::handle_socket_event(native_socket fd, int mask,
ptr->handle_event(operation::write); ptr->handle_event(operation::write);
} }
if (checkerror && ((mask & error_mask) != 0)) { if (checkerror && ((mask & error_mask) != 0)) {
CAF_LOG_DEBUG("error occured on socket:" CAF_LOG_DEBUG("error occurred on socket:"
<< CAF_ARG(fd) << CAF_ARG(last_socket_error()) << CAF_ARG(fd) << CAF_ARG(last_socket_error())
<< CAF_ARG(last_socket_error_as_string())); << CAF_ARG(last_socket_error_as_string()));
ptr->handle_event(operation::propagate_error); ptr->handle_event(operation::propagate_error);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment