diff --git a/common/db_test.go b/common/db_test.go index 9034aef29f..de5e06397d 100644 --- a/common/db_test.go +++ b/common/db_test.go @@ -775,7 +775,7 @@ func TestDBUnbondingLocks(t *testing.T) { return } if len(unbondingLocks) != 2 { - t.Error("Unxpected number of unbonding locks after deletion; expected 2, got", len(unbondingLocks)) + t.Error("Unexpected number of unbonding locks after deletion; expected 2, got", len(unbondingLocks)) return } diff --git a/discovery/discovery.go b/discovery/discovery.go index 5f135034b3..e2e657d5dc 100644 --- a/discovery/discovery.go +++ b/discovery/discovery.go @@ -155,7 +155,7 @@ func (o *orchestratorPool) GetOrchestrators(ctx context.Context, numOrchestrator cutoffTimer := time.NewTimer(maxGetOrchestratorCutoffTimeout) defer cutoffTimer.Stop() - // try to wait for orchestrators until at least 1 is found (with the exponential backoff timout) + // try to wait for orchestrators until at least 1 is found (with the exponential backoff timeout) timeout := o.discoveryTimeout timer := time.NewTimer(timeout) diff --git a/media/whip_connection_test.go b/media/whip_connection_test.go index cfe73db403..15ea769512 100644 --- a/media/whip_connection_test.go +++ b/media/whip_connection_test.go @@ -801,7 +801,7 @@ func TestConcurrentOperations(t *testing.T) { for i := 0; i < numGoroutines; i++ { go func(i int) { defer wg.Done() - assert.Nil(t, conn.AwaitClose(), "expcted await close to not return an error") + assert.Nil(t, conn.AwaitClose(), "expected await close to not return an error") }(i) } diff --git a/server/broadcast_test.go b/server/broadcast_test.go index 426dc81938..0a72f046e6 100644 --- a/server/broadcast_test.go +++ b/server/broadcast_test.go @@ -1614,7 +1614,7 @@ func TestVerifier_SegDownload(t *testing.T) { assert.Nil(err) assert.True(downloaded[url]) - // When segments are not in the broadcaster's exernal OS, segments should be downloaded + // When segments are not in the broadcaster's external OS, segments should be downloaded url = "somewhere4" cxn.sessManager = bsmWithSessList([]*BroadcastSession{genBcastSess(ctx, t, url, externalOS, mid)}) _, _, err = transcodeSegment(context.TODO(), cxn, seg, "dummy", verifier, nil) diff --git a/server/job_rpc.go b/server/job_rpc.go index ef29eff243..88d27b33e7 100644 --- a/server/job_rpc.go +++ b/server/job_rpc.go @@ -552,7 +552,7 @@ func processJob(ctx context.Context, h *lphttp, w http.ResponseWriter, r *http.R if payment.TicketParams == nil { - //if price is not 0, comfirm balance + //if price is not 0, confirm balance if jobPriceRat.Cmp(big.NewRat(0, 1)) > 0 { minBal := jobPriceRat.Mul(jobPriceRat, big.NewRat(60, 1)) //minimum 1 minute balance orchBal := getPaymentBalance(orch, sender, jobId) diff --git a/trickle/trickle_publisher.go b/trickle/trickle_publisher.go index 364f0af8e3..ecb98f5b11 100644 --- a/trickle/trickle_publisher.go +++ b/trickle/trickle_publisher.go @@ -170,7 +170,7 @@ func (c *TricklePublisher) Next() (*pendingPost, error) { func (p *pendingPost) reconnect() (*pendingPost, error) { // This is a little gnarly but works for now: - // Set the publisher's sequence sequence to the intended reconnect + // Set the publisher's sequence to the intended reconnect // Call publisher's preconnect (which increments its sequence) // then reset publisher's sequence back to the original // Also recreate the client to force a fresh connection