Skip to content

Commit

Permalink
Tweak formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
babbageclunk committed Jun 27, 2016
1 parent f2d024e commit cd7f33e
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions txn/flusher.go
Original file line number Diff line number Diff line change
Expand Up @@ -287,8 +287,7 @@ NextDoc:
// Document missing. Use stash collection.
change.Upsert = true
chaos("")
err := f.applyUpsertToStash(dkey, change, &info)
if err != nil {
if err := f.applyUpsertToStash(dkey, change, &info); err != nil {
return nil, err
}
if info.Insert != "" {
Expand Down Expand Up @@ -796,8 +795,7 @@ func (f *flusher) apply(t *transaction, pull map[bson.ObjectId]*transaction) err
Upsert: true,
ReturnNew: true,
}
err = f.applyUpsertToStash(dkey, change, &stash)
if err != nil {
if err = f.applyUpsertToStash(dkey, change, &stash); err != nil {
return err
}
change = mgo.Change{
Expand Down

0 comments on commit cd7f33e

Please sign in to comment.