Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 97 for addErr (0.47 sec)

  1. cmd/admin-handlers.go

    	anonAddr := func(addr string) string {
    		if anonParam != anonymizeStrict {
    			return addr
    		}
    		newAddr, found := hostAnonymizer[addr]
    		if found {
    			return newAddr
    		}
    
    		// If we reach here, it means that the given addr doesn't contain any of the hosts.
    		// Return it as is. Can happen for drive paths in non-distributed mode
    		return addr
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 99.7K bytes
    - Viewed (0)
  2. cmd/net.go

    	logger.FatalIf(err, "Unable to get IP addresses of this host")
    
    	for _, interf := range ifs {
    		addrs, err := interf.Addrs()
    		if err != nil {
    			continue
    		}
    		if runtime.GOOS == "windows" && interf.Flags&net.FlagUp == 0 {
    			continue
    		}
    
    		for _, addr := range addrs {
    			var ip net.IP
    			switch v := addr.(type) {
    			case *net.IPNet:
    				ip = v.IP
    			case *net.IPAddr:
    				ip = v.IP
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  3. cmd/net_test.go

    			}
    		}
    	}
    }
    
    func TestSameLocalAddrs(t *testing.T) {
    	testCases := []struct {
    		addr1       string
    		addr2       string
    		sameAddr    bool
    		expectedErr error
    	}{
    		{"", "", false, errors.New("unable to process empty address")},
    		{":9000", ":9000", true, nil},
    		{"localhost:9000", ":9000", true, nil},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 19 08:43:09 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  4. internal/http/listener.go

    	}
    
    	addr = tcpAddr
    	return addr
    }
    
    // Addrs - returns all address information of TCP listeners.
    func (listener *httpListener) Addrs() (addrs []net.Addr) {
    	for i := range listener.listeners {
    		addrs = append(addrs, listener.listeners[i].Addr())
    	}
    
    	return addrs
    }
    
    // TCPOptions specify customizable TCP optimizations on raw socket
    type TCPOptions struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/endpoint.go

    	addrs := []*core.Address{ep.GetEndpoint().GetAddress()}
    	for _, a := range ep.GetEndpoint().GetAdditionalAddresses() {
    		addrs = append(addrs, a.GetAddress())
    	}
    	result := make([]string, 0, len(addrs))
    	for _, addr := range addrs {
    		if addr := addr.GetSocketAddress(); addr != nil {
    			result = append(result, addr.Address+":"+strconv.Itoa(int(addr.GetPortValue())))
    			continue
    		}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 09:57:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cni/pkg/repair/netns.go

    	if interfaces, err = net.Interfaces(); err != nil {
    		return false, fmt.Errorf("failed to get interfaces")
    	}
    
    	for _, ief := range interfaces {
    		var addrs []net.Addr
    		if addrs, err = ief.Addrs(); err != nil {
    			return
    		}
    		for _, addr := range addrs {
    			switch v := addr.(type) {
    			case *net.IPNet:
    				if v.IP.Equal(targetAddr) {
    					return true, nil
    				}
    			}
    		}
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. internal/http/listener_test.go

    				t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err)
    			}
    		}
    
    		addrs := listener.Addrs()
    		addrSet := set.NewStringSet()
    		for _, addr := range addrs {
    			addrSet.Add(addr.String())
    		}
    
    		if !addrSet.Equals(testCase.expectedAddrs) {
    			t.Fatalf("Test %d: addr: expected = %v, got = %v", i+1, testCase.expectedAddrs, addrs)
    		}
    
    		listener.Close()
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:41:02 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/listener.go

    	}
    
    	return ""
    }
    
    func retrieveListenerAdditionalAddresses(l *listener.Listener) []string {
    	var addrs []string
    	socketAddresses := l.GetAdditionalAddresses()
    	for _, socketAddr := range socketAddresses {
    		addr := socketAddr.Address
    		addrs = append(addrs, addr.GetSocketAddress().Address)
    	}
    
    	return addrs
    }
    
    func retrieveListenerPort(l *listener.Listener) uint32 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  9. cmd/server-main.go

    		haddrs, err := globalDNSCache.LookupHost(ctx, host)
    		if err == nil {
    			for _, addr := range haddrs {
    				addrs.Add(net.JoinHostPort(addr, globalMinioPort))
    			}
    		} else {
    			// Unable to lookup host in 2-secs, let it fail later anyways.
    			addrs.Add(globalMinioAddr)
    		}
    	} else {
    		addrs.Add(globalMinioAddr)
    	}
    	return addrs.ToSlice()
    }
    
    var globalLoggerOutput io.WriteCloser
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (1)
  10. cmd/common-main.go

    			if net.ParseIP(endpoint) == nil {
    				// Checking if the IP is a DNS entry.
    				addrs, err := globalDNSCache.LookupHost(GlobalContext, endpoint)
    				if err != nil {
    					logger.FatalIf(err, "Unable to initialize MinIO server with [%s] invalid entry found in MINIO_PUBLIC_IPS", endpoint)
    				}
    				for _, addr := range addrs {
    					domainIPs.Add(addr)
    				}
    			}
    			domainIPs.Add(endpoint)
    		}
    		updateDomainIPs(domainIPs)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
Back to top