Index: state/relationunit.go |
=== modified file 'state/relationunit.go' |
--- state/relationunit.go 2013-05-31 01:02:53 +0000 |
+++ state/relationunit.go 2013-06-13 07:59:07 +0000 |
@@ -128,7 +128,7 @@ |
} |
// Now run the complete transaction, or figure out why we can't. |
- if err := ru.st.runner.Run(ops, "", nil); err != txn.ErrAborted { |
+ if err := ru.st.runTransaction(ops); err != txn.ErrAborted { |
return err |
} |
if count, err := ru.st.relationScopes.FindId(ruKey).Count(); err != nil { |
@@ -284,7 +284,7 @@ |
} |
ops = append(ops, relOps...) |
} |
- if err = ru.st.runner.Run(ops, "", nil); err != txn.ErrAborted { |
+ if err = ru.st.runTransaction(ops); err != txn.ErrAborted { |
if err != nil { |
return fmt.Errorf("cannot leave scope for %s: %v", desc, err) |
} |