Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 466 for blocked (0.34 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. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  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. tensorflow/compiler/mlir/tensorflow/ir/tf_device_ops.td

        regions inside ParallelExecute op is blocked until all inputs to all regions
        are materialized and ops following ParallelExecute op are blocked until all
        regions are executed.
      }];
    
      let results = (outs
        Variadic<AnyType>:$execute_outputs
      );
    
      let regions = (region VariadicRegion<SizedRegion<1>>:$regions);
    
      let extraClassDeclaration = [{
        Block& GetRegionBlockWithIndex(unsigned index);
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jan 23 23:53:20 UTC 2024
    - 14.8K bytes
    - Viewed (0)
Back to top