Skip to content

Commit

Permalink
comment out clean-up channel associated with migration cleanup server
Browse files Browse the repository at this point in the history
  • Loading branch information
vkuznet committed Aug 26, 2022
1 parent a962dd4 commit 5b482a0
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions web/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -500,7 +500,7 @@ func Server(configFile string) {
}

migDone := make(chan bool)
clpDone := make(chan bool)
// clpDone := make(chan bool)
if Config.ServerType == "DBSMigration" {
go dbs.MigrationServer(dbs.MigrationServerInterval, dbs.MigrationProcessTimeout, migDone)
//go dbs.MigrationCleanupServer(dbs.MigrationCleanupInterval, dbs.MigrationCleanupOffset, clpDone)
Expand All @@ -525,9 +525,9 @@ func Server(configFile string) {
migDone <- true
}
// send notification to stop cleanup migration server
if Config.ServerType == "DBSMigration" {
clpDone <- true
}
// if Config.ServerType == "DBSMigration" {
// clpDone <- true
// }

// add extra timeout for shutdown service stuff
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
Expand Down

0 comments on commit 5b482a0

Please sign in to comment.