Merge pull request #380 from AkihiroSuda/fix-events-test
Fix compilation error in events/events_test.go
This commit is contained in:
commit
95c13af2f9
1 changed files with 4 additions and 4 deletions
|
@ -12,19 +12,19 @@ func TestBasicEvent(t *testing.T) {
|
||||||
// simulate a layer pull with events
|
// simulate a layer pull with events
|
||||||
ctx, commit, _ := WithTx(ctx)
|
ctx, commit, _ := WithTx(ctx)
|
||||||
|
|
||||||
G(ctx).Post("pull ubuntu")
|
G(ctx).Post(ctx, "pull ubuntu")
|
||||||
|
|
||||||
for layer := 0; layer < 4; layer++ {
|
for layer := 0; layer < 4; layer++ {
|
||||||
// make a subtransaction for each layer
|
// make a subtransaction for each layer
|
||||||
ctx, commit, _ := WithTx(ctx)
|
ctx, commit, _ := WithTx(ctx)
|
||||||
|
|
||||||
G(ctx).Post(fmt.Sprintf("fetch layer %v", layer))
|
G(ctx).Post(ctx, fmt.Sprintf("fetch layer %v", layer))
|
||||||
|
|
||||||
ctx = WithTopic(ctx, "content")
|
ctx = WithTopic(ctx, "content")
|
||||||
// simulate sub-operations with a separate topic, on the content store
|
// simulate sub-operations with a separate topic, on the content store
|
||||||
G(ctx).Post(fmt.Sprintf("received sha:256"))
|
G(ctx).Post(ctx, fmt.Sprintf("received sha:256"))
|
||||||
|
|
||||||
G(ctx).Post(fmt.Sprintf("unpack layer %v", layer))
|
G(ctx).Post(ctx, fmt.Sprintf("unpack layer %v", layer))
|
||||||
|
|
||||||
commit()
|
commit()
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue