Skip to content

Commit 8b091c9

Browse files
committed
Check tests
1 parent e65a864 commit 8b091c9

File tree

4 files changed

+36
-36
lines changed

4 files changed

+36
-36
lines changed

eventstreamrpc/include/aws/eventstreamrpc/EventStreamClient.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -352,6 +352,7 @@ namespace Aws
352352
ProtectedPromise<RpcError> m_connectAckedPromise;
353353
std::promise<RpcError> m_closedPromise;
354354
OnMessageFlushCallback m_onConnectRequestCallback;
355+
Crt::Io::SocketOptions m_socketOptions;
355356
static void s_customDeleter(ClientConnection *connection) noexcept;
356357
std::future<RpcError> SendProtocolMessage(
357358
const Crt::List<EventStreamHeader> &headers,

eventstreamrpc/source/EventStreamClient.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -280,16 +280,15 @@ namespace Aws
280280
return m_connectAckedPromise.GetFuture();
281281
}
282282

283-
Crt::Io::SocketOptions socketOptions;
284283
if (connectionConfig.GetSocketDomain().has_value())
285284
{
286-
socketOptions.SetSocketDomain(connectionConfig.GetSocketDomain().value());
285+
m_socketOptions.SetSocketDomain(connectionConfig.GetSocketDomain().value());
287286
}
288287
if (connectionConfig.GetSocketType().has_value())
289288
{
290-
socketOptions.SetSocketType(connectionConfig.GetSocketType().value());
289+
m_socketOptions.SetSocketType(connectionConfig.GetSocketType().value());
291290
}
292-
connOptions.socket_options = &socketOptions.GetImpl();
291+
connOptions.socket_options = &m_socketOptions.GetImpl();
293292

294293
connOptions.on_connection_setup = ClientConnection::s_onConnectionSetup;
295294
connOptions.on_connection_protocol_message = ClientConnection::s_onProtocolMessage;

ipc/source/GreengrassCoreIpcModel.cpp

Lines changed: 26 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -4736,7 +4736,7 @@ namespace Aws
47364736
std::future<SubscribeToIoTCoreResult> SubscribeToIoTCoreOperation::GetResult() noexcept
47374737
{
47384738
std::promise<SubscribeToIoTCoreResult> result;
4739-
result.set_value(SubscribeToIoTCoreResult(std::move(GetOperationResult().get())));
4739+
result.set_value(SubscribeToIoTCoreResult(GetOperationResult().get()));
47404740
return result.get_future();
47414741
}
47424742

@@ -4805,7 +4805,7 @@ namespace Aws
48054805
std::future<PublishToIoTCoreResult> PublishToIoTCoreOperation::GetResult() noexcept
48064806
{
48074807
std::promise<PublishToIoTCoreResult> result;
4808-
result.set_value(PublishToIoTCoreResult(std::move(GetOperationResult().get())));
4808+
result.set_value(PublishToIoTCoreResult(GetOperationResult().get()));
48094809
return result.get_future();
48104810
}
48114811

@@ -4894,7 +4894,7 @@ namespace Aws
48944894
std::future<SubscribeToConfigurationUpdateResult> SubscribeToConfigurationUpdateOperation::GetResult() noexcept
48954895
{
48964896
std::promise<SubscribeToConfigurationUpdateResult> result;
4897-
result.set_value(SubscribeToConfigurationUpdateResult(std::move(GetOperationResult().get())));
4897+
result.set_value(SubscribeToConfigurationUpdateResult(GetOperationResult().get()));
48984898
return result.get_future();
48994899
}
49004900

@@ -4963,7 +4963,7 @@ namespace Aws
49634963
std::future<DeleteThingShadowResult> DeleteThingShadowOperation::GetResult() noexcept
49644964
{
49654965
std::promise<DeleteThingShadowResult> result;
4966-
result.set_value(DeleteThingShadowResult(std::move(GetOperationResult().get())));
4966+
result.set_value(DeleteThingShadowResult(GetOperationResult().get()));
49674967
return result.get_future();
49684968
}
49694969

@@ -5031,7 +5031,7 @@ namespace Aws
50315031
std::future<DeferComponentUpdateResult> DeferComponentUpdateOperation::GetResult() noexcept
50325032
{
50335033
std::promise<DeferComponentUpdateResult> result;
5034-
result.set_value(DeferComponentUpdateResult(std::move(GetOperationResult().get())));
5034+
result.set_value(DeferComponentUpdateResult(GetOperationResult().get()));
50355035
return result.get_future();
50365036
}
50375037

