octoleo/gh-ost
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

some cleanup

Browse Source
This commit is contained in:
Shlomi Noach 2016-12-24 10:01:03 +02:00
parent e50361ab61
commit 6128076485
1 changed files with 4 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
go/logic/migrator.go
View File

@ -76,9 +76,7 @@ type Migrator struct {
copyRowsQueue chan tableWriteFunc
applyEventsQueue chan tableWriteFunc
handledChangelogStates map[string]bool
contextDumpFiles []string
panicAbort chan error
panicAbort chan error
}
func NewMigrator() *Migrator {
@ -90,12 +88,10 @@ func NewMigrator() *Migrator {
rowCopyComplete: make(chan bool),
allEventsUpToLockProcessed: make(chan string),
copyRowsQueue: make(chan tableWriteFunc),
applyEventsQueue: make(chan tableWriteFunc, applyEventsQueueBuffer),
handledChangelogStates: make(map[string]bool),
copyRowsQueue: make(chan tableWriteFunc),
applyEventsQueue: make(chan tableWriteFunc, applyEventsQueueBuffer),
contextDumpFiles: []string{},
panicAbort: make(chan error),
panicAbort: make(chan error),
}
return migrator
}