Skip to content
Snippets Groups Projects
Commit 8a32c0d3 authored by Jono Wenger's avatar Jono Wenger
Browse files

More fixes

parent 244622df
No related branches found
No related tags found
3 merge requests!510Release,!207WIP: Client Restructure,!203Symmetric broadcast
...@@ -7,6 +7,7 @@ ...@@ -7,6 +7,7 @@
package utility package utility
/*
import ( import (
"encoding/binary" "encoding/binary"
"encoding/json" "encoding/json"
...@@ -164,3 +165,4 @@ func (emb *E2eMessageBuffer) Failed(m message.Send, p params.E2E) { ...@@ -164,3 +165,4 @@ func (emb *E2eMessageBuffer) Failed(m message.Send, p params.E2E) {
emb.mb.Failed(e2eMessage{m.Recipient.Marshal(), emb.mb.Failed(e2eMessage{m.Recipient.Marshal(),
m.Payload, uint32(m.MessageType), p}) m.Payload, uint32(m.MessageType), p})
} }
*/
...@@ -29,11 +29,11 @@ func StoreGroup(kv *versioned.KV, grp *cyclic.Group, key string) error { ...@@ -29,11 +29,11 @@ func StoreGroup(kv *versioned.KV, grp *cyclic.Group, key string) error {
Data: data, Data: data,
} }
return kv.Set(key, currentE2EMessageVersion, &obj) return kv.Set(key, currentGroupVersion, &obj)
} }
func LoadGroup(kv *versioned.KV, key string) (*cyclic.Group, error) { func LoadGroup(kv *versioned.KV, key string) (*cyclic.Group, error) {
vo, err := kv.Get(key, currentE2EMessageVersion) vo, err := kv.Get(key, currentGroupVersion)
if err != nil { if err != nil {
return nil, err return nil, err
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment