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
4b9d37c1
Commit
4b9d37c1
authored
Oct 03, 2019
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'topic/basp-broker'
parents
1d73fb39
43424f3f
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
16 additions
and
0 deletions
+16
-0
libcaf_io/src/io/basp_broker.cpp
libcaf_io/src/io/basp_broker.cpp
+16
-0
No files found.
libcaf_io/src/io/basp_broker.cpp
View file @
4b9d37c1
...
...
@@ -253,6 +253,22 @@ behavior basp_broker::make_behavior() {
system
().
registry
().
put
(
whom
->
id
(),
whom
);
instance
.
add_published_actor
(
port
,
whom
,
std
::
move
(
sigs
));
},
// received from test code to set up two instances without doorman
[
=
](
publish_atom
,
scribe_ptr
&
ptr
,
uint16_t
port
,
const
strong_actor_ptr
&
whom
,
std
::
set
<
std
::
string
>&
sigs
)
{
CAF_LOG_TRACE
(
CAF_ARG
(
ptr
)
<<
CAF_ARG
(
port
)
<<
CAF_ARG
(
whom
)
<<
CAF_ARG
(
sigs
));
CAF_ASSERT
(
ptr
!=
nullptr
);
auto
hdl
=
ptr
->
hdl
();
add_scribe
(
std
::
move
(
ptr
));
if
(
whom
)
system
().
registry
().
put
(
whom
->
id
(),
whom
);
instance
.
add_published_actor
(
port
,
whom
,
std
::
move
(
sigs
));
set_context
(
hdl
);
instance
.
write_server_handshake
(
context
(),
get_buffer
(
hdl
),
port
);
flush
(
hdl
);
configure_read
(
hdl
,
receive_policy
::
exactly
(
basp
::
header_size
));
},
// received from middleman actor (delegated)
[
=
](
connect_atom
,
scribe_ptr
&
ptr
,
uint16_t
port
)
{
CAF_LOG_TRACE
(
CAF_ARG
(
ptr
)
<<
CAF_ARG
(
port
));
...
...
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