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
90ce18a1
Commit
90ce18a1
authored
Mar 18, 2020
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Fix documentation errors, use deprecated attribute
parent
a0d0ab45
Changes
6
Show whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
40 additions
and
46 deletions
+40
-46
CMakeLists.txt
CMakeLists.txt
+4
-0
libcaf_core/caf/actor_profiler.hpp
libcaf_core/caf/actor_profiler.hpp
+1
-1
libcaf_core/caf/attach_continuous_stream_source.hpp
libcaf_core/caf/attach_continuous_stream_source.hpp
+1
-4
libcaf_core/caf/attach_stream_source.hpp
libcaf_core/caf/attach_stream_source.hpp
+4
-7
libcaf_core/caf/local_actor.hpp
libcaf_core/caf/local_actor.hpp
+3
-3
libcaf_core/caf/scheduled_actor.hpp
libcaf_core/caf/scheduled_actor.hpp
+27
-31
No files found.
CMakeLists.txt
View file @
90ce18a1
...
...
@@ -322,6 +322,10 @@ if(CMAKE_CXX_COMPILER_ID MATCHES "Clang"
add_compile_options
(
"-ftemplate-depth=512"
"-ftemplate-backtrace-limit=0"
)
endif
()
# enable useful warnings by default
if
(
CMAKE_CXX_COMPILER_ID MATCHES
"Clang"
)
add_compile_options
(
-Wdocumentation
)
endif
()
# explicitly disable obnoxious GCC warnings
if
(
CMAKE_CXX_COMPILER_ID MATCHES
"GNU"
)
build_string
(
"EXTRA_FLAGS"
"-Wno-missing-field-initializers"
)
...
...
libcaf_core/caf/actor_profiler.hpp
View file @
90ce18a1
...
...
@@ -44,7 +44,7 @@ public:
=
0
;
/// Called before the actor system calls the destructor for `self`.
/// @param
ptr
Points to an actor that is about to get destroyed.
/// @param
self
Points to an actor that is about to get destroyed.
/// @thread-safe
virtual
void
remove_actor
(
const
local_actor
&
self
)
=
0
;
...
...
libcaf_core/caf/attach_continuous_stream_source.hpp
View file @
90ce18a1
...
...
@@ -33,10 +33,7 @@ namespace caf {
/// implementation with `Driver`. The returned manager is not connected to any
/// slot and thus not stored by the actor automatically.
/// @param self Points to the hosting actor.
/// @param init Function object for initializing the state of the source.
/// @param pull Generator function object for producing downstream messages.
/// @param done Predicate returning `true` when generator is done.
/// @param fin Cleanup handler.
/// @param xs Parameter pack for constructing the driver.
/// @returns The new `stream_manager`.
template
<
class
Driver
,
class
...
Ts
>
typename
Driver
::
source_ptr_type
...
...
libcaf_core/caf/attach_stream_source.hpp
View file @
90ce18a1
...
...
@@ -40,10 +40,7 @@ namespace caf {
/// manager with `Driver`.
/// @param self Points to the hosting actor.
/// @param xs User-defined arguments for the stream handshake.
/// @param init Function object for initializing the state of the source.
/// @param pull Function object for generating downstream messages.
/// @param done Predicate returning `true` when generator is done.
/// @param fin Optional cleanup handler.
/// @param ctor_args Parameter pack for constructing the driver.
/// @returns The allocated `stream_manager` and the output slot.
template
<
class
Driver
,
class
...
Ts
,
class
...
CtorArgs
>
make_source_result_t
<
typename
Driver
::
downstream_manager_type
,
Ts
...
>
...
...
@@ -104,10 +101,10 @@ template <class Init, class Pull, class Done, class Finalize = unit_t,
detail
::
enable_if_t
<!
is_actor_handle
<
Init
>::
value
&&
Trait
::
valid
,
make_source_result_t
<
DownstreamManager
>>
attach_stream_source
(
scheduled_actor
*
self
,
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
alize
=
{},
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
return
attach_stream_source
(
self
,
std
::
make_tuple
(),
init
,
pull
,
done
,
finalize
,
token
);
return
attach_stream_source
(
self
,
std
::
make_tuple
(),
init
,
pull
,
done
,
fin
,
token
);
}
/// Attaches a new stream source to `self` by creating a default stream source
...
...
libcaf_core/caf/local_actor.hpp
View file @
90ce18a1
...
...
@@ -167,13 +167,13 @@ public:
// -- sending asynchronous messages ------------------------------------------
/// Sends an exit message to `
dest
`.
/// Sends an exit message to `
whom
`.
void
send_exit
(
const
actor_addr
&
whom
,
error
reason
);
/// Sends an exit message to `
dest
`.
/// Sends an exit message to `
whom
`.
void
send_exit
(
const
strong_actor_ptr
&
whom
,
error
reason
);
/// Sends an exit message to `
dest
`.
/// Sends an exit message to `
whom
`.
template
<
class
ActorHandle
>
void
send_exit
(
const
ActorHandle
&
whom
,
error
reason
)
{
if
(
whom
)
...
...
libcaf_core/caf/scheduled_actor.hpp
View file @
90ce18a1
...
...
@@ -429,10 +429,10 @@ public:
// -- stream management ------------------------------------------------------
/// @deprecated Please use `attach_stream_source` instead.
template
<
class
Driver
,
class
...
Ts
,
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
>
make_source_result_t
<
typename
Driver
::
downstream_manager_type
,
Ts
...
>
[[
deprecated
(
"use attach_stream_source instead"
)]]
make_source_result_t
<
typename
Driver
::
downstream_manager_type
,
Ts
...
>
make_source
(
std
::
tuple
<
Ts
...
>
xs
,
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{})
{
using
detail
::
make_stream_source
;
...
...
@@ -442,12 +442,12 @@ public:
return
{
slot
,
std
::
move
(
mgr
)};
}
/// @deprecated Please use `attach_stream_source` instead.
template
<
class
...
Ts
,
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
broadcast_downstream_manager
<
typename
stream_source_trait_t
<
Pull
>
::
output
>>
make_source_result_t
<
DownstreamManager
,
Ts
...
>
[[
deprecated
(
"use attach_stream_source instead"
)]]
make_source_result_t
<
DownstreamManager
,
Ts
...
>
make_source
(
std
::
tuple
<
Ts
...
>
xs
,
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
=
{})
{
using
driver
=
detail
::
stream_source_driver_impl
<
DownstreamManager
,
Pull
,
...
...
@@ -456,23 +456,23 @@ public:
std
::
move
(
done
),
std
::
move
(
fin
));
}
/// @deprecated Please use `attach_stream_source` instead.
template
<
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
default_downstream_manager_t
<
Pull
>,
class
Trait
=
stream_source_trait_t
<
Pull
>>
detail
::
enable_if_t
<!
is_actor_handle
<
Init
>::
value
&&
Trait
::
valid
,
[[
deprecated
(
"use attach_stream_source instead"
)]]
detail
::
enable_if_t
<
!
is_actor_handle
<
Init
>::
value
&&
Trait
::
valid
,
make_source_result_t
<
DownstreamManager
>>
make_source
(
Init
init
,
Pull
pull
,
Done
done
,
Finalize
finalize
=
{},
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
return
make_source
(
std
::
make_tuple
(),
init
,
pull
,
done
,
finalize
,
token
);
}
/// @deprecated Please use `attach_stream_source` instead.
template
<
class
ActorHandle
,
class
...
Ts
,
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
default_downstream_manager_t
<
Pull
>,
class
Trait
=
stream_source_trait_t
<
Pull
>>
detail
::
enable_if_t
<
is_actor_handle
<
ActorHandle
>::
value
,
[[
deprecated
(
"use attach_stream_source instead"
)]]
detail
::
enable_if_t
<
is_actor_handle
<
ActorHandle
>::
value
,
make_source_result_t
<
DownstreamManager
>>
make_source
(
const
ActorHandle
&
dest
,
std
::
tuple
<
Ts
...
>
xs
,
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{},
...
...
@@ -486,12 +486,12 @@ public:
return
{
slot
,
std
::
move
(
mgr
)};
}
/// @deprecated Please use `attach_stream_source` instead.
template
<
class
ActorHandle
,
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
default_downstream_manager_t
<
Pull
>,
class
Trait
=
stream_source_trait_t
<
Pull
>>
detail
::
enable_if_t
<
is_actor_handle
<
ActorHandle
>::
value
&&
Trait
::
valid
,
[[
deprecated
(
"use attach_stream_source instead"
)]]
detail
::
enable_if_t
<
is_actor_handle
<
ActorHandle
>::
value
&&
Trait
::
valid
,
make_source_result_t
<
DownstreamManager
>>
make_source
(
const
ActorHandle
&
dest
,
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
...
...
@@ -499,10 +499,9 @@ public:
std
::
move
(
pull
),
std
::
move
(
done
),
std
::
move
(
fin
),
token
);
}
/// @deprecated Please use `attach_continuous_stream_source` instead.
template
<
class
Driver
,
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
>
typename
Driver
::
source_ptr_type
[[
deprecated
(
"use attach_continuous_stream_source instead"
)]]
auto
make_continuous_source
(
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{})
{
using
detail
::
make_stream_source
;
auto
mgr
=
make_stream_source
<
Driver
>
(
...
...
@@ -511,11 +510,10 @@ public:
return
mgr
;
}
/// @deprecated Please use `attach_continuous_stream_source` instead.
template
<
class
Init
,
class
Pull
,
class
Done
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
broadcast_downstream_manager
<
typename
stream_source_trait_t
<
Pull
>
::
output
>>
stream_source_ptr
<
DownstreamManager
>
[[
deprecated
(
"use attach_continuous_stream_source instead"
)]]
auto
make_continuous_source
(
Init
init
,
Pull
pull
,
Done
done
,
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
=
{})
{
using
driver
=
detail
::
stream_source_driver_impl
<
DownstreamManager
,
Pull
,
...
...
@@ -524,28 +522,27 @@ public:
std
::
move
(
done
),
std
::
move
(
fin
));
}
/// @deprecated Please use `attach_stream_sink` instead.
template
<
class
Driver
,
class
...
Ts
>
make_sink_result
<
typename
Driver
::
input_type
>
[[
deprecated
(
"use attach_stream_sink instead"
)]]
make_sink_result
<
typename
Driver
::
input_type
>
make_sink
(
const
stream
<
typename
Driver
::
input_type
>&
src
,
Ts
&&
...
xs
)
{
auto
mgr
=
detail
::
make_stream_sink
<
Driver
>
(
this
,
std
::
forward
<
Ts
>
(
xs
)...);
auto
slot
=
mgr
->
add_inbound_path
(
src
);
return
{
slot
,
std
::
move
(
mgr
)};
}
/// @deprecated Please use `attach_stream_sink` instead.
template
<
class
In
,
class
Init
,
class
Fun
,
class
Finalize
=
unit_t
,
class
Trait
=
stream_sink_trait_t
<
Fun
>
>
make_sink_result
<
In
>
[[
deprecated
(
"use attach_stream_sink instead"
)]]
make_sink_result
<
In
>
make_sink
(
const
stream
<
In
>&
in
,
Init
init
,
Fun
fun
,
Finalize
fin
=
{})
{
using
driver
=
detail
::
stream_sink_driver_impl
<
In
,
Fun
,
Finalize
>
;
return
make_sink
<
driver
>
(
in
,
std
::
move
(
init
),
std
::
move
(
fun
),
std
::
move
(
fin
));
}
/// @deprecated Please use `attach_stream_stage` instead.
template
<
class
Driver
,
class
In
,
class
...
Ts
,
class
...
Us
>
make_stage_result_t
<
In
,
typename
Driver
::
downstream_manager_type
,
Ts
...
>
[[
deprecated
(
"use attach_stream_stage instead"
)]]
make_stage_result_t
<
In
,
typename
Driver
::
downstream_manager_type
,
Ts
...
>
make_stage
(
const
stream
<
In
>&
src
,
std
::
tuple
<
Ts
...
>
xs
,
Us
&&
...
ys
)
{
using
detail
::
make_stream_stage
;
auto
mgr
=
make_stream_stage
<
Driver
>
(
this
,
std
::
forward
<
Us
>
(
ys
)...);
...
...
@@ -554,12 +551,12 @@ public:
return
{
in
,
out
,
std
::
move
(
mgr
)};
}
/// @deprecated Please use `attach_stream_stage` instead.
template
<
class
In
,
class
...
Ts
,
class
Init
,
class
Fun
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
default_downstream_manager_t
<
Fun
>,
class
Trait
=
stream_stage_trait_t
<
Fun
>>
make_stage_result_t
<
In
,
DownstreamManager
,
Ts
...
>
[[
deprecated
(
"use attach_stream_stage instead"
)]]
make_stage_result_t
<
In
,
DownstreamManager
,
Ts
...
>
make_stage
(
const
stream
<
In
>&
in
,
std
::
tuple
<
Ts
...
>
xs
,
Init
init
,
Fun
fun
,
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
CAF_IGNORE_UNUSED
(
token
);
...
...
@@ -584,30 +581,29 @@ public:
std
::
move
(
fun
),
std
::
move
(
fin
));
}
/// @deprecated Please use `attach_stream_stage` instead.
template
<
class
In
,
class
Init
,
class
Fun
,
class
Finalize
=
unit_t
,
class
DownstreamManager
=
default_downstream_manager_t
<
Fun
>,
class
Trait
=
stream_stage_trait_t
<
Fun
>>
make_stage_result_t
<
In
,
DownstreamManager
>
[[
deprecated
(
"use attach_stream_stage instead"
)]]
make_stage_result_t
<
In
,
DownstreamManager
>
make_stage
(
const
stream
<
In
>&
in
,
Init
init
,
Fun
fun
,
Finalize
fin
=
{},
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
return
make_stage
(
in
,
std
::
make_tuple
(),
std
::
move
(
init
),
std
::
move
(
fun
),
std
::
move
(
fin
),
token
);
}
/// @deprecated Please use `attach_continuous_stream_stage` instead.
template
<
class
Driver
,
class
...
Ts
>
typename
Driver
::
stage_ptr_type
make_continuous_stage
(
Ts
&&
...
xs
)
{
[[
deprecated
(
"use attach_continuous_stream_stage instead"
)]]
auto
make_continuous_stage
(
Ts
&&
...
xs
)
{
auto
ptr
=
detail
::
make_stream_stage
<
Driver
>
(
this
,
std
::
forward
<
Ts
>
(
xs
)...);
ptr
->
continuous
(
true
);
return
ptr
;
}
/// @deprecated Please use `attach_continuous_stream_stage` instead.
template
<
class
Init
,
class
Fun
,
class
Cleanup
,
class
DownstreamManager
=
default_downstream_manager_t
<
Fun
>,
class
Trait
=
stream_stage_trait_t
<
Fun
>>
stream_stage_ptr
<
typename
Trait
::
input
,
DownstreamManager
>
[[
deprecated
(
"use attach_continuous_stream_stage instead"
)]]
auto
make_continuous_stage
(
Init
init
,
Fun
fun
,
Cleanup
cleanup
,
policy
::
arg
<
DownstreamManager
>
token
=
{})
{
CAF_IGNORE_UNUSED
(
token
);
...
...
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