We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
message
1 parent 0610569 commit 7eebcefCopy full SHA for 7eebcef
message.go
@@ -48,17 +48,22 @@ func newMessageFromBuf(b []byte) (*message, error) {
48
}
49
50
func (m *message) add(key, val string, expired int64, deleted bool) {
51
+ m.mux.Lock()
52
m.Entries[key] = entry{
53
Key: key,
54
Val: val,
55
Expired: expired,
56
Deleted: deleted,
57
58
+ m.mux.Unlock()
59
60
61
// Encode implements mesh.GossipData.Encode
62
// TODO: split the encoding by X number of keys
63
func (m *message) Encode() [][]byte {
64
+ m.mux.RLock()
65
+ defer m.mux.RUnlock()
66
+
67
b, err := marshal(m)
68
if err != nil {
69
log.Printf("failed to encode message: %v", err)
0 commit comments