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

Fix tests with new host lifecycle handling

Browse Source
This commit is contained in:
Hector Sanjuan 2019-05-25 00:53:43 +02:00
parent ab46f233e7
commit a1d95f5637
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ipfscluster_test.go
View File

@ -705,6 +705,7 @@ func TestClustersStatusAllWithErrors(t *testing.T) {
// shutdown 1 cluster peer
clusters[1].Shutdown(ctx)
clusters[1].host.Close()
delay()
f := func(t *testing.T, c *Cluster) {
@ -740,7 +741,7 @@ func TestClustersStatusAllWithErrors(t *testing.T) {
}
if errst.Status != api.TrackerStatusClusterError {
t.Error("erroring status should be set to ClusterError")
t.Error("erroring status should be set to ClusterError:", errst.Status)
}
// now check with Cid status
@ -752,7 +753,7 @@ func TestClustersStatusAllWithErrors(t *testing.T) {
pinfo := status.PeerMap[pid]
if pinfo.Status != api.TrackerStatusClusterError {
t.Error("erroring status should be ClusterError")
t.Error("erroring status should be ClusterError:", pinfo.Status)
}
if !pinfo.Cid.Equals(h) {
@ -1817,7 +1818,9 @@ func TestClustersGraphUnhealthy(t *testing.T) {
}
clusters[discon1].Shutdown(ctx)
clusters[discon1].host.Close()
clusters[discon2].Shutdown(ctx)
clusters[discon2].host.Close()
waitForLeaderAndMetrics(t, clusters)