@@ -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 )
@@ -560,10 +556,6 @@ func (c *CollectEndorsementsView) distributeEvnToParty(context view.Context, ent
560556 if err != nil {
561557 return errors .Wrapf (err , "failed reading message on session [%s]" , session .Info ().ID )
562558 }
563- if len (sigma ) == 0 {
564- info := context .Session ().Info ()
565- return errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
566- }
567559 logger .Debugf ("received ack from [%s] [%s], checking signature on [%s]" ,
568560 entry .LongTerm , hash .Hashable (sigma ).String (),
569561 hash .Hashable (txRaw ).String ())
@@ -748,10 +740,6 @@ func (f *ReceiveTransactionView) Call(context view.Context) (interface{}, error)
748740 if err != nil {
749741 span .RecordError (err )
750742 }
751- if len (msg ) == 0 {
752- info := context .Session ().Info ()
753- return nil , errors .Errorf ("received empty message, session closed [%s:%v]" , info .ID , info .Closed )
754- }
755743 span .AddEvent ("receive_tx" )
756744
757745 if logger .IsEnabledFor (zapcore .DebugLevel ) {
0 commit comments