mtcontrib/mtsatellite
1
0
Fork 0
mirror of https://bitbucket.org/s_l_teichmann/mtsatellite synced 2024-12-24 17:20:18 +01:00
Code Issues Projects Releases Wiki Activity

Fixed bogus error handling in change tracking notification.

Browse Source
This commit is contained in:
Sascha L. Teichmann 2014-11-03 18:57:10 +01:00
parent cf9cbe7087
commit 52932b0351
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cmd/mtredisalize/changetracker.go
View File

@ -41,7 +41,7 @@ func (ct *ChangeTracker) BlockChanged(key []byte) {
ct.mutex.Unlock() ct.mutex.Unlock()
} }
func (ct *ChangeTracker) FlushChanges(url string) (err error) { func (ct *ChangeTracker) FlushChanges(url string) {
var oldChanges map[quantizedXZ]bool var oldChanges map[quantizedXZ]bool
ct.mutex.Lock() ct.mutex.Lock()
if len(ct.changes) > 0 { if len(ct.changes) > 0 {
@ -59,6 +59,7 @@ func (ct *ChangeTracker) FlushChanges(url string) (err error) {
changes[i] = change changes[i] = change
i++ i++
} }
var err error
var buf bytes.Buffer var buf bytes.Buffer
encoder := json.NewEncoder(&buf) encoder := json.NewEncoder(&buf)
if err = encoder.Encode(changes); err != nil { if err = encoder.Encode(changes); err != nil {