scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-10-06 19:07:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

reverted the broadcaster handler for internal.CreateFrameMessage

Browse source
This commit is contained in:
Michael Baird 2017-06-16 13:25:45 -05:00
parent 64b51f3bc3
commit 8c8f863943
1 changed files with 4 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
server.go
View file

@ -311,8 +311,10 @@ func (s *Server) ReceiveMessage(pb proto.Message) error {
CacheSize: obj.Meta.CacheSize,
TimeQuantum: TimeQuantum(obj.Meta.TimeQuantum),
}
err := s.createFrame(idx, obj.Frame, opt)
return err
_, err := idx.CreateFrame(obj.Frame, opt)
if err != nil {
return err
}
case *internal.DeleteFrameMessage:
idx := s.Holder.Index(obj.Index)
if err := idx.DeleteFrame(obj.Frame); err != nil {
@ -328,14 +330,6 @@ func (s *Server) ReceiveMessage(pb proto.Message) error {
return nil
}
func (s *Server) createFrame(idx *Index, frame string, opt FrameOptions) error {
_, err := idx.CreateFrame(frame, opt)
if err != nil {
return err
}
return nil
}
// LocalStatus returns the state of the local node as well as the
// holder (indexes/frames) according to the local node.
// In a gossip implementation, memberlist.Delegate.LocalState() uses this.