Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 176 for blocked (0.38 sec)

  1. tests/integration/helm/install_test.go

    			framework.
    				NewTest(t).
    				Run(setupInstallation(ambientProfileOverride, true, tt.nsConfig, ""))
    		})
    	}
    }
    
    // TestReleaseChannels tests that non-stable CRDs and fields get blocked
    // by the default ValidatingAdmissionPolicy
    func TestReleaseChannels(t *testing.T) {
    	overrideValuesStr := `
    global:
      hub: %s
      tag: %s
      variant: %q
    profile: stable
    `
    
    	framework.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  2. src/runtime/internal/wasitest/nonblock_test.go

    // the FIFOs in their original order and spawns a goroutine for each that reads
    // from the FIFO and writes the result to stderr. If I/O was blocking, all
    // goroutines would be blocked waiting for one read call to return, and the
    // output order wouldn't match.
    
    type fifo struct {
    	file *os.File
    	path string
    }
    
    func TestNonblock(t *testing.T) {
    	if target != "wasip1/wasm" {
    		t.Skip()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 29 15:35:27 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  3. src/internal/trace/testdata/testprog/stress-start-stop.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines,
    // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS).
    
    //go:build ignore
    
    package main
    
    import (
    	"bytes"
    	"io"
    	"log"
    	"net"
    	"os"
    	"runtime"
    	"runtime/trace"
    	"sync"
    	"time"
    )
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/testprog/stacks.go

    	// Now we will do a bunch of things for which we verify stacks later.
    	// It is impossible to ensure that a goroutine has actually blocked
    	// on a channel, in a select or otherwise. So we kick off goroutines
    	// that need to block first in the hope that while we are executing
    	// the rest of the test, they will block.
    	go func() { // func1
    		select {}
    	}()
    	go func() { // func2
    		var c chan int
    		c <- 0
    	}()
    	go func() { // func3
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/SendPartialResponseThenBlock.java

            }
        }
    
        @Override
        public void release() {
            lock.lock();
            try {
                if (!requestStarted) {
                    throw new IllegalStateException("Response is not blocked, should call waitUntilBlocked() first.");
                }
                released = true;
                condition.signalAll();
            } finally {
                lock.unlock();
            }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  6. src/syscall/js/func.go

    // Other wrapped functions which are triggered during a call from Go to JavaScript
    // get executed on the same goroutine.
    //
    // As a consequence, if one wrapped function blocks, JavaScript's event loop
    // is blocked until that function returns. Hence, calling any async JavaScript
    // API, which requires the event loop, like fetch (http.Client), will cause an
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 22 17:47:47 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  7. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/IndexedCache.java

         *
         * A file lock is held until the value has been produced and written to the persistent store, and other processes will be blocked from producing the same value until this process has completed doing so.
         *
         * @return The value.
         */
        @Override
        V get(K key, Function<? super K, ? extends V> producer);
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  8. src/runtime/traceevent.go

    	traceEvGoBlock             // goroutine blocks [timestamp, reason, stack ID]
    	traceEvGoUnblock           // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID]
    	traceEvGoSyscallBegin      // syscall enter [timestamp, P seq, stack ID]
    	traceEvGoSyscallEnd        // syscall exit [timestamp]
    	traceEvGoSyscallEndBlocked // syscall exit and it blocked at some point [timestamp]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. platforms/core-execution/execution-e2e-tests/src/integTest/groovy/org/gradle/integtests/ParallelProjectExecutionIntegrationTest.groovy

                tasks.getByPath(':b:pingC').dependsOn([':b:pingA', ':b:pingB'])
            """
    
            expect:
            //project a and b are both executed even though alphabetically more important task is blocked
            blockingServer.expectConcurrent(':b:pingB', ':a:pingA')
            blockingServer.expect(':b:pingA')
            blockingServer.expect(':b:pingC')
    
            run 'b:pingC'
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Mar 04 10:15:40 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java

        ) {
            this.userInput = userInput;
            // Use a single reader thread, and make it a daemon thread so that it does not block process shutdown
            // In most cases, we try to cleanly shut down all threads. However, in this case it is difficult to disconnect a thread blocked trying to read from the
            // process' stdin, so use a daemon thread instead.
            executor = Executors.newSingleThreadExecutor(r -> {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 15 19:53:31 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top