build: Remove unnecessary std::ref, causing compilation issues with Boost 1.70.0
Refs: #4923 Change-Id: Idba1abe89161b11b1ec80fdceac51e2b00ed507b
This commit is contained in:
1 parent
b31206e87e
commit
a6bd7da559
8 files changed
+15
-9
No files matched your search
+1
-1
@@ -1,3 +1,3 @@
|
|||||||
[submodule "websocketpp"]
|
[submodule "websocketpp"]
|
||||||
path = websocketpp
|
path = websocketpp
|
||||||
url = https://github.com/zaphoyd/websocketpp.git
|
url = https://github.com/cawka/websocketpp.git
|
||||||
@@ -65,7 +65,7 @@ def checkWebsocket(self, **kw):
|
|||||||
Logs.warn(' git submodule update --init')
|
Logs.warn(' git submodule update --init')
|
||||||
Logs.warn('Otherwise, manually download and extract the websocketpp library:')
|
Logs.warn('Otherwise, manually download and extract the websocketpp library:')
|
||||||
Logs.warn(' mkdir -p websocketpp')
|
Logs.warn(' mkdir -p websocketpp')
|
||||||
Logs.warn(' curl -L https://github.com/zaphoyd/websocketpp/archive/0.8.1.tar.gz > websocketpp.tar.gz')
|
Logs.warn(' curl -L https://github.com/cawka/websocketpp/archive/0.8.1-hotfix.tar.gz > websocketpp.tar.gz')
|
||||||
Logs.warn(' tar xf websocketpp.tar.gz -C websocketpp/ --strip 1')
|
Logs.warn(' tar xf websocketpp.tar.gz -C websocketpp/ --strip 1')
|
||||||
Logs.warn('Alternatively, WebSocket support can be disabled with --without-websocket')
|
Logs.warn('Alternatively, WebSocket support can be disabled with --without-websocket')
|
||||||
self.fatal('WebSocket++ not found')
|
self.fatal('WebSocket++ not found')
|
||||||
|
|||||||
@@ -83,7 +83,7 @@ TcpChannel::connect(const tcp::Endpoint& remoteEndpoint,
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
auto clientSocket = make_shared<ip::tcp::socket>(std::ref(getGlobalIoService()));
|
auto clientSocket = make_shared<ip::tcp::socket>(getGlobalIoService());
|
||||||
auto timeoutEvent = getScheduler().schedule(timeout, [=] {
|
auto timeoutEvent = getScheduler().schedule(timeout, [=] {
|
||||||
handleConnectTimeout(remoteEndpoint, clientSocket, onConnectFailed);
|
handleConnectTimeout(remoteEndpoint, clientSocket, onConnectFailed);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -133,7 +133,13 @@ TcpTransport::reconnect()
|
|||||||
BOOST_ASSERT(getState() == TransportState::DOWN);
|
BOOST_ASSERT(getState() == TransportState::DOWN);
|
||||||
|
|
||||||
// recreate the socket
|
// recreate the socket
|
||||||
m_socket = protocol::socket(m_socket.get_io_service());
|
m_socket = protocol::socket(
|
||||||
|
#if BOOST_VERSION >= 107000
|
||||||
|
m_socket.get_executor()
|
||||||
|
#else
|
||||||
|
m_socket.get_io_service()
|
||||||
|
#endif // BOOST_VERSION >= 107000
|
||||||
|
);
|
||||||
this->resetReceiveBuffer();
|
this->resetReceiveBuffer();
|
||||||
this->resetSendQueue();
|
this->resetSendQueue();
|
||||||
|
|
||||||
|
|||||||
@@ -123,7 +123,7 @@ WebSocketChannel::handleOpen(websocketpp::connection_hdl hdl)
|
|||||||
NFD_LOG_CHAN_TRACE("Incoming connection from " << m_server.get_con_from_hdl(hdl)->get_remote_endpoint());
|
NFD_LOG_CHAN_TRACE("Incoming connection from " << m_server.get_con_from_hdl(hdl)->get_remote_endpoint());
|
||||||
|
|
||||||
auto linkService = make_unique<GenericLinkService>();
|
auto linkService = make_unique<GenericLinkService>();
|
||||||
auto transport = make_unique<WebSocketTransport>(hdl, std::ref(m_server), m_pingInterval);
|
auto transport = make_unique<WebSocketTransport>(hdl, m_server, m_pingInterval);
|
||||||
auto face = make_shared<Face>(std::move(linkService), std::move(transport));
|
auto face = make_shared<Face>(std::move(linkService), std::move(transport));
|
||||||
|
|
||||||
BOOST_ASSERT(m_channelFaces.count(hdl) == 0);
|
BOOST_ASSERT(m_channelFaces.count(hdl) == 0);
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
|
||||||
/*
|
/*
|
||||||
* Copyright (c) 2014-2018, Regents of the University of California,
|
* Copyright (c) 2014-2019, Regents of the University of California,
|
||||||
* Arizona Board of Regents,
|
* Arizona Board of Regents,
|
||||||
* Colorado State University,
|
* Colorado State University,
|
||||||
* University Pierre & Marie Curie, Sorbonne University,
|
* University Pierre & Marie Curie, Sorbonne University,
|
||||||
@@ -177,7 +177,7 @@ BOOST_FIXTURE_TEST_CASE_TEMPLATE(PermanentReconnectWithExponentialBackoff, T, Tc
|
|||||||
BOOST_REQUIRE_EQUAL(this->limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
|
BOOST_REQUIRE_EQUAL(this->limitedIo.run(2, 1_s), LimitedIo::EXCEED_OPS);
|
||||||
|
|
||||||
auto transportObserver =
|
auto transportObserver =
|
||||||
make_unique<PermanentTcpTransportReconnectObserver>(std::move(sock), std::ref(this->limitedIo));
|
make_unique<PermanentTcpTransportReconnectObserver>(std::move(sock), this->limitedIo);
|
||||||
BOOST_REQUIRE_EQUAL(transportObserver->getState(), TransportState::UP);
|
BOOST_REQUIRE_EQUAL(transportObserver->getState(), TransportState::UP);
|
||||||
|
|
||||||
// break the TCP connection
|
// break the TCP connection
|
||||||
|
|||||||
@@ -110,7 +110,7 @@ protected:
|
|||||||
1_s), LimitedIo::EXCEED_OPS);
|
1_s), LimitedIo::EXCEED_OPS);
|
||||||
|
|
||||||
face = make_unique<Face>(make_unique<DummyLinkService>(),
|
face = make_unique<Face>(make_unique<DummyLinkService>(),
|
||||||
make_unique<WebSocketTransport>(serverHdl, std::ref(server), pingInterval));
|
make_unique<WebSocketTransport>(serverHdl, server, pingInterval));
|
||||||
transport = static_cast<WebSocketTransport*>(face->getTransport());
|
transport = static_cast<WebSocketTransport*>(face->getTransport());
|
||||||
serverReceivedPackets = &static_cast<DummyLinkService*>(face->getLinkService())->receivedPackets;
|
serverReceivedPackets = &static_cast<DummyLinkService*>(face->getLinkService())->receivedPackets;
|
||||||
|
|
||||||
|
|||||||
+1
-1
Submodule websocketpp updated: c6d7e295bf...ac4e021333.
Reference in new issue
Block a user