Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for resMatch (0.22 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go

    				err = fmt.Sprintf("%v\n%s", err, buf)
    			}
    			resultCh <- err
    		}()
    		t.handler.ServeHTTP(w, rCopy)
    	}()
    	select {
    	case err := <-resultCh:
    		// panic if error occurs; stop otherwise
    		if err != nil {
    			panic(err)
    		}
    		return
    	case <-timeoutCh:
    		defer func() {
    			// resultCh needs to have a reader, since the function doing
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go

    			// and the initialization signal will not be send.
    			// It has to happen before waiting on the resultCh below.
    			watchInitializationSignal.Signal()
    			// TODO: Consider finishing the request as soon as Handle call panics.
    			if err := <-resultCh; err != nil {
    				panic(err)
    			}
    		case err := <-resultCh:
    			if err != nil {
    				panic(err)
    			}
    		}
    	} else {
    		execute := func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_test.go

    	}
    	bak := os.Stderr
    	os.Stderr = w
    	defer func() { os.Stderr = bak }()
    
    	resultCh := make(chan string)
    	// copy the output in a separate goroutine so printing can't block indefinitely
    	go func() {
    		var buf bytes.Buffer
    		io.Copy(&buf, r)
    		resultCh <- buf.String()
    	}()
    
    	f()
    	w.Close()
    
    	return <-resultCh, nil
    }
    
    func Test_rudimentaryErrorBackoff_OnError_ParallelSleep(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 16:28:45 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. src/go/build/read.go

    					continue
    				}
    				if c == '"' {
    					c = r.readByteNoBuf()
    					goto Reswitch
    				}
    			}
    			goto Reswitch
    
    		case '`':
    			startLine = false
    			for r.err == nil {
    				if r.eof {
    					r.syntaxError()
    				}
    				c = r.readByteNoBuf()
    				if c == '`' {
    					c = r.readByteNoBuf()
    					goto Reswitch
    				}
    			}
    
    		case '\'':
    			startLine = false
    			for r.err == nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

    }
    
    type inFlightRequest struct {
    	blockedCh, startedCh chan struct{}
    	resultCh             chan result
    	url                  string
    }
    
    func setupInFlightNonLongRunningRequestHandler(s *GenericAPIServer) *inFlightRequest {
    	inflight := &inFlightRequest{
    		blockedCh: make(chan struct{}),
    		startedCh: make(chan struct{}),
    		resultCh:  make(chan result),
    		url:       "/in-flight-non-long-running-request-as-designed",
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  6. platforms/core-runtime/files/src/main/java/org/gradle/internal/file/PathTraversalChecker.java

         *
         * This code is used for path traversal, ZipSlip and TarSlip detection.
         *
         * <b>IMPLEMENTATION NOTE</b>
         * We do it this way instead of the way recommended in <a href="https://snyk.io/research/zip-slip-vulnerability"></a>
         * for performance reasons, calling {@link File#getCanonicalPath()} is too expensive.
         *
         * @throws IllegalArgumentException if the entry contains vulnerable sequences
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:55:52 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. platforms/core-runtime/wrapper-shared/src/integTest/groovy/org/gradle/integtests/PathTraversalCheckerIntegrationTest.groovy

    import java.util.zip.ZipEntry
    import java.util.zip.ZipFile
    import java.util.zip.ZipOutputStream
    
    /**
     * Ensures Gradle core tasks and types are not subject to the
     * <a href="https://snyk.io/research/zip-slip-vulnerability">Zip Slip Vulnerability</a>.
     */
    class PathTraversalCheckerIntegrationTest extends AbstractIntegrationSpec {
    
        private TestFile getEvilZip() {
            file("evil.zip")
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:12:34 UTC 2023
    - 4K bytes
    - Viewed (0)
  8. common/scripts/setup_env.sh

    #
    # testcase: "a:b c:d"
    # testcase: "a b:c d:e f"
    # testcase: "a b:c:d e"
    parse_KUBECONFIG () {
    TMPDIR=""
    if [[ "$1" =~ ([^:]*):(.*) ]]; then
      while true; do
        rematch=${BASH_REMATCH[1]}
        add_KUBECONFIG_if_exists "$rematch"
        remainder="${BASH_REMATCH[2]}"
        if [[ ! "$remainder" =~ ([^:]*):(.*) ]]; then
          if [[ -n "$remainder" ]]; then
            add_KUBECONFIG_if_exists "$remainder"
            break
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 12 14:37:27 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  9. okhttp-tls/src/test/java/okhttp3/tls/internal/der/DerCertificatesTest.kt

      }
    
      @Test
      fun `certificate attributes`() {
        val certificate =
          HeldCertificate.Builder()
            .certificateAuthority(3)
            .commonName("Jurassic Park")
            .organizationalUnit("Gene Research")
            .addSubjectAlternativeName("*.example.com")
            .addSubjectAlternativeName("www.example.org")
            .validityInterval(-1000L, 2000L)
            .serialNumber(17L)
            .build()
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  10. src/cmd/go/internal/mvs/mvs.go

    // Copyright 2018 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Package mvs implements Minimal Version Selection.
    // See https://research.swtch.com/vgo-mvs.
    package mvs
    
    import (
    	"fmt"
    	"slices"
    	"sort"
    	"sync"
    
    	"cmd/go/internal/par"
    
    	"golang.org/x/mod/module"
    )
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 21:58:12 UTC 2024
    - 14.5K bytes
    - Viewed (0)
Back to top