Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Comparing changes

Choose two branches to see what's changed or to start a new pull request. If you need to, you can also compare across forks.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also compare across forks.
base fork: actor-framework/actor-framework
...
head fork: actor-framework/actor-framework
Checking mergeability… Don't worry, you can still create the pull request.
  • 2 commits
  • 2 files changed
  • 0 commit comments
  • 1 contributor
Showing with 5 additions and 11 deletions.
  1. +3 −9 cppa/local_actor.hpp
  2. +2 −2 src/local_actor.cpp
View
12 cppa/local_actor.hpp
@@ -189,7 +189,7 @@ class local_actor : public extend<actor>::with<memory_cached> {
/**
* @brief Returns all joined groups of this actor.
*/
- std::vector<group_ptr> joined_groups();
+ std::vector<group_ptr> joined_groups() const;
/**
* @ingroup BlockingAPI
@@ -236,24 +236,18 @@ class local_actor : public extend<actor>::with<memory_cached> {
on_sync_failure(fun);
}
- /**
- * @brief Invokes the handler for synchronous timeouts.
- */
+ /** @cond PRIVATE */
+
inline void handle_sync_timeout() {
if (m_sync_timeout_handler) m_sync_timeout_handler();
else quit(exit_reason::unhandled_sync_timeout);
}
- /**
- * @brief Invokes the handler for unexpected synchronous response messages.
- */
inline void handle_sync_failure() {
if (m_sync_failure_handler) m_sync_failure_handler();
else quit(exit_reason::unhandled_sync_failure);
}
- /** @cond PRIVATE */
-
virtual void dequeue(behavior& bhvr) = 0;
inline void dequeue(behavior&& bhvr);
View
4 src/local_actor.cpp
@@ -98,7 +98,7 @@ void local_actor::leave(const group_ptr& what) {
if (what) m_subscriptions.erase(what);
}
-std::vector<group_ptr> local_actor::joined_groups() {
+std::vector<group_ptr> local_actor::joined_groups() const {
std::vector<group_ptr> result;
for (auto& kvp : m_subscriptions) {
result.emplace_back(kvp.first);
@@ -146,7 +146,7 @@ void local_actor::forward_message(const actor_ptr& new_receiver) {
response_handle local_actor::make_response_handle() {
auto n = m_current_node;
- response_handle result(this, n->sender, n->mid.response_id());
+ response_handle result{this, n->sender, n->mid.response_id()};
n->mid.mark_as_answered();
return std::move(result);
}

No commit comments for this range

Something went wrong with that request. Please try again.