Commit bdcaba66 authored by Dominik Charousset's avatar Dominik Charousset

Add inbound_paths getter

parent 1664eb97
...@@ -36,6 +36,10 @@ namespace caf { ...@@ -36,6 +36,10 @@ namespace caf {
/// @relates stream_msg /// @relates stream_msg
class stream_manager : public ref_counted { class stream_manager : public ref_counted {
public: public:
// -- member types -----------------------------------------------------------
using inbound_paths_list = std::vector<inbound_path*>;
stream_manager(local_actor* selfptr, stream_manager(local_actor* selfptr,
stream_priority prio = stream_priority::normal); stream_priority prio = stream_priority::normal);
...@@ -158,8 +162,12 @@ public: ...@@ -158,8 +162,12 @@ public:
continuous_ = x; continuous_ = x;
} }
// -- inline functions ------------------------------------------------------- /// Returns the list of inbound paths.
inline const inbound_paths_list& inbound_paths() const {
return inbound_paths_;
}
/// Returns the parent actor.
inline local_actor* self() { inline local_actor* self() {
return self_; return self_;
} }
...@@ -197,7 +205,7 @@ protected: ...@@ -197,7 +205,7 @@ protected:
local_actor* self_; local_actor* self_;
/// Stores non-owning pointers to all input paths. /// Stores non-owning pointers to all input paths.
std::vector<inbound_path*> inbound_paths_; inbound_paths_list inbound_paths_;
/// Keeps track of pending handshakes. /// Keeps track of pending handshakes.
long pending_handshakes_; long pending_handshakes_;
......
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