github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-08-18 08:29:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

🐛 Start watching scripts after the hub and front are ready

Browse Source
This commit is contained in:
M. Mert Yildiran 2023-11-03 01:05:03 +03:00
parent bed59e12ea
commit 7737bdf4fc
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
cmd/tapRunner.go
View File

@ -200,7 +200,6 @@ func watchHubPod(ctx context.Context, kubernetesProvider *kubernetes.Provider, c
ready.Lock() ready.Lock()
ready.Hub = true ready.Hub = true
ready.Unlock() ready.Unlock()
postHubStarted(ctx, kubernetesProvider, cancel)
} }
ready.Lock() ready.Lock()
@ -406,12 +405,6 @@ func watchHubEvents(ctx context.Context, kubernetesProvider *kubernetes.Provider
} }
} }
func postHubStarted(ctx context.Context, kubernetesProvider *kubernetes.Provider, cancel context.CancelFunc) {
if config.Config.Scripting.Source != "" && config.Config.Scripting.WatchScripts {
watchScripts(false)
}
}
func postFrontStarted(ctx context.Context, kubernetesProvider *kubernetes.Provider, cancel context.CancelFunc) { func postFrontStarted(ctx context.Context, kubernetesProvider *kubernetes.Provider, cancel context.CancelFunc) {
startProxyReportErrorIfAny( startProxyReportErrorIfAny(
kubernetesProvider, kubernetesProvider,
@ -435,6 +428,14 @@ func postFrontStarted(ctx context.Context, kubernetesProvider *kubernetes.Provid
if !config.Config.HeadlessMode { if !config.Config.HeadlessMode {
utils.OpenBrowser(url) utils.OpenBrowser(url)
} }
for !ready.Hub {
time.Sleep(100 * time.Millisecond)
}
if config.Config.Scripting.Source != "" && config.Config.Scripting.WatchScripts {
watchScripts(false)
}
} }
func updateConfig(kubernetesProvider *kubernetes.Provider) { func updateConfig(kubernetesProvider *kubernetes.Provider) {