Mirroristas/kaspad
2
0
Fork 0
mirror of https://github.com/kaspanet/kaspad.git synced 2025-10-14 00:59:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set stream max message size and increase the max message size to 1GB (#1300)

Browse Source
This commit is contained in:
Ori Newman 2020-12-28 12:53:11 +02:00 committed by GitHub
parent b0251fe1a6
commit c7c8b25c09
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
app/protocol/flows/blockrelay/ibd.go
View File

@ -53,6 +53,7 @@ func (flow *handleRelayInvsFlow) runIBDIfNotRunning(highHash *externalapi.Domain
} }
if blockInfo.BlockStatus == externalapi.StatusHeaderOnly { if blockInfo.BlockStatus == externalapi.StatusHeaderOnly {
log.Infof("Checking if the suggested pruning point %s is compatible to the node DAG", msgIBDRootHash.Hash)
isValid, err := flow.Domain().Consensus().IsValidPruningPoint(msgIBDRootHash.Hash) isValid, err := flow.Domain().Consensus().IsValidPruningPoint(msgIBDRootHash.Hash)
if err != nil { if err != nil {
return err return err

2
infrastructure/network/netadapter/server/grpcserver/grpc_server.go
View File

@ -18,7 +18,7 @@ type gRPCServer struct {
} }
// MaxMessageSize is the max size allowed for a message // MaxMessageSize is the max size allowed for a message
const MaxMessageSize = 1024 * 1024 * 10 // 10MB const MaxMessageSize = 1024 * 1024 * 1024 // 1GB
// newGRPCServer creates a gRPC server // newGRPCServer creates a gRPC server
func newGRPCServer(listeningAddresses []string) *gRPCServer { func newGRPCServer(listeningAddresses []string) *gRPCServer {

3
infrastructure/network/netadapter/server/grpcserver/p2pserver.go
View File

@ -47,7 +47,8 @@ func (p *p2pServer) Connect(address string) (server.Connection, error) {
} }
client := protowire.NewP2PClient(gRPCClientConnection) client := protowire.NewP2PClient(gRPCClientConnection)
stream, err := client.MessageStream(context.Background(), grpc.UseCompressor(gzip.Name)) stream, err := client.MessageStream(context.Background(), grpc.UseCompressor(gzip.Name),
grpc.MaxCallRecvMsgSize(MaxMessageSize), grpc.MaxCallSendMsgSize(MaxMessageSize))
if err != nil { if err != nil {
return nil, errors.Wrapf(err, "error getting client stream for %s", address) return nil, errors.Wrapf(err, "error getting client stream for %s", address)
} }