GithubBackup/httprunner
1
0
Fork 0
mirror of https://github.com/httprunner/httprunner.git synced 2026-07-12 16:01:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

suport for distributing tasks that contain plugins

Browse Source
This commit is contained in:
xucong053
2022-05-26 10:51:59 +08:00
committed by 徐聪
parent 4ff3179a22
commit c72dc38bd3
4 changed files with 51 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hrp/internal/boomer/client_grpc.go
View File

@@ -74,12 +74,12 @@ func newClient(masterHost string, masterPort int, identity string) (client *grpc
func (c *grpcClient) connect() (err error) {
addr := fmt.Sprintf("%v:%v", c.masterHost, c.masterPort)
c.config.conn, err = grpc.Dial(addr, grpc.WithInsecure())
c.config.conn, err = grpc.Dial(addr, grpc.WithInsecure(), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024*1024)))
if err != nil {
log.Error().Err(err).Msg("failed to connect")
return err
}
grpc.MaxCallRecvMsgSize(32 * 10e9)
go c.recv()
go c.send()