Search Options

Results per page
Sort
Preferred Languages
Advance

Results 651 - 660 of 1,020 for err (0.01 sec)

  1. cmd/signature-v2.go

    // if any while unescaping the values.
    func unescapeQueries(encodedQuery string) (unescapedQueries []string, err error) {
    	for _, query := range strings.Split(encodedQuery, "&") {
    		var unescapedQuery string
    		unescapedQuery, err = url.QueryUnescape(query)
    		if err != nil {
    			return nil, err
    		}
    		unescapedQueries = append(unescapedQueries, unescapedQuery)
    	}
    	return unescapedQueries, nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  2. internal/deadlineconn/deadlineconn.go

    func (c *DeadlineConn) Read(b []byte) (n int, err error) {
    	c.setReadDeadline()
    	n, err = c.Conn.Read(b)
    	return n, err
    }
    
    // Write - writes data to the connection.
    func (c *DeadlineConn) Write(b []byte) (n int, err error) {
    	c.setWriteDeadline()
    	n, err = c.Conn.Write(b)
    	return n, err
    }
    
    // WithReadDeadline sets a new read side net.Conn deadline.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 17:40:11 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  3. src/cmd/addr2line/main.go

    	counter.CountFlags("addr2line/flag:", *flag.CommandLine)
    	if flag.NArg() != 1 {
    		usage()
    	}
    
    	f, err := objfile.Open(flag.Arg(0))
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer f.Close()
    
    	tab, err := f.PCLineTable()
    	if err != nil {
    		log.Fatalf("reading %s: %v", flag.Arg(0), err)
    	}
    
    	stdin := bufio.NewScanner(os.Stdin)
    	stdout := bufio.NewWriter(os.Stdout)
    
    	for stdin.Scan() {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. istioctl/pkg/workload/workload_test.go

    		IstioNamespace: "istio-system",
    	})
    	rootCmd := Cmd(ctx)
    	rootCmd.SetArgs(args)
    	client, err := ctx.CLIClientWithRevision(rev)
    	if err != nil {
    		return "", err
    	}
    	createResourceFunc(client)
    
    	rootCmd.SetOut(&out)
    	rootCmd.SetErr(&out)
    	err = rootCmd.Execute()
    	output := out.String()
    	return output, err
    }
    
    func checkOutputFiles(t *testing.T, testdir string, checkFiles map[string]bool) {
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1.go

    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(data, &info); err != nil {
    		return err
    	}
    	sum, err := hex.DecodeString(info.Hash)
    	if err != nil {
    		return err
    	}
    	c.Algorithm = BitrotAlgorithmFromString(info.Algorithm)
    	c.Hash = sum
    	if _, err = fmt.Sscanf(info.Name, "part.%d", &c.PartNumber); err != nil {
    		return err
    	}
    
    	if !c.Algorithm.Available() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cni/pkg/plugin/sidecar_iptables_linux.go

    	cfg.DualStack = rdrct.dualStack
    
    	netNs, err := getNs(netns)
    	if err != nil {
    		err = fmt.Errorf("failed to open netns %q: %s", netns, err)
    		return err
    	}
    	defer netNs.Close()
    
    	return netNs.Do(func(_ ns.NetNS) error {
    		// Important: run within the pod network namespace since some attributes are namespace specific
    		if err := cfg.FillConfigFromEnvironment(); err != nil {
    			return err
    		}
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Sat Jun 29 01:24:47 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  7. internal/s3select/sql/jsonpath.go

    		case simdjson.Object:
    			elem := kvs.FindKey(key, nil)
    			if elem == nil {
    				// Key not found - return nil result
    				return Missing{}, false, nil
    			}
    			val, err := IterToValue(elem.Iter)
    			if err != nil {
    				return nil, false, err
    			}
    			return jsonpathEval(p[1:], val)
    		default:
    			return nil, false, errKeyLookup
    		}
    
    	case p[0].Index != nil:
    		idx := *p[0].Index
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/tag.go

    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			var s string
    			if err = d.DecodeElement(&s, &se); err != nil {
    				return err
    			}
    			switch se.Name.Local {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  9. internal/bucket/lifecycle/transition.go

    	var dateStr string
    	err := d.DecodeElement(&dateStr, &startElement)
    	if err != nil {
    		return err
    	}
    	// While AWS documentation mentions that the date specified
    	// must be present in ISO 8601 format, in reality they allow
    	// users to provide RFC 3339 compliant dates.
    	trnDate, err := time.Parse(time.RFC3339, dateStr)
    	if err != nil {
    		return errTransitionInvalidDate
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 10 17:07:49 UTC 2022
    - 5.1K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/net_test.go

    		Name:      "foo",
    		Namespace: "bar",
    		UID:       "123",
    	}
    	podIP := netip.MustParseAddr("99.9.9.9")
    	podIPs := []netip.Addr{podIP}
    
    	err := netServer.AddPodToMesh(ctx, &corev1.Pod{ObjectMeta: podMeta}, podIPs, "fakenetns")
    	assert.NoError(t, err)
    	assert.Equal(t, 1, ztunnelServer.addedPods.Load())
    }
    
    func TestServerRemovePod(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Thu Jul 25 16:13:38 UTC 2024
    - 10.7K bytes
    - Viewed (0)
Back to top