@@ -68,10 +68,12 @@ rmw_take_response(
68
68
iceoryx_response_payload);
69
69
// / @todo check writer guid?
70
70
request_header->request_id .sequence_number = iceoryx_response_header->getSequenceId ();
71
- request_header->source_timestamp = 0 ; // Unsupported until needed
71
+ request_header->source_timestamp = 0 ; // Unsupported until needed
72
72
ret = rcutils_system_time_now (&request_header->received_timestamp );
73
73
74
- if (iceoryx_response_header->getSequenceId () == iceoryx_client_abstraction->sequence_id_ - 1 ) {
74
+ if (iceoryx_response_header->getSequenceId () ==
75
+ iceoryx_client_abstraction->sequence_id_ - 1 )
76
+ {
75
77
user_payload = iceoryx_response_payload;
76
78
chunk_header = iox::mepoo::ChunkHeader::fromUserPayload (user_payload);
77
79
ret = RMW_RET_OK;
@@ -139,9 +141,10 @@ rmw_send_response(
139
141
140
142
auto * iceoryx_request_header = iox::popo::RequestHeader::fromPayload (
141
143
iceoryx_server_abstraction->request_payload_ );
142
- // / @todo Why is it not possible to set the sequence id? Is this automatically done? If so, we need to compare
143
- // / the user-provided sequence id with the one from the 'iceoryx_request_header'
144
- // iceoryx_request_header->setSequenceId(request_header->sequence_number);
144
+ // / @todo Why is it not possible to set the sequence id? Is this automatically done? If so,
145
+ // / we need to compare the user-provided sequence id with the one from the
146
+ // / 'iceoryx_request_header'
147
+ // iceoryx_request_header->setSequenceId(request_header->sequence_number);
145
148
146
149
iceoryx_server->loan (
147
150
iceoryx_request_header, iceoryx_server_abstraction->response_size_ ,
@@ -158,7 +161,8 @@ rmw_send_response(
158
161
&iceoryx_server_abstraction->type_supports_ , payload_vector);
159
162
memcpy (responsePayload, payload_vector.data (), payload_vector.size ());
160
163
}
161
- // / @todo Why are the sleep before and after 'send()' needed? rmw_cyclonedds and rmw_fastrtps seem to do something similar in 'rmw_send_response'..
164
+ // / @todo Why are the sleeps before and after 'send()' needed?
165
+ // / rmw_cyclonedds and rmw_fastrtps seem to do something similar in 'rmw_send_response'..
162
166
std::this_thread::sleep_for (std::chrono::milliseconds (100 ));
163
167
iceoryx_server->send (responsePayload).and_then (
164
168
[&] {
0 commit comments