Skip to content

Commit

Permalink
Refactor of regenerate_port. (#3640)
Browse files Browse the repository at this point in the history
Signed-off-by: Miguel Company <MiguelCompany@eprosima.com>
Co-authored-by: Miguel Company <MiguelCompany@eprosima.com>
  • Loading branch information
jsan-rt and MiguelCompany committed Jul 11, 2023
1 parent 3513d0d commit e8fb3ec
Showing 1 changed file with 7 additions and 10 deletions.
17 changes: 7 additions & 10 deletions src/cpp/rtps/transport/shared_mem/SharedMemManager.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -784,10 +784,9 @@ class SharedMemManager :

void regenerate_port()
{
auto new_port = shared_mem_manager_->regenerate_port(global_port_, global_port_->open_mode());

auto new_listener = new_port->create_listener();

auto new_port = global_port_;
shared_mem_manager_->regenerate_port(new_port, new_port->open_mode());
auto new_listener = std::make_shared<Listener>(shared_mem_manager_, new_port);
*this = std::move(*new_listener);
}

Expand Down Expand Up @@ -931,9 +930,7 @@ class SharedMemManager :
void regenerate_port()
{
recover_blocked_processing();
auto new_port = shared_mem_manager_->regenerate_port(global_port_, open_mode_);

*this = std::move(*new_port);
shared_mem_manager_->regenerate_port(global_port_, open_mode_);
}

SharedMemManager* shared_mem_manager_;
Expand Down Expand Up @@ -1017,11 +1014,11 @@ class SharedMemManager :

private:

std::shared_ptr<Port> regenerate_port(
std::shared_ptr<SharedMemGlobal::Port> port,
void regenerate_port(
std::shared_ptr<SharedMemGlobal::Port>& port,
SharedMemGlobal::Port::OpenMode open_mode)
{
return std::make_shared<Port>(this, global_segment_.regenerate_port(port, open_mode), open_mode);
port = global_segment_.regenerate_port(port, open_mode);
}

/**
Expand Down

0 comments on commit e8fb3ec

Please sign in to comment.