Skip to content

Commit

Permalink
chore: fix some function names in comment (#3272)
Browse files Browse the repository at this point in the history
Signed-off-by: wanxiangchwng <[email protected]>
  • Loading branch information
wanxiangchwng authored Nov 25, 2024
1 parent 4d3ce42 commit 47066c5
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion core/ai.go
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ func (s JSONRat) String() string {
return s.FloatString(2)
}

// parsePipelineFromModelID converts a pipeline name to a capability enum.
// PipelineToCapability converts a pipeline name to a capability enum.
func PipelineToCapability(pipeline string) (Capability, error) {
if pipeline == "" {
return Capability_Unused, errPipelineNotAvailable
Expand Down
2 changes: 1 addition & 1 deletion core/ai_worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -241,7 +241,7 @@ func (rwm *RemoteAIWorkerManager) workerHasCapacity(pipeline, modelID string) bo
return false
}

// completeRequestSessions end a AI request session for a remote ai worker
// completeAIRequest end a AI request session for a remote ai worker
// caller should hold the mutex lock
func (rwm *RemoteAIWorkerManager) completeAIRequest(requestID, pipeline, modelID string) {
rwm.RWmutex.Lock()
Expand Down
2 changes: 1 addition & 1 deletion crypto/verify.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ var (
secp256k1halfN = new(big.Int).Div(secp256k1N, big.NewInt(2))
)

// Verify verifies that a ETH ECDSA signature over a given message
// VerifySig verifies that a ETH ECDSA signature over a given message
// is produced by a given ETH address
func VerifySig(addr ethcommon.Address, msg, sig []byte) bool {
recovered, err := ecrecover(msg, sig)
Expand Down
4 changes: 2 additions & 2 deletions pm/broker.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,11 +76,11 @@ type TimeManager interface {
PreLastInitializedL1BlockHash() [32]byte
// GetTranscoderPoolSize returns the size of the active transcoder set for a round
GetTranscoderPoolSize() *big.Int
// LastSeenBlock returns the last seen block number
// LastSeenL1Block returns the last seen block number
LastSeenL1Block() *big.Int
// SubscribeRounds allows one to subscribe to new round events
SubscribeRounds(sink chan<- types.Log) event.Subscription
// SubscribeBlocks allows one to subscribe to newly seen block numbers
// SubscribeL1Blocks allows one to subscribe to newly seen block numbers
SubscribeL1Blocks(sink chan<- *big.Int) event.Subscription
}

Expand Down

0 comments on commit 47066c5

Please sign in to comment.