| 257 | } |
| 258 | |
| 259 | void WriteCache::SaveFlexRayMessage(const IDataGroup& data_group, |
| 260 | const IChannelGroup& channel_group, uint64_t time, |
| 261 | const IFlexRayEvent& msg) { |
| 262 | msg.DataGroup( &data_group); |
| 263 | msg.ChannelGroup(&channel_group); |
| 264 | |
| 265 | if (SampleQueue* queue = GetSampleQueue(data_group); |
| 266 | queue != nullptr) { |
| 267 | std::lock_guard lock(locker_); |
| 268 | queue->SaveFlexRayMessage(channel_group, time, msg); |
| 269 | } |
| 270 | } |
| 271 | SampleQueue* WriteCache::GetSampleQueue( |
| 272 | const IDataGroup& data_group) const { |
| 273 | if (auto itr = cache_.find(&data_group); |