Skip to content

Commit

Permalink
Merge branch 'main' into marko/kill_migration
Browse files Browse the repository at this point in the history
  • Loading branch information
tac0turtle authored Jan 14, 2025
2 parents e0251f6 + 5fb5dda commit 6fd3181
Show file tree
Hide file tree
Showing 6 changed files with 7 additions and 8 deletions.
2 changes: 1 addition & 1 deletion baseapp/abci_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -2204,7 +2204,7 @@ func TestABCI_ProcessProposal_PanicRecovery(t *testing.T) {
})
}

// TestABCI_Proposal_Reset_State ensures that state is reset between runs of
// TestABCI_Proposal_Reset_State_Between_Calls ensures that state is reset between runs of
// PrepareProposal and ProcessProposal in case they are called multiple times.
// This is only valid for heights > 1, given that on height 1 we always set the
// state to be deliverState.
Expand Down
2 changes: 1 addition & 1 deletion client/v2/tx/encoder.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ func encodeTextTx(tx Tx) ([]byte, error) {
return textMarshalOptions.Marshal(wTx.Tx)
}

// decodeJsonTx decodes transaction bytes into an apitx.Tx structure using JSON format.
// decodeTextTx decodes transaction bytes into an apitx.Tx structure using TEXT format.
func decodeTextTx(cdc codec.BinaryCodec, decoder Decoder) txDecoder {
return func(txBytes []byte) (Tx, error) {
jsonTx := new(txv1beta1.Tx)
Expand Down
2 changes: 1 addition & 1 deletion crypto/ledger/ledger_secp256k1.go
Original file line number Diff line number Diff line change
Expand Up @@ -332,7 +332,7 @@ func getPubKeyUnsafe(device SECP256K1, path hd.BIP44Params) (types.PubKey, error
return options.createPubkey(compressedPublicKey), nil
}

// getPubKeyAddr reads the pubkey and the address from a ledger device.
// getPubKeyAddrSafe reads the pubkey and the address from a ledger device.
// This function is marked as Safe as it will require user confirmation and
// account and index will be shown in the device.
//
Expand Down
4 changes: 2 additions & 2 deletions schema/appdata/mux.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,8 +138,8 @@ func ListenerMux(listeners ...Listener) Listener {
}

mux.onBatch = func(batch PacketBatch) error {
for _, listener := range listeners {
err := batch.apply(&listener)
for i := range listeners {
err := batch.apply(&listeners[i])
if err != nil {
return err
}
Expand Down
1 change: 1 addition & 0 deletions server/v2/cometbft/query.go
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ func (c *consensus[T]) handleQueryP2P(path []string) (*abci.QueryResponse, error
return c.idPeerFilter(arg)
}
}
return &abci.QueryResponse{}, nil
}

return nil, errorsmod.Wrap(cometerrors.ErrUnknownRequest, "expected second parameter to be 'filter'")
Expand Down
4 changes: 1 addition & 3 deletions store/cache/cache.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,9 +84,7 @@ func (cmgr *CommitKVStoreCacheManager) Reset() {
// Clear the map.
// Please note that we are purposefully using the map clearing idiom.
// See https://github.com/cosmos/cosmos-sdk/issues/6681.
for key := range cmgr.caches {
delete(cmgr.caches, key)
}
clear(cmgr.caches)
}

// CacheWrap implements the CacheWrapper interface
Expand Down

0 comments on commit 6fd3181

Please sign in to comment.