Skip to content

Commit

Permalink
Make sure we signal, even during an error...
Browse files Browse the repository at this point in the history
  • Loading branch information
brett19 committed Jan 14, 2015
1 parent 0c5c656 commit 1ebe475
Showing 1 changed file with 13 additions and 16 deletions.
29 changes: 13 additions & 16 deletions bucket.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,17 +33,16 @@ func (b *Bucket) hlpGetExec(valuePtr interface{}, execFn hlpGetHandler) (valOut
go func() {
if err != nil {
errOut = err
return
}
} else {
value, err := b.decodeValue(bytes, flags, valuePtr)
if err != nil {
errOut = err
} else {
valOut = value
casOut = cas
}

value, err := b.decodeValue(bytes, flags, valuePtr)
if err != nil {
errOut = err
return
}

valOut = value
casOut = cas
signal <- true
}()
})
Expand All @@ -68,10 +67,9 @@ func (b *Bucket) hlpCasExec(execFn hlpCasHandler) (casOut uint64, errOut error)
go func() {
if err != nil {
errOut = err
return
} else {
casOut = cas
}

casOut = cas
signal <- true
}()
})
Expand All @@ -96,11 +94,10 @@ func (b *Bucket) hlpCtrExec(execFn hlpCtrHandler) (valOut uint64, casOut uint64,
go func() {
if err != nil {
errOut = err
return
} else {
valOut = value
casOut = cas
}

valOut = value
casOut = cas
signal <- true
}()
})
Expand Down

0 comments on commit 1ebe475

Please sign in to comment.