Conversation
|
The latest Buf updates on your PR. Results from workflow Buf / buf (pull_request).
|
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## main #2775 +/- ##
==========================================
- Coverage 56.73% 56.65% -0.08%
==========================================
Files 2023 2031 +8
Lines 165575 165854 +279
==========================================
+ Hits 93939 93972 +33
- Misses 63407 63650 +243
- Partials 8229 8232 +3
Flags with carried forward coverage won't be shown. Click here to find out more.
🚀 New features to boost your workflow:
|
![github-advanced-security[bot]](https://avatars.githubusercontent.com/in/57789?s=60&v=4){kind=small}
| for _, ch := range q.channels { | ||
| // Exponential decay of stats. | ||
| // TODO(gprusak): This is not atomic at all. | ||
| ch.recentlySent.Store(uint64(float64(ch.recentlySent.Load()) * 0.8)) | ||
| } |
Check warning
Code scanning / CodeQL
Iteration over map Warning
| for { | ||
| if q.ping { | ||
| q.ping = false | ||
| q.setFlush(time.Now()) |
Check warning
Code scanning / CodeQL
Calling the system time Warning
| } | ||
| if q.pong { | ||
| q.pong = false | ||
| q.setFlush(time.Now()) |
Check warning
Code scanning / CodeQL
Calling the system time Warning
| for _, channel := range q.channels { | ||
| if channel.queue.Len() == 0 { | ||
| continue | ||
| } | ||
| if ratio := channel.ratio(); ratio < leastRatio { | ||
| leastRatio = ratio | ||
| leastChannel = channel | ||
| } | ||
| } |
Check warning
Code scanning / CodeQL
Iteration over map Warning
| } | ||
| } | ||
| if leastChannel != nil { | ||
| q.setFlush(time.Now().Add(c.config.FlushThrottle)) |
Check warning
Code scanning / CodeQL
Calling the system time Warning
| _ "github.com/tendermint/tendermint/internal/hashable/pb" | ||
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" | ||
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" | ||
| reflect "reflect" |
Check notice
Code scanning / CodeQL
Sensitive package import Note
| protoimpl "google.golang.org/protobuf/runtime/protoimpl" | ||
| reflect "reflect" | ||
| sync "sync" | ||
| unsafe "unsafe" |
Check notice
Code scanning / CodeQL
Sensitive package import Note
| for _, ch := range q.channels { | ||
| // Exponential decay of stats. | ||
| // TODO(gprusak): This is not atomic at all. | ||
| ch.recentlySent.Store(uint64(float64(ch.recentlySent.Load()) * 0.8)) |
Check notice
Code scanning / CodeQL
Floating point arithmetic Note
| } | ||
|
|
||
| func (ch *sendChannel) ratio() float32 { | ||
| return float32(ch.recentlySent.Load()) / float32(ch.desc.Priority) |
Check notice
Code scanning / CodeQL
Floating point arithmetic Note
| "github.com/tendermint/tendermint/libs/utils" | ||
| "github.com/tendermint/tendermint/libs/utils/scope" | ||
| "golang.org/x/time/rate" | ||
| "reflect" |
Check notice
Code scanning / CodeQL
Sensitive package import Note
3 participants
GigaRouter is a router which will handle seigiga p2p connections. GigaRouter shares the tcp port with SeiV2 Router - I've added a bool flag to the handshake message to distinguish one from another (for backward compatibility both peers need to set it for the connection to be considered Giga). It can be enabled by setting Giga config in the RouterOptions. Currently it is hardcoded to None (i.e. disabled). It is a stub in a sense that all the autobahn RPCs are already defined, but there is no logic handling those. The next PR will be porting the autobahn core logic to sei-chain. Additionally: