From 3b67f1bd9248d0f05d2e6e0d7ad66312591259c3 Mon Sep 17 00:00:00 2001 From: Michael Baird Date: Thu, 1 Jun 2017 10:24:57 -0500 Subject: [PATCH] return an error if the BroadcastHandler CreateFrameMessage encounters an Index that does not exist --- server.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/server.go b/server.go index 84314cebe..66034e5d6 100644 --- a/server.go +++ b/server.go @@ -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 } }