github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-18 10:21:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

🔨 Add more logging to PCAP runner

Browse Source
This commit is contained in:
M. Mert Yildiran 2022-12-28 05:48:47 +03:00
parent 46c5e18937
commit 09f1669627
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
cmd/tapPcapRunner.go
View File

@ -98,6 +98,8 @@ func createAndStartContainers(
workerIPAddr string, workerIPAddr string,
err error, err error,
) { ) {
log.Info().Msg("Creating containers...")
hostIP := "0.0.0.0" hostIP := "0.0.0.0"
hostConfigFront := &container.HostConfig{ hostConfigFront := &container.HostConfig{
@ -124,10 +126,6 @@ func createAndStartContainers(
return return
} }
if err = cli.ContainerStart(ctx, respFront.ID, types.ContainerStartOptions{}); err != nil {
return
}
hostConfigHub := &container.HostConfig{ hostConfigHub := &container.HostConfig{
PortBindings: nat.PortMap{ PortBindings: nat.PortMap{
nat.Port(fmt.Sprintf("%d/tcp", config.Config.Tap.Proxy.Hub.DstPort)): []nat.PortBinding{ nat.Port(fmt.Sprintf("%d/tcp", config.Config.Tap.Proxy.Hub.DstPort)): []nat.PortBinding{
@ -154,10 +152,6 @@ func createAndStartContainers(
return return
} }
if err = cli.ContainerStart(ctx, respHub.ID, types.ContainerStartOptions{}); err != nil {
return
}
cmdWorker := []string{"-f", "./import", "-port", fmt.Sprintf("%d", config.Config.Tap.Proxy.Worker.DstPort)} cmdWorker := []string{"-f", "./import", "-port", fmt.Sprintf("%d", config.Config.Tap.Proxy.Worker.DstPort)}
if config.DebugMode { if config.DebugMode {
cmdWorker = append(cmdWorker, fmt.Sprintf("-%s", config.DebugFlag)) cmdWorker = append(cmdWorker, fmt.Sprintf("-%s", config.DebugFlag))
@ -176,6 +170,16 @@ func createAndStartContainers(
return return
} }
log.Info().Msg("Starting containers...")
if err = cli.ContainerStart(ctx, respFront.ID, types.ContainerStartOptions{}); err != nil {
return
}
if err = cli.ContainerStart(ctx, respHub.ID, types.ContainerStartOptions{}); err != nil {
return
}
if err = cli.ContainerStart(ctx, respWorker.ID, types.ContainerStartOptions{}); err != nil { if err = cli.ContainerStart(ctx, respWorker.ID, types.ContainerStartOptions{}); err != nil {
return return
} }
@ -198,6 +202,7 @@ func stopAndRemoveContainers(
respHub container.ContainerCreateCreatedBody, respHub container.ContainerCreateCreatedBody,
respWorker container.ContainerCreateCreatedBody, respWorker container.ContainerCreateCreatedBody,
) (err error) { ) (err error) {
log.Warn().Msg("Stopping containers...")
err = cli.ContainerStop(ctx, respFront.ID, nil) err = cli.ContainerStop(ctx, respFront.ID, nil)
if err != nil { if err != nil {
return return
@ -211,6 +216,7 @@ func stopAndRemoveContainers(
return return
} }
log.Warn().Msg("Removing containers...")
err = cli.ContainerRemove(ctx, respFront.ID, types.ContainerRemoveOptions{}) err = cli.ContainerRemove(ctx, respFront.ID, types.ContainerRemoveOptions{})
if err != nil { if err != nil {
return return