Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 44 for didreq (0.17 sec)

  1. src/net/http/transport_test.go

    	})).ts
    	c := ts.Client()
    	tr = c.Transport.(*Transport)
    
    	didreq := make(chan bool)
    	go func() {
    		res, err := c.Get(ts.URL)
    		if err != nil {
    			t.Error(err)
    		} else {
    			res.Body.Close() // returns idle conn
    		}
    		didreq <- true
    	}()
    	unblockCh <- true
    	<-didreq
    }
    
    // Test that the transport doesn't close the TCP connection early,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  2. src/vendor/golang.org/x/net/lif/link.go

    	Flags int    // flags
    	MTU   int    // maximum transmission unit, basically link MTU but may differ between IP address families
    	Addr  []byte // address
    }
    
    func (ll *Link) fetch(s uintptr) {
    	var lifr lifreq
    	for i := 0; i < len(ll.Name); i++ {
    		lifr.Name[i] = int8(ll.Name[i])
    	}
    	ioc := int64(syscall.SIOCGLIFINDEX)
    	if err := ioctl(s, uintptr(ioc), unsafe.Pointer(&lifr)); err == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/ioctl_linux.go

    	return ByteSliceToString(value[:]), err
    }
    
    // IoctlIfreq performs an ioctl using an Ifreq structure for input and/or
    // output. See the netdevice(7) man page for details.
    func IoctlIfreq(fd int, req uint, value *Ifreq) error {
    	// It is possible we will add more fields to *Ifreq itself later to prevent
    	// misuse, so pass the raw *ifreq directly.
    	return ioctlPtr(fd, req, unsafe.Pointer(&value.raw))
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 29 21:28:33 UTC 2023
    - 8.1K bytes
    - Viewed (0)
  4. pilot/pkg/xds/workload.go

    	// However, other code will merge "Partial push + Full push -> Full push", so skipping full pushes isn't viable.
    	full := (isReq && w.Wildcard) || (!isReq && req.Full && len(req.ConfigsUpdated) == 0)
    
    	// Nothing to do
    	if len(addresses) == 0 && !full {
    		if isReq {
    			// We need to respond for requests, even if we have nothing to respond with
    			return make(model.Resources, 0), nil, model.XdsLogDetails{}, false, nil
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 14:14:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  5. pkg/test/echo/server/forwarder/util.go

    				addr = address
    			}
    			return d.DialContext(ctx, nt, addr)
    		},
    	}
    }
    
    // doForward sends the requests and collect the responses.
    func doForward(ctx context.Context, cfg *Config, e *executor, doReq func(context.Context, *Config, int) (string, error)) (*proto.ForwardEchoResponse, error) {
    	// make the timeout apply to the entire set of requests
    	ctx, cancel := context.WithTimeout(ctx, cfg.timeout)
    	defer cancel()
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Oct 08 09:39:20 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  6. cmd/bucket-handlers_test.go

    	// The only aim is to generate an HTTP request in a way that the relevant/registered end point is evoked/called.
    
    	nilBucket := "dummy-bucket"
    	nilReq, err := newTestRequest(http.MethodGet, getBucketLocationURL("", nilBucket), 0, nil)
    	if err != nil {
    		t.Errorf("MinIO %s: Failed to create HTTP request for testing the response when object Layer is set to `nil`.", instanceType)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/sys/unix/syscall_darwin.go

    	return &ifreq, err
    }
    
    // IoctlSetIfreqMTU performs the SIOCSIFMTU ioctl operation on fd to set the MTU
    // of the network device specified by ifreq.Name.
    func IoctlSetIfreqMTU(fd int, ifreq *IfreqMTU) error {
    	return ioctlPtr(fd, SIOCSIFMTU, unsafe.Pointer(ifreq))
    }
    
    //sys	sysctl(mib []_C_int, old *byte, oldlen *uintptr, new *byte, newlen uintptr) (err error) = SYS_SYSCTL
    
    func Uname(uname *Utsname) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 10 16:32:44 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  8. src/net/http/client.go

    					host = req.Host
    				}
    			}
    			ireq := reqs[0]
    			req = &Request{
    				Method:   redirectMethod,
    				Response: resp,
    				URL:      u,
    				Header:   make(Header),
    				Host:     host,
    				Cancel:   ireq.Cancel,
    				ctx:      ireq.ctx,
    			}
    			if includeBody && ireq.GetBody != nil {
    				req.Body, err = ireq.GetBody()
    				if err != nil {
    					resp.closeBody()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 26 06:06:11 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  9. src/vendor/golang.org/x/net/lif/address.go

    	}
    	defer func() {
    		for _, ep := range eps {
    			ep.close()
    		}
    	}()
    	lls, err := links(eps, name)
    	if len(lls) == 0 {
    		return nil, err
    	}
    	var as []Addr
    	for _, ll := range lls {
    		var lifr lifreq
    		for i := 0; i < len(ll.Name); i++ {
    			lifr.Name[i] = int8(ll.Name[i])
    		}
    		for _, ep := range eps {
    			ioc := int64(syscall.SIOCGLIFADDR)
    			err := ioctl(ep.s, uintptr(ioc), unsafe.Pointer(&lifr))
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  10. cmd/bucket-policy-handlers_test.go

    	// The only aim is to generate an HTTP request in a way that the relevant/registered end point is evoked/called.
    	nilBucket := "dummy-bucket"
    
    	nilReq, err := newTestSignedRequestV4(http.MethodPut, getPutPolicyURL("", nilBucket),
    		0, nil, "", "", nil)
    	if err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
Back to top