Merge pull request #1 from vimeo/delete_non_fakeclock_tests

Remove non-fake-clock tests

Author: dfinkel

campaign_test.go

@@ -19,114 +19,6 @@ func init() {
 	rand.Seed(int64(os.Getpid()) * time.Now().UnixNano())
 }
 
-func TestAcquireTrivialUncontended(t *testing.T) {
-	t.Parallel()
-	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
-	d := memory.NewDecider()
-	elected := atomicBool{}
-	onElectedCalls := 0
-
-	c := Config{
-		Decider:  d,
-		HostPort: "127.0.0.1:8080",
-		LeaderID: "yabadabadoo",
-		OnElected: func(ctx context.Context, tv *TimeView) {
-			if elected.get() {
-				t.Error("OnElected called while still elected")
-			}
-			elected.set(true)
-			onElectedCalls++
-			// we've run (and won), let this run for a bit longer
-			// then cancel the context (set it just longer than
-			// half the term-length so we can extend the lease ).
-			time.AfterFunc(time.Millisecond*16, cancel)
-		},
-		OnOusting: func(ctx context.Context) {
-			elected.set(false)
-		},
-		LeaderChanged: func(ctx context.Context, entry entry.RaceEntry) {
-		},
-		TermLength:   time.Millisecond * 30,
-		MaxClockSkew: time.Microsecond,
-	}
-
-	if err := c.Acquire(ctx); err != context.Canceled {
-		t.Errorf("failed to acquire: %s", err)
-	}
-	if onElectedCalls != 1 {
-		t.Errorf("unexpected number of OnElected calls: %d", onElectedCalls)
-	}
-}
-
-func TestAcquireTrivialWithMinorContention(t *testing.T) {
-	t.Parallel()
-	ctx, cancel := context.WithCancel(context.Background())
-	defer cancel()
-	d := memory.NewDecider()
-	elected := atomicBool{}
-	onElectedCalls := 0
-	wg := sync.WaitGroup{}
-	defer wg.Wait()
-
-	loserConfig := Config{
-		OnElected:        func(context.Context, *TimeView) { t.Error("unexpected election win of loser") },
-		LeaderChanged:    func(_ context.Context, e entry.RaceEntry) { t.Logf("lost election: %+v", e); cancel() },
-		LeaderID:         "nottheleader",
-		HostPort:         "127.0.0.2:7123",
-		Decider:          d,
-		TermLength:       time.Millisecond * 30,
-		ConnectionParams: []byte("bimbat"),
-		MaxClockSkew:     time.Microsecond,
-	}
-	const realleaderID = "yabadabadoo"
-	const realLeaderConnectionParams = "boodle_doodle"
-
-	c := Config{
-		Decider:  d,
-		HostPort: "127.0.0.1:8080",
-		LeaderID: realleaderID,
-		OnElected: func(ctx context.Context, tv *TimeView) {
-			if elected.get() {
-				t.Error("OnElected called while still elected")
-			}
-			elected.set(true)
-			onElectedCalls++
-			// now that we've run and won, spin off another
-			// goroutine with a loser to contend on the lock.
-			wg.Add(1)
-			go func() {
-				defer wg.Done()
-				if err := loserConfig.Acquire(ctx); err != context.Canceled {
-					t.Errorf("non-cancel error: %s", err)
-				}
-
-			}()
-		},
-		OnOusting: func(ctx context.Context) {
-			elected.set(false)
-		},
-		LeaderChanged: func(ctx context.Context, rentry entry.RaceEntry) {
-			if rentry.LeaderID != realleaderID && rentry.ElectionNumber != entry.NoElections {
-				t.Errorf("wrong leader grabbed lock: %q", rentry.LeaderID)
-			}
-			if string(rentry.ConnectionParams) != realLeaderConnectionParams && rentry.ElectionNumber != entry.NoElections {
-				t.Errorf("wrong ConnectionParams: %q; expected %q",
-					string(rentry.ConnectionParams), realLeaderConnectionParams)
-			}
-		},
-		TermLength:       time.Millisecond * 30,
-		ConnectionParams: []byte(realLeaderConnectionParams),
-	}
-
-	if err := c.Acquire(ctx); err != context.Canceled {
-		t.Errorf("non-cancel-error: %s", err)
-	}
-	if onElectedCalls != 1 {
-		t.Errorf("unexpected number of OnElected calls: %d", onElectedCalls)
-	}
-}
-
 func TestAcquireTrivialUncontendedFakeClock(t *testing.T) {
 	t.Parallel()
 	ctx, cancel := context.WithCancel(context.Background())