Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
895146b472
|
|||
|
522012d7d5
|
|||
|
a3c33d7ec1
|
|||
|
d7f28413b2
|
@@ -14,7 +14,7 @@ import (
|
||||
"github.com/redis/go-redis/v9"
|
||||
)
|
||||
|
||||
const VERSION = "1.1.0"
|
||||
const VERSION = "1.1.2"
|
||||
|
||||
// Arguments описывает аргументы командной строки
|
||||
type Arguments struct {
|
||||
|
||||
@@ -196,6 +196,9 @@ func CheckChannels(pls playlist.Playlist) playlist.Playlist {
|
||||
return pls
|
||||
}
|
||||
|
||||
pls.OnlineCount = 0
|
||||
pls.OfflineCount = 0
|
||||
|
||||
timeout, routines := calcParameters(count)
|
||||
httpClient := http.Client{Timeout: timeout}
|
||||
chSemaphores := make(chan struct{}, routines)
|
||||
|
||||
16
cmd/check.go
16
cmd/check.go
@@ -35,13 +35,8 @@ var checkCmd = &cobra.Command{
|
||||
}
|
||||
|
||||
currentIteration := 1
|
||||
iterationCount := app.Args.RepeatCount
|
||||
if iterationCount <= 0 {
|
||||
iterationCount = 1
|
||||
}
|
||||
|
||||
for {
|
||||
if app.Args.RepeatCount > 1 {
|
||||
if app.Args.RepeatCount != 1 {
|
||||
log.Printf(
|
||||
"@ New iteration current=%d count=%d\n",
|
||||
currentIteration,
|
||||
@@ -65,11 +60,12 @@ var checkCmd = &cobra.Command{
|
||||
fmt.Println(string(marshal))
|
||||
}
|
||||
|
||||
if app.Args.RepeatCount <= 1 || uint(currentIteration) == app.Args.RepeatCount {
|
||||
break
|
||||
if app.Args.RepeatCount != 0 {
|
||||
if uint(currentIteration) == app.Args.RepeatCount {
|
||||
break
|
||||
}
|
||||
currentIteration++
|
||||
}
|
||||
|
||||
currentIteration++
|
||||
log.Printf("Waiting for new iteration... seconds=%d\n", app.Args.RepeatEverySec)
|
||||
time.Sleep(time.Duration(app.Args.RepeatEverySec) * time.Second)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user