main_port_.reset(new ProxyPort(this, fds_[0], target_appid_, false));
delegate_port_.reset(new ProxyPort(this, fds_[1], target_appid_));
- listener_->OnConnected(target_appid_, main_port_.get());
DebugPort::GetInst()->AddSession(port_name, target_appid_, fds_[0], fds_[1]);
+ listener_->OnConnected(target_appid_, main_port_.get());
return RPC_PORT_ERROR_NONE;
}
proxy->fds_[1] = client_fd;
proxy->delegate_port_.reset(
new ProxyPort(proxy, proxy->fds_[1], proxy->target_appid_));
- listener->OnConnected(proxy->target_appid_, proxy->main_port_.get());
DebugPort::GetInst()->AddSession(proxy->port_name_, proxy->target_appid_,
proxy->fds_[0], proxy->fds_[1]);
+ listener->OnConnected(proxy->target_appid_, proxy->main_port_.get());
_W("target_appid(%s), port_name(%s), main_fd(%d), delegate_fd(%d)",
proxy->target_appid_.c_str(), proxy->port_name_.c_str(),
proxy->fds_[0], proxy->fds_[1]);
_W("sender_appid(%s), instance(%s), main_fd(%d), delegate_fd(%d)",
sender_appid.c_str(), instance.c_str(), main_fd, fd);
- listener_->OnConnected(sender_appid, instance);
DebugPort::GetInst()->AddSession(port_name_, sender_appid, main_fd, fd);
+ listener_->OnConnected(sender_appid, instance);
}
std::recursive_mutex& Stub::GetMutex() const {