cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adder: fix old mock rpc in tests

Browse Source
This commit is contained in:
Hector Sanjuan 2019-08-09 17:13:01 +02:00
parent fb2d427035
commit 3720d288a0
3 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
adder/adder_test.go
View File

@ -137,7 +137,7 @@ func TestAdder_ContextCancelled(t *testing.T) {
} }
t.Log(err) t.Log(err)
}() }()
time.Sleep(200 * time.Millisecond) time.Sleep(100 * time.Millisecond)
cancel() cancel()
wg.Wait() wg.Wait()
} }

3
adder/local/dag_service_test.go
View File

@ -28,8 +28,9 @@ func (rpcs *testIPFSRPC) BlockPut(ctx context.Context, in *api.NodeWithMeta, out
return nil return nil
} }
func (rpcs *testClusterRPC) Pin(ctx context.Context, in *api.Pin, out *struct{}) error { func (rpcs *testClusterRPC) Pin(ctx context.Context, in *api.Pin, out *api.Pin) error {
rpcs.pins.Store(in.Cid.String(), in) rpcs.pins.Store(in.Cid.String(), in)
*out = *in
return nil return nil
} }

3
adder/sharding/dag_service_test.go
View File

@ -32,8 +32,9 @@ func (rpcs *testRPC) BlockPut(ctx context.Context, in *api.NodeWithMeta, out *st
return nil return nil
} }
func (rpcs *testRPC) Pin(ctx context.Context, in *api.Pin, out *struct{}) error { func (rpcs *testRPC) Pin(ctx context.Context, in *api.Pin, out *api.Pin) error {
rpcs.pins.Store(in.Cid.String(), in) rpcs.pins.Store(in.Cid.String(), in)
*out = *in
return nil return nil
} }