@@ -172,7 +172,7 @@ bool stream_outlet_impl::wait_for_consumers(double timeout) {
172
172
return send_buffer_->wait_for_consumers (timeout);
173
173
}
174
174
175
- void stream_outlet_impl::push_timestamp_sync (double timestamp) {
175
+ void stream_outlet_impl::push_timestamp_sync (const double & timestamp) {
176
176
static_assert (TAG_TRANSMITTED_TIMESTAMP == 2 , " Unexpected TAG_TRANSMITTED_TIMESTAMP" );
177
177
const uint64_t ENDIAN_SAFE_TAG_TRANSMITTED = (2LL << 28 ) | 2LL ;
178
178
if (timestamp == DEDUCED_TIMESTAMP) {
@@ -193,7 +193,7 @@ void stream_outlet_impl::pushthrough_sync() {
193
193
}
194
194
195
195
void stream_outlet_impl::enqueue_sync (
196
- asio::const_buffer buff, double timestamp, bool pushthrough) {
196
+ asio::const_buffer buff, const double & timestamp, bool pushthrough) {
197
197
push_timestamp_sync (timestamp);
198
198
sync_buffs_.push_back (buff);
199
199
if (pushthrough) pushthrough_sync ();
@@ -221,7 +221,7 @@ template void stream_outlet_impl::enqueue<double>(const double *data, double, bo
221
221
template void stream_outlet_impl::enqueue<std::string>(const std::string *data, double , bool );
222
222
223
223
void stream_outlet_impl::enqueue_sync_multi (
224
- std::vector<asio::const_buffer> buffs, double timestamp, bool pushthrough) {
224
+ std::vector<asio::const_buffer> buffs, const double & timestamp, bool pushthrough) {
225
225
push_timestamp_sync (timestamp);
226
226
sync_buffs_.insert (sync_buffs_.end (), buffs.begin (), buffs.end ());
227
227
if (pushthrough) pushthrough_sync ();
0 commit comments