@@ -5119,7 +5119,7 @@ namespace Aws
51195119
GetResult() noexcept
51205120
{
51215121
std::promise<SubscribeToValidateConfigurationUpdatesResult> result;
5122-
result.set_value(SubscribeToValidateConfigurationUpdatesResult(std::move(GetOperationResult().get())));
5122+
result.set_value(SubscribeToValidateConfigurationUpdatesResult(GetOperationResult().get()));
51235123
return result.get_future();
51245124
}
51255125

@@ -5188,7 +5188,7 @@ namespace Aws
51885188
std::future<GetConfigurationResult> GetConfigurationOperation::GetResult() noexcept
51895189
{
51905190
std::promise<GetConfigurationResult> result;
5191-
result.set_value(GetConfigurationResult(std::move(GetOperationResult().get())));
5191+
result.set_value(GetConfigurationResult(GetOperationResult().get()));
51925192
return result.get_future();
51935193
}
51945194

@@ -5280,7 +5280,7 @@ namespace Aws
52805280
std::future<SubscribeToTopicResult> SubscribeToTopicOperation::GetResult() noexcept
52815281
{
52825282
std::promise<SubscribeToTopicResult> result;
5283-
result.set_value(SubscribeToTopicResult(std::move(GetOperationResult().get())));
5283+
result.set_value(SubscribeToTopicResult(GetOperationResult().get()));
52845284
return result.get_future();
52855285
}
52865286

@@ -5349,7 +5349,7 @@ namespace Aws
53495349
std::future<GetComponentDetailsResult> GetComponentDetailsOperation::GetResult() noexcept
53505350
{
53515351
std::promise<GetComponentDetailsResult> result;
5352-
result.set_value(GetComponentDetailsResult(std::move(GetOperationResult().get())));
5352+
result.set_value(GetComponentDetailsResult(GetOperationResult().get()));
53535353
return result.get_future();
53545354
}
53555355

@@ -5417,7 +5417,7 @@ namespace Aws
54175417
std::future<PublishToTopicResult> PublishToTopicOperation::GetResult() noexcept
54185418
{
54195419
std::promise<PublishToTopicResult> result;
5420-
result.set_value(PublishToTopicResult(std::move(GetOperationResult().get())));
5420+
result.set_value(PublishToTopicResult(GetOperationResult().get()));
54215421
return result.get_future();
54225422
}
54235423

@@ -5485,7 +5485,7 @@ namespace Aws
54855485
std::future<ListComponentsResult> ListComponentsOperation::GetResult() noexcept
54865486
{
54875487
std::promise<ListComponentsResult> result;
5488-
result.set_value(ListComponentsResult(std::move(GetOperationResult().get())));
5488+
result.set_value(ListComponentsResult(GetOperationResult().get()));
54895489
return result.get_future();
54905490
}
54915491

@@ -5553,7 +5553,7 @@ namespace Aws
55535553
std::future<CreateDebugPasswordResult> CreateDebugPasswordOperation::GetResult() noexcept
55545554
{
55555555
std::promise<CreateDebugPasswordResult> result;
5556-
result.set_value(CreateDebugPasswordResult(std::move(GetOperationResult().get())));
5556+
result.set_value(CreateDebugPasswordResult(GetOperationResult().get()));
55575557
return result.get_future();
55585558
}
55595559

@@ -5621,7 +5621,7 @@ namespace Aws
56215621
std::future<GetThingShadowResult> GetThingShadowOperation::GetResult() noexcept
56225622
{
56235623
std::promise<GetThingShadowResult> result;
5624-
result.set_value(GetThingShadowResult(std::move(GetOperationResult().get())));
5624+
result.set_value(GetThingShadowResult(GetOperationResult().get()));
56255625
return result.get_future();
56265626
}
56275627

@@ -5690,7 +5690,7 @@ namespace Aws
56905690
GetResult() noexcept
56915691
{
56925692
std::promise<SendConfigurationValidityReportResult> result;
5693-
result.set_value(SendConfigurationValidityReportResult(std::move(GetOperationResult().get())));
5693+
result.set_value(SendConfigurationValidityReportResult(GetOperationResult().get()));
56945694
return result.get_future();
56955695
}
56965696

@@ -5758,7 +5758,7 @@ namespace Aws
57585758
std::future<UpdateThingShadowResult> UpdateThingShadowOperation::GetResult() noexcept
57595759
{
57605760
std::promise<UpdateThingShadowResult> result;
5761-
result.set_value(UpdateThingShadowResult(std::move(GetOperationResult().get())));
5761+
result.set_value(UpdateThingShadowResult(GetOperationResult().get()));
57625762
return result.get_future();
57635763
}
57645764

@@ -5826,7 +5826,7 @@ namespace Aws
58265826
std::future<UpdateConfigurationResult> UpdateConfigurationOperation::GetResult() noexcept
58275827
{
58285828
std::promise<UpdateConfigurationResult> result;
5829-
result.set_value(UpdateConfigurationResult(std::move(GetOperationResult().get())));
5829+
result.set_value(UpdateConfigurationResult(GetOperationResult().get()));
58305830
return result.get_future();
58315831
}
58325832

@@ -5894,7 +5894,7 @@ namespace Aws
58945894
std::future<ValidateAuthorizationTokenResult> ValidateAuthorizationTokenOperation::GetResult() noexcept
58955895
{
58965896
std::promise<ValidateAuthorizationTokenResult> result;
5897-
result.set_value(ValidateAuthorizationTokenResult(std::move(GetOperationResult().get())));
5897+
result.set_value(ValidateAuthorizationTokenResult(GetOperationResult().get()));
58985898
return result.get_future();
58995899
}
59005900

@@ -5962,7 +5962,7 @@ namespace Aws
59625962
std::future<RestartComponentResult> RestartComponentOperation::GetResult() noexcept
59635963
{
59645964
std::promise<RestartComponentResult> result;
5965-
result.set_value(RestartComponentResult(std::move(GetOperationResult().get())));
5965+
result.set_value(RestartComponentResult(GetOperationResult().get()));
59665966
return result.get_future();
59675967
}
59685968

@@ -6030,7 +6030,7 @@ namespace Aws
60306030
std::future<GetLocalDeploymentStatusResult> GetLocalDeploymentStatusOperation::GetResult() noexcept
60316031
{
60326032
std::promise<GetLocalDeploymentStatusResult> result;
6033-
result.set_value(GetLocalDeploymentStatusResult(std::move(GetOperationResult().get())));
6033+
result.set_value(GetLocalDeploymentStatusResult(GetOperationResult().get()));
60346034
return result.get_future();
60356035
}
60366036

@@ -6098,7 +6098,7 @@ namespace Aws
60986098
std::future<GetSecretValueResult> GetSecretValueOperation::GetResult() noexcept
60996099
{
61006100
std::promise<GetSecretValueResult> result;
6101-
result.set_value(GetSecretValueResult(std::move(GetOperationResult().get())));
6101+
result.set_value(GetSecretValueResult(GetOperationResult().get()));
61026102
return result.get_future();
61036103
}
61046104

@@ -6165,7 +6165,7 @@ namespace Aws
61656165
std::future<UpdateStateResult> UpdateStateOperation::GetResult() noexcept
61666166
{
61676167
std::promise<UpdateStateResult> result;
6168-
result.set_value(UpdateStateResult(std::move(GetOperationResult().get())));
6168+
result.set_value(UpdateStateResult(GetOperationResult().get()));
61696169
return result.get_future();
61706170
}
61716171

@@ -6233,7 +6233,7 @@ namespace Aws
62336233
std::future<ListNamedShadowsForThingResult> ListNamedShadowsForThingOperation::GetResult() noexcept
62346234
{
62356235
std::promise<ListNamedShadowsForThingResult> result;
6236-
result.set_value(ListNamedShadowsForThingResult(std::move(GetOperationResult().get())));
6236+
result.set_value(ListNamedShadowsForThingResult(GetOperationResult().get()));
62376237
return result.get_future();
62386238
}
62396239

@@ -6322,7 +6322,7 @@ namespace Aws
63226322
std::future<SubscribeToComponentUpdatesResult> SubscribeToComponentUpdatesOperation::GetResult() noexcept
63236323
{
63246324
std::promise<SubscribeToComponentUpdatesResult> result;
6325-
result.set_value(SubscribeToComponentUpdatesResult(std::move(GetOperationResult().get())));
6325+
result.set_value(SubscribeToComponentUpdatesResult(GetOperationResult().get()));
63266326
return result.get_future();
63276327
}
63286328

@@ -6391,7 +6391,7 @@ namespace Aws
63916391
std::future<ListLocalDeploymentsResult> ListLocalDeploymentsOperation::GetResult() noexcept
63926392
{
63936393
std::promise<ListLocalDeploymentsResult> result;
6394-
result.set_value(ListLocalDeploymentsResult(std::move(GetOperationResult().get())));
6394+
result.set_value(ListLocalDeploymentsResult(GetOperationResult().get()));
63956395
return result.get_future();
63966396
}
63976397

@@ -6459,7 +6459,7 @@ namespace Aws
64596459
std::future<StopComponentResult> StopComponentOperation::GetResult() noexcept
64606460
{
64616461
std::promise<StopComponentResult> result;
6462-
result.set_value(StopComponentResult(std::move(GetOperationResult().get())));
6462+
result.set_value(StopComponentResult(GetOperationResult().get()));
64636463
return result.get_future();
64646464
}
64656465

@@ -6527,7 +6527,7 @@ namespace Aws
65276527
std::future<CreateLocalDeploymentResult> CreateLocalDeploymentOperation::GetResult() noexcept
65286528
{
65296529
std::promise<CreateLocalDeploymentResult> result;
6530-
result.set_value(CreateLocalDeploymentResult(std::move(GetOperationResult().get())));
6530+
result.set_value(CreateLocalDeploymentResult(GetOperationResult().get()));
65316531
return result.get_future();
65326532
}
65336533

ipc/tests/EchoTestRpcModel.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -963,7 +963,7 @@ namespace Awstest
963963
std::future<GetAllProductsResult> GetAllProductsOperation::GetResult() noexcept
964964
{
965965
std::promise<GetAllProductsResult> result;
966-
result.set_value(GetAllProductsResult(std::move(GetOperationResult().get())));
966+
result.set_value(GetAllProductsResult(GetOperationResult().get()));
967967
return result.get_future();
968968
}
969969

@@ -1031,7 +1031,7 @@ namespace Awstest
10311031
std::future<CauseServiceErrorResult> CauseServiceErrorOperation::GetResult() noexcept
10321032
{
10331033
std::promise<CauseServiceErrorResult> result;
1034-
result.set_value(CauseServiceErrorResult(std::move(GetOperationResult().get())));
1034+
result.set_value(CauseServiceErrorResult(GetOperationResult().get()));
10351035
return result.get_future();
10361036
}
10371037

@@ -1115,7 +1115,7 @@ namespace Awstest
11151115
std::future<CauseStreamServiceToErrorResult> CauseStreamServiceToErrorOperation::GetResult() noexcept
11161116
{
11171117
std::promise<CauseStreamServiceToErrorResult> result;
1118-
result.set_value(CauseStreamServiceToErrorResult(std::move(GetOperationResult().get())));
1118+
result.set_value(CauseStreamServiceToErrorResult(GetOperationResult().get()));
11191119
return result.get_future();
11201120
}
11211121

@@ -1196,7 +1196,7 @@ namespace Awstest
11961196
std::future<EchoStreamMessagesResult> EchoStreamMessagesOperation::GetResult() noexcept
11971197
{
11981198
std::promise<EchoStreamMessagesResult> result;
1199-
result.set_value(EchoStreamMessagesResult(std::move(GetOperationResult().get())));
1199+
result.set_value(EchoStreamMessagesResult(GetOperationResult().get()));
12001200
return result.get_future();
12011201
}
12021202

@@ -1263,7 +1263,7 @@ namespace Awstest
12631263
std::future<EchoMessageResult> EchoMessageOperation::GetResult() noexcept
12641264
{
12651265
std::promise<EchoMessageResult> result;
1266-
result.set_value(EchoMessageResult(std::move(GetOperationResult().get())));
1266+
result.set_value(EchoMessageResult(GetOperationResult().get()));
12671267
return result.get_future();
12681268
}
12691269

@@ -1330,7 +1330,7 @@ namespace Awstest
13301330
std::future<GetAllCustomersResult> GetAllCustomersOperation::GetResult() noexcept
13311331
{
13321332
std::promise<GetAllCustomersResult> result;
1333-
result.set_value(GetAllCustomersResult(std::move(GetOperationResult().get())));
1333+
result.set_value(GetAllCustomersResult(GetOperationResult().get()));
13341334
return result.get_future();
13351335
}
13361336

0 commit comments

Comments
 (0)