()
| 1839 | } |
| 1840 | |
| 1841 | func (m *KV) storeCopy() map[string]ValueDesc { |
| 1842 | m.storeMu.Lock() |
| 1843 | defer m.storeMu.Unlock() |
| 1844 | |
| 1845 | result := make(map[string]ValueDesc, len(m.store)) |
| 1846 | for k, v := range m.store { |
| 1847 | result[k] = v.Clone() |
| 1848 | } |
| 1849 | return result |
| 1850 | } |
| 1851 | |
| 1852 | func (m *KV) addReceivedMessage(msg Message) { |
| 1853 | if m.cfg.MessageHistoryBufferBytes == 0 { |