Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 192 for blocked (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/internal/trace/parser.go

    	EvGoBlock           = 20 // goroutine blocks [timestamp, stack]
    	EvGoUnblock         = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack]
    	EvGoBlockSend       = 22 // goroutine blocks on chan send [timestamp, stack]
    	EvGoBlockRecv       = 23 // goroutine blocks on chan recv [timestamp, stack]
    	EvGoBlockSelect     = 24 // goroutine blocks on select [timestamp, stack]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:31:04 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  5. test/chan/select3.go

    			time.Sleep(10 * time.Millisecond)
    		}
    		c <- always // f blocked always
    	}()
    	if <-c != signal {
    		panic(signal + " block")
    	}
    }
    
    func main() {
    	const async = 1 // asynchronous channels
    	var nilch chan int
    	closedch := make(chan int)
    	close(closedch)
    
    	// sending/receiving from a nil channel blocks
    	testBlock(always, func() {
    		nilch <- 7
    	})
    	testBlock(always, func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Jul 08 02:10:12 UTC 2017
    - 4.1K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStateControl.java

         * Requests that a running build be canceled.  Note that this method does NOT block until the operation has been cancelled.
         */
        void requestCancel();
    
        /**
         * Communicates a request for build cancellation. Note that this method blocks until the operation has been cancelled.
         *
         * <p>If any long running command is currently running, this method does block for certain time to give chance to perform cancellation, and if the command
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sun May 05 22:24:02 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt

       * Returns the name of the server the client requested via the SNI (Server Name Indication)
       * attribute in the TLS handshake. Unlike the rest of the HTTP exchange, this name is sent in
       * cleartext and may be monitored or blocked by a proxy or other middlebox.
       */
      val handshakeServerNames: List<String>
    
      init {
        if (socket is SSLSocket) {
          try {
            this.handshake = socket.session.handshake()
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. pkg/registry/scheduling/rest/storage_scheduling.go

    						if err == nil || apierrors.IsAlreadyExists(err) {
    							klog.Infof("created PriorityClass %s with value %v", pc.Name, pc.Value)
    							continue
    						}
    						// ServiceUnavailble error is returned when the API server is blocked by storage version updates
    						if apierrors.IsServiceUnavailable(err) {
    							klog.Infof("going to retry, unable to create PriorityClass %s: %v", pc.Name, err)
    							return false, nil
    						}
    						return false, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 23 18:36:33 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  9. src/net/mptcpsock_linux_test.go

    		t.Error("outgoing connection is not an MPTCP proto")
    	}
    }
    
    func canCreateMPTCPSocket() bool {
    	// We want to know if we can create an MPTCP socket, not just if it is
    	// available (mptcpAvailable()): it could be blocked by the admin
    	fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, _IPPROTO_MPTCP)
    	if err != nil {
    		return false
    	}
    
    	syscall.Close(fd)
    	return true
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 11 00:36:57 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  10. src/sync/waitgroup.go

    	state atomic.Uint64 // high 32 bits are counter, low 32 bits are waiter count.
    	sema  uint32
    }
    
    // Add adds delta, which may be negative, to the [WaitGroup] counter.
    // If the counter becomes zero, all goroutines blocked on [WaitGroup.Wait] are released.
    // If the counter goes negative, Add panics.
    //
    // Note that calls with a positive delta that occur when the counter is zero
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4K bytes
    - Viewed (0)
Back to top