cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Set more timeouts to 30s

Browse Source
This commit is contained in:
Geoff Stuart 2022-11-29 10:31:45 -05:00
parent dfbf4d0f43
commit 61ac270876
5 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
itests/kit/rpc.go
View File

@ -25,7 +25,7 @@ func CreateRPCServer(t *testing.T, handler http.Handler, listener net.Listener)
Listener: listener, Listener: listener,
Config: &http.Server{ Config: &http.Server{
Handler: handler, Handler: handler,
ReadHeaderTimeout: 3 * time.Second, ReadHeaderTimeout: 30 * time.Second,
}, },
} }
testServ.Start() testServ.Start()

2
node/rpc.go
View File

@ -53,7 +53,7 @@ func ServeRPC(h http.Handler, id string, addr multiaddr.Multiaddr) (StopFunc, er
// Instantiate the server and start listening. // Instantiate the server and start listening.
srv := &http.Server{ srv := &http.Server{
Handler: h, Handler: h,
ReadHeaderTimeout: 3 * time.Second, ReadHeaderTimeout: 30 * time.Second,
BaseContext: func(listener net.Listener) context.Context { BaseContext: func(listener net.Listener) context.Context {
ctx, _ := tag.New(context.Background(), tag.Upsert(metrics.APIInterface, id)) ctx, _ := tag.New(context.Background(), tag.Upsert(metrics.APIInterface, id))
return ctx return ctx

2
testplans/lotus-soup/testkit/role_client.go
View File

@ -182,7 +182,7 @@ func startFullNodeAPIServer(t *TestEnvironment, repo repo.Repo, napi api.FullNod
Next: mux.ServeHTTP, Next: mux.ServeHTTP,
} }
srv := &http.Server{Handler: ah, ReadHeaderTimeout: 3 * time.Second} srv := &http.Server{Handler: ah, ReadHeaderTimeout: 30 * time.Second}
endpoint, err := repo.APIEndpoint() endpoint, err := repo.APIEndpoint()
if err != nil { if err != nil {

2
testplans/lotus-soup/testkit/role_miner.go
View File

@ -638,7 +638,7 @@ func startStorageMinerAPIServer(t *TestEnvironment, repo repo.Repo, minerApi api
return nil, fmt.Errorf("no API endpoint in repo: %w", err) return nil, fmt.Errorf("no API endpoint in repo: %w", err)
} }
srv := &http.Server{Handler: ah, ReadHeaderTimeout: 3 * time.Second} srv := &http.Server{Handler: ah, ReadHeaderTimeout: 30 * time.Second}
listenAddr, err := startServer(endpoint, srv) listenAddr, err := startServer(endpoint, srv)
if err != nil { if err != nil {