Skip to content

Commit 7641094

Browse files
author
Bret Ambrose
committed
Unreferenced params
1 parent 70c5183 commit 7641094

File tree

1 file changed

+19
-23
lines changed

1 file changed

+19
-23
lines changed

‎tests/Mqtt5ClientTest.cpp‎

Lines changed: 19 additions & 23 deletions
Original file line numberDiff line numberDiff line change
@@ -1516,7 +1516,7 @@ static int s_TestMqtt5SubUnsub(Aws::Crt::Allocator *allocator, void *)
15161516
allocator,
15171517
MQTT5CONNECT_DIRECT_IOT_CORE,
15181518
[&receivedLock, &receivedCount, &receivedSignal, &TEST_TOPIC](
1519-
Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
1519+
Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
15201520
{
15211521
options.WithPublishReceivedCallback(
15221522
[&receivedLock, &receivedCount, &receivedSignal, &TEST_TOPIC](const PublishReceivedEventData &eventData)
@@ -1551,8 +1551,7 @@ static int s_TestMqtt5SubUnsub(Aws::Crt::Allocator *allocator, void *)
15511551
Aws::Crt::MakeShared<Mqtt5::SubscribePacket>(allocator, allocator);
15521552
subscribe->WithSubscription(std::move(subscription));
15531553
ASSERT_TRUE(mqtt5Client->Subscribe(
1554-
subscribe,
1555-
[&subscribed](int errorCode, std::shared_ptr<SubAckPacket> suback) { subscribed.set_value(suback); }));
1554+
subscribe, [&subscribed](int, std::shared_ptr<SubAckPacket> suback) { subscribed.set_value(suback); }));
15561555
const auto &suback = subscribed.get_future().get();
15571556
ASSERT_NOT_NULL(suback.get());
15581557

@@ -1574,9 +1573,7 @@ static int s_TestMqtt5SubUnsub(Aws::Crt::Allocator *allocator, void *)
15741573
Aws::Crt::MakeShared<Mqtt5::UnsubscribePacket>(allocator, allocator);
15751574
unsub->WithTopicFilters(topics);
15761575
ASSERT_TRUE(mqtt5Client->Unsubscribe(
1577-
unsub,
1578-
[&unsubscribed](int errorCode, std::shared_ptr<UnSubAckPacket> unsuback)
1579-
{ unsubscribed.set_value(unsuback); }));
1576+
unsub, [&unsubscribed](int, std::shared_ptr<UnSubAckPacket> unsuback) { unsubscribed.set_value(unsuback); }));
15801577
unsubscribed.get_future().get();
15811578

