- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for didreq (0.51 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)