return -1;
if (mock_) {
- (*fds)[0] = main_sock_pair.Detach(SocketPair::RECEIVER);
- (*fds)[1] = delegate_sock_pair.Detach(SocketPair::RECEIVER);
- int ret = DBusMock::GetInst().Send("TestApp", port_name, *fds);
+ int send_fds[2];
+ send_fds[0] = main_sock_pair.Detach(SocketPair::RECEIVER);
+ send_fds[1] = delegate_sock_pair.Detach(SocketPair::RECEIVER);
+ int ret = DBusMock::GetInst().Send("TestApp", port_name, send_fds);
if (ret < 0)
return ret;
- return main_sock_pair.Detach(SocketPair::SENDER);
+ (*fds)[0] = main_sock_pair.Detach(SocketPair::SENDER);
+ (*fds)[1] = delegate_sock_pair.Detach(SocketPair::SENDER);
+ return (*fds)[0];
}
if (fd_list.Add(main_sock_pair.Detach(SocketPair::RECEIVER)) != 0)
IEventListener* listener = proxy->listener_;
proxy->listener_ = nullptr;
proxy->main_port_.get()->SetSource(0);
- listener->OnDisconnected(proxy->target_appid_);
+ if (listener)
+ listener->OnDisconnected(proxy->target_appid_);
return FALSE;
}
}
void Proxy::ProxyPort::SetSource(int sourceId) {
- disconn_src_ = sourceId;
+ src_ = sourceId;
}
} // namespace internal