Commit 513c5687 authored by Brian Tiger Chow's avatar Brian Tiger Chow

rename

parent 1891c891
...@@ -24,7 +24,7 @@ func Test1KBInstantaneous(t *testing.T) { ...@@ -24,7 +24,7 @@ func Test1KBInstantaneous(t *testing.T) {
BlockstoreLatency: 0, BlockstoreLatency: 0,
} }
if err := AddCatBytes(RandomBytes(1*KB), conf); err != nil { if err := DirectAddCat(RandomBytes(1*KB), conf); err != nil {
t.Fatal(err) t.Fatal(err)
} }
} }
...@@ -56,7 +56,7 @@ func TestDegenerateSlowRouting(t *testing.T) { ...@@ -56,7 +56,7 @@ func TestDegenerateSlowRouting(t *testing.T) {
func Test100MBMacbookCoastToCoast(t *testing.T) { func Test100MBMacbookCoastToCoast(t *testing.T) {
SkipUnlessEpic(t) SkipUnlessEpic(t)
conf := Config{}.Network_NYtoSF().Blockstore_SlowSSD2014().Routing_Slow() conf := Config{}.Network_NYtoSF().Blockstore_SlowSSD2014().Routing_Slow()
if err := AddCatBytes(RandomBytes(100*1024*1024), conf); err != nil { if err := DirectAddCat(RandomBytes(100*1024*1024), conf); err != nil {
t.Fatal(err) t.Fatal(err)
} }
} }
...@@ -65,7 +65,7 @@ func AddCatPowers(conf Config, megabytesMax int64) error { ...@@ -65,7 +65,7 @@ func AddCatPowers(conf Config, megabytesMax int64) error {
var i int64 var i int64
for i = 1; i < megabytesMax; i = i * 2 { for i = 1; i < megabytesMax; i = i * 2 {
fmt.Printf("%d MB\n", i) fmt.Printf("%d MB\n", i)
if err := AddCatBytes(RandomBytes(i*1024*1024), conf); err != nil { if err := DirectAddCat(RandomBytes(i*1024*1024), conf); err != nil {
return err return err
} }
} }
...@@ -78,7 +78,7 @@ func RandomBytes(n int64) []byte { ...@@ -78,7 +78,7 @@ func RandomBytes(n int64) []byte {
return data.Bytes() return data.Bytes()
} }
func AddCatBytes(data []byte, conf Config) error { func DirectAddCat(data []byte, conf Config) error {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
defer cancel() defer cancel()
const numPeers = 2 const numPeers = 2
......
...@@ -10,7 +10,7 @@ func benchmarkAddCat(numBytes int64, conf Config, b *testing.B) { ...@@ -10,7 +10,7 @@ func benchmarkAddCat(numBytes int64, conf Config, b *testing.B) {
b.StartTimer() b.StartTimer()
for n := 0; n < b.N; n++ { for n := 0; n < b.N; n++ {
if err := AddCatBytes(data, conf); err != nil { if err := DirectAddCat(data, conf); err != nil {
b.Fatal(err) b.Fatal(err)
} }
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment