jprdonnelly/steampipe
1
0
Fork 0
mirror of https://github.com/turbot/steampipe.git synced 2025-12-23 21:09:15 -05:00
Code Issues Packages Projects Releases Wiki Activity

plugin install and plugin update take a long time to shutdown the service. Closes #305

Browse Source
This commit is contained in:
Binaek Sarkar
2021-03-18 19:38:33 +05:30
committed by GitHub
parent 91bfe54e66
commit deb3014b5a
1 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cmd/plugin.go
View File

@@ -477,8 +477,8 @@ func refreshConnections() error {
var client *db.Client
if status == nil {
// the db service is not started - start it
db.StartService(db.InvokerInstaller)
defer db.Shutdown(client, db.InvokerInstaller)
db.StartService(db.InvokerPlugin)
defer func() { db.Shutdown(client, db.InvokerPlugin) }()
}
client, err = db.GetClient(false)
@@ -564,18 +564,14 @@ func getPluginConnectionMap() (map[string][]string, error) {
return nil, fmt.Errorf("Could not start steampipe service")
}
var client *db.Client
if status == nil {
// the db service is not started - start it
db.StartService(db.InvokerPlugin)
defer func() {
status, _ := db.GetStatus()
if status.Invoker == db.InvokerPlugin {
db.StopDB(true, db.InvokerPlugin)
}
}()
defer func() { db.Shutdown(client, db.InvokerPlugin) }()
}
client, err := db.GetClient(true)
client, err = db.GetClient(true)
if err != nil {
return nil, fmt.Errorf("Could not connect with steampipe service")
}