Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
A
Actor Framework
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Operations
Operations
Metrics
Environments
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
cpp-libs
Actor Framework
Commits
d52371cf
Commit
d52371cf
authored
Oct 30, 2019
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fix formatting
parent
e371e74c
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
5 additions
and
10 deletions
+5
-10
libcaf_core/src/stream_manager.cpp
libcaf_core/src/stream_manager.cpp
+5
-10
No files found.
libcaf_core/src/stream_manager.cpp
View file @
d52371cf
...
...
@@ -37,10 +37,7 @@
namespace
caf
{
stream_manager
::
stream_manager
(
scheduled_actor
*
selfptr
,
stream_priority
prio
)
:
self_
(
selfptr
),
pending_handshakes_
(
0
),
priority_
(
prio
),
flags_
(
0
)
{
:
self_
(
selfptr
),
pending_handshakes_
(
0
),
priority_
(
prio
),
flags_
(
0
)
{
// nop
}
...
...
@@ -144,8 +141,9 @@ void stream_manager::shutdown() {
if
(
getf
(
is_shutting_down_flag
|
is_stopped_flag
))
return
;
flags_
=
is_shutting_down_flag
;
CAF_LOG_DEBUG
(
"emit shutdown messages on"
<<
inbound_paths_
.
size
()
<<
"inbound paths;"
<<
CAF_ARG2
(
"out.clean"
,
out
().
clean
())
CAF_LOG_DEBUG
(
"emit shutdown messages on"
<<
inbound_paths_
.
size
()
<<
"inbound paths;"
<<
CAF_ARG2
(
"out.clean"
,
out
().
clean
())
<<
CAF_ARG2
(
"out.paths"
,
out
().
num_paths
()));
for
(
auto
ipath
:
inbound_paths_
)
ipath
->
emit_regular_shutdown
(
self_
);
...
...
@@ -238,15 +236,12 @@ void stream_manager::remove_input_path(stream_slot slot, error reason,
}
inbound_path
*
stream_manager
::
get_inbound_path
(
stream_slot
x
)
const
noexcept
{
auto
pred
=
[
=
](
inbound_path
*
ptr
)
{
return
ptr
->
slots
.
receiver
==
x
;
};
auto
pred
=
[
=
](
inbound_path
*
ptr
)
{
return
ptr
->
slots
.
receiver
==
x
;
};
auto
e
=
inbound_paths_
.
end
();
auto
i
=
std
::
find_if
(
inbound_paths_
.
begin
(),
e
,
pred
);
return
i
!=
e
?
*
i
:
nullptr
;
}
bool
stream_manager
::
inbound_paths_idle
()
const
noexcept
{
auto
f
=
[](
inbound_path
*
x
)
{
return
x
->
up_to_date
()
&&
x
->
assigned_credit
>
0
;
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment