Skip to content
Snippets Groups Projects
Commit c2b52f4b authored by Josh Brooks's avatar Josh Brooks
Browse files

WIP: Add ring buffer store to session

parent 9b3af620
No related branches found
No related tags found
3 merge requests!117Release,!116Dev,!84Ring buffer for received message (KV backed work done)
......@@ -70,6 +70,7 @@ type Session struct {
uncheckedRounds *rounds.UncheckedRoundStore
hostList *hostList.Store
edgeCheck *edge.Store
ringBuff *conversation.Buff
}
// Initialize a new Session object
......@@ -161,6 +162,13 @@ func New(baseDir, password string, u userInterface.User, currentVersion version.
if err != nil {
return nil, errors.WithMessage(err, "Failed to edge check store")
}
// Todo: implement with a specified bufflen (from pareters or a
// constant?
//s.ringBuff, err = conversation.NewBuff(s.kv, buffLen)
//if err != nil {
// return nil, errors.WithMessage(err, "Failed to create ring buffer store")
//}
return s, nil
}
......@@ -244,6 +252,11 @@ func Load(baseDir, password string, currentVersion version.Version,
return nil, errors.WithMessage(err, "Failed to load edge check store")
}
s.ringBuff, err = conversation.LoadBuff(s.kv)
if err != nil {
return nil, errors.WithMessage(err, "Failed to load ring buffer store")
}
return s, nil
}
......@@ -441,5 +454,10 @@ func InitTestingSession(i interface{}) *Session {
jww.FATAL.Panicf("Failed to create new edge Store: %+v", err)
}
s.ringBuff, err = conversation.NewBuff(s.kv, 100)
if err != nil {
jww.FATAL.Panicf("Failed to create ring buffer store: %+v", err)
}
return s
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment