tcp multiplexer for sei giga #2679
Conversation
![github-advanced-security[bot]](https://avatars.githubusercontent.com/in/57789?s=60&v=4){kind=small}
| } | ||
| } | ||
| return n, err | ||
| panic("unreachable") |
Check warning
Code scanning / CodeQL
Panic in BeginBock or EndBlock consensus methods Warning
| for kind, c := range cfg.Kinds { | ||
| kinds[kind] = &kindState{ | ||
| acceptsQueue: make(chan *streamState, c.MaxAccepts), | ||
| connectsQueue: make(chan *streamState, c.MaxConnects), | ||
| } | ||
| } |
Check warning
Code scanning / CodeQL
Iteration over map Warning
| for kind, c := range h.Kinds { | ||
| kinds = append(kinds, &pb.StreamKindConfig{ | ||
| Kind: uint64(kind), | ||
| MaxConnects: c.MaxConnects, | ||
| MaxAccepts: c.MaxAccepts, | ||
| }) | ||
| } |
Check warning
Code scanning / CodeQL
Iteration over map Warning
| import ( | ||
| 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 kind, cfg := range m.cfg.Kinds { | ||
| remCfg, ok := handshake.Kinds[kind] | ||
| if !ok { | ||
| remCfg = &StreamKindConfig{} | ||
| } | ||
| inner.acceptsSem[kind] = min(cfg.MaxAccepts, remCfg.MaxConnects) | ||
| for range min(cfg.MaxConnects, remCfg.MaxAccepts) { | ||
| m.kinds[kind].connectsQueue <- inner.newConnectStream(kind) | ||
| } | ||
| } |
Check warning
Code scanning / CodeQL
Iteration over map Warning
TCP Multiplexer for sei giga. It is a replacement for sei-tendermint/internal/p2p/conn.MConnection. It will be used with autobahn only (currently unused). The high level overview of the protocol is described in package comment in mux/mux.go