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
d70d3a51
Commit
d70d3a51
authored
Apr 07, 2023
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'topic/neverlord/clang-warnings'
parents
9e921a91
1c1de32a
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
11 additions
and
19 deletions
+11
-19
examples/remoting/distributed_calculator.cpp
examples/remoting/distributed_calculator.cpp
+1
-1
libcaf_core/caf/policy/select_any.hpp
libcaf_core/caf/policy/select_any.hpp
+2
-3
libcaf_core/caf/scheduled_actor.hpp
libcaf_core/caf/scheduled_actor.hpp
+6
-10
libcaf_core/src/config_option.cpp
libcaf_core/src/config_option.cpp
+0
-1
libcaf_io/caf/io/network/datagram_handler.hpp
libcaf_io/caf/io/network/datagram_handler.hpp
+1
-1
libcaf_openssl/test/openssl/authentication.cpp
libcaf_openssl/test/openssl/authentication.cpp
+1
-1
tools/caf-vec.cpp
tools/caf-vec.cpp
+0
-2
No files found.
examples/remoting/distributed_calculator.cpp
View file @
d70d3a51
...
@@ -257,7 +257,7 @@ void client_repl(actor_system& system, const config& cfg) {
...
@@ -257,7 +257,7 @@ void client_repl(actor_system& system, const config& cfg) {
cout
<<
R"(")"
<<
arg2
<<
R"(" > )"
cout
<<
R"(")"
<<
arg2
<<
R"(" > )"
<<
std
::
numeric_limits
<
uint16_t
>::
max
()
<<
endl
;
<<
std
::
numeric_limits
<
uint16_t
>::
max
()
<<
endl
;
else
else
anon_send
(
client
,
connect_atom_v
,
move
(
arg1
),
anon_send
(
client
,
connect_atom_v
,
std
::
move
(
arg1
),
static_cast
<
uint16_t
>
(
lport
));
static_cast
<
uint16_t
>
(
lport
));
}
else
{
}
else
{
auto
x
=
toint
(
arg0
);
auto
x
=
toint
(
arg0
);
...
...
libcaf_core/caf/policy/select_any.hpp
View file @
d70d3a51
...
@@ -26,9 +26,8 @@ struct select_any_factory<F, type_list<Ts...>> {
...
@@ -26,9 +26,8 @@ struct select_any_factory<F, type_list<Ts...>> {
template
<
class
Fun
>
template
<
class
Fun
>
static
auto
static
auto
make
(
std
::
shared_ptr
<
size_t
>
pending
,
disposable
timeouts
,
Fun
f
)
{
make
(
std
::
shared_ptr
<
size_t
>
pending
,
disposable
timeouts
,
Fun
f
)
{
using
std
::
move
;
return
[
pending
{
std
::
move
(
pending
)},
timeouts
{
std
::
move
(
timeouts
)},
return
[
pending
{
move
(
pending
)},
timeouts
{
move
(
timeouts
)},
f
{
std
::
move
(
f
)}](
Ts
...
xs
)
mutable
{
f
{
move
(
f
)}](
Ts
...
xs
)
mutable
{
CAF_LOG_TRACE
(
CAF_ARG2
(
"pending"
,
*
pending
));
CAF_LOG_TRACE
(
CAF_ARG2
(
"pending"
,
*
pending
));
if
(
*
pending
>
0
)
{
if
(
*
pending
>
0
)
{
timeouts
.
dispose
();
timeouts
.
dispose
();
...
...
libcaf_core/caf/scheduled_actor.hpp
View file @
d70d3a51
...
@@ -286,8 +286,8 @@ public:
...
@@ -286,8 +286,8 @@ public:
template
<
class
F
>
template
<
class
F
>
std
::
enable_if_t
<
std
::
is_invocable_r_v
<
skippable_result
,
F
,
message
&>>
std
::
enable_if_t
<
std
::
is_invocable_r_v
<
skippable_result
,
F
,
message
&>>
set_default_handler
(
F
fun
)
{
set_default_handler
(
F
fun
)
{
using
std
::
move
;
default_handler_
=
[
fn
{
std
::
move
(
fun
)}](
scheduled_actor
*
,
default_handler_
=
[
fn
{
move
(
fun
)}](
scheduled_actor
*
,
message
&
xs
)
mutable
{
message
&
xs
)
mutable
{
return
fn
(
xs
);
return
fn
(
xs
);
};
};
}
}
...
@@ -319,10 +319,8 @@ public:
...
@@ -319,10 +319,8 @@ public:
/// Sets a custom handler for down messages.
/// Sets a custom handler for down messages.
template
<
class
F
>
template
<
class
F
>
std
::
enable_if_t
<
std
::
is_invocable_v
<
F
,
down_msg
&>>
set_down_handler
(
F
fun
)
{
std
::
enable_if_t
<
std
::
is_invocable_v
<
F
,
down_msg
&>>
set_down_handler
(
F
fun
)
{
using
std
::
move
;
down_handler_
=
[
fn
{
std
::
move
(
fun
)}](
scheduled_actor
*
,
down_handler_
=
[
fn
{
move
(
fun
)}](
scheduled_actor
*
,
down_msg
&
x
)
mutable
{
down_msg
&
x
)
mutable
{
fn
(
x
);
};
fn
(
x
);
};
}
}
/// Sets a custom handler for node down messages.
/// Sets a custom handler for node down messages.
...
@@ -354,10 +352,8 @@ public:
...
@@ -354,10 +352,8 @@ public:
/// Sets a custom handler for exit messages.
/// Sets a custom handler for exit messages.
template
<
class
F
>
template
<
class
F
>
std
::
enable_if_t
<
std
::
is_invocable_v
<
F
,
exit_msg
&>>
set_exit_handler
(
F
fun
)
{
std
::
enable_if_t
<
std
::
is_invocable_v
<
F
,
exit_msg
&>>
set_exit_handler
(
F
fun
)
{
using
std
::
move
;
exit_handler_
=
[
fn
{
std
::
move
(
fun
)}](
scheduled_actor
*
,
exit_handler_
=
[
fn
{
move
(
fun
)}](
scheduled_actor
*
,
exit_msg
&
x
)
mutable
{
exit_msg
&
x
)
mutable
{
fn
(
x
);
};
fn
(
x
);
};
}
}
#ifdef CAF_ENABLE_EXCEPTIONS
#ifdef CAF_ENABLE_EXCEPTIONS
...
...
libcaf_core/src/config_option.cpp
View file @
d70d3a51
...
@@ -13,7 +13,6 @@
...
@@ -13,7 +13,6 @@
#include "caf/error.hpp"
#include "caf/error.hpp"
#include "caf/expected.hpp"
#include "caf/expected.hpp"
using
std
::
move
;
using
std
::
string
;
using
std
::
string
;
namespace
caf
{
namespace
caf
{
...
...
libcaf_io/caf/io/network/datagram_handler.hpp
View file @
d70d3a51
...
@@ -56,7 +56,7 @@ public:
...
@@ -56,7 +56,7 @@ public:
/// @warning Must not be modified outside the IO multiplexers event loop
/// @warning Must not be modified outside the IO multiplexers event loop
/// once the stream has been started.
/// once the stream has been started.
void
enqueue_datagram
(
datagram_handle
hdl
,
byte_buffer
buf
)
{
void
enqueue_datagram
(
datagram_handle
hdl
,
byte_buffer
buf
)
{
wr_offline_buf_
.
emplace_back
(
hdl
,
move
(
buf
));
wr_offline_buf_
.
emplace_back
(
hdl
,
std
::
move
(
buf
));
}
}
/// Returns the read buffer of this stream.
/// Returns the read buffer of this stream.
...
...
libcaf_openssl/test/openssl/authentication.cpp
View file @
d70d3a51
...
@@ -160,7 +160,7 @@ struct fixture {
...
@@ -160,7 +160,7 @@ struct fixture {
}
}
void
exec_loop
()
{
void
exec_loop
()
{
while
(
exec_one
(
client_side
)
|
exec_one
(
server_side
))
while
(
exec_one
(
client_side
)
|
|
exec_one
(
server_side
))
;
// nop
;
// nop
}
}
...
...
tools/caf-vec.cpp
View file @
d70d3a51
...
@@ -616,7 +616,6 @@ void second_pass(blocking_actor* self, const group& grp,
...
@@ -616,7 +616,6 @@ void second_pass(blocking_actor* self, const group& grp,
CAF_RAISE_ERROR
(
"logger ID not found"
);
CAF_RAISE_ERROR
(
"logger ID not found"
);
};
};
// additional state for second pass
// additional state for second pass
size_t
line
=
0
;
log_entry
plain_entry
;
log_entry
plain_entry
;
std
::
vector
<
se_event
>
in_flight_messages
;
std
::
vector
<
se_event
>
in_flight_messages
;
std
::
vector
<
se_event
>
in_flight_spawns
;
std
::
vector
<
se_event
>
in_flight_spawns
;
...
@@ -654,7 +653,6 @@ void second_pass(blocking_actor* self, const group& grp,
...
@@ -654,7 +653,6 @@ void second_pass(blocking_actor* self, const group& grp,
};
};
// second pass
// second pass
while
(
in
>>
plain_entry
)
{
while
(
in
>>
plain_entry
)
{
++
line
;
// increment local time
// increment local time
auto
&
st
=
state
(
plain_entry
.
id
);
auto
&
st
=
state
(
plain_entry
.
id
);
// do not produce log output for internal actors but still track messages
// do not produce log output for internal actors but still track messages
...
...
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