- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 395 for resch (0.04 sec)
-
pkg/lazy/lazy_test.go
}) wg := sync.WaitGroup{} wg.Add(10) results := []int32{} resCh := make(chan int32, 10) for i := 0; i < 10; i++ { go func() { res, err := l.Get() if res >= 6 { assert.NoError(t, err) } else { assert.Error(t, err) } resCh <- res wg.Done() }() } wg.Wait() close(resCh) for r := range resCh { results = append(results, r) } slices.Sort(results)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 3K bytes - Viewed (0) -
cmd/metacache-set.go
// We have enough and we have more. // Do not return io.EOF if resCh != nil { resErr = nil select { case resCh <- results: case <-ctx.Done(): } resCh = nil returned = true } continue } results.o = append(results.o, entry) } if resCh != nil { resErr = io.EOF select { case <-ctx.Done(): // Nobody wants it.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 30.4K bytes - Viewed (0) -
src/net/http/transport_test.go
fmt.Fprintf(bodyw, "num%d\n", i) } }() resc := make(chan *Response) go func() { req, _ := NewRequest("POST", "http://localhost:8080", bodyr) req.Header.Set("User-Agent", "x") // known value for test res, err := tr.RoundTrip(req) if err != nil { t.Errorf("RoundTrip: %v", err) close(resc) return } resc <- res }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
cmd/background-heal-ops.go
} else { res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts) } } if task.respCh != nil { task.respCh <- healResult{result: res, err: err} continue } // when respCh is not set caller is not waiting but we // update the relevant metrics for them if bgSeq != nil { if err == nil { bgSeq.countHealed(res.Type)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
src/net/resolverdialfunc_test.go
a.h.Question(h, q) } if err != nil && err != dnsmessage.ErrSectionDone { return 0, err } resh := h resh.Response = true resh.Authoritative = true if hadQ { resh.RCode = dnsmessage.RCodeSuccess } else { resh.RCode = dnsmessage.RCodeNotImplemented } a.rbuf.Grow(514) a.rbuf.WriteByte('X') // reserved header for beu16 length
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8.3K bytes - Viewed (0) -
manifests/charts/base/templates/services.yaml
apiVersion: v1 kind: Service metadata: {{- if .Values.pilot.enabled }} # when local istiod is enabled, we can't use istiod service name to reach the remote control plane name: istiod{{- if .Values.revision }}-{{ .Values.revision}}{{- end }}-remote {{- else }} # when local istiod isn't enabled, we can use istiod service name to reach the remote control plane name: istiod{{- if .Values.revision }}-{{ .Values.revision}}{{- end }} {{- end }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:40 UTC 2024 - 1.1K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/services.yaml
apiVersion: v1 kind: Service metadata: {{- if .Values.pilot.enabled }} # when local istiod is enabled, we can't use istiod service name to reach the remote control plane name: istiod{{- if .Values.revision }}-{{ .Values.revision}}{{- end }}-remote {{- else }} # when local istiod isn't enabled, we can use istiod service name to reach the remote control plane name: istiod{{- if .Values.revision }}-{{ .Values.revision}}{{- end }} {{- end }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:40 UTC 2024 - 1.1K bytes - Viewed (0) -
test/fixedbugs/issue16095.go
// Allocate that same object again and clobber it. y := new([20]byte) for i := 0; i < 20; i++ { y[i] = 99 } // Make sure y is heap allocated. sink = y panic(nil) // After the recover we reach the deferreturn, which // copies the heap version of x back to the stack. // It gets the pointer to x from a stack slot that was // not marked as live during the call to runtime.GC(). } var sinkint int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 27 16:48:48 UTC 2016 - 1.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Service.java
/** * Waits for the {@link Service} to reach the {@linkplain State#TERMINATED terminated state}. * * @throws IllegalStateException if the service {@linkplain State#FAILED fails}. * @since 15.0 */ void awaitTerminated(); /** * Waits for the {@link Service} to reach a terminal state (either {@link Service.State#TERMINATED
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 12.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/preflight/checks.go
return &url.URL{}, fmt.Errorf("unable to parse etcd url: %v", err) } return connURL, nil } // CheckEtcdServers will attempt to reach all etcd servers once. If any // can be reached, return true. func (con EtcdConnection) CheckEtcdServers() (done bool, err error) { // Attempt to reach every Etcd server randomly. serverNumber := len(con.ServerList) serverPerms := rand.Perm(serverNumber) for _, index := range serverPerms {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 20 10:50:48 UTC 2018 - 1.8K bytes - Viewed (0)