rename to toughswitch
This commit is contained in:
@@ -1,4 +1,4 @@
|
||||
package edgeos
|
||||
package toughswitch
|
||||
|
||||
import (
|
||||
"bytes"
|
||||
@@ -34,11 +34,9 @@ func TestClient_ThreadSafety(t *testing.T) {
|
||||
start := make(chan struct{})
|
||||
|
||||
// Writer: Adds and deletes hosts
|
||||
wg.Add(1)
|
||||
go func() {
|
||||
defer wg.Done()
|
||||
wg.Go(func() {
|
||||
<-start
|
||||
for i := 0; i < 100; i++ {
|
||||
for i := range 100 {
|
||||
host := fmt.Sprintf("host-%d", i)
|
||||
cfg := &Config{
|
||||
Host: host,
|
||||
@@ -54,20 +52,18 @@ func TestClient_ThreadSafety(t *testing.T) {
|
||||
t.Logf("Del error: %v", err)
|
||||
}
|
||||
}
|
||||
}()
|
||||
})
|
||||
|
||||
// Reader: Iterates hosts
|
||||
wg.Add(1)
|
||||
go func() {
|
||||
defer wg.Done()
|
||||
wg.Go(func() {
|
||||
<-start
|
||||
for i := 0; i < 10; i++ {
|
||||
for range 10 {
|
||||
// GetAllInterfaces iterates keys.
|
||||
// With mock transport, this will succeed (returning empty structs)
|
||||
// checking for race conditions.
|
||||
_, _ = client.GetAllInterfaces(ctx)
|
||||
}
|
||||
}()
|
||||
})
|
||||
|
||||
close(start)
|
||||
wg.Wait()
|
||||
@@ -106,4 +102,4 @@ func TestClient_AddDel(t *testing.T) {
|
||||
if err := client.Del("test-host"); err == nil {
|
||||
t.Fatal("Expected error deleting non-existent host, got nil")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user