forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/storage/localstore: re-enable pull subs tests for travis race

Browse source
This commit is contained in:
Janos Guljas 2019-02-21 12:29:01 +01:00
parent 09c184aa0e
commit 68f1e07f7e
1 changed files with 0 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
swarm/storage/localstore/subscription_pull_test.go
View file

@ -20,13 +20,11 @@ import (
"bytes" "bytes"
"context" "context"
"fmt" "fmt"
"os"
"sync" "sync"
"testing" "testing"
"time" "time"
"github.com/ethereum/go-ethereum/swarm/storage" "github.com/ethereum/go-ethereum/swarm/storage"
"github.com/ethereum/go-ethereum/swarm/testutil"
) )
// TestDB_SubscribePull uploads some chunks before and after // TestDB_SubscribePull uploads some chunks before and after
@ -34,12 +32,6 @@ import (
// all addresses are received in the right order // all addresses are received in the right order
// for expected proximity order bins. // for expected proximity order bins.
func TestDB_SubscribePull(t *testing.T) { func TestDB_SubscribePull(t *testing.T) {
if testutil.RaceEnabled && os.Getenv("TRAVIS") == "true" {
t.Skip("does not complete with -race on Travis")
// Note: related ticket TODO
}
db, cleanupFunc := newTestDB(t, nil) db, cleanupFunc := newTestDB(t, nil)
defer cleanupFunc() defer cleanupFunc()
@ -87,12 +79,6 @@ func TestDB_SubscribePull(t *testing.T) {
// validates if all addresses are received in the right order // validates if all addresses are received in the right order
// for expected proximity order bins. // for expected proximity order bins.
func TestDB_SubscribePull_multiple(t *testing.T) { func TestDB_SubscribePull_multiple(t *testing.T) {
if testutil.RaceEnabled && os.Getenv("TRAVIS") == "true" {
t.Skip("does not complete with -race on Travis")
// Note: related ticket TODO
}
db, cleanupFunc := newTestDB(t, nil) db, cleanupFunc := newTestDB(t, nil)
defer cleanupFunc() defer cleanupFunc()
@ -146,12 +132,6 @@ func TestDB_SubscribePull_multiple(t *testing.T) {
// and validates if all expected addresses are received in the // and validates if all expected addresses are received in the
// right order for expected proximity order bins. // right order for expected proximity order bins.
func TestDB_SubscribePull_since(t *testing.T) { func TestDB_SubscribePull_since(t *testing.T) {
if testutil.RaceEnabled && os.Getenv("TRAVIS") == "true" {
t.Skip("does not complete with -race on Travis")
// Note: related ticket TODO
}
db, cleanupFunc := newTestDB(t, nil) db, cleanupFunc := newTestDB(t, nil)
defer cleanupFunc() defer cleanupFunc()
@ -242,12 +222,6 @@ func TestDB_SubscribePull_since(t *testing.T) {
// and validates if all expected addresses are received in the // and validates if all expected addresses are received in the
// right order for expected proximity order bins. // right order for expected proximity order bins.
func TestDB_SubscribePull_until(t *testing.T) { func TestDB_SubscribePull_until(t *testing.T) {
if testutil.RaceEnabled && os.Getenv("TRAVIS") == "true" {
t.Skip("does not complete with -race on Travis")
// Note: related ticket TODO
}
db, cleanupFunc := newTestDB(t, nil) db, cleanupFunc := newTestDB(t, nil)
defer cleanupFunc() defer cleanupFunc()
@ -337,12 +311,6 @@ func TestDB_SubscribePull_until(t *testing.T) {
// and until arguments, and validates if all expected addresses // and until arguments, and validates if all expected addresses
// are received in the right order for expected proximity order bins. // are received in the right order for expected proximity order bins.
func TestDB_SubscribePull_sinceAndUntil(t *testing.T) { func TestDB_SubscribePull_sinceAndUntil(t *testing.T) {
if testutil.RaceEnabled && os.Getenv("TRAVIS") == "true" {
t.Skip("does not complete with -race on Travis")
// Note: related ticket TODO
}
db, cleanupFunc := newTestDB(t, nil) db, cleanupFunc := newTestDB(t, nil)
defer cleanupFunc() defer cleanupFunc()