| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 package memory | 5 package memory |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "fmt" | 8 "fmt" |
| 9 "strings" | 9 "strings" |
| 10 "testing" | 10 "testing" |
| (...skipping 505 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 516 for ns, ents := range byNs { | 516 for ns, ents := range byNs { |
| 517 c := info.Get(c).MustNamespace(n
s) | 517 c := info.Get(c).MustNamespace(n
s) |
| 518 data := ds.Get(c) | 518 data := ds.Get(c) |
| 519 if err := data.PutMulti(ents); e
rr != nil { | 519 if err := data.PutMulti(ents); e
rr != nil { |
| 520 // prevent Convey from t
hinking this assertion should show up in | 520 // prevent Convey from t
hinking this assertion should show up in |
| 521 // every test loop. | 521 // every test loop. |
| 522 panic(err) | 522 panic(err) |
| 523 } | 523 } |
| 524 } | 524 } |
| 525 | 525 |
| 526 » » » » » if err := data.DeleteMulti(stage.delEnts
); err != nil { | 526 » » » » » if err := data.DeleteMulti(stage.delEnts
...); err != nil { |
| 527 panic(err) | 527 panic(err) |
| 528 } | 528 } |
| 529 | 529 |
| 530 Convey(fmt.Sprintf("stage %d", i), func(
) { | 530 Convey(fmt.Sprintf("stage %d", i), func(
) { |
| 531 for j, expect := range stage.exp
ect { | 531 for j, expect := range stage.exp
ect { |
| 532 runner := func(f func(ic
context.Context) error, _ *ds.TransactionOptions) error { | 532 runner := func(f func(ic
context.Context) error, _ *ds.TransactionOptions) error { |
| 533 return f(c) | 533 return f(c) |
| 534 } | 534 } |
| 535 if expect.inTxn { | 535 if expect.inTxn { |
| 536 runner = data.Ru
nInTransaction | 536 runner = data.Ru
nInTransaction |
| (...skipping 102 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 639 | 639 |
| 640 v, ok := actual.(error) | 640 v, ok := actual.(error) |
| 641 if !ok { | 641 if !ok { |
| 642 return fmt.Sprintf("type of 'actual' must be error, not %T", act
ual) | 642 return fmt.Sprintf("type of 'actual' must be error, not %T", act
ual) |
| 643 } | 643 } |
| 644 if v == nil || v == ds.Stop { | 644 if v == nil || v == ds.Stop { |
| 645 return "" | 645 return "" |
| 646 } | 646 } |
| 647 return fmt.Sprintf("expected success value, not %v", v) | 647 return fmt.Sprintf("expected success value, not %v", v) |
| 648 } | 648 } |
| OLD | NEW |