fix(logic): avoid killing querying goroutine on gas limit exceeded

x/logic/keeper/grpc_query_ask.go

@@ -34,13 +34,6 @@ func (k Keeper) Ask(ctx goctx.Context, req *types.QueryServiceAskRequest) (respo
 
 			panic(r)
 		}
-		if sdkCtx.GasMeter().IsOutOfGas() {
-			response, err = nil, sdkerrors.Wrapf(
-				types.LimitExceeded, "out of gas: %s (%d/%d)",
-				types.ModuleName, sdkCtx.GasMeter().GasConsumed(), sdkCtx.GasMeter().Limit())
-
-			return
-		}
 	}()
 	sdkCtx.GasMeter().ConsumeGas(sdkCtx.GasMeter().GasConsumed(), types.ModuleName)
 

x/logic/keeper/interpreter.go

@@ -73,6 +73,10 @@ func (k Keeper) execute(ctx goctx.Context, program, query string) (*types.QueryS
 		results = append(results, types.Result{Substitutions: m.ToSubstitutions()})
 	}
 
+	if sols.Err() != nil && sdkCtx.GasMeter().IsOutOfGas() {
+		panic(sdk.ErrorOutOfGas{Descriptor: "Prolog interpreter execution"})
+	}
+
 	return &types.QueryServiceAskResponse{
 		Height:  uint64(sdkCtx.BlockHeight()),
 		GasUsed: sdkCtx.GasMeter().GasConsumed(),

x/logic/meter/safe.go

@@ -1,7 +1,6 @@
 package meter
 
 import (
-	"runtime"
 	"sync"
 
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -25,20 +24,6 @@ func WithSafeMeter(gasMeter sdk.GasMeter) sdk.GasMeter {
 // ConsumeGas consumes the given amount of gas from the decorated gas meter.
 func (m *safeMeterDecorater) ConsumeGas(amount uint64, descriptor string) {
 	m.mutex.Lock()
-	defer func() {
-		if r := recover(); r != nil {
-			if _, ok := r.(sdk.ErrorOutOfGas); ok {
-				// Since predicate is called into a goroutine, when out of gas is thrown, the main caller
-				// (grpc: https://github.com/okp4/okp4d/blob/main/x/logic/keeper/grpc_query_ask.go#L25-L36, or querier)
-				// cannot recover ErrOutOfGas. To avoid the chain panicking, we need to exit without panic.
-				// Goexit runs all deferred calls before terminating the goroutine. Because Goexit
-				// is not a panic, any recover calls in those deferred functions will return nil.
-				// This is a temporary solution before implementing a context cancellation.
-				runtime.Goexit()
-			}
-			panic(r)
-		}
-	}()
 	defer m.mutex.Unlock()
 
 	m.gasMeter.ConsumeGas(amount, descriptor)