| 196 | } |
| 197 | |
| 198 | void WriteCache::SaveLinMessage(const IChannelGroup& channel_group, uint64_t time, |
| 199 | const LinMessage& msg) { |
| 200 | msg.DataGroup(channel_group.DataGroup()); |
| 201 | msg.ChannelGroup(&channel_group); |
| 202 | if (SampleQueue* queue = GetSampleQueue(channel_group); |
| 203 | queue != nullptr) { |
| 204 | std::lock_guard lock(locker_); |
| 205 | queue->SaveLinMessage(channel_group, time, msg); |
| 206 | } |
| 207 | } |
| 208 | |
| 209 | |
| 210 |