face: group parameters to createFace and connect into a common structure
Change-Id: Icb6857602ed7e897be6c5334b05be23793d133bb
diff --git a/daemon/face/tcp-channel.cpp b/daemon/face/tcp-channel.cpp
index 1dee521..b6f434d 100644
--- a/daemon/face/tcp-channel.cpp
+++ b/daemon/face/tcp-channel.cpp
@@ -69,9 +69,7 @@
void
TcpChannel::connect(const tcp::Endpoint& remoteEndpoint,
- ndn::nfd::FacePersistency persistency,
- bool wantLocalFields,
- bool wantLpReliability,
+ const FaceParams& params,
const FaceCreatedCallback& onFaceCreated,
const FaceCreationFailedCallback& onConnectFailed,
time::nanoseconds timeout)
@@ -91,17 +89,12 @@
clientSocket->async_connect(remoteEndpoint,
bind(&TcpChannel::handleConnect, this,
boost::asio::placeholders::error, remoteEndpoint, clientSocket,
- // Creating a parameters struct works around limit on number of
- // parameters to bind
- ConnectParams{persistency, wantLocalFields, wantLpReliability},
- timeoutEvent, onFaceCreated, onConnectFailed));
+ params, timeoutEvent, onFaceCreated, onConnectFailed));
}
void
TcpChannel::createFace(ip::tcp::socket&& socket,
- ndn::nfd::FacePersistency persistency,
- bool wantLocalFields,
- bool wantLpReliability,
+ const FaceParams& params,
const FaceCreatedCallback& onFaceCreated)
{
shared_ptr<Face> face;
@@ -110,12 +103,12 @@
auto it = m_channelFaces.find(remoteEndpoint);
if (it == m_channelFaces.end()) {
GenericLinkService::Options options;
- options.allowLocalFields = wantLocalFields;
- options.reliabilityOptions.isEnabled = wantLpReliability;
+ options.allowLocalFields = params.wantLocalFields;
+ options.reliabilityOptions.isEnabled = params.wantLpReliability;
options.allowCongestionMarking = m_wantCongestionMarking;
auto linkService = make_unique<GenericLinkService>(options);
- auto transport = make_unique<TcpTransport>(std::move(socket), persistency);
+ auto transport = make_unique<TcpTransport>(std::move(socket), params.persistency);
face = make_shared<Face>(std::move(linkService), std::move(transport));
m_channelFaces[remoteEndpoint] = face;
@@ -160,7 +153,10 @@
}
NFD_LOG_CHAN_TRACE("Incoming connection from " << m_socket.remote_endpoint());
- createFace(std::move(m_socket), ndn::nfd::FACE_PERSISTENCY_ON_DEMAND, false, false, onFaceCreated);
+
+ FaceParams params;
+ params.persistency = ndn::nfd::FACE_PERSISTENCY_ON_DEMAND;
+ createFace(std::move(m_socket), params, onFaceCreated);
// prepare accepting the next connection
accept(onFaceCreated, onAcceptFailed);
@@ -170,7 +166,7 @@
TcpChannel::handleConnect(const boost::system::error_code& error,
const tcp::Endpoint& remoteEndpoint,
const shared_ptr<ip::tcp::socket>& socket,
- TcpChannel::ConnectParams params,
+ const FaceParams& params,
const scheduler::EventId& connectTimeoutEvent,
const FaceCreatedCallback& onFaceCreated,
const FaceCreationFailedCallback& onConnectFailed)
@@ -195,8 +191,7 @@
}
NFD_LOG_CHAN_TRACE("Connected to " << socket->remote_endpoint());
- createFace(std::move(*socket), params.persistency, params.wantLocalFields,
- params.wantLpReliability, onFaceCreated);
+ createFace(std::move(*socket), params, onFaceCreated);
}
void