12343072627

Committed 15 Dec 2024 11:09PM UTC coverage: 57.504% (-1.1%) from 58.636%

Build # 12343072627

Build Type

Pull #9315

github

Committed by

yyforyongyu

Commit Message

contractcourt: offer outgoing htlc one block earlier before its expiry

We need to offer the outgoing htlc one block earlier to make sure when
the expiry height hits, the sweeper will not miss sweeping it in the
same block. This also means the outgoing contest resolver now only does
one thing - watch for preimage spend till height expiry-1, which can
easily be moved into the timeout resolver instead in the future.

Pull Request Pull Request #9315: Implement `blockbeat`

Run Details

1445 of 2007 new or added lines in 26 files covered. (72.0%)

19246 existing lines in 249 files now uncovered.

102342 of 177975 relevant lines covered (57.5%)

24772.24 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

45.45

/lncfg/rpcmiddleware.go

package lncfg

import (
        "fmt"
        "time"
)

const (
        // defaultRPCMiddlewareTimeout is the time after which a request sent to
        // a gRPC interception middleware times out. This value is chosen very
        // low since in a worst case scenario that time is added to a request's
        // full duration twice (request and response interception) if a
        // middleware is very slow.
        defaultRPCMiddlewareTimeout = 2 * time.Second
)

// RPCMiddleware holds the configuration for RPC interception middleware.
//
//nolint:ll
type RPCMiddleware struct {
        Enable           bool          `long:"enable" description:"Enable the RPC middleware interceptor functionality."`
        InterceptTimeout time.Duration `long:"intercepttimeout" description:"Time after which a RPC middleware intercept request will time out and return an error if it hasn't yet received a response."`
        Mandatory        []string      `long:"addmandatory" description:"Add the named middleware to the list of mandatory middlewares. All RPC requests are blocked/denied if any of the mandatory middlewares is not registered. Can be specified multiple times."`
}

// Validate checks the values configured for the RPC middleware.
func (r *RPCMiddleware) Validate() error {
        if r.InterceptTimeout < 0 {
                return fmt.Errorf("RPC middleware intercept timeout cannot " +
                        "be negative")
        }

        return nil
}

// DefaultRPCMiddleware returns the default values for the RPC interception
// middleware configuration.
func DefaultRPCMiddleware() *RPCMiddleware {
        return &RPCMiddleware{
                InterceptTimeout: defaultRPCMiddlewareTimeout,
        }
}

1	package lncfg
2
3	import (
4	"fmt"
5	"time"
6	)
7
8	const (
9	// defaultRPCMiddlewareTimeout is the time after which a request sent to
10	// a gRPC interception middleware times out. This value is chosen very
11	// low since in a worst case scenario that time is added to a request's
12	// full duration twice (request and response interception) if a
13	// middleware is very slow.
14	defaultRPCMiddlewareTimeout = 2 * time.Second
15	)
16
17	// RPCMiddleware holds the configuration for RPC interception middleware.
18	//
19	//nolint:ll
20	type RPCMiddleware struct {
21	Enable bool `long:"enable" description:"Enable the RPC middleware interceptor functionality."`
22	InterceptTimeout time.Duration `long:"intercepttimeout" description:"Time after which a RPC middleware intercept request will time out and return an error if it hasn't yet received a response."`
23	Mandatory []string `long:"addmandatory" description:"Add the named middleware to the list of mandatory middlewares. All RPC requests are blocked/denied if any of the mandatory middlewares is not registered. Can be specified multiple times."`
24	}
25
26	// Validate checks the values configured for the RPC middleware.
UNCOV 27	func (r *RPCMiddleware) Validate() error {	×
UNCOV 28	if r.InterceptTimeout < 0 {	×
29	return fmt.Errorf("RPC middleware intercept timeout cannot " +	×
30	"be negative")	×
31	}	×
32
UNCOV 33	return nil	×
34	}
35
36	// DefaultRPCMiddleware returns the default values for the RPC interception
37	// middleware configuration.
38	func DefaultRPCMiddleware() *RPCMiddleware {	1✔
39	return &RPCMiddleware{	1✔
40	InterceptTimeout: defaultRPCMiddlewareTimeout,	1✔
41	}	1✔
42	}	1✔

lightningnetwork / lnd / 12343072627

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous