()
| 1886 | } |
| 1887 | |
| 1888 | func (m *KV) deleteSentReceivedMessages() { |
| 1889 | m.messagesMu.Lock() |
| 1890 | defer m.messagesMu.Unlock() |
| 1891 | |
| 1892 | m.sentMessages = nil |
| 1893 | m.sentMessagesSize = 0 |
| 1894 | m.receivedMessages = nil |
| 1895 | m.receivedMessagesSize = 0 |
| 1896 | } |
| 1897 | |
| 1898 | func (m *KV) cleanupObsoleteEntries() { |
| 1899 | m.storeMu.Lock() |