int ret = SendRequest(main_client_.get(), request);
if (ret != 0) return RPC_PORT_ERROR_IO_ERROR; // LCOV_EXCL_LINE
+ main_client_->SetNonblock();
if (sync) {
Response* response = nullptr;
ret = ReceiveResponse(main_client_.get(), &response);
return RPC_PORT_ERROR_PERMISSION_DENIED; // LCOV_EXCL_LINE
}
- main_client_->SetNonblock();
fds_[0] = main_client_->RemoveFd();
} else {
- main_client_->SetNonblock();
ret = main_client_->Watch();
if (ret != 0) return RPC_PORT_ERROR_IO_ERROR; // LCOV_EXCL_LINE
}
int ret = SendRequest(delegate_client_.get(), request);
if (ret != 0) return RPC_PORT_ERROR_IO_ERROR; // LCOV_EXCL_LINE
+ delegate_client_->SetNonblock();
if (sync) {
Response* response = nullptr;
ret = ReceiveResponse(delegate_client_.get(), &response);
return RPC_PORT_ERROR_PERMISSION_DENIED; // LCOV_EXCL_LINE
}
- delegate_client_->SetNonblock();
fds_[1] = delegate_client_->RemoveFd();
} else {
- delegate_client_->SetNonblock();
ret = delegate_client_->Watch();
if (ret != 0) return RPC_PORT_ERROR_IO_ERROR; // LCOV_EXCL_LINE
}