Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for isNetworkError (0.18 sec)

  1. cmd/bootstrap-peer-server.go

    				defer cancel()
    
    				err := clnt.Verify(ctx, srcCfg)
    				mu.Lock()
    				if err != nil {
    					bootstrapTraceMsg(fmt.Sprintf("clnt.Verify: %v, endpoint: %s", err, clnt))
    					if !isNetworkError(err) {
    						bootLogOnceIf(context.Background(), fmt.Errorf("%s has incorrect configuration: %w", clnt, err), "incorrect_"+clnt.String())
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 7.5K bytes
    - Viewed (0)
  2. cmd/storage-rest-client.go

    	xioutil "github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/rest"
    	xnet "github.com/minio/pkg/v2/net"
    	xbufio "github.com/philhofer/fwd"
    	"github.com/tinylib/msgp/msgp"
    )
    
    func isNetworkError(err error) bool {
    	if err == nil {
    		return false
    	}
    
    	if nerr, ok := err.(*rest.NetworkError); ok {
    		if down := xnet.IsNetworkOrHostDown(nerr.Err, false); down {
    			return true
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    		ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout)
    		defer cancel()
    		respBody, err := healthClient.Call(ctx, peerRESTMethodHealth, nil, nil, -1)
    		xhttp.DrainBody(respBody)
    		return !isNetworkError(err)
    	}
    	var gridConn atomic.Pointer[grid.Connection]
    
    	return &peerRESTClient{
    		host: peer, restClient: restClient, gridHost: gridHost,
    		gridConn: func() *grid.Connection {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
Back to top