- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 643 for dialing (0.16 sec)
-
src/net/http/serve_test.go
conn, err := net.Dial("tcp", ts.Listener.Addr().String()) if err != nil { t.Fatalf("error dialing: %v", err) } _, err = conn.Write([]byte("GET /?underwrite=1 HTTP/1.1\r\nHost: foo\r\n\r\n")) if err != nil { t.Fatalf("error writing: %v", err) } // The ReadAll will hang for a failing test. got, _ := io.ReadAll(conn) expectedSuffix := "\r\n\r\ntoo short"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
// TODO: move into SecureServing(WithLoopback) as soon as insecure serving is gone LoopbackClientConfig *restclient.Config // EgressSelector provides a lookup mechanism for dialing outbound connections. // It does so based on a EgressSelectorConfiguration which was read at startup. EgressSelector *egressselector.EgressSelector
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
src/net/http/transport_test.go
dialGate := make(chan bool, 1) dialing := make(chan bool) c := ts.Client() c.Transport.(*Transport).Dial = func(n, addr string) (net.Conn, error) { for { select { case ok := <-dialGate: if !ok { return nil, errors.New("manually closed") } return net.Dial(n, addr) case dialing <- true: } } } defer close(dialGate)
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/net/http/h2_bundle.go
if call, ok := p.dialing[addr]; ok { // A dial is already in-flight. Don't start another. return call } call := &http2dialCall{p: p, done: make(chan struct{}), ctx: ctx} if p.dialing == nil { p.dialing = make(map[string]*http2dialCall) } p.dialing[addr] = call go call.dial(call.ctx, addr) return call }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
req.Header.Set("Connection", "Upgrade") req.Header.Set("Upgrade", "websocket") res, err := frontendProxy.Client().Do(req) if err != nil { t.Fatalf("Dialing to frontend proxy: %v", err) } defer res.Body.Close() if g, w := res.StatusCode, 101; g != w { t.Fatalf("Switching protocols failed, got: %d, want: %d", g, w) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
cmd/erasure-healing.go
const ( xMinIOHealing = ReservedMetadataPrefix + "healing" xMinIODataMov = ReservedMetadataPrefix + "data-mov" ) // SetHealing marks object (version) as being healed. // Note: this is to be used only from healObject func (fi *FileInfo) SetHealing() { if fi.Metadata == nil { fi.Metadata = make(map[string]string) } fi.Metadata[xMinIOHealing] = "true" }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.8K bytes - Viewed (0) -
buildscripts/verify-healing.sh
for i in $(seq 1 3); do echo "server$i log:" cat "${WORK_DIR}/dist-minio-server$i.log" done echo "FAILED" purge "$WORK_DIR" exit 1 fi sleep 1 if pgrep minio; then # forcibly killing, to proceed further properly. if ! pkill -9 minio; then echo "no minio process running anymore, proceed." fi fi } function check_heal() { if ! grep -q 'Status:' ${WORK_DIR}/dist-minio-*.log; then
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.3K bytes - Viewed (0) -
.github/workflows/go-healing.yml
run: | sudo sysctl net.ipv6.conf.all.disable_ipv6=0 sudo sysctl net.ipv6.conf.default.disable_ipv6=0 make verify-healing make verify-healing-inconsistent-versions make verify-healing-with-root-disks
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 1.2K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/failing-test.yaml
name: Failing Test description: Report continuously failing tests or jobs in Kubernetes CI labels: kind/failing-test body: - type: textarea id: jobs attributes: label: Which jobs are failing? placeholder: | Please only use this template for submitting reports about continuously failing tests or jobs in Kubernetes CI. validations: required: true - type: textarea id: tests attributes:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 05 16:55:38 UTC 2021 - 1.1K bytes - Viewed (0) -
cmd/erasure-healing-common.go
meta.DataDir = latestMeta.DataDir switch scanMode { case madmin.HealDeepScan: // disk has a valid xl.meta but may not have all the // parts. This is considered an outdated disk, since // it needs healing too. verifyResp, verifyErr = onlineDisk.VerifyFile(ctx, bucket, object, meta) default: verifyResp, verifyErr = onlineDisk.CheckParts(ctx, bucket, object, meta) } for p := range latestMeta.Parts {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 12.5K bytes - Viewed (0)