akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

mobile: return error in case lnd is already running

Browse Source
This commit is contained in:
Johan T. Halseth 2021-03-30 08:58:12 +02:00
parent 321141600e
commit 980beba985
No known key found for this signature in database
GPG Key ID: 15BAADA29DA20D26
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
mobile/bindings.go
View File

@ -3,9 +3,11 @@
package lndmobile package lndmobile
import ( import (
"errors"
"fmt" "fmt"
"os" "os"
"strings" "strings"
"sync/atomic"
flags "github.com/jessevdk/go-flags" flags "github.com/jessevdk/go-flags"
"github.com/lightningnetwork/lnd" "github.com/lightningnetwork/lnd"
@ -13,6 +15,10 @@ import (
"google.golang.org/grpc" "google.golang.org/grpc"
) )
// lndStarted will be used atomically to ensure only a singel lnd instance is
// attempted to be started at once.
var lndStarted int32
// Start starts lnd in a new goroutine. // Start starts lnd in a new goroutine.
// //
// extraArgs can be used to pass command line arguments to lnd that will // extraArgs can be used to pass command line arguments to lnd that will
@ -77,9 +83,19 @@ func Start(extraArgs string, rpcReady Callback) {
}, },
} }
// We only support a single lnd instance at a time (singleton) for now,
// so we make sure to return immediately if it has already been
// started.
if !atomic.CompareAndSwapInt32(&lndStarted, 0, 1) {
err := errors.New("lnd already started")
rpcReady.OnError(err)
return
}
// Call the "real" main in a nested manner so the defers will properly // Call the "real" main in a nested manner so the defers will properly
// be executed in the case of a graceful shutdown. // be executed in the case of a graceful shutdown.
go func() { go func() {
defer atomic.StoreInt32(&lndStarted, 0)
defer close(quit) defer close(quit)
if err := lnd.Main( if err := lnd.Main(