@@ -355,10 +355,6 @@ func (c *CollectEndorsementsView) signRemote(context view.Context, party view.Id
355355 if err != nil {
356356 return nil , errors .Wrap (err , "failed reading message" )
357357 }
358- if len (sigma ) == 0 {
359- info := context .Session ().Info ()
360- return nil , errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
361- }
362358 verifier , err := verifierGetter (party )
363359 if err != nil {
364360 return nil , errors .Wrapf (err , "failed getting verifier for [%s]" , party )
@@ -564,10 +560,6 @@ func (c *CollectEndorsementsView) distributeEvnToParty(context view.Context, ent
564560 if err != nil {
565561 return errors .Wrapf (err , "failed reading message on session [%s]" , session .Info ().ID )
566562 }
567- if len (sigma ) == 0 {
568- info := context .Session ().Info ()
569- return errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
570- }
571563 logger .Debugf ("received ack from [%s] [%s], checking signature on [%s]" ,
572564 entry .LongTerm , hash .Hashable (sigma ).String (),
573565 hash .Hashable (txRaw ).String ())
@@ -751,10 +743,6 @@ func (f *ReceiveTransactionView) Call(context view.Context) (interface{}, error)
751743 if err != nil {
752744 span .RecordError (err )
753745 }
754- if len (msg ) == 0 {
755- info := context .Session ().Info ()
756- return nil , errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
757- }
758746 span .AddEvent ("receive_tx" )
759747
760748 if logger .IsEnabledFor (zapcore .DebugLevel ) {
0 commit comments