multi: improve comment grammar

This commit is contained in:
ffranr authored and Oliver Gugger committed 2024-08-22 18:33:24 +02:00
1 parent 9f3593a341
commit 7df093b3b1
3 files changed
+4 -4

No files matched your search

+1 -1
View File
@@ -331,7 +331,7 @@ type InterceptableHtlcForwarder interface {
type ForwardInterceptor func(InterceptedPacket) error type ForwardInterceptor func(InterceptedPacket) error
// InterceptedPacket contains the relevant information for the interceptor about // InterceptedPacket contains the relevant information for the interceptor about
// an htlc. // an HTLC.
type InterceptedPacket struct { type InterceptedPacket struct {
// IncomingCircuit contains the incoming channel and htlc id of the // IncomingCircuit contains the incoming channel and htlc id of the
// packet. // packet.
+2 -2
View File
@@ -22,7 +22,7 @@ var (
ErrMissingPreimage = errors.New("missing preimage") ErrMissingPreimage = errors.New("missing preimage")
) )
// forwardInterceptor is a helper struct that handles the lifecycle of an rpc // forwardInterceptor is a helper struct that handles the lifecycle of an RPC
// interceptor streaming session. // interceptor streaming session.
// It is created when the stream opens and disconnects when the stream closes. // It is created when the stream opens and disconnects when the stream closes.
type forwardInterceptor struct { type forwardInterceptor struct {
@@ -43,7 +43,7 @@ func newForwardInterceptor(htlcSwitch htlcswitch.InterceptableHtlcForwarder,
} }
// run sends the intercepted packets to the client and receives the // run sends the intercepted packets to the client and receives the
// corersponding responses. On one hand it registered itself as an interceptor // corresponding responses. On one hand it registered itself as an interceptor
// that receives the switch packets and on the other hand launches a go routine // that receives the switch packets and on the other hand launches a go routine
// to read from the client stream. // to read from the client stream.
// To coordinate all this and make sure it is safe for concurrent access all // To coordinate all this and make sure it is safe for concurrent access all
+1 -1
View File
@@ -1525,7 +1525,7 @@ func (s *Server) HtlcInterceptor(stream Router_HtlcInterceptorServer) error {
} }
defer atomic.CompareAndSwapInt32(&s.forwardInterceptorActive, 1, 0) defer atomic.CompareAndSwapInt32(&s.forwardInterceptorActive, 1, 0)
// run the forward interceptor. // Run the forward interceptor.
return newForwardInterceptor( return newForwardInterceptor(
s.cfg.RouterBackend.InterceptableForwarder, stream, s.cfg.RouterBackend.InterceptableForwarder, stream,
).run() ).run()