Commit 255967b6 authored by Matthias Vallentin's avatar Matthias Vallentin

Adjust a few boost references.

parent d8fc2abe
...@@ -138,8 +138,8 @@ ...@@ -138,8 +138,8 @@
* *
* Please read the <b>Manual</b> for an introduction to @p libcaf. * Please read the <b>Manual</b> for an introduction to @p libcaf.
* It is available online as HTML at * It is available online as HTML at
* http://neverlord.github.com/boost.actor/manual/index.html or as PDF at * http://neverlord.github.com/libcaf/manual/index.html or as PDF at
* http://neverlord.github.com/boost.actor/manual/manual.pdf * http://neverlord.github.com/libcaf/manual/manual.pdf
* *
* @section IntroHelloWorld Hello World Example * @section IntroHelloWorld Hello World Example
* *
......
...@@ -258,7 +258,7 @@ class broker : public extend<local_actor>:: ...@@ -258,7 +258,7 @@ class broker : public extend<local_actor>::
} }
void configure_read(receive_policy::config config) override { 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); m_stream.configure_read(config);
if (!m_launched) launch(); if (!m_launched) launch();
} }
...@@ -272,18 +272,18 @@ class broker : public extend<local_actor>:: ...@@ -272,18 +272,18 @@ class broker : public extend<local_actor>::
} }
void stop_reading() override { void stop_reading() override {
CAF_LOGM_TRACE("boost::actor_io::broker::scribe", ""); CAF_LOGM_TRACE("caf::io::broker::scribe", "");
m_stream.stop_reading(); m_stream.stop_reading();
disconnect(); disconnect();
} }
void flush() override { void flush() override {
CAF_LOGM_TRACE("boost::actor_io::broker::scribe", ""); CAF_LOGM_TRACE("caf::io::broker::scribe", "");
m_stream.flush(this); m_stream.flush(this);
} }
void launch() { void launch() {
CAF_LOGM_TRACE("boost::actor_io::broker::scribe", ""); CAF_LOGM_TRACE("caf::io::broker::scribe", "");
CAF_REQUIRE(!m_launched); CAF_REQUIRE(!m_launched);
m_launched = true; m_launched = true;
m_stream.start(this); m_stream.start(this);
......
...@@ -21,8 +21,8 @@ ...@@ -21,8 +21,8 @@
#include <cstddef> // size_t #include <cstddef> // size_t
namespace boost { namespace caf {
namespace actor_io { namespace io {
/** /**
* @brief Sets the maximum size of a message over network. * @brief Sets the maximum size of a message over network.
...@@ -36,7 +36,7 @@ void max_msg_size(size_t size); ...@@ -36,7 +36,7 @@ void max_msg_size(size_t size);
*/ */
size_t max_msg_size(); size_t max_msg_size();
} // namespace actor_io } // namespace io
} // namespace boost } // namespace caf
#endif // CAF_IO_MAX_MSG_SIZE_HPP #endif // CAF_IO_MAX_MSG_SIZE_HPP
...@@ -622,7 +622,7 @@ class stream : public event_handler { ...@@ -622,7 +622,7 @@ class stream : public event_handler {
} }
void stop_reading() { void stop_reading() {
CAF_LOGM_TRACE("boost::actor_io::network::stream", ""); CAF_LOGM_TRACE("caf::io::network::stream", "");
m_sock.close_read(); m_sock.close_read();
backend().del(operation::read, m_sock.fd(), this); backend().del(operation::read, m_sock.fd(), this);
} }
......
...@@ -33,6 +33,6 @@ namespace io { ...@@ -33,6 +33,6 @@ namespace io {
void publish_local_groups(uint16_t port, const char* addr = nullptr); void publish_local_groups(uint16_t port, const char* addr = nullptr);
} // namespace io } // namespace io
} // namespace boost } // namespace caf
#endif // CAF_IO_PUBLISH_LOCAL_GROUPS_HPP #endif // CAF_IO_PUBLISH_LOCAL_GROUPS_HPP
...@@ -31,14 +31,6 @@ ...@@ -31,14 +31,6 @@
#include "caf/policy/invoke_policy.hpp" #include "caf/policy/invoke_policy.hpp"
namespace boost {
namespace actor {
namespace detail {
class receive_policy;
}
}
}
namespace caf { namespace caf {
namespace policy { namespace policy {
......
...@@ -18,10 +18,10 @@ ...@@ -18,10 +18,10 @@
#include <atomic> #include <atomic>
#include "boost/actor_io/max_msg_size.hpp" #include "caf/io/max_msg_size.hpp"
namespace boost { namespace caf {
namespace actor_io { namespace io {
namespace { namespace {
std::atomic<size_t> default_max_msg_size{16 * 1024 * 1024}; 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; } ...@@ -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; } size_t max_msg_size() { return default_max_msg_size; }
} // namespace actor_io } // namespace io
} // namespace boost } // namespace caf
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment