Skip to content

Commit 5cc6d91

Browse files
committed
Refs #23432. Uncrustify.
Signed-off-by: Miguel Company <miguelcompany@eprosima.com>
1 parent 699fafe commit 5cc6d91

File tree

5 files changed

+13
-10
lines changed

5 files changed

+13
-10
lines changed

src/cpp/fastdds/publisher/DataWriterImpl.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1224,9 +1224,9 @@ ReturnCode_t DataWriterImpl::set_qos(
12241224
{
12251225
int32_t transport_priority = writer_->get_transport_priority();
12261226

1227-
if ( (qos_.reliability().kind == ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS &&
1227+
if ((qos_.reliability().kind == ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS &&
12281228
qos_.reliable_writer_qos() == qos_to_set.reliable_writer_qos()) ||
1229-
(transport_priority != qos_to_set.transport_priority().value) )
1229+
(transport_priority != qos_to_set.transport_priority().value))
12301230
{
12311231
// Update times and positive_acks attributes on RTPS Layer
12321232
WriterAttributes w_att;

src/cpp/rtps/reader/StatefulReader.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1242,7 +1242,8 @@ void StatefulReader::NotifyChanges(
12421242
do
12431243
{
12441244
next_seq = prox->next_cache_change_to_be_notified();
1245-
} while (next_seq != c_SequenceNumber_Unknown && next_seq <= aux_ch->sequenceNumber);
1245+
}
1246+
while (next_seq != c_SequenceNumber_Unknown && next_seq <= aux_ch->sequenceNumber);
12461247
}
12471248
// Ensure correct state of proxy when max_seq is not present in history
12481249
while (c_SequenceNumber_Unknown != prox->next_cache_change_to_be_notified())

src/cpp/rtps/writer/StatefulWriter.cpp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1508,7 +1508,8 @@ void StatefulWriter::check_acked_status()
15081508
listener_->on_writer_change_received_by_all(this, change);
15091509

15101510
// Stop if we got to either next_all_acked_notify_sequence_ or the first change
1511-
} while (seq > end_seq);
1511+
}
1512+
while (seq > end_seq);
15121513
}
15131514

15141515
next_all_acked_notify_sequence_ = min_low_mark + 1;
@@ -2081,10 +2082,9 @@ bool StatefulWriter::ack_timer_expired()
20812082
do
20822083
{
20832084
last_sequence_number_++;
2084-
} while (!history_->get_change(
2085-
last_sequence_number_,
2086-
getGuid(),
2087-
&change) && last_sequence_number_ < next_sequence_number());
2085+
}
2086+
while (!history_->get_change(last_sequence_number_, getGuid(), &change) &&
2087+
last_sequence_number_ < next_sequence_number());
20882088

20892089
if (!history_->get_change(
20902090
last_sequence_number_,

test/unittest/transport/SharedMemTests.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -519,7 +519,8 @@ TEST_F(SHMCondition, max_listeners)
519519
do
520520
{
521521
std::this_thread::sleep_for(std::chrono::milliseconds(100));
522-
} while (waiting_threads.load() + wait_exception.load() < threads.size());
522+
}
523+
while (waiting_threads.load() + wait_exception.load() < threads.size());
523524

524525
std::cout << waiting_threads.load() << " waiting. " << wait_exception.load() << " failed." << std::endl;
525526

test/unittest/transport/TCPv4Tests.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,8 @@ TEST_F(TCPv4Tests, send_is_rejected_if_buffer_size_is_bigger_to_size_specified_i
344344
std::vector<NetworkBuffer> buffer_list;
345345
buffer_list.emplace_back(receiveBufferWrongSize.data(), (uint32_t)receiveBufferWrongSize.size());
346346
ASSERT_FALSE(send_resource_list.at(0)->send(buffer_list, (uint32_t)receiveBufferWrongSize.size(),
347-
&destination_begin, &destination_end, (std::chrono::steady_clock::now() + std::chrono::microseconds(100)), 0));
347+
&destination_begin, &destination_end, (std::chrono::steady_clock::now() + std::chrono::microseconds(
348+
100)), 0));
348349
}
349350

350351
TEST_F(TCPv4Tests, RemoteToMainLocal_simply_strips_out_address_leaving_IP_ANY)

0 commit comments

Comments
 (0)