| 244 | } |
| 245 | |
| 246 | void WriteCache::SaveMostMessage(const IDataGroup& data_group, |
| 247 | const IChannelGroup& channel_group, uint64_t time, |
| 248 | const IMostEvent& msg) { |
| 249 | msg.DataGroup( &data_group); |
| 250 | msg.ChannelGroup(&channel_group); |
| 251 | |
| 252 | if (SampleQueue* queue = GetSampleQueue(data_group); |
| 253 | queue != nullptr) { |
| 254 | std::lock_guard lock(locker_); |
| 255 | queue->SaveMostMessage(channel_group, time, msg); |
| 256 | } |
| 257 | } |
| 258 | |
| 259 | void WriteCache::SaveFlexRayMessage(const IDataGroup& data_group, |
| 260 | const IChannelGroup& channel_group, uint64_t time, |