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

Merge pull request #5213 from hsjoberg/mobile-moveup

Browse Source 
mobile: Move lndStarted check to the top of the Start function
This commit is contained in:
Olaoluwa Osuntokun 2021-04-20 09:16:55 -07:00 committed by GitHub
commit 1a8d1874a5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
mobile/bindings.go
View File

@ -31,6 +31,15 @@ var lndStarted int32
// current app directory in order to ensure lnd has the permissions needed to
// write to it.
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
}
// (Re-)initialize the in-mem gRPC listeners we're going to give to lnd.
// This is required each time lnd is started, because when lnd shuts
// down, the in-mem listeners are closed.
@ -58,6 +67,7 @@ func Start(extraArgs string, rpcReady Callback) {
// Hook interceptor for os signals.
shutdownInterceptor, err := signal.Intercept()
if err != nil {
atomic.StoreInt32(&lndStarted, 0)
_, _ = fmt.Fprintln(os.Stderr, err)
rpcReady.OnError(err)
return
@ -67,6 +77,7 @@ func Start(extraArgs string, rpcReady Callback) {
// line options. This function will also set up logging properly.
loadedConfig, err := lnd.LoadConfig(shutdownInterceptor)
if err != nil {
atomic.StoreInt32(&lndStarted, 0)
_, _ = fmt.Fprintln(os.Stderr, err)
rpcReady.OnError(err)
return
@ -88,15 +99,6 @@ 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
// be executed in the case of a graceful shutdown.
go func() {