Skip to content

Commit

Permalink
Merge pull request #47 from spacemeshos/fix_receive_size
Browse files Browse the repository at this point in the history
Make receive size bigger
  • Loading branch information
pigmej authored Mar 24, 2023
2 parents 7a0d415 + 5428a5e commit c7030ed
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions collector/collector.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,10 @@ package collector

import (
"context"
"google.golang.org/grpc/credentials/insecure"
"time"

"google.golang.org/grpc/credentials/insecure"

pb "github.com/spacemeshos/api/release/go/spacemesh/v1"
"google.golang.org/grpc"

Expand Down Expand Up @@ -63,7 +64,8 @@ func (c *Collector) Run() {
log.Info("dial node %v", c.apiUrl)
c.connecting = true

conn, err := grpc.Dial(c.apiUrl, grpc.WithTransportCredentials(insecure.NewCredentials()))
conn, err := grpc.Dial(c.apiUrl, grpc.WithTransportCredentials(insecure.NewCredentials()),
grpc.WithBlock(), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(50*1024*1024)))
if err != nil {
log.Error("cannot dial node: %v", err)
time.Sleep(1 * time.Second)
Expand Down

0 comments on commit c7030ed

Please sign in to comment.