htlcswitch: log err in the end in handleUpstreamMsg

htlcswitch/link.go

@@ -1916,66 +1916,32 @@ func (l *channelLink) handleUpstreamMsg(ctx context.Context,
 		return
 	}
 
+	var err error
+
 	switch msg := msg.(type) {
 	case *lnwire.UpdateAddHTLC:
-		err := l.processRemoteUpdateAddHTLC(msg)
+		err = l.processRemoteUpdateAddHTLC(msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote ADD: %v", err)
-			return
-		}
 
 	case *lnwire.UpdateFulfillHTLC:
-		err := l.processRemoteUpdateFulfillHTLC(msg)
+		err = l.processRemoteUpdateFulfillHTLC(msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote fulfill: %v",
-				err)
-
-			return
-		}
 
 	case *lnwire.UpdateFailMalformedHTLC:
-		err := l.processRemoteUpdateFailMalformedHTLC(msg)
+		err = l.processRemoteUpdateFailMalformedHTLC(msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote fail "+
-				"malformed: %v", err)
-
-			return
-		}
 
 	case *lnwire.UpdateFailHTLC:
-		err := l.processRemoteUpdateFailHTLC(msg)
+		err = l.processRemoteUpdateFailHTLC(msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote fail: %v", err)
-			return
-		}
 
 	case *lnwire.CommitSig:
-		err := l.processRemoteCommitSig(ctx, msg)
+		err = l.processRemoteCommitSig(ctx, msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote commit sig: %v",
-				err)
-
-			return
-		}
 
 	case *lnwire.RevokeAndAck:
-		err := l.processRemoteRevokeAndAck(ctx, msg)
+		err = l.processRemoteRevokeAndAck(ctx, msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote revoke: %v", err)
-			return
-		}
 
 	case *lnwire.UpdateFee:
-		err := l.processRemoteUpdateFee(msg)
+		err = l.processRemoteUpdateFee(msg)
-		if err != nil {
-			l.log.Errorf("failed to process remote update fee: %v",
-				err)
-
-			return
-		}
 
 	case *lnwire.Stfu:
-		err := l.handleStfu(msg)
+		err = l.handleStfu(msg)
 		if err != nil {
 			l.stfuFailf("handleStfu: %v", err.Error())
 		}
@@ -1993,6 +1959,11 @@ func (l *channelLink) handleUpstreamMsg(ctx context.Context,
 	default:
 		l.log.Warnf("received unknown message of type %T", msg)
 	}
+
+	if err != nil {
+		l.log.Errorf("failed to process remote %v: %v", msg.MsgType(),
+			err)
+	}
 }
 
 // handleStfu implements the top-level logic for handling the Stfu message from