Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 355 for blocked (0.22 sec)

  1. src/internal/trace/trace_test.go

    			// of entered -> blocked -> runnable -> running. If in the running state
    			// we block, then we have a futile wakeup. Because of the runtime.Gosched
    			// on these specially marked goroutines, we should end up back in runnable
    			// first. If at any point we go to a different state, switch back to entered
    			// and wait for the next time the goroutine blocks.
    			if ev.Kind() != trace.EventStateTransition {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. src/net/net_test.go

    			return
    		}
    		err = peer2(c2.(*TCPConn))
    		c2.Close()
    		errc <- err
    	}()
    	for i := 0; i < 2; i++ {
    		if err := <-errc; err != nil {
    			t.Error(err)
    		}
    	}
    }
    
    // Tests that a blocked Read is interrupted by a concurrent SetReadDeadline
    // modifying that Conn's read deadline to the past.
    // See golang.org/cl/30164 which documented this. The net/http package
    // depends on this.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 22 21:04:44 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. src/runtime/preempt.go

    // Goroutine preemption
    //
    // A goroutine can be preempted at any safe-point. Currently, there
    // are a few categories of safe-points:
    //
    // 1. A blocked safe-point occurs for the duration that a goroutine is
    //    descheduled, blocked on synchronization, or in a system call.
    //
    // 2. Synchronous safe-points occur when a running goroutine checks
    //    for a preemption request.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 15:41:45 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. src/runtime/sema.go

    // The operations on the inner lists of sudogs with the same address
    // are all O(1). The scanning of the top-level semaRoot list is O(log n),
    // where n is the number of distinct addresses with goroutines blocked
    // on them that hash to the given semaRoot.
    // See golang.org/issue/17953 for a program that worked badly
    // before we introduced the second level of list, and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go

    func (ping) Name() string {
    	return "ping"
    }
    
    // PingHealthz is a health check that returns true.
    func (ping) Check(_ *http.Request) error {
    	return nil
    }
    
    // LogHealthz returns true if logging is not blocked
    var LogHealthz HealthChecker = &log{}
    
    type log struct {
    	startOnce    sync.Once
    	lastVerified atomic.Value
    }
    
    func (l *log) Name() string {
    	return "log"
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 10.5K 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