Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 129 for addErr (0.15 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. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            UniAddress[] addrs = new UniAddress[iaddrs.length];
            for ( int ii = 0; ii < iaddrs.length; ii++ ) {
                addrs[ ii ] = new UniAddress(iaddrs[ ii ]);
            }
            return addrs;
        }
    
    
        private static UniAddress[] wrapNetbiosAddresses ( NetbiosAddress[] addr ) {
            UniAddress[] addrs = new UniAddress[addr.length];
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. internal/http/dial_dnscache.go

    		}).DialContext
    	}
    
    	return func(ctx context.Context, network, addr string) (conn net.Conn, err error) {
    		host, port, err := net.SplitHostPort(addr)
    		if err != nil {
    			return nil, err
    		}
    
    		if net.ParseIP(host) != nil {
    			// For IP only setups there is no need for DNS lookups.
    			return baseDialCtx(ctx, "tcp", addr)
    		}
    
    		ips, err := lookupHost(ctx, host)
    		if err != nil {
    			return nil, err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 03 19:30:51 UTC 2023
    - 2.6K bytes
    - Viewed (0)
Back to top