Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for Tr (0.32 sec)

  1. internal/http/transports.go

    func (s ConnSettings) NewRemoteTargetHTTPTransport(insecure bool) func() *http.Transport {
    	tr := s.getDefaultTransport(0)
    
    	tr.TLSHandshakeTimeout = 10 * time.Second
    	tr.ResponseHeaderTimeout = 0
    	tr.TLSClientConfig.InsecureSkipVerify = insecure
    
    	return func() *http.Transport {
    		return tr
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  2. src/bytes/bytes.go

    	for ; i < len(s) && i < len(t); i++ {
    		sr := s[i]
    		tr := t[i]
    		if sr|tr >= utf8.RuneSelf {
    			goto hasUnicode
    		}
    
    		// Easy case.
    		if tr == sr {
    			continue
    		}
    
    		// Make sr < tr to simplify what follows.
    		if tr < sr {
    			tr, sr = sr, tr
    		}
    		// ASCII only, sr/tr must be upper/lower case
    		if 'A' <= sr && sr <= 'Z' && tr == sr+'a'-'A' {
    			continue
    		}
    		return false
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Feb 19 19:51:15 GMT 2024
    - 33.8K bytes
    - Viewed (0)
  3. internal/dsync/dsync-client_test.go

    // It _doesn't_ connect to the remote endpoint. See Call method to see when the
    // connect happens.
    func newClient(endpoint string) NetLocker {
    	u, err := url.Parse(endpoint)
    	if err != nil {
    		panic(err)
    	}
    
    	tr := &http.Transport{
    		Proxy:                 http.ProxyFromEnvironment,
    		MaxIdleConnsPerHost:   1024,
    		WriteBufferSize:       32 << 10, // 32KiB moving up from 4KiB default
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 20 17:36:09 GMT 2022
    - 4.4K bytes
    - Viewed (0)
  4. src/archive/tar/reader.go

    	for {
    		// Discard the remainder of the file and any padding.
    		if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil {
    			return nil, err
    		}
    		if _, err := tryReadFull(tr.r, tr.blk[:tr.pad]); err != nil {
    			return nil, err
    		}
    		tr.pad = 0
    
    		hdr, rawHdr, err := tr.readHeader()
    		if err != nil {
    			return nil, err
    		}
    		if err := tr.handleRegularFile(hdr); err != nil {
    			return nil, err
    		}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  5. src/archive/tar/reader_test.go

    		})
    		tw.Close()
    
    		tr := NewReader(&buf)
    		h, err := tr.Next()
    		if err != ErrInsecurePath {
    			t.Errorf("tr.Next for file %q: got err %v, want ErrInsecurePath", path, err)
    			continue
    		}
    		if h.Name != path {
    			t.Errorf("tr.Next for file %q: got name %q, want %q", path, h.Name, path)
    		}
    		// Error should not be sticky.
    		h, err = tr.Next()
    		if err != nil {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Nov 21 21:14:38 GMT 2022
    - 47.1K bytes
    - Viewed (0)
  6. internal/rest/client.go

    }
    
    // Close closes all idle connections of the underlying http client
    func (c *Client) Close() {
    	atomic.StoreInt32(&c.connected, closed)
    }
    
    // NewClient - returns new REST client.
    func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client {
    	connected := int32(online)
    	urlStr := uu.String()
    	u, err := url.Parse(urlStr)
    	if err != nil {
    		// Mark offline, with no reconnection attempts.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 14.4K bytes
    - Viewed (0)
  7. src/archive/tar/tar_test.go

    	if err := tw.Close(); err != nil {
    		t.Fatalf("tw.Close: %v", err)
    	}
    
    	// Read it back.
    	tr := NewReader(&b)
    	rHdr, err := tr.Next()
    	if err != nil {
    		t.Fatalf("tr.Next: %v", err)
    	}
    	if !reflect.DeepEqual(rHdr, hdr) {
    		t.Errorf("Header mismatch.\n got %+v\nwant %+v", rHdr, hdr)
    	}
    	rData, err := io.ReadAll(tr)
    	if err != nil {
    		t.Fatalf("Read: %v", err)
    	}
    	if !bytes.Equal(rData, data) {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Mar 15 16:01:50 GMT 2024
    - 24K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    			"mode":   fmt.Sprint(opts.ScanMode),
    		}
    		if result != nil {
    			tr.Custom["version-id"] = result.VersionID
    			tr.Custom["disks"] = strconv.Itoa(result.DiskCount)
    		}
    	}
    	if err != nil {
    		tr.Error = err.Error()
    	} else {
    		tr.HealResult = result
    	}
    	globalTrace.Publish(tr)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  9. src/cmd/asm/internal/lex/input.go

    	// Newline must be next.
    	tok := in.Stack.Next()
    	if tok != '\n' {
    		in.Error("syntax error in #undef for macro:", name)
    	}
    	delete(in.macros, name)
    }
    
    func (in *Input) Push(r TokenReader) {
    	if len(in.tr) > 100 {
    		in.Error("input recursion")
    	}
    	in.Stack.Push(r)
    }
    
    func (in *Input) Close() {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Aug 29 07:48:38 GMT 2023
    - 12.6K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/transition_test.go

    		  </Transition>`,
    			err: errXMLNotWellFormed,
    		},
    	}
    
    	for i, tc := range trTests {
    		var tr Transition
    		err := xml.Unmarshal([]byte(tc.input), &tr)
    		if err != nil {
    			t.Fatalf("%d: xml unmarshal failed with %v", i+1, err)
    		}
    		if err = tr.Validate(); err != tc.err {
    			t.Fatalf("%d: Invalid transition %v: err %v", i+1, tr, err)
    		}
    	}
    
    	ntrTests := []struct {
    		input string
    		err   error
    	}{
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Oct 01 18:58:17 GMT 2021
    - 2.3K bytes
    - Viewed (0)
Back to top