diff --git a/clog/clog_test.go b/clog/clog_test.go index 3613f2f68e..caa696db9c 100644 --- a/clog/clog_test.go +++ b/clog/clog_test.go @@ -79,7 +79,7 @@ func TestPublicLogs(t *testing.T) { val = GetVal(publicCtx, "foo") assert.Equal("", val) - // Verify [PublicLogs] gets pre-pended: + // Verify [PublicLogs] gets prepended: msg, _ := formatMessage(ctx, false, true, "testing message num=%d", 123) assert.Equal("[PublicLogs] manifestID=fooManID sessionID=fooSessionID nonce=999 seqNo=555 orchSessionID=fooOrchID ethaddress=0x0 orchestrator=http://127.0.0.1:8935 foo=Bar testing message num=123", msg) } diff --git a/doc/discovery.md b/doc/discovery.md index 8a41c31a26..985a5d0624 100644 --- a/doc/discovery.md +++ b/doc/discovery.md @@ -17,7 +17,7 @@ After feching active orchestrators, the discovery algorithm filters for eligible - Choosing the first M orchestrators out of N that respond to a `GetOrchestrator` request within a [timeout](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/discovery/discovery.go#L127) - If an insufficient number of orchestrators are found within the timeout, a timeout escalation is used [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/discovery/discovery.go#L146) to continue trying to find orchestrators - At the moment, a broadcaster uses separate pools of trusted and untrusted orchestrators for fast verification and for the untrusted orchestrator pool discovery will set M = N (see [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/server/broadcast.go#L411) and [here](https://github.com/livepeer/go-livepeer/blob/1af0a5182cd3a9aa38d961b6d1d104a3693ec814/server/broadcast.go#L726)) -- Exclusing orchestrators that are temporarily suspended +- Excluding orchestrators that are temporarily suspended - Excluding orchestrators that do not have compatible capabilities for the job - Excluding orchestrators that advertise invalid ticket parameters, that advertise a price that exceeds the broadcaster's max price diff --git a/pm/broker.go b/pm/broker.go index 1b2d55b463..f3592542b3 100644 --- a/pm/broker.go +++ b/pm/broker.go @@ -92,6 +92,6 @@ type SenderManager interface { ClaimedReserve(reserveHolder ethcommon.Address, claimant ethcommon.Address) (*big.Int, error) // Clear clears the cached values for a sender Clear(addr ethcommon.Address) - // SubscribeReserveChange notifies a subcriber when the senderInfo for a sender changes + // SubscribeReserveChange notifies a subscriber when the senderInfo for a sender changes SubscribeReserveChange(sink chan<- ethcommon.Address) event.Subscription } diff --git a/pm/sendermonitor.go b/pm/sendermonitor.go index 5ef5dcfedd..ae2a4c6f3e 100644 --- a/pm/sendermonitor.go +++ b/pm/sendermonitor.go @@ -440,7 +440,7 @@ func (sm *LocalSenderMonitor) redeemWinningTicket(ticket *SignedTicket) (*types. return tx, nil } -// SubscribeMaxFloatChange notifies subcribers when the max float for a sender has changed +// SubscribeMaxFloatChange notifies subscribers when the max float for a sender has changed // and that it should call LocalSenderMonitor.MaxFloat() to get the latest value func (sm *LocalSenderMonitor) SubscribeMaxFloatChange(sender ethcommon.Address, sink chan<- struct{}) event.Subscription { sm.mu.Lock() diff --git a/server/job_rpc.go b/server/job_rpc.go index 88d27b33e7..364a729960 100644 --- a/server/job_rpc.go +++ b/server/job_rpc.go @@ -880,7 +880,7 @@ func chargeForCompute(start time.Time, price *net.PriceInfo, orch Orchestrator, } func addPaymentBalanceHeader(w http.ResponseWriter, orch Orchestrator, sender ethcommon.Address, jobId string) { - //check balance and return remaning balance in header of response + //check balance and return remaining balance in header of response senderBalance := getPaymentBalance(orch, sender, jobId) if senderBalance != nil { w.Header().Set("Livepeer-Payment-Balance", senderBalance.FloatString(0)) @@ -892,7 +892,7 @@ func addPaymentBalanceHeader(w http.ResponseWriter, orch Orchestrator, sender et } func getPaymentBalance(orch Orchestrator, sender ethcommon.Address, jobId string) *big.Rat { - //check balance and return remaning balance in header of response + //check balance and return remaining balance in header of response senderBalance := orch.Balance(sender, core.ManifestID(jobId)) if senderBalance == nil { senderBalance = big.NewRat(0, 1)