Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for IsNetworkOrHostDown (0.1 sec)

  1. cmd/peer-rest-client.go

    	}
    
    	if values == nil {
    		values = make(url.Values)
    	}
    
    	respBody, err = client.restClient.Call(ctx, method, values, body, length)
    	if err == nil {
    		return respBody, nil
    	}
    
    	if xnet.IsNetworkOrHostDown(err, true) {
    		return nil, errPeerNotReachable
    	}
    
    	return nil, err
    }
    
    // Stringer provides a canonicalized representation of node.
    func (client *peerRESTClient) String() string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  2. cmd/utils.go

    	versionID := ""
    	if len(params) >= 1 {
    		bucket = params[0]
    	}
    	if len(params) >= 2 {
    		object = params[1]
    	}
    	if len(params) >= 3 {
    		versionID = params[2]
    	}
    
    	if xnet.IsNetworkOrHostDown(err, false) {
    		return BackendDown{Err: err.Error()}
    	}
    
    	minioErr, ok := err.(minio.ErrorResponse)
    	if !ok {
    		// We don't interpret non MinIO errors. As minio errors will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    			}
    			t.activeTasks.Add(1)
    			if err := transitionObject(t.ctx, objectAPI, task.objInfo, newLifecycleAuditEvent(task.src, task.event)); err != nil {
    				if !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !xnet.IsNetworkOrHostDown(err, false) {
    					if !strings.Contains(err.Error(), "use of closed network connection") {
    						transitionLogIf(t.ctx, fmt.Errorf("Transition to %s failed for %s/%s version:%s with %w",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    	defer rc.Close()
    
    	_, err = xioutil.Copy(w, rc)
    	if !xnet.IsNetworkOrHostDown(err, true) { // do not need to log disconnected clients
    		storageLogIf(r.Context(), err)
    	}
    }
    
    // ListDirHandler - list a directory.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  5. cmd/site-replication.go

    			}
    		}(i)
    	}
    	wg.Wait()
    	errMap := make(map[string]error, len(c.state.Peers))
    	for i, depID := range depIDs {
    		errMap[depID] = errs[i]
    		if errs[i] != nil && minio.IsNetworkOrHostDown(errs[i], true) {
    			ep := c.state.Peers[depID].Endpoint
    			epURL, _ := url.Parse(ep)
    			if !globalBucketTargetSys.isOffline(epURL) {
    				globalBucketTargetSys.markOffline(epURL)
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top