Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 353 for resch (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. releasenotes/notes/46678.yaml

    # issue is a list of GitHub issues resolved in this note.
    issue:
      - 46555
    # releaseNotes is a markdown listing of any user facing changes. This will appear in the
    # release notes.
    releaseNotes:
    - |
      **Fixed** attempting to reach multi-network endpoints that are unreachable due to `DestinationRule` TLS mode
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Aug 24 21:40:59 UTC 2023
    - 407 bytes
    - Viewed (0)
  10. .github/ISSUE_TEMPLATE/config.yml

    blank_issues_enabled: false
    contact_links:
      - name: Ask for help
        url: http://help.gradle.org/
        about: If you need help with Gradle or have a usage question, please reach our community instead of creating an issue.
      - name: Create an issue without template
        url: https://github.com/gradle/gradle/issues/new
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 06 11:10:39 UTC 2023
    - 387 bytes
    - Viewed (0)
Back to top