@@ -352,10 +352,6 @@ func (c *CollectEndorsementsView) signRemote(context view.Context, party view.Id
352352 if err != nil {
353353 return nil , errors .Wrap (err , "failed reading message" )
354354 }
355- if len (sigma ) == 0 {
356- info := context .Session ().Info ()
357- return nil , errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
358- }
359355 verifier , err := verifierGetter (party )
360356 if err != nil {
361357 return nil , errors .Wrapf (err , "failed getting verifier for [%s]" , party )
@@ -566,10 +562,6 @@ func (c *CollectEndorsementsView) distributeEvnToParty(context view.Context, ent
566562 if err != nil {
567563 return errors .Wrapf (err , "failed reading message on session [%s]" , session .Info ().ID )
568564 }
569- if len (sigma ) == 0 {
570- info := context .Session ().Info ()
571- return errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
572- }
573565 logger .Debugf ("received ack from [%s] [%s], checking signature on [%s]" ,
574566 entry .LongTerm , hash .Hashable (sigma ).String (),
575567 hash .Hashable (txRaw ).String ())
@@ -754,10 +746,6 @@ func (f *ReceiveTransactionView) Call(context view.Context) (interface{}, error)
754746 if err != nil {
755747 span .RecordError (err )
756748 }
757- if len (msg ) == 0 {
758- info := context .Session ().Info ()
759- return nil , errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
760- }
761749 span .AddEvent ("receive_tx" )
762750
763751 if logger .IsEnabledFor (zapcore .DebugLevel ) {
0 commit comments