native_socket_stream.cpp

Go to the documentation of this file.

/* Flow-IPC: Core
 * Copyright 2023 Akamai Technologies, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in
 * compliance with the License.  You may obtain a copy
 * of the License at
 *
 *   https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in
 * writing, software distributed under the License is
 * distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 * CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing
 * permissions and limitations under the License. */
 
/// @file
 
#include "ipc/transport/native_socket_stream.hpp"
#include "ipc/transport/sync_io/native_socket_stream.hpp"
#include <boost/move/make_unique.hpp>
#include <ostream>
#include <string>
#include <utility>
 
namespace ipc::transport
{
 
// Initializers.
 
const Shared_name& Native_socket_stream::S_RESOURCE_TYPE_ID = Sync_io_obj::S_RESOURCE_TYPE_ID;
 
// Implementations.
 
Native_socket_stream::Native_socket_stream(Native_socket_stream&&) = default; // Nice and performant: ptr exchange.
Native_socket_stream& Native_socket_stream::operator=(Native_socket_stream&&) = default; // Ditto.
 
Native_socket_stream::Impl_ptr& Native_socket_stream::impl() const
{
  return m_impl ? m_impl
                : (m_impl = boost::movelib::make_unique<Impl>(nullptr, ""));
}
 
Native_socket_stream::Native_socket_stream() :
  Native_socket_stream(nullptr, "")
{
  // Yay.
}
 
// The rest is forwarding to impl() (essentially m_impl) a-la pImpl.
 
Native_socket_stream::Native_socket_stream(flow::log::Logger* logger_ptr, util::String_view nickname_str) :
  m_impl(boost::movelib::make_unique<Impl>(logger_ptr, nickname_str))
{
  // Yay.
}
 
Native_socket_stream::Native_socket_stream(flow::log::Logger* logger_ptr, util::String_view nickname_str,
                                           Native_handle&& native_peer_socket_moved) :
  m_impl(boost::movelib::make_unique<Impl>(logger_ptr, nickname_str, std::move(native_peer_socket_moved)))
{
  // Yay.
}
 
Native_socket_stream::Native_socket_stream(Sync_io_obj&& sync_io_core_in_peer_state_moved) :
  m_impl(boost::movelib::make_unique<Impl>(std::move(sync_io_core_in_peer_state_moved)))
{
  // Yay.
}
 
Native_socket_stream::~Native_socket_stream() = default; // It's only explicitly defined to formally document it.
 
const std::string& Native_socket_stream::nickname() const
{
  return impl()->nickname();
}
 
bool Native_socket_stream::sync_connect(const Shared_name& absolute_name, Error_code* err_code)
{
  return impl()->sync_connect(absolute_name, err_code);
}
 
const util::Process_credentials& Native_socket_stream::remote_peer_process_credentials(Error_code* err_code) const
{
  return impl()->remote_peer_process_credentials(err_code);
}
 
bool Native_socket_stream::remote_peer_process_credentials(const util::Process_credentials& creds)
{
  return impl()->remote_peer_process_credentials(creds);
}
 
size_t Native_socket_stream::send_meta_blob_max_size() const
{
  return impl()->send_meta_blob_max_size();
}
 
size_t Native_socket_stream::send_blob_max_size() const
{
  return impl()->send_blob_max_size();
}
 
bool Native_socket_stream::send_native_handle(Native_handle hndl_or_null, const util::Blob_const& meta_blob,
                                              Error_code* err_code)
{
  return impl()->send_native_handle(hndl_or_null, meta_blob, err_code);
}
 
bool Native_socket_stream::send_blob(const util::Blob_const& blob, Error_code* err_code)
{
  return impl()->send_blob(blob, err_code);
}
 
bool Native_socket_stream::end_sending()
{
  return impl()->end_sending();
}
 
bool Native_socket_stream::auto_ping(util::Fine_duration period)
{
  return impl()->auto_ping(period);
}
 
stat::Blob_snd_stats Native_socket_stream::blob_send_stats() const
{
  return impl()->blob_send_stats();
}
 
void Native_socket_stream::blob_send_stats_reset()
{
  impl()->blob_send_stats_reset();
}
 
stat::Blob_snd_stats Native_socket_stream::native_handle_send_stats() const
{
  return impl()->native_handle_send_stats();
}
 
void Native_socket_stream::native_handle_send_stats_reset()
{
  impl()->native_handle_send_stats_reset();
}
 
size_t Native_socket_stream::receive_meta_blob_max_size() const
{
  return impl()->receive_meta_blob_max_size();
}
 
size_t Native_socket_stream::receive_blob_max_size() const
{
  return impl()->receive_blob_max_size();
}
 
bool Native_socket_stream::idle_timer_run(util::Fine_duration timeout)
{
  return impl()->idle_timer_run(timeout);
}
 
stat::Blob_rcv_stats Native_socket_stream::blob_receive_stats() const
{
  return impl()->blob_receive_stats();
}
 
void Native_socket_stream::blob_receive_stats_reset()
{
  impl()->blob_receive_stats_reset();
}
 
stat::Blob_rcv_stats Native_socket_stream::native_handle_receive_stats() const
{
  return impl()->native_handle_receive_stats();
}
 
void Native_socket_stream::native_handle_receive_stats_reset()
{
  impl()->native_handle_receive_stats_reset();
}
 
// `friend`ship needed for this "non-method method":
 
std::ostream& operator<<(std::ostream& os, const Native_socket_stream& val)
{
  return os << *(val.impl());
}
 
} // namespace ipc::transport