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
465cbea1
Commit
465cbea1
authored
Jul 17, 2014
by
Dominik Charousset
Browse files
Options
Browse Files
Download
Plain Diff
Merge pull request #147 from mavam/unstable
Cleanup migration from cppa to caf
parents
b26c3212
cff00163
Changes
10
Hide whitespace changes
Inline
Side-by-side
Showing
10 changed files
with
18 additions
and
27 deletions
+18
-27
CMakeLists.txt
CMakeLists.txt
+1
-0
caf/all.hpp
caf/all.hpp
+2
-2
caf/io/broker.hpp
caf/io/broker.hpp
+4
-4
caf/io/max_msg_size.hpp
caf/io/max_msg_size.hpp
+4
-4
caf/io/network.hpp
caf/io/network.hpp
+1
-1
caf/io/publish_local_groups.hpp
caf/io/publish_local_groups.hpp
+1
-1
caf/policy/nestable_invoke.hpp
caf/policy/nestable_invoke.hpp
+0
-8
src/max_msg_size.cpp
src/max_msg_size.cpp
+5
-5
unit_testing/test_remote_actor.cpp
unit_testing/test_remote_actor.cpp
+0
-1
unit_testing/test_typed_remote_actor.cpp
unit_testing/test_typed_remote_actor.cpp
+0
-1
No files found.
CMakeLists.txt
View file @
465cbea1
...
...
@@ -243,6 +243,7 @@ include_directories(${INCLUDE_DIRS})
# install includes
install
(
DIRECTORY caf/ DESTINATION include/caf FILES_MATCHING PATTERN
"*.hpp"
)
install
(
DIRECTORY cppa/ DESTINATION include/cppa FILES_MATCHING PATTERN
"*.hpp"
)
# process cmake_uninstall.cmake.in
configure_file
(
"
${
CMAKE_CURRENT_SOURCE_DIR
}
/cmake_uninstall.cmake.in"
...
...
caf/all.hpp
View file @
465cbea1
...
...
@@ -138,8 +138,8 @@
*
* Please read the <b>Manual</b> for an introduction to @p libcaf.
* It is available online as HTML at
* http://neverlord.github.com/
boost.actor
/manual/index.html or as PDF at
* http://neverlord.github.com/
boost.actor
/manual/manual.pdf
* http://neverlord.github.com/
libcaf
/manual/index.html or as PDF at
* http://neverlord.github.com/
libcaf
/manual/manual.pdf
*
* @section IntroHelloWorld Hello World Example
*
...
...
caf/io/broker.hpp
View file @
465cbea1
...
...
@@ -258,7 +258,7 @@ class broker : public extend<local_actor>::
}
void
configure_read
(
receive_policy
::
config
config
)
override
{
CAF_LOGM_TRACE
(
"
boost::actor_
io::broker::scribe"
,
""
);
CAF_LOGM_TRACE
(
"
caf::
io::broker::scribe"
,
""
);
m_stream
.
configure_read
(
config
);
if
(
!
m_launched
)
launch
();
}
...
...
@@ -272,18 +272,18 @@ class broker : public extend<local_actor>::
}
void
stop_reading
()
override
{
CAF_LOGM_TRACE
(
"
boost::actor_
io::broker::scribe"
,
""
);
CAF_LOGM_TRACE
(
"
caf::
io::broker::scribe"
,
""
);
m_stream
.
stop_reading
();
disconnect
();
}
void
flush
()
override
{
CAF_LOGM_TRACE
(
"
boost::actor_
io::broker::scribe"
,
""
);
CAF_LOGM_TRACE
(
"
caf::
io::broker::scribe"
,
""
);
m_stream
.
flush
(
this
);
}
void
launch
()
{
CAF_LOGM_TRACE
(
"
boost::actor_
io::broker::scribe"
,
""
);
CAF_LOGM_TRACE
(
"
caf::
io::broker::scribe"
,
""
);
CAF_REQUIRE
(
!
m_launched
);
m_launched
=
true
;
m_stream
.
start
(
this
);
...
...
caf/io/max_msg_size.hpp
View file @
465cbea1
...
...
@@ -21,8 +21,8 @@
#include <cstddef> // size_t
namespace
boost
{
namespace
actor_
io
{
namespace
caf
{
namespace
io
{
/**
* @brief Sets the maximum size of a message over network.
...
...
@@ -36,7 +36,7 @@ void max_msg_size(size_t size);
*/
size_t
max_msg_size
();
}
// namespace
actor_
io
}
// namespace
boost
}
// namespace io
}
// namespace
caf
#endif // CAF_IO_MAX_MSG_SIZE_HPP
caf/io/network.hpp
View file @
465cbea1
...
...
@@ -622,7 +622,7 @@ class stream : public event_handler {
}
void
stop_reading
()
{
CAF_LOGM_TRACE
(
"
boost::actor_
io::network::stream"
,
""
);
CAF_LOGM_TRACE
(
"
caf::
io::network::stream"
,
""
);
m_sock
.
close_read
();
backend
().
del
(
operation
::
read
,
m_sock
.
fd
(),
this
);
}
...
...
caf/io/publish_local_groups.hpp
View file @
465cbea1
...
...
@@ -33,6 +33,6 @@ namespace io {
void
publish_local_groups
(
uint16_t
port
,
const
char
*
addr
=
nullptr
);
}
// namespace io
}
// namespace
boost
}
// namespace
caf
#endif // CAF_IO_PUBLISH_LOCAL_GROUPS_HPP
caf/policy/nestable_invoke.hpp
View file @
465cbea1
...
...
@@ -31,14 +31,6 @@
#include "caf/policy/invoke_policy.hpp"
namespace
boost
{
namespace
actor
{
namespace
detail
{
class
receive_policy
;
}
}
}
namespace
caf
{
namespace
policy
{
...
...
src/max_msg_size.cpp
View file @
465cbea1
...
...
@@ -18,10 +18,10 @@
#include <atomic>
#include "
boost/actor_
io/max_msg_size.hpp"
#include "
caf/
io/max_msg_size.hpp"
namespace
boost
{
namespace
actor_
io
{
namespace
caf
{
namespace
io
{
namespace
{
std
::
atomic
<
size_t
>
default_max_msg_size
{
16
*
1024
*
1024
};
...
...
@@ -31,5 +31,5 @@ void max_msg_size(size_t size) { default_max_msg_size = size; }
size_t
max_msg_size
()
{
return
default_max_msg_size
;
}
}
// namespace
actor_
io
}
// namespace
boost
}
// namespace io
}
// namespace
caf
unit_testing/test_remote_actor.cpp
View file @
465cbea1
...
...
@@ -16,7 +16,6 @@
using
namespace
std
;
using
namespace
caf
;
using
namespace
boost
::
actor_io
;
namespace
{
...
...
unit_testing/test_typed_remote_actor.cpp
View file @
465cbea1
...
...
@@ -11,7 +11,6 @@
using
namespace
std
;
using
namespace
caf
;
using
namespace
boost
::
actor_io
;
struct
ping
{
int32_t
value
;
...
...
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