pkg/rpcserver: don't fail requests in LocalRun

It's assumed that the caller would use a context to control waits on
individual requests.

1 files changed, 0 insertions, 19 deletions

diff --git a/pkg/rpcserver/local.go b/pkg/rpcserver/local.go
index 27c0aac4a..d30e3acfc 100644
--- a/pkg/rpcserver/local.go
+++ b/pkg/rpcserver/local.go
@@ -5,11 +5,9 @@ package rpcserver
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"os"
 	"os/exec"
-	"time"
 
 	"github.com/google/syzkaller/pkg/cover"
 	"github.com/google/syzkaller/pkg/flatrpc"
@@ -100,23 +98,6 @@ func RunLocal(cfg *LocalConfig) error {
 		cmd.Process.Kill()
 		<-res
 	}
-	if !cfg.HandleInterrupts {
-		// If the executor has crashed early, reply to all remaining requests to unblock tests.
-	loop:
-		for {
-			req := serv.execSource.Next()
-			if req == nil {
-				select {
-				case <-cfg.Context.Done():
-					break loop
-				default:
-					time.Sleep(time.Millisecond)
-					continue loop
-				}
-			}
-			req.Done(&queue.Result{Status: queue.ExecFailure, Err: errors.New("executor crashed")})
-		}
-	}
 	return cmdErr
 }