scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-15 08:41:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #597 from raskle/576-handler-missing-index

Browse source 
BroadcastHandler handle missing index
This commit is contained in:
Michael Baird 2017-06-01 15:44:08 -05:00 • committed by GitHub
commit 8cd8661241
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
server.go
View file

@ -297,7 +297,10 @@ func (s *Server) ReceiveMessage(pb proto.Message) error {
return err
}
case *internal.CreateFrameMessage:
index := s.Holder.Index(obj.Index)
idx := s.Holder.Index(obj.Index)
if idx == nil {
return fmt.Errorf("Local Index not found: %s", obj.Index)
}
opt := FrameOptions{
RowLabel: obj.Meta.RowLabel,
InverseEnabled: obj.Meta.InverseEnabled,
@ -305,13 +308,13 @@ func (s *Server) ReceiveMessage(pb proto.Message) error {
CacheSize: obj.Meta.CacheSize,
TimeQuantum: TimeQuantum(obj.Meta.TimeQuantum),
}
_, err := index.CreateFrame(obj.Frame, opt)
_, err := idx.CreateFrame(obj.Frame, opt)
if err != nil {
return err
}
case *internal.DeleteFrameMessage:
index := s.Holder.Index(obj.Index)
if err := index.DeleteFrame(obj.Frame); err != nil {
idx := s.Holder.Index(obj.Index)
if err := idx.DeleteFrame(obj.Frame); err != nil {
return err
}
}