diff --git a/server.go b/server.go index 6903c216b..fe69a1457 100644 --- a/server.go +++ b/server.go @@ -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.