15821579
/* Publish message2 to test topic */
@@ -1613,7 +1610,7 @@ static int s_TestMqtt5WillTest(Aws::Crt::Allocator *allocator, void *)
16131610
allocator,
16141611
MQTT5CONNECT_DIRECT_IOT_CORE,
16151612
[&receivedLock, &receivedWill, &receivedSignal, &TEST_TOPIC](
1616-
Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
1613+
Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
16171614
{
16181615
options.WithPublishReceivedCallback(
16191616
[&receivedLock, &receivedWill, &receivedSignal, &TEST_TOPIC](const PublishReceivedEventData &eventData)
@@ -1854,8 +1851,7 @@ static int s_TestMqtt5QoS1SubPub(Aws::Crt::Allocator *allocator, void *)
18541851
Mqtt5TestContext subscriberContext = createTestContext(
18551852
allocator,
18561853
MQTT5CONNECT_DIRECT_IOT_CORE,
1857-
[&receivedMessages,
1858-
&TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
1854+
[&receivedMessages, &TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
18591855
{
18601856
options.WithPublishReceivedCallback(
18611857
[&receivedMessages, &TEST_TOPIC](const PublishReceivedEventData &eventData)
@@ -1964,7 +1960,7 @@ static int s_TestMqtt5RetainSetAndClear(Aws::Crt::Allocator *allocator, void *)
19641960
allocator,
19651961
MQTT5CONNECT_DIRECT_IOT_CORE,
19661962
[&receivedRetainedMessage,
1967-
&TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
1963+
&TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
19681964
{
19691965
options.WithPublishReceivedCallback(
19701966
[&receivedRetainedMessage, &TEST_TOPIC](const PublishReceivedEventData &eventData)
@@ -1989,7 +1985,7 @@ static int s_TestMqtt5RetainSetAndClear(Aws::Crt::Allocator *allocator, void *)
19891985
Mqtt5TestContext testContext3 = createTestContext(
19901986
allocator,
19911987
MQTT5CONNECT_DIRECT_IOT_CORE,
1992-
[&TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
1988+
[&TEST_TOPIC](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
19931989
{
19941990
options.WithPublishReceivedCallback(
19951991
[&TEST_TOPIC](const PublishReceivedEventData &eventData)
@@ -2041,7 +2037,7 @@ static int s_TestMqtt5RetainSetAndClear(Aws::Crt::Allocator *allocator, void *)
20412037
clearRetainPacket->WithTopic(TEST_TOPIC).WithRetain(true);
20422038
ASSERT_TRUE(mqtt5Client1->Publish(
20432039
clearRetainPacket,
2044-
[&retainCleared](int errorCode, std::shared_ptr<PublishResult> result)
2040+
[&retainCleared](int errorCode, std::shared_ptr<PublishResult>)
20452041
{
20462042
if (errorCode == AWS_ERROR_SUCCESS)
20472043
{
@@ -2428,7 +2424,7 @@ static int s_TestMqtt5to3AdapterWSConnectionMinimalThroughMqtt3(Aws::Crt::Alloca
24282424
Mqtt5TestContext testContext = createTestContext(
24292425
allocator,
24302426
MQTT5CONNECT_WS_IOT_CORE,
2431-
[](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
2427+
[](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
24322428
{
24332429
options.WithWebsocketHandshakeTransformCallback(
24342430
[](std::shared_ptr<Http::HttpRequest>, const OnWebSocketHandshakeInterceptComplete &)
@@ -2572,7 +2568,7 @@ static int s_TestMqtt5to3AdapterWSConnectionMinimalThroughMqtt5(Aws::Crt::Alloca
25722568
Mqtt5TestContext testContext = createTestContext(
25732569
allocator,
25742570
MQTT5CONNECT_WS,
2575-
[](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &context)
2571+
[](Mqtt5ClientOptions &options, const Mqtt5TestEnvVars &, Mqtt5TestContext &)
25762572
{
25772573
options.WithWebsocketHandshakeTransformCallback(
25782574
[](std::shared_ptr<Http::HttpRequest>, const OnWebSocketHandshakeInterceptComplete &)
@@ -2715,16 +2711,16 @@ static int s_TestMqtt5to3AdapterOperations(Aws::Crt::Allocator *allocator, void
27152711
ASSERT_TRUE(mqtt5Client->Start());
27162712
ASSERT_TRUE(testContext.connectionPromise.get_future().get());
27172713

2718-
auto onMessage = [&](Mqtt::MqttConnection &, const String &topic, const ByteBuf &payload, bool, Mqtt::QOS, bool)
2714+
auto onMessage = [&](Mqtt::MqttConnection &, const String &, const ByteBuf &, bool, Mqtt::QOS, bool)
27192715
{
27202716
std::lock_guard<std::mutex> lock(mutex);
27212717
++received;
27222718
cv.notify_one();
27232719
};
2724-
auto onSubAck = [&](Mqtt::MqttConnection &, uint16_t packetId, const Aws::Crt::String &topic, Mqtt::QOS qos, int)
2720+
auto onSubAck = [&](Mqtt::MqttConnection &, uint16_t, const Aws::Crt::String &, Mqtt::QOS, int)
27252721
{ subscribed.set_value(); };
2726-
auto onPubAck = [&](Mqtt::MqttConnection &, uint16_t packetId, int) { published.set_value(); };
2727-
auto onUnsubAck = [&](Mqtt::MqttConnection &, uint16_t packetId, int) { unsubscribed.set_value(); };
2722+
auto onPubAck = [&](Mqtt::MqttConnection &, uint16_t, int) { published.set_value(); };
2723+
auto onUnsubAck = [&](Mqtt::MqttConnection &, uint16_t, int) { unsubscribed.set_value(); };
27282724

27292725
mqttConnection->Subscribe(
27302726
testTopic.c_str(), Mqtt::QOS::AWS_MQTT_QOS_AT_LEAST_ONCE, std::move(onMessage), std::move(onSubAck));
@@ -2838,7 +2834,7 @@ static int s_TestMqtt5to3AdapterMultipleAdapters(Aws::Crt::Allocator *allocator,
28382834
std::promise<void> published;
28392835
ByteBuf testPayload = Aws::Crt::ByteBufFromCString("PUBLISH ME!");
28402836

2841-
auto onMessage1 = [&](Mqtt::MqttConnection &, const String &topic, const ByteBuf &payload, bool, Mqtt::QOS, bool)
2837+
auto onMessage1 = [&](Mqtt::MqttConnection &, const String &, const ByteBuf &, bool, Mqtt::QOS, bool)
28422838
{
28432839
{
28442840
std::lock_guard<std::mutex> lock(mutex);
@@ -2847,10 +2843,10 @@ static int s_TestMqtt5to3AdapterMultipleAdapters(Aws::Crt::Allocator *allocator,
28472843
}
28482844
};
28492845

2850-
auto onSubAck1 = [&](Mqtt::MqttConnection &, uint16_t packetId, const Aws::Crt::String &topic, Mqtt::QOS qos, int)
2846+
auto onSubAck1 = [&](Mqtt::MqttConnection &, uint16_t, const Aws::Crt::String &, Mqtt::QOS, int)
28512847
{ subscribed1.set_value(); };
28522848

2853-
auto onMessage2 = [&](Mqtt::MqttConnection &, const String &topic, const ByteBuf &payload, bool, Mqtt::QOS, bool)
2849+
auto onMessage2 = [&](Mqtt::MqttConnection &, const String &, const ByteBuf &, bool, Mqtt::QOS, bool)
28542850
{
28552851
{
28562852
std::lock_guard<std::mutex> lock(mutex);
@@ -2859,7 +2855,7 @@ static int s_TestMqtt5to3AdapterMultipleAdapters(Aws::Crt::Allocator *allocator,
28592855
}
28602856
};
28612857

2862-
auto onSubAck2 = [&](Mqtt::MqttConnection &, uint16_t packetId, const Aws::Crt::String &topic, Mqtt::QOS qos, int)
2858+
auto onSubAck2 = [&](Mqtt::MqttConnection &, uint16_t, const Aws::Crt::String &, Mqtt::QOS, int)
28632859
{ subscribed2.set_value(); };
28642860

28652861
ASSERT_TRUE(mqtt5Client->Start());
@@ -2871,7 +2867,7 @@ static int s_TestMqtt5to3AdapterMultipleAdapters(Aws::Crt::Allocator *allocator,
28712867
mqttConnection2->Subscribe(testTopic2.c_str(), Mqtt::QOS::AWS_MQTT_QOS_AT_LEAST_ONCE, onMessage2, onSubAck2);
28722868
subscribed2.get_future().get();
28732869

2874-
auto onPubAck = [&](Mqtt::MqttConnection &, uint16_t packetId, int) { published.set_value(); };
2870+
auto onPubAck = [&](Mqtt::MqttConnection &, uint16_t, int) { published.set_value(); };
28752871

28762872
// Publish to testTopic1
28772873
mqttConnection1->Publish(testTopic1.c_str(), Mqtt::QOS::AWS_MQTT_QOS_AT_LEAST_ONCE, false, testPayload, onPubAck);

0 commit comments

Comments
 (0)