()
| 1878 | } |
| 1879 | |
| 1880 | func (m *KV) getSentAndReceivedMessages() (sent, received []Message) { |
| 1881 | m.messagesMu.Lock() |
| 1882 | defer m.messagesMu.Unlock() |
| 1883 | |
| 1884 | // Make copy of both slices. |
| 1885 | return append([]Message(nil), m.sentMessages...), append([]Message(nil), m.receivedMessages...) |
| 1886 | } |
| 1887 | |
| 1888 | func (m *KV) deleteSentReceivedMessages() { |
| 1889 | m.messagesMu.Lock() |