Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
A
actor-incubator
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
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-incubator
Commits
03bd502e
Commit
03bd502e
authored
Aug 30, 2019
by
Jakob Otto
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Add review feedback
parent
3e744f04
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
12 additions
and
9 deletions
+12
-9
libcaf_net/caf/net/fwd.hpp
libcaf_net/caf/net/fwd.hpp
+2
-0
libcaf_net/caf/net/stream_transport.hpp
libcaf_net/caf/net/stream_transport.hpp
+2
-1
libcaf_net/caf/net/transport_worker.hpp
libcaf_net/caf/net/transport_worker.hpp
+1
-1
libcaf_net/caf/net/write_packet_decorator.hpp
libcaf_net/caf/net/write_packet_decorator.hpp
+2
-2
libcaf_net/test/socket_guard.cpp
libcaf_net/test/socket_guard.cpp
+2
-0
libcaf_net/test/string_application.cpp
libcaf_net/test/string_application.cpp
+1
-3
libcaf_net/test/transport_worker.cpp
libcaf_net/test/transport_worker.cpp
+2
-2
No files found.
libcaf_net/caf/net/fwd.hpp
View file @
03bd502e
...
...
@@ -27,6 +27,8 @@ namespace net {
class
multiplexer
;
class
socket_manager
;
template
<
class
Application
,
class
IdType
>
class
transport_worker
;
struct
network_socket
;
struct
pipe_socket
;
...
...
libcaf_net/caf/net/stream_transport.hpp
View file @
03bd502e
...
...
@@ -65,7 +65,8 @@ public:
template
<
class
Parent
>
error
init
(
Parent
&
parent
)
{
worker_
.
init
(
parent
);
if
(
auto
err
=
worker_
.
init
(
parent
))
return
err
;
parent
.
mask_add
(
operation
::
read
);
return
none
;
}
...
...
libcaf_net/caf/net/transport_worker.hpp
View file @
03bd502e
...
...
@@ -29,7 +29,7 @@
namespace
caf
{
namespace
net
{
///
implements a worker for the udp_transport policy
///
Implements a worker for transport protocols.
template
<
class
Application
,
class
IdType
=
unit_t
>
class
transport_worker
{
public:
...
...
libcaf_net/caf/net/write_packet_decorator.hpp
View file @
03bd502e
...
...
@@ -54,8 +54,8 @@ public:
// -- member functions -------------------------------------------------------
template
<
class
Header
,
class
...
Ts
>
void
write_packet
(
const
Header
&
header
,
span
<
const
byte
>
payload
,
template
<
class
...
Ts
>
void
write_packet
(
span
<
const
byte
>
header
,
span
<
const
byte
>
payload
,
Ts
&&
...
xs
)
{
object_
.
write_packet
(
parent_
,
header
,
payload
,
std
::
forward
<
Ts
>
(
xs
)...);
}
...
...
libcaf_net/test/socket_guard.cpp
View file @
03bd502e
...
...
@@ -37,6 +37,8 @@ struct dummy_socket {
// nop
}
dummy_socket
(
const
dummy_socket
&
)
=
default
;
dummy_socket
&
operator
=
(
const
dummy_socket
&
other
)
{
id
=
other
.
id
;
closed
=
other
.
closed
;
...
...
libcaf_net/test/string_application.cpp
View file @
03bd502e
...
...
@@ -101,10 +101,8 @@ public:
void
write_message
(
Parent
&
parent
,
std
::
unique_ptr
<
net
::
endpoint_manager
::
message
>
msg
)
{
header_type
header
{
static_cast
<
uint32_t
>
(
msg
->
payload
.
size
())};
std
::
vector
<
byte
>
header_buf
(
sizeof
(
header_type
));
std
::
vector
<
byte
>
payload
(
msg
->
payload
.
begin
(),
msg
->
payload
.
end
());
memcpy
(
header_buf
.
data
(),
&
header
,
header_buf
.
size
());
parent
.
write_packet
(
make_span
(
header_buf
),
make_span
(
payload
));
parent
.
write_packet
(
as_bytes
(
make_span
(
&
header
,
1
)),
make_span
(
payload
));
}
static
expected
<
std
::
vector
<
byte
>>
serialize
(
actor_system
&
sys
,
...
...
libcaf_net/test/transport_worker.cpp
View file @
03bd502e
...
...
@@ -122,8 +122,8 @@ public:
// nop
}
template
<
class
Header
>
void
write_packet
(
Header
header
,
span
<
const
byte
>
payload
,
ip_endpoint
ep
)
{
void
write_packet
(
span
<
const
byte
>
header
,
span
<
const
byte
>
payload
,
ip_endpoint
ep
)
{
auto
&
buf
=
res_
->
packet_buffer
;
buf
.
insert
(
buf
.
begin
(),
header
.
begin
(),
header
.
end
());
buf
.
insert
(
buf
.
begin
(),
payload
.
begin
(),
payload
.
end
());
...
...
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