| 221 | } |
| 222 | |
| 223 | void WriteCache::SaveEthMessage(const IChannelGroup& channel_group, uint64_t time, |
| 224 | const EthMessage& msg) { |
| 225 | msg.DataGroup(channel_group.DataGroup()); |
| 226 | msg.ChannelGroup(&channel_group); |
| 227 | if (SampleQueue* queue = GetSampleQueue(channel_group); |
| 228 | queue != nullptr) { |
| 229 | std::lock_guard lock(locker_); |
| 230 | queue->SaveEthMessage(channel_group, time, msg); |
| 231 | } |
| 232 | } |
| 233 | |
| 234 | void WriteCache::SaveEthMessage(const IDataGroup& data_group, |
| 235 | const IChannelGroup& channel_group, uint64_t time, |