Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for didreq (0.23 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/zsys_solaris_amd64.go

    	sizeofLifreq       = 0x178
    	sizeofLifconf      = 0x18
    	sizeofLifIfinfoReq = 0x10
    )
    
    type lifnum struct {
    	Family    uint16
    	Pad_cgo_0 [2]byte
    	Flags     int32
    	Count     int32
    }
    
    type lifreq struct {
    	Name   [32]int8
    	Lifru1 [4]byte
    	Type   uint32
    	Lifru  [336]byte
    }
    
    type lifconf struct {
    	Family    uint16
    	Pad_cgo_0 [2]byte
    	Flags     int32
    	Len       int32
    	Pad_cgo_1 [4]byte
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 05 19:54:32 UTC 2022
    - 981 bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. internal/handlers/forwarder.go

    func (f *Forwarder) ServeHTTP(w http.ResponseWriter, inReq *http.Request) {
    	outReq := new(http.Request)
    	*outReq = *inReq // includes shallow copies of maps, but we handle this in Director
    
    	revproxy := httputil.ReverseProxy{
    		Director: func(req *http.Request) {
    			f.modifyRequest(req, inReq.URL)
    		},
    		BufferPool:    newBufPool(128 << 10),
    		Transport:     f.RoundTripper,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  10. 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)
Back to top