24
24
#include < vrs/IndexRecord.h>
25
25
26
26
namespace rerun_vrs {
27
-
28
- using namespace std ;
29
-
30
27
RerunFramePlayer::RerunFramePlayer (StreamId id, rerun::RecordingStream& rec)
31
28
: id_{id}, rec_{rec} {}
32
29
@@ -36,8 +33,10 @@ namespace rerun_vrs {
36
33
if (!enabled_)
37
34
return false ;
38
35
36
+ rec_.set_time_seconds (" timestamp" , record.timestamp );
37
+
39
38
/* std::cout << "onDataLayoutRead " << std::endl; */
40
- ostringstream buffer;
39
+ std:: ostringstream buffer;
41
40
layout.printLayoutCompact (buffer);
42
41
/* std::cout << buffer.str() << std::endl; */
43
42
// TODO write this information to a markdown file
@@ -60,7 +59,7 @@ namespace rerun_vrs {
60
59
) {
61
60
/* std::cout << "onImageRead" << std::endl; */
62
61
const auto & spec = contentBlock.image ();
63
- shared_ptr<PixelFrame> frame = getFrame (true );
62
+ std:: shared_ptr<PixelFrame> frame = getFrame (true );
64
63
const auto & imageFormat = spec.getImageFormat ();
65
64
const auto & imageFormatStr = spec.getImageFormatAsString ();
66
65
bool frameValid = false ;
@@ -154,11 +153,11 @@ namespace rerun_vrs {
154
153
/* } */
155
154
}
156
155
157
- void RerunFramePlayer::convertFrame (shared_ptr<PixelFrame>& frame) {
156
+ void RerunFramePlayer::convertFrame (std:: shared_ptr<PixelFrame>& frame) {
158
157
if (blankMode_) {
159
158
makeBlankFrame (frame);
160
159
} else {
161
- shared_ptr<PixelFrame> convertedFrame =
160
+ std:: shared_ptr<PixelFrame> convertedFrame =
162
161
needsConvertedFrame_ ? getFrame (false ) : nullptr ;
163
162
PixelFrame::normalizeFrame (frame, convertedFrame, false );
164
163
needsConvertedFrame_ = (frame != convertedFrame); // for next time!
@@ -169,26 +168,28 @@ namespace rerun_vrs {
169
168
}
170
169
}
171
170
172
- void RerunFramePlayer::makeBlankFrame (shared_ptr<PixelFrame>& frame) {
171
+ void RerunFramePlayer::makeBlankFrame (std:: shared_ptr<PixelFrame>& frame) {
173
172
frame->init (vrs::PixelFormat::GREY8, frame->getWidth (), frame->getHeight ());
174
173
frame->blankFrame ();
175
174
}
176
175
177
- shared_ptr<PixelFrame> RerunFramePlayer::getFrame (bool inputNotConvertedFrame) {
178
- vector<shared_ptr<PixelFrame>>& frames =
176
+ std:: shared_ptr<PixelFrame> RerunFramePlayer::getFrame (bool inputNotConvertedFrame) {
177
+ std:: vector<std:: shared_ptr<PixelFrame>>& frames =
179
178
inputNotConvertedFrame ? inputFrames_ : convertedframes_;
180
179
if (frames.empty ()) {
181
180
return nullptr ;
182
181
}
183
- shared_ptr<PixelFrame> frame = std::move (frames.back ());
182
+ std:: shared_ptr<PixelFrame> frame = std::move (frames.back ());
184
183
frames.pop_back ();
185
184
return frame;
186
185
}
187
186
188
- void RerunFramePlayer::recycle (shared_ptr<PixelFrame>& frame, bool inputNotConvertedFrame) {
187
+ void RerunFramePlayer::recycle (
188
+ std::shared_ptr<PixelFrame>& frame, bool inputNotConvertedFrame
189
+ ) {
189
190
if (frame) {
190
191
{
191
- vector<shared_ptr<PixelFrame>>& frames =
192
+ std:: vector<std:: shared_ptr<PixelFrame>>& frames =
192
193
inputNotConvertedFrame ? inputFrames_ : convertedframes_;
193
194
if (frames.size () < 10 ) {
194
195
frames.emplace_back (std::move (frame));
@@ -199,9 +200,9 @@ namespace rerun_vrs {
199
200
}
200
201
201
202
void RerunFramePlayer::imageJobsThreadActivity () {
202
- unique_ptr<ImageJob> job;
203
+ std:: unique_ptr<ImageJob> job;
203
204
while (imageJobs_.waitForJob (job)) {
204
- shared_ptr<PixelFrame> frame = std::move (job->frame );
205
+ std:: shared_ptr<PixelFrame> frame = std::move (job->frame );
205
206
// if we're behind, we just drop images except the last one!
206
207
while (imageJobs_.getJob (job)) {
207
208
recycle (frame, true );
@@ -213,7 +214,7 @@ namespace rerun_vrs {
213
214
frameValid = (frame != nullptr );
214
215
} else {
215
216
if (!frame) {
216
- frame = make_shared<PixelFrame>();
217
+ frame = std:: make_shared<PixelFrame>();
217
218
}
218
219
frameValid = frame->readCompressedFrame (job->buffer , job->imageFormat );
219
220
}
0 commit comments