@@ -30,8 +30,6 @@ Replay::Replay(QString route, QStringList allow, QStringList block, SubMaster *s
30
30
31
31
route_ = std::make_unique<Route>(route);
32
32
events_ = new std::vector<Event *>();
33
- device_id = cl_get_device_id (CL_DEVICE_TYPE_DEFAULT);
34
- context = CL_CHECK_ERR (clCreateContext (NULL , 1 , &device_id, NULL , NULL , &err));
35
33
// queueSegment is always executed in the main thread
36
34
connect (this , &Replay::segmentChanged, this , &Replay::queueSegment);
37
35
}
@@ -47,8 +45,6 @@ Replay::~Replay() {
47
45
stream_thread_->wait ();
48
46
}
49
47
50
- delete vipc_server;
51
- CL_CHECK (clReleaseContext (context));
52
48
delete pm;
53
49
delete events_;
54
50
segments_.clear ();
@@ -263,36 +259,7 @@ void Replay::stream() {
263
259
}
264
260
265
261
if (evt->frame ) {
266
- <<<<<<< HEAD
267
262
publishFrame (evt);
268
- =======
269
- // TODO: publish all frames
270
- if (evt->which == cereal::Event::ROAD_ENCODE_IDX) {
271
- auto idx = evt->event .getRoadEncodeIdx ();
272
- auto &seg = segments_[idx.getSegmentNum ()];
273
-
274
- if (seg && seg->isLoaded () && idx.getType () == cereal::EncodeIndex::Type::FULL_H_E_V_C) {
275
- auto &frm = seg->frames [RoadCam];
276
-
277
- if (vipc_server == nullptr ) {
278
- vipc_server = new VisionIpcServer (" camerad" , device_id, context);
279
- vipc_server->create_buffers (VisionStreamType::VISION_STREAM_RGB_BACK, UI_BUF_COUNT,
280
- true , frm->width , frm->height );
281
- vipc_server->start_listener ();
282
- }
283
-
284
- uint8_t *dat = frm->get (idx.getSegmentId ());
285
- if (dat) {
286
- VisionIpcBufExtra extra = {};
287
- VisionBuf *buf = vipc_server->get_buffer (VisionStreamType::VISION_STREAM_RGB_BACK);
288
- memcpy (buf->addr , dat, frm->getRGBSize ());
289
- vipc_server->send (buf, &extra, false );
290
- }
291
- }
292
- }
293
-
294
- // publish msg
295
- >>>>>>> relase context
296
263
} else {
297
264
// publish msg
298
265
if (sm == nullptr ) {
0 commit